FilesExpand file tree

 master

/

UserDAO.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

162 lines (155 loc) · 5.34 KB

 master

/

UserDAO.java

Copy path

Top

File metadata and controls

• Code
• Blame

162 lines (155 loc) · 5.34 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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;

}

}