forked from maxliaops/Java_Web_Examples
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathManagerDAO.java
More file actions
100 lines (97 loc) · 3.38 KB
/
ManagerDAO.java
File metadata and controls
100 lines (97 loc) · 3.38 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
package com.wgh.dao;
import com.wgh.actionForm.ManagerForm;
import com.wgh.core.ConnDB;
import java.sql.*;
import java.util.*;
public class ManagerDAO {
private ConnDB conn=new ConnDB();
//管理员身份验证
public int checkManager(ManagerForm managerForm) {
int flag = 1;
String sql = "SELECT * FROM tb_manager where name='" +
managerForm.getName() + "'";
ResultSet rs = conn.executeQuery(sql);
try {
if (rs.next()) {
String pwd = managerForm.getPwd();
if (pwd.equals(rs.getString(3))) {
rs.last();
int rowSum = rs.getRow(); //获取记录总数
rs.first();
if (rowSum!=1) {
flag = 2;
System.out.print("获取row的值：" + sql + rowSum);
}
} else {
flag = 2;
}
}else{
flag = 2;
}
} catch (SQLException ex) {
flag = 2;
System.out.println(ex.getMessage());
}
return flag;
}
//添加数据
public int insert(ManagerForm managerForm) {
String sql1="SELECT * FROM tb_manager WHERE name='"+managerForm.getName()+"'";
ResultSet rs = conn.executeQuery(sql1);
String sql = "";
int falg = 0;
try {
if (rs.next()) {
falg=2;
} else {
sql = "INSERT INTO tb_manager (name,pwd) values('" +
managerForm.getName() + "','" +
managerForm.getPwd() +
"')";
falg = conn.executeUpdate(sql);
System.out.println("添加管理员信息的SQL：" + sql);
conn.close();
}
} catch (SQLException ex) {
falg=0;
}
return falg;
}
//查询方法
public List query(int id) {
List managerList = new ArrayList();
ManagerForm managerForm1 = null;
String sql="";
if(id==0){
sql = "SELECT * FROM tb_manager";
}else{
sql = "SELECT * FROM tb_manager WHERE id=" +id+ "";
}
ResultSet rs = conn.executeQuery(sql);
try {
while (rs.next()) {
managerForm1 = new ManagerForm();
managerForm1.setID(rs.getInt(1));
managerForm1.setName(rs.getString(2));
managerForm1.setPwd(rs.getString(3));
managerList.add(managerForm1);
}
} catch (SQLException ex) {}
return managerList;
}
//修改管理员密码
public int updatePwd(ManagerForm managerForm){
String sql="UPDATE tb_manager SET pwd='"+managerForm.getPwd()+"' where name='"+managerForm.getName()+"'";
int ret=conn.executeUpdate(sql);
System.out.println("修改管理员密码时的SQL："+sql);
conn.close();
return ret;
}
// 删除数据
public int delete(ManagerForm managerForm) {
String sql = "DELETE FROM tb_manager where id=" + managerForm.getID() +"";
int flag = conn.executeUpdate(sql);
conn.close();
return flag;
}
}