📄 registermodel.java
字号:
/**
*
*/
package com.phone.struts.model;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.apache.struts.validator.DynaValidatorForm;
import com.phone.struts.db.DatabaseConn;
import com.phone.struts.db.User;
import com.phone.struts.form.RegisterUserForm;
/**
* @author 雷东平 翁丽聪 陈国斌
* @exception SQLException
* @docRoot
* @return
* 说明:此函数是REGISTER USER
* 主要功能:增加新用户的信息、用户查询信息、管理员删除用户、用户修改个人信息等功能
* 模块中心:注册
*/
public class RegisterModel {
private Connection conn;
private Statement stmt;
/**
* 说明:构造函数
* 作用:初始化数据库连接
* @throws e
*/
public RegisterModel(){
try {
conn = DatabaseConn.getConnection();
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* 说明:销毁对象
* 作用:释放数据库连接:归还到连接池
*/
public void destory(){
try {
stmt.close();
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* 说明:添加数据
* 作用:添加用户注册的信息;持久化用户信息到关系数据库中
* 流程:FROM读取用户表单数据--->执行持久化数据库动作----->成功返回TRUE否则返回flase
* @return void
* @author heyidlg
* @exception null
* @param RegisterForm
* @struts.name
*/
public boolean InsertRegisterDate(DynaValidatorForm form){
boolean flag=false;
try{
String sql="INSERT INTO TABLE_USERS(userName,userCode,userAddr,userPhone,userEmail,userSex," +
"userAnswer,userCity,userProvince,userQuestion,userPass) VALUES('"+form.get("userName")+"','"+form.get("userCode")+"'" +
",'"+form.get("userAddr")+"','"+form.get("userPhone")+"','"+form.get("userEmail")+"','"+form.get("userSex")+"'" +
",'"+form.get("userAnswer")+"','"+form.get("userCity")+"','"+form.get("userProvince")+"','"+form.get("userQuestion")+"'" +
",'"+form.get("userPass")+"')";
stmt.executeUpdate(sql);
flag=true;
}
catch(SQLException e){
e.printStackTrace();
flag=false;
}
return flag;
}
/**
* @author 雷东平 翁丽聪 陈国斌
* @param form
* @return boolean
* 作用:检查用户名是否已经被注册
* 说明:返回true则该用户可以被注册
*/
public boolean checkUserExit(DynaValidatorForm form){
boolean tag=false;
String sql="SELECT userName FROM TABLE_USERS WHERE userName='"+form.get("userName")+"'";
int index =0;
try{
ResultSet rs=stmt.executeQuery(sql);
while(rs.next()){
index++;
}
}
catch(SQLException e){
e.printStackTrace();
System.out.println(e.getMessage()+"数据库错误");
tag=false;
return tag;
}
if(index==0){
tag=true;
}
return tag;
}
/**
* @author 雷东平 翁丽聪 陈国斌
* @param user
* @return Vector
* 作用:显示用户个人信息、已代修改
* 说明:修改用户跟人基本信息
*/
public RegisterUserForm updateRegisterUser(User user){
RegisterUserForm registerUserForm = new RegisterUserForm();
String sql="SELECT * FROM TABLE_USERS WHERE userName='"+user.getLoginName()+"'";
try{
ResultSet rs=stmt.executeQuery(sql);
while(rs.next()){
registerUserForm.setUserName(rs.getString("userName"));
registerUserForm.setUserPass(rs.getString("userPass"));
registerUserForm.setUserAddr(rs.getString("userAddr"));
registerUserForm.setUserAnswer(rs.getString("userAnswer"));
registerUserForm.setUserCity(rs.getString("userCity"));
registerUserForm.setUserCode(rs.getString("userCode"));
registerUserForm.setUserEmail(rs.getString("userEmail"));
registerUserForm.setUserPhone(rs.getString("userPhone"));
registerUserForm.setUserProvince(rs.getString("userProvince"));
registerUserForm.setUserQuestion(rs.getString("userQuestion"));
registerUserForm.setUserSex(rs.getString("userSex"));
}
if(rs!=null){
rs.close();
}
}
catch(SQLException e){
e.printStackTrace();
System.out.println(e.getMessage());
}
return registerUserForm;
}
public boolean updateUser(DynaValidatorForm form){
boolean tag=false;
try{
String sql="UPDATE TABLE_USERS SET userName='"+form.get("userName")+"',userPass='"+form.get("userPass")+"'," +
"userAddr='"+form.get("userAddr")+"',userAnswer='"+form.get("userAnswer")+"',userCity='"+form.get("userCity")+"'," +
"userCode='"+form.get("userCode")+"',userEmail='"+form.get("userEmail")+"',userPhone='"+form.get("userPhone")+"'," +
"userProvince='"+form.get("userProvince")+"',userQuestion='"+form.get("userQuestion")+"',userSex='"+form.get("userSex")+"'";
stmt.executeUpdate(sql);
tag=true;
}
catch(SQLException e){
e.printStackTrace();
System.out.println(e.getMessage());
tag=false;
}
return tag;
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -