forked from maxliaops/Java_Web_Examples
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathOpDB.java
More file actions
157 lines (148 loc) · 4.38 KB
/
OpDB.java
File metadata and controls
157 lines (148 loc) · 4.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
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
package com.yxq.dao;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.TreeMap;
import com.yxq.model.CreatePage;
import com.yxq.model.InfoSingle;
import com.yxq.tools.DoString;
public class OpDB {
private DB mydb;
public OpDB(){
mydb=new DB();
}
public TreeMap OpGetListBox(String sql,Object[] params){
TreeMap typeMap=new TreeMap();
mydb.doPstm(sql, params);
try {
ResultSet rs=mydb.getRs();
if(rs!=null){
while(rs.next()){
Integer sign=Integer.valueOf(rs.getInt("type_sign"));
String intro=rs.getString("type_intro");
typeMap.put(sign,intro);
}
rs.close();
}
} catch (SQLException e) {
System.out.println("OpGetListBox()方法查询失败！");
e.printStackTrace();
}finally{
mydb.closed();
}
return typeMap;
}
public List OpListShow(String sql,Object[] params){
List onelist=new ArrayList();
mydb.doPstm(sql, params);
try{
ResultSet rs=mydb.getRs();
if(rs!=null){
while(rs.next()){
InfoSingle infoSingle=new InfoSingle();
infoSingle.setId(rs.getInt("id"));
infoSingle.setInfoType(rs.getInt("info_type"));
infoSingle.setInfoTitle(rs.getString("info_title"));
infoSingle.setInfoContent(rs.getString("info_content"));
infoSingle.setInfoLinkman(rs.getString("info_linkman"));
infoSingle.setInfoPhone(rs.getString("info_phone"));
infoSingle.setInfoEmail(rs.getString("info_email"));
infoSingle.setInfoDate(DoString.dateTimeChange(rs.getTimestamp("info_date")));
infoSingle.setInfoState(rs.getString("info_state"));
infoSingle.setInfoPayfor(rs.getString("info_payfor"));
onelist.add(infoSingle);
}
}
rs.close();
}catch (Exception e){
System.out.println("查看信息列表失败！(查询数据库)");
e.printStackTrace();
}finally{
mydb.closed();
}
return onelist;
}
public InfoSingle OpSingleShow(String sql,Object[] params){
InfoSingle infoSingle=null;
mydb.doPstm(sql, params);
try{
ResultSet rs=mydb.getRs();
if(rs!=null&&rs.next()){
infoSingle=new InfoSingle();
infoSingle.setId(rs.getInt("id"));
infoSingle.setInfoType(rs.getInt("info_type"));
infoSingle.setInfoTitle(rs.getString("info_title"));
infoSingle.setInfoContent(rs.getString("info_content"));
infoSingle.setInfoLinkman(rs.getString("info_linkman"));
infoSingle.setInfoPhone(rs.getString("info_phone"));
infoSingle.setInfoEmail(rs.getString("info_email"));
infoSingle.setInfoDate(DoString.dateTimeChange(rs.getTimestamp("info_date")));
infoSingle.setInfoState(rs.getString("info_state"));
infoSingle.setInfoPayfor(rs.getString("info_payfor"));
rs.close();
}
}catch(Exception e){
System.out.println("查看详细内容失败！(查询数据库)");
e.printStackTrace();
}finally{
mydb.closed();
}
return infoSingle;
}
public int OpUpdate(String sql,Object[] params){
int i=-1;
mydb.doPstm(sql, params);
try{
i=mydb.getCount();
}catch(SQLException e){
System.out.println("执行OpUpdate()方法失败！(更新数据库)");
e.printStackTrace();
}finally{
mydb.closed();
}
return i;
}
public CreatePage OpCreatePage(String sqlall,Object[] params,int perR,String strCurrentP,String gowhich){
CreatePage page=new CreatePage();
page.setPerR(perR);
if(sqlall!=null&&!sqlall.equals("")){
DB mydb=new DB();
mydb.doPstm(sqlall,params);
try {
ResultSet rs=mydb.getRs();
if(rs!=null&&rs.next()){
rs.last();
page.setAllR(rs.getRow()); //设置总记录数
page.setAllP();
page.setCurrentP(strCurrentP);
page.setPageInfo();
page.setPageLink(gowhich);
rs.close();
}
} catch (SQLException e) {
System.out.println("OpDB.java/OpCreatePage()方法：创建CreatePage分页类失败！");
e.printStackTrace();
}finally{
mydb.closed();
}
}
return page;
}
public boolean LogOn(String sql,Object[] params){
mydb.doPstm(sql, params);
try {
ResultSet rs=mydb.getRs();
boolean mark=(rs==null||!rs.next()?false:true);
rs.close();
return mark;
} catch (SQLException e) {
System.out.println("登录失败！");
e.printStackTrace();
return false;
}
finally{
mydb.closed();
}
}
}