商品表的增加，修改，删除，订单表的增加，确认，用户表的查看，日志表的增加，查看
商品表建表语句：
1 create table TEST.GOODS_TABLE 2 ( 3 gid NUMBER not null, 4 gname VARCHAR2(90), 5 gdetails CLOB, 6 gpicture VARCHAR2(100), 7 gprice NUMBER, 8 gleixing NUMBER, 9 gpinpai VARCHAR2(20) 10 ) 11 tablespace USERS 12 pctfree 10 13 initrans 1 14 maxtrans 255 15 storage 16 ( 17 initial 64K 18 next 1M 19 minextents 1 20 maxextents unlimited 21 ); 22 comment on column TEST.GOODS_TABLE.gid 23 is ‘商品ID‘; 24 comment on column TEST.GOODS_TABLE.gname 25 is ‘商品名称‘; 26 comment on column TEST.GOODS_TABLE.gdetails 27 is ‘商品详情‘; 28 comment on column TEST.GOODS_TABLE.gpicture 29 is ‘商品图片‘; 30 comment on column TEST.GOODS_TABLE.gprice 31 is ‘商品价格‘; 32 comment on column TEST.GOODS_TABLE.gleixing 33 is ‘商品类型‘; 34 comment on column TEST.GOODS_TABLE.gpinpai 35 is ‘商品品牌‘; 36 alter table TEST.GOODS_TABLE 37 add constraint PK_GOODSID primary key (GID) 38 using index 39 tablespace USERS 40 pctfree 10 41 initrans 2 42 maxtrans 255 43 storage 44 ( 45 initial 64K 46 next 1M 47 minextents 1 48 maxextents unlimited 49 );
订单表建表语句：
1 create table TEST.SHOPORDER 2 ( 3 scid VARCHAR2(10), 4 scuser VARCHAR2(20), 5 scgid VARCHAR2(15), 6 scnum NUMBER, 7 scmoney NUMBER, 8 sctime VARCHAR2(20), 9 sczt VARCHAR2(10) 10 ) 11 tablespace SYSTEM 12 pctfree 10 13 pctused 40 14 initrans 1 15 maxtrans 255 16 storage 17 ( 18 initial 64K 19 next 1M 20 minextents 1 21 maxextents unlimited 22 ); 23 comment on column TEST.SHOPORDER.scid 24 is ‘订单号‘; 25 comment on column TEST.SHOPORDER.scuser 26 is ‘用户名‘; 27 comment on column TEST.SHOPORDER.scgid 28 is ‘商品ID‘; 29 comment on column TEST.SHOPORDER.scnum 30 is ‘商品数量‘; 31 comment on column TEST.SHOPORDER.scmoney 32 is ‘商品总价‘; 33 comment on column TEST.SHOPORDER.sctime 34 is ‘交易时间‘; 35 comment on column TEST.SHOPORDER.sczt 36 is ‘订单状态‘;
用户表建表语句：
1 create table TEST.USER_TABLE 2 ( 3 userid NUMBER not null, 4 uname VARCHAR2(20), 5 upassword VARCHAR2(20), 6 unickname VARCHAR2(20), 7 uemail VARCHAR2(50), 8 utime VARCHAR2(30) 9 ) 10 tablespace USERS 11 pctfree 10 12 initrans 1 13 maxtrans 255 14 storage 15 ( 16 initial 64K 17 next 1M 18 minextents 1 19 maxextents unlimited 20 ); 21 comment on column TEST.USER_TABLE.userid 22 is ‘用户id‘; 23 comment on column TEST.USER_TABLE.uname 24 is ‘用户名‘; 25 comment on column TEST.USER_TABLE.upassword 26 is ‘用户密码‘; 27 comment on column TEST.USER_TABLE.unickname 28 is ‘用户昵称‘; 29 comment on column TEST.USER_TABLE.uemail 30 is ‘用户邮箱‘; 31 comment on column TEST.USER_TABLE.utime 32 is ‘注册时间‘;
日志表建表语句：
1 create table TEST.SHOPLOG 2 ( 3 pname VARCHAR2(30), 4 pugroup VARCHAR2(30), 5 puptime VARCHAR2(30), 6 pip VARCHAR2(30), 7 plog VARCHAR2(100) 8 ) 9 tablespace SYSTEM 10 pctfree 10 11 pctused 40 12 initrans 1 13 maxtrans 255 14 storage 15 ( 16 initial 64K 17 next 1M 18 minextents 1 19 maxextents unlimited 20 ); 21 comment on column TEST.SHOPLOG.pname 22 is ‘用户名‘; 23 comment on column TEST.SHOPLOG.pugroup 24 is ‘用户组‘; 25 comment on column TEST.SHOPLOG.puptime 26 is ‘登陆时间‘; 27 comment on column TEST.SHOPLOG.pip 28 is ‘IP‘; 29 comment on column TEST.SHOPLOG.plog 30 is ‘操作‘;
数据库链接驱动类：
1 package com.hanqi.util;
2
3 import java.sql.Connection;
4 import java.sql.DriverManager;
5 import java.sql.ResultSet;
6 import java.sql.SQLException;
7 import java.sql.Statement;
8
9 /**
10 * 数据库驱动连接类
11 * @author ZBK
12 */
13 public class DBHelper {
14 /**
15 * 数据库用户名
16 */
17 public static final String USERNAME = "test";
18 /**
19 * 数据库密码
20 */
21 public static final String PASSWORD = "test";
22 /**
23 * 数据库驱动类
24 */
25 public static final String DRIVER = "oracle.jdbc.OracleDriver";
26 /**
27 * 数据库地址URL
28 */
29 public static final String URL = "jdbc:oracle:thin:@localhost:1521:xe";
30
31 /**
32 * 获取数据库连接
33 * @return
34 */
35 public static Connection getConnection() {
36 Connection conn = null;
37 try {
38 Class.forName(DRIVER);
39 conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
40 } catch (ClassNotFoundException e) {
41 e.printStackTrace();
42 } catch (SQLException e) {
43 e.printStackTrace();
44 }
45 return conn;
46 }
47
48
49 /**
50 * 释放资源
51 * @param conn 数据库连接对象
52 * @param sm Statement对象
53 * @param rs ResultSet结果集对象
54 */
55 public static void destroy(Connection conn, Statement sm, ResultSet rs) {
56 if (conn != null) {
57 try {
58 conn.close();
59 } catch (SQLException e) {
60 e.printStackTrace();
61 }
62 conn = null;
63 }
64 if (sm != null) {
65 try {
66 sm.close();
67 } catch (SQLException e) {
68 e.printStackTrace();
69 }
70 sm = null;
71 }
72 if (rs != null) {
73 try {
74 rs.close();
75 } catch (SQLException e) {
76 e.printStackTrace();
77 }
78 rs = null;
79 }
80 }
81
82 /**
83 * 验证前台传入的参数是否为空
84 * @param args
85 * @return
86 */
87 public static boolean checkParam(String... args) {
88 for (String s : args) {
89 if (s == null || s.trim().length() < 1) {
90 return false;
91 }
92 }
93 return true;
94 }
95 }
数据库操作方法类：
1 package com.hanqi.dal;
2
3 import java.sql.Connection;
4 import java.sql.PreparedStatement;
5 import java.sql.ResultSet;
6 import java.sql.SQLException;
7 import java.util.ArrayList;
8 import java.util.Date;
9 import java.util.List;
10
11 import com.hanqi.model.Goods;
12 import com.hanqi.model.Log;
13 import com.hanqi.model.Order;
14 import com.hanqi.model.TradingStatusFile;
15 import com.hanqi.model.User;
16 import com.hanqi.util.DBHelper;
17
18 public class MethodDal {
19 private Connection conn;
20 private PreparedStatement ps;
21 private ResultSet rs;
22
23 private static int scnum=1000;
24 //初始化链接
25 public void init(String sql) {
26 conn = DBHelper.getConnection();
27 try {
28 ps = conn.prepareStatement(sql);
29 } catch (SQLException e) {
30 e.printStackTrace();
31 }
32 }
33 //释放资源
34 public void close(){
35 DBHelper.destroy(conn, ps, rs);
36 }
37 //判断传入的参数有没有空的方法，只要有空的就返回false
38 public boolean checkParam(String... args){//这样传参数代表参数个数不确定，传几个都可以
39 for(String s : args){
40 if("".equals(s)||s==null){
41 return false;
42 }
43 }
44 return true;
45 }
46 /**
47 * 返回所有商品
48 * @return
49 */
50 public List<Goods> getAllGoods(){
51 String sql = "select * from GOODS_TABLE g";
52 init(sql);
53 List<Goods> list = new ArrayList<Goods>();
54
55 try {
56 rs = ps.executeQuery();
57 while (rs.next()) {
58 Goods good=new Goods(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getString(4),rs.getInt(5),rs.getInt(6),rs.getString(7));
59 list.add(good);
60 }
61 } catch (SQLException e) {
62 e.printStackTrace();
63 }
64 return list;
65 }
66 /**
67 * 增加一条商品信息
68 * @param g
69 * @return
70 */
71 public int insertGoods(Goods g) {
72 String sql = "insert into GOODS_TABLE values(tablexulie.nextval,?,?,?,?,?,?)";
73
74 init(sql);
75 int a = -1;
76 try {
77 ps.setString(1, g.getGname());
78 ps.setString(2, g.getGdetails());
79 ps.setString(3, g.getGpicture());
80 ps.setInt(4, g.getGprice());
81 ps.setInt(5, g.getGleixing());
82 ps.setString(6, g.getGpinpai());
83 a = ps.executeUpdate();
84 } catch (SQLException e) {
85 e.printStackTrace();
86 }
87 return a;
88 }
89 /**
90 * 删除商品信息
91 */
92 public int deleteGoods(int gid) {
93 String sql = "delete from GOODS_TABLE g where g.gid=? ";
94
95 init(sql);
96 int a = -1;
97 try {
98 ps.setInt(1, gid);
99 a = ps.executeUpdate();
100 } catch (SQLException e) {
101 e.printStackTrace();
102 }
103 return a;
104 }
105 //修改商品信息
106 public int UpdateGood(Goods g) {
107 String sql = "update GOODS_TABLE g set g.gname=?,g.gdetails=?,g.gpicture=?,g.gprice=?,g.gleixing=?,g.gpinpai=? where g.gid=?";
108 init(sql);
109 int a = -1;
110 try {
111 ps.setString(1, g.getGname());
112 ps.setString(2, g.getGdetails());
113 ps.setString(3, g.getGpicture());
114 ps.setInt(4, g.getGprice());
115 ps.setInt(5, g.getGleixing());
116 ps.setString(6, g.getGpinpai());
117 ps.setInt(7, g.getGid());
118 a = ps.executeUpdate();
119 } catch (SQLException e) {
120 e.printStackTrace();
121 }
122 return a;
123 }
124 public int UpdateGoodNP(Goods g) {
125 String sql = "update GOODS_TABLE g set g.gname=?,g.gdetails=?,g.gprice=?,g.gleixing=?,g.gpinpai=? where g.gid=?";
126 init(sql);
127 int a = -1;
128 try {
129 ps.setString(1, g.getGname());
130 ps.setString(2, g.getGdetails());
131 ps.setInt(3, g.getGprice());
132 ps.setInt(4, g.getGleixing());
133 ps.setString(5, g.getGpinpai());
134 ps.setInt(6, g.getGid());
135
136 a = ps.executeUpdate();
137 } catch (SQLException e) {
138 e.printStackTrace();
139 }
140 return a;
141 }
142
143 //获取数量
144 public int getGoodsSum(String scuser) {
145 String sql = "select s.scnum from SHOPPINGCAR s where s.scuser=?";
146 int sum=0;
147 init(sql);
148
149 try {
150 ps.setString(1, scuser);
151 rs = ps.executeQuery();
152
153 while (rs.next()) {
154 sum+=rs.getInt("scnum");
155 }
156 } catch (SQLException e) {
157 e.printStackTrace();
158 }
159 return sum;
160 }
161
162 public Goods getGoods(String gid) {
163 String sql = "select * from GOODS_TABLE g where g.gid="+gid;
164 init(sql);
165 Goods good=new Goods();
166 try {
167 rs = ps.executeQuery();
168 while (rs.next()) {
169 good=new Goods(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getString(4),rs.getInt(5),rs.getInt(6),rs.getString(7));
170 }
171 } catch (SQLException e) {
172 e.printStackTrace();
173 }
174 return good;
175 }
176 /**
177 * 增加日志记录
178 * @param g
179 * @return
180 */
181 public int insertLog(Log l) {
182 String sql = "insert into ShopLog values(?,?,?,?,?)";
183
184 init(sql);
185 int a = -1;
186 try {
187 ps.setString(1, l.getPname());
188 ps.setString(2, l.getPugroup());
189 ps.setString(3, l.getPuptime());
190 ps.setString(4, l.getPip());
191 ps.setString(5, l.getPlog());
192 a = ps.executeUpdate();
193 } catch (SQLException e) {
194 e.printStackTrace();
195 }
196 return a;
197 }
198 /**
199 * 返回所有日志
200 * @return
201 */
202 public List<Log> getAllLogs(){
203 String sql = "select * from ShopLog s order by s.puptime desc";
204 init(sql);
205 List<Log> list = new ArrayList<Log>();
206
207 try {
208 rs = ps.executeQuery();
209 while (rs.next()) {
210 Log l=new Log();
211 l.setPname(rs.getString(1));
212 l.setPugroup(rs.getString(2));
213 l.setPuptime(rs.getString(3));
214 l.setPip(rs.getString(4));
215 l.setPlog(rs.getString(5));
216
217 list.add(l);
218 }
219 } catch (SQLException e) {
220 e.printStackTrace();
221 }
222 return list;
223 }
224 /**
225 * 返回购物车数据
226 * @return
227 */
228 public List<Order> getAllOrder(String username){
229 String sql = "select t.* from SHOPPINGCAR t where t.scuser=?";
230 init(sql);
231 List<Order> list = new ArrayList<Order>();
232
233 try {
234 ps.setString(1, username);
235 rs = ps.executeQuery();
236 while (rs.next()) {
237 Order l=new Order();
238
239 l.setScid(rs.getString(1));
240 l.setScuser(rs.getString(4));
241 l.setScgid(rs.getString(5));
242 l.setScnum(rs.getInt(3));
243 l.setSctime((new Date()).toLocaleString());
244
245 list.add(l);
246 }
247 } catch (SQLException e) {
248 e.printStackTrace();
249 }
250 return list;
251 }
252 /**
253 * 删除购物车已经提交的信息
254 */
255 public int deleteSCar(String username) {
256 String sql = "delete from SHOPPINGCAR g where g.scuser=? ";
257
258 init(sql);
259 int a = -1;
260 try {
261 ps.setString(1, username);
262 a = ps.executeUpdate();
263 } catch (SQLException e) {
264 e.printStackTrace();
265 }
266 return a;
267 }
268 /**
269 * 增加订单记录
270 * @param g
271 * @return
272 */
273 public int insertOrder(Order l) {
274 String sql = "insert into SHOPORDER values(?,?,?,?,?,?,?)";
275
276 init(sql);
277 int a = -1;
278 try {
279 ps.setString(1, l.getScid());
280 ps.setString(2, l.getScuser());
281 ps.setString(3, l.getScgid());
282 ps.setInt(4, l.getScnum());
283 ps.setInt(5, l.getScmoney());
284 ps.setString(6, l.getSctime());
285 ps.setString(7, l.getSczt());
286 a = ps.executeUpdate();
287 } catch (SQLException e) {
288 e.printStackTrace();
289 }
290 return a;
291 }
292 /**
293 * 返回未确认订单
294 * @return
295 */
296 public List<Order> getAllOrder(){
297 String sql = "select t.* from SHOPORDER t where t.sczt=‘待确认‘ order by t.sctime desc";
298 init(sql);
299 List<Order> list = new ArrayList<Order>();
300
301 try {
302 rs = ps.executeQuery();
303 while (rs.next()) {
304 Order l=new Order();
305 l.setScid(rs.getString(1));
306 l.setScuser(rs.getString(2));
307 l.setScgid(rs.getString(3));
308 l.setScnum(rs.getInt(4));
309 l.setScmoney(rs.getInt(5));
310 l.setSctime(rs.getString(6));
311 l.setSczt(rs.getString(7));
312 list.add(l);
313 }
314 } catch (SQLException e) {
315 e.printStackTrace();
316 }
317 return list;
318 }
319 /**
320 * 返回确认订单
321 * @return
322 */
323 public List<Order> getAllOrder1(){
324 String sql = "select t.* from SHOPORDER t where t.sczt=‘已确认‘ order by t.sctime desc";
325 init(sql);
326 List<Order> list = new ArrayList<Order>();
327
328 try {
329 rs = ps.executeQuery();
330 while (rs.next()) {
331 Order l=new Order();
332 l.setScid(rs.getString(1));
333 l.setScuser(rs.getString(2));
334 l.setScgid(rs.getString(3));
335 l.setScnum(rs.getInt(4));
336 l.setScmoney(rs.getInt(5));
337 l.setSctime(rs.getString(6));
338 l.setSczt(rs.getString(7));
339 list.add(l);
340 }
341 } catch (SQLException e) {
342 e.printStackTrace();
343 }
344 return list;
345 }
346 /**
347 * 修改订单状态
348 * @return
349 */
350 public void UpdateOrder(String sctime){
351 String sql = "update SHOPORDER s set s.sczt=‘已确认‘ where s.sctime=?";
352 init(sql);
353 try {
354 ps.setString(1, sctime);
355 ps.executeQuery();
356
357 } catch (SQLException e) {
358 e.printStackTrace();
359 }
360 }
361 /**
362 * 返回用户信息
363 * @return
364 */
365 public List<User> getAllUsers(){
366 String sql = "select t.*, t.rowid from USER_TABLE t order by t.utime desc";
367 init(sql);
368 List<User> list = new ArrayList<User>();
369
370 try {
371 rs = ps.executeQuery();
372 while (rs.next()) {
373 User l=new User();
374
375 l.setUserid(rs.getInt(1));
376 l.setUname(rs.getString(2));
377 l.setUpassword(rs.getString(3));
378 l.setUnickname(rs.getString(4));
379 l.setUemail(rs.getString(5));
380 l.setUtime(rs.getString(6));
381 list.add(l);
382 }
383 } catch (SQLException e) {
384 e.printStackTrace();
385 }
386 return list;
387 }
388
389 }
时间： 2024-12-16 08:07:30