forked from maxliaops/Java_Web_Examples
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathUserDAO.java
More file actions
162 lines (155 loc) · 5.34 KB
/
UserDAO.java
File metadata and controls
162 lines (155 loc) · 5.34 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
package com.dao;
import org.hibernate.Transaction;
import com.actionForm.UserForm;
import org.hibernate.Query;
import java.util.List;
import org.hibernate.Session;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import com.core.MySession;
public class UserDAO {
private Session session = null;
public List query(String strif) {
session=MySession.openSession(); //打开Session
String hql = "";
if (strif != "all" && strif != null && strif != "") { //条件查询
hql = "FROM UserForm user WHERE " + strif +
"";
} else { //查询全部数据
hql = "FROM UserForm user";
}
System.out.println(hql);
List list=null;
try{
Query query = session.createQuery(hql);
list = query.list();
}catch(Exception e){
e.printStackTrace();
}finally{
MySession.closeSession(session); //关闭Session
}
return list;
}
//保存用户信息
public int insert(UserForm userForm) {
int ret = 0;
Transaction tx = null;
String str="name='" + userForm.getName() + "'";
List list = query(str);
if (list.size()> 0) { //存在该信息
ret = 2;
} else {
session=MySession.openSession(); //打开Session
try {
tx = session.beginTransaction();
session.save(userForm);
tx.commit();
ret = 1;
} catch (Exception e) {
if (tx != null) {
tx.rollback();
}
e.printStackTrace();
System.out.println("添加用户信息时的错误信息：" + e.getMessage());
return ret = 0;
} finally {
MySession.closeSession(session); //关闭Session
}
}
return ret;
}
public String login(UserForm userForm,HttpServletRequest request){
String rtn="";
String name=userForm.getName();
String pwd=userForm.getPwd();
String str="name='"+name+"'";
List list = query(str);
if(list.size()==1){
UserForm m=(UserForm)list.get(0);
String username=m.getName();
if(pwd.equals(m.getPwd())){
rtn="ok";
//********将登录的用户名称保存到HttpSession中****
HttpSession httpsession=request.getSession();
httpsession.setAttribute("username",username);
//********************************************
System.out.println("登录成功！");
}else{
rtn="您输入的密码错误！";
System.out.println("密码错误！");
}
}else{
rtn="您输入的用户名称错误！";
System.out.println("您输入的用户名称错误！");
}
return rtn;
}
//查询要修改的用户信息
public UserForm query(int id) {
session = MySession.openSession(); //打开Session
UserForm userForm =null;
try{
userForm = (UserForm) session.get(UserForm.class, id);
}catch(Exception e){
e.printStackTrace();
}finally{
MySession.closeSession(session); //关闭Session
}
return userForm;
}
//修改用户信息
public int Modify(UserForm userForm,int flag) {
int id = userForm.getId();
int ret = 0;
Transaction tx = null;
session=MySession.openSession(); //打开Session
try {
tx = session.beginTransaction();
UserForm userF=(UserForm)session.get(UserForm.class,id);
if(flag==1){
userF.setPwd(userForm.getPwd());
}else{
userF.setSetInstorage(userForm.getSetInstorage());
userF.setSetOutstorage(userForm.getSetOutstorage());
userF.setSetDeal(userForm.getSetDeal());
userF.setSetQuery(userForm.getSetQuery());
userF.setSetBasic(userForm.getSetBasic());
userF.setSetSys(userForm.getSetSys());
}
session.update(userF);
tx.commit();
ret = 1;
} catch (Exception e) {
if (tx != null) {
tx.rollback();
}
System.out.println("修改用户信息时的错误信息：" + e.getMessage());
return ret = 0;
} finally {
MySession.closeSession(session); //关闭Session
}
return ret;
}
//删除用户信息
public int del(int id) {
session=MySession.openSession(); //打开Session
int ret = 0;
Transaction tx = null;
try {
tx = session.beginTransaction();
UserForm userForm = (UserForm) session.get(UserForm.class, id);
session.delete(userForm);
tx.commit();
ret = 1;
} catch (Exception e) {
if (tx != null) {
tx.rollback();
}
System.out.println("删除用户信息时的错误信息：" + e.getMessage());
return ret = 0;
} finally {
MySession.closeSession(session); //关闭Session
}
return ret;
}
}