淘宝商城
model/** * 功能：这是一个数据库连接，一个model类 */package com.xf.model;import java.sql.*;public class conndb{ private connection ct=null; public connection getconn() { try { class.forname(com.mysql.jdbc.driver); ct=drivermanager.getconnection(jdbc:mysql://localhost:3306/db3,root,); } catch (exception e) { // todo: handle exception e.printstacktrace(); } return ct; }}
/** * 功能：这是一个model类对应goods表 */package com.xf.model;public class goodsbean{ private long goodsid; //货物id private string goodsname; //货物名称 private string goodsintro; //介绍 private float goodsprice; //价格 private int goodsnum; //数量 private string publisher; //发行商 private string photo=11.jpg; //照片 private string type; //类型 public long getgoodsid() { return goodsid; } public void setgoodsid(long goodsid) { this.goodsid = goodsid; } public string getgoodsname() { return goodsname; } public void setgoodsname(string goodsname) { this.goodsname = goodsname; } public string getgoodsintro() { return goodsintro; } public void setgoodsintro(string goodsintro) { this.goodsintro = goodsintro; } public float getgoodsprice() { return goodsprice; } public void setgoodsprice(float goodsprice) { this.goodsprice = goodsprice; } public int getgoodsnum() { return goodsnum; } public void setgoodsnum(int goodsnum) { this.goodsnum = goodsnum; } public string getpublisher() { return publisher; } public void setpublisher(string publisher) { this.publisher = publisher; } public string getphoto() { return photo; } public void setphoto(string photo) { this.photo = photo; } public string gettype() { return type; } public void settype(string type) { this.type = type; } }
/** * 功能：也是一个model，业务逻辑，处理和goods表相关的业务逻辑 */package com.xf.model;import java.sql.*;import java.util.arraylist;public class goodsbeanbo{ //定义一些要用到的变量 private resultset rs=null; private connection ct=null; private preparedstatement ps; public int getpagecount(int pagesize) { int pagecount=0; //总页数 int rowcount=0; //一共有多少条记录 try { //链接数据库 ct=new conndb().getconn(); //查询语句 string mysql=select count(*) from `goods`; ps=ct.preparestatement(mysql); //全部记录放入 rs=ps.executequery(); if(rs.next()) //如果查找到了数据 { rowcount=rs.getint(1); //得到个数 if(rowcount%pagesize != 0) { pagecount=rowcount/pagesize+1; //得到结果四舍五入然后加一 } else { pagecount=rowcount/pagesize; //恰好整除，那么就直接得到结果 } } } catch (exception e) { // todo: handle exception e.printstacktrace(); } finally { this.close(); } return pagecount; } /** * 功能：得到分页数据,分页显示数据 * @param pagesize 这个是每页面显示地个数 * @author cutter_point * @param pagenow 当前要显示地页面 */ public arraylist getgoodsbypage(int pagesize, int pagenow) { arraylist a1=new arraylist(); //这是要返回的数据 try { //得到链接 ct=new conndb().getconn(); //导入mysql语句 string mysql=select * from `goods` limit ?,?; ps=ct.preparestatement(mysql); //吧?设置成想要变成的值 ps.setint(1, pagesize*(pagenow-1)); ps.setint(2, pagesize); //执行查询，结果放入resultset中 rs=ps.executequery(); while(rs.next()) //只要取出一行数据，循环下去 { goodsbean gb=new goodsbean(); //吧查找到的数据放入到gb中 gb.setgoodsid(rs.getint(1)); gb.setgoodsname(rs.getstring(2)); gb.setgoodsintro(rs.getstring(3)); gb.setgoodsprice(rs.getfloat(4)); gb.setgoodsnum(rs.getint(5)); gb.setpublisher(rs.getstring(6)); gb.setphoto(rs.getstring(7)); gb.settype(rs.getstring(8)); //吧goodsbean的数据放入到arraylist里面去 a1.add(gb); } } catch (exception e) { // todo: handle exception e.printstacktrace(); } finally { this.close(); } return a1; //吧arraylist返回上去 } //根据货物id，得到货物具体信息的函数 public goodsbean getgoodsbean(string id) { goodsbean gb=new goodsbean(); try { //建立连接 ct=new conndb().getconn(); //存放连接数据库的脚本语句 string mysql=select * from `goods` where `goodsid`=?; ps=ct.preparestatement(mysql); //吧id传给第一个? ps.setstring(1, id); //吧查询到的数据给rs rs=ps.executequery(); if(rs.next()) //只要查找到了数据 { //吧查找到的数据放入到gb中 gb.setgoodsid(rs.getint(1)); gb.setgoodsname(rs.getstring(2)); gb.setgoodsintro(rs.getstring(3)); gb.setgoodsprice(rs.getfloat(4)); gb.setgoodsnum(rs.getint(5)); gb.setpublisher(rs.getstring(6)); gb.setphoto(rs.getstring(7)); gb.settype(rs.getstring(8)); } } catch (exception e) { // todo: handle exception e.printstacktrace(); } finally { //关闭资源 this.close(); } return gb; } //关闭资源 public void close() { try { if(!rs.isclosed()) { rs.close(); rs=null; } if(!ps.isclosed()) { ps.close(); ps=null; } if(!ct.isclosed()) { ct.close(); ct=null; } } catch (exception e) { // todo: handle exception e.printstacktrace(); } } }
/** * 功能：这是一个bo（model），用来处理与购物相关的业务逻辑 * 时间：2014年7月9日14:29:30 * 作者：cutter_point */package com.xf.model;import java.sql.*;import java.util.*;public class mycartbo{ //定义一个hashmap集合，用于存放书的id和数量 hashmap hm=new hashmap(); //链接数据库的一些变量 private resultset rs=null; private connection ct=null; private preparedstatement ps=null; private float allprice=0.0f; //得到这个商品的购买数量 public string getgoodsnumbyid(string goodsid) { return hm.get(goodsid); } //得到总价 public float getallprice() { return this.allprice; } //1、添加货物 public void addgoods(string goodsid, string goodsnum) { hm.put(goodsid, goodsnum); } //2、删除货物 public void delgoods(string goodsid) { hm.remove(goodsid); } //3、清空货物 public void clear() { hm.clear(); } //4、修改货物数量 public void upgoods(string goodsid, string newnum) { hm.put(goodsid, newnum); } //5、显示购物车 public arraylist showmycart() { arraylist a1=new arraylist(); try { string mysql=select * from `goods` where `goodsid` in ;//(1,4) //使用迭代器重hm中取出id iterator it=hm.keyset().iterator(); string sub=(; while(it.hasnext()) //迭代取出数据 { //取出goodsid string goodsid=(string)it.next(); //判断是不是最后一个id if(it.hasnext()) { sub+=goodsid+, ; } else { sub+=goodsid+); } } mysql+=sub; //链接数据库进行mysql语句使用 ct=new conndb().getconn(); //然后声明要使用mysql语句了 ps=ct.preparestatement(mysql); //得到语句执行结果 rs=ps.executequery(); //总价清空 this.allprice=0.0f; while(rs.next()) { goodsbean gb=new goodsbean(); //吧查找到的数据放入到gb中 int goodsid=rs.getint(1); gb.setgoodsid(goodsid); gb.setgoodsname(rs.getstring(2)); gb.setgoodsintro(rs.getstring(3)); float unit=rs.getfloat(4); gb.setgoodsprice(unit); gb.setgoodsnum(rs.getint(5)); gb.setpublisher(rs.getstring(6)); gb.setphoto(rs.getstring(7)); gb.settype(rs.getstring(8)); this.allprice+=unit*integer.parseint(this.getgoodsnumbyid(goodsid+)); //吧goodsbean的数据放入到arraylist里面去 a1.add(gb); } } catch (exception e) { // todo: handle exception e.printstacktrace(); } finally { this.close(); } return a1; } //关闭资源 public void close() { try { if(!rs.isclosed()) { rs.close(); rs=null; } if(!ps.isclosed()) { ps.close(); ps=null; } if(!ct.isclosed()) { ct.close(); ct=null; } } catch (exception e) { // todo: handle exception e.printstacktrace(); } }}
/** * 这是一个model和order表对应 */package com.xf.model;import java.util.date;public class orderbean{ private long ordersid; // '订单号' , private long userid; // '那个用户订的' , private date orderdate; // '订单下的时期' , private string paymode; // '付款方式' , private byte ispayed; //'0表示没有付款，1表示已经付款' , private float totalprice; //'总价格' , public long getordersid() { return ordersid; } public void setordersid(long ordersid) { this.ordersid = ordersid; } public long getuserid() { return userid; } public void setuserid(long userid) { this.userid = userid; } public date getorderdate() { return orderdate; } public void setorderdate(date orderdate) { this.orderdate = orderdate; } public string getpaymode() { return paymode; } public void setpaymode(string paymode) { this.paymode = paymode; } public byte getispayed() { return ispayed; } public void setispayed(byte ispayed) { this.ispayed = ispayed; } public float gettotalprice() { return totalprice; } public void settotalprice(float totalprice) { this.totalprice = totalprice; } }
//这是一个model，对order，orderdetail的处理package com.xf.model;import java.sql.*;import java.util.*;public class orderbeanbo{ //定义数据库相关变量 private resultset rs=null; private connection ct=null; private preparedstatement ps=null; /** * 生成订单 * @param mbo 用户的购物车 * @param userid 用户id * @return 返回一个订单详细信息bean【oderinfobean】 */ public orderinfobean addorder(mycartbo mcbo, string userid) { orderinfobean oifb=new orderinfobean(); boolean b=true; try { //得到链接 ct=new conndb().getconn(); //带入mysql代码 string mysql=insert into `orders` (`userid`, `ispayed`, `totalprice`) values(?,?,?); ps=ct.preparestatement(mysql); ps.setstring(1, userid); ps.setbyte(2, (byte)0); ps.setfloat(3, mcbo.getallprice()); //执行 int a=ps.executeupdate(); if(a == 1) { //还得取出刚刚添加到orders表的订单号 //取出最后那条就是了 ps=ct.preparestatement(select max(`ordersid`) from `orders`); rs=ps.executequery(); int orderid=0; if(rs.next()) { orderid=rs.getint(1); } //orders表天机成功 //添加ordersdetail表 //从购物车中取出所有选购的货物 arraylist a1=mcbo.showmycart(); //循环添加到orderdetail中 //使用批量执行操作数据库 statement sm=ct.createstatement(); for(int i=0 ; i != a1.size() ; ++i) { goodsbean gb=(goodsbean)a1.get(i); string mysql2=insert into `orderdetail` values(+orderid+, +gb.getgoodsid()+, +mcbo.getgoodsnumbyid(gb.getgoodsid()+)+); sm.addbatch(mysql2); } //批量执行 sm.executebatch(); //顺带把要显示的订单细节 string mysql3=select `ordersid`, `truename`, `address`, `postcode`, `phone`, `totalprice`, `username`, `email` from + `users`, `orders` where `ordersid`=? and `users`.userid= ( select `orders`.userid from + `orders` where `ordersid`=? ); //执行语句 ps=ct.preparestatement(mysql3); ps.setint(1, orderid); ps.setint(2, orderid); rs=ps.executequery(); if(rs.next()) { //将rs封装到orderinfobean oifb.setordersid(rs.getint(1)); oifb.settruename(rs.getstring(2)); oifb.setaddress(rs.getstring(3)); oifb.setpostcode(rs.getstring(4)); oifb.setphone(rs.getstring(5)); oifb.settotalprice(rs.getfloat(6)); oifb.setusername(rs.getstring(7)); oifb.setemail(rs.getstring(8)); } } } catch (exception e) { // todo: handle exception b=false; e.printstacktrace(); } finally { this.close(); } if(b) { return oifb; } else { return null; } } //关闭资源 public void close() { try { if(!rs.isclosed()) { rs.close(); rs=null; } if(!ps.isclosed()) { ps.close(); ps=null; } if(!ct.isclosed()) { ct.close(); ct=null; } } catch (exception e) { // todo: handle exception e.printstacktrace(); } } }
package com.xf.model;public class orderdetailbean{ private long orderiid; private long goodsid; private int nums; public long getorderiid() { return orderiid; } public void setorderiid(long orderiid) { this.orderiid = orderiid; } public long getgoodsid() { return goodsid; } public void setgoodsid(long goodsid) { this.goodsid = goodsid; } public int getnums() { return nums; } public void setnums(int nums) { this.nums = nums; } }
/** * 信息最全的bean */package com.xf.model;import java.util.date;public class orderinfobean{ private long userid; // '用户id', private string username; // '用户名', private string truename; // '真实姓名', private string passwd; // '密码', private string email; // '电子邮件', private string phone; // '电话号码', private string address; // '用户地址', private string postcode; // '编邮', private int grade=1; // '户用级别', private long ordersid; // '订单号' , private long userid; // '那个用户订的' , private date orderdate; // '订单下的时期' , private string paymode; // '付款方式' , private byte ispayed; //'0表示没有付款，1表示已经付款' , private float totalprice; //'总价格' , public long getuserid() { return userid; } public void setuserid(long userid) { this.userid = userid; } public string getusername() { return username; } public void setusername(string username) { this.username = username; } public string gettruename() { return truename; } public void settruename(string truename) { this.truename = truename; } public string getpasswd() { return passwd; } public void setpasswd(string passwd) { this.passwd = passwd; } public string getemail() { return email; } public void setemail(string email) { this.email = email; } public string getphone() { return phone; } public void setphone(string phone) { this.phone = phone; } public string getaddress() { return address; } public void setaddress(string address) { this.address = address; } public string getpostcode() { return postcode; } public void setpostcode(string postcode) { this.postcode = postcode; } public int getgrade() { return grade; } public void setgrade(int grade) { this.grade = grade; } public long getordersid() { return ordersid; } public void setordersid(long ordersid) { this.ordersid = ordersid; } public long getuserid() { return userid; } public void setuserid(long userid) { this.userid = userid; } public date getorderdate() { return orderdate; } public void setorderdate(date orderdate) { this.orderdate = orderdate; } public string getpaymode() { return paymode; } public void setpaymode(string paymode) { this.paymode = paymode; } public byte getispayed() { return ispayed; } public void setispayed(byte ispayed) { this.ispayed = ispayed; } public float gettotalprice() { return totalprice; } public void settotalprice(float totalprice) { this.totalprice = totalprice; } }
package com.xf.model;public class usersbean{ private long userid; // '用户id', private string username; // '用户名', private string truename; // '真实姓名', private string passwd; // '密码', private string email; // '电子邮件', private string phone; // '电话号码', private string address; // '用户地址', private string postcode; // '编邮', private int grade=1; // '户用级别', public long getuserid() { return userid; } public void setuserid(long userid) { this.userid = userid; } public string getusername() { return username; } public void setusername(string username) { this.username = username; } public string gettruename() { return truename; } public void settruename(string truename) { this.truename = truename; } public string getpasswd() { return passwd; } public void setpasswd(string passwd) { this.passwd = passwd; } public string getemail() { return email; } public void setemail(string email) { this.email = email; } public string getphone() { return phone; } public void setphone(string phone) { this.phone = phone; } public string getaddress() { return address; } public void setaddress(string address) { this.address = address; } public string getpostcode() { return postcode; } public void setpostcode(string postcode) { this.postcode = postcode; } public int getgrade() { return grade; } public void setgrade(int grade) { this.grade = grade; }}
/** * 功能：处理有关users表的逻辑业务 * 时间：2014年7月10日15:22:10 * 作者：cutter_point */package com.xf.model;import java.sql.*;import com.xf.model.*;public class usersbeanbo{ //连接数据库的一些变量 private connection ct=null; private resultset rs=null; private preparedstatement ps=null; /** * 更具用户名返回用户的全部信息 * @param u * @return usersbean */ public usersbean getuserbean(string u) { usersbean ub=new usersbean(); try { //连接 ct=new conndb().getconn(); //导入mysql语句 string mysql=select * from `users` where username=? limit 0,1; ps=ct.preparestatement(mysql); ps.setstring(1, u); //执行语句 rs=ps.executequery(); if(rs.next()) { ub.setuserid(rs.getlong(1)); ub.setusername(rs.getstring(2)); ub.settruename(rs.getstring(3)); ub.setpasswd(rs.getstring(4)); ub.setemail(rs.getstring(5)); ub.setphone(rs.getstring(6)); ub.setaddress(rs.getstring(7)); ub.setpostcode(rs.getstring(8)); ub.setgrade(rs.getint(9)); } } catch (exception e) { // todo: handle exception e.printstacktrace(); } finally { this.close(); } return ub; } /** * @author xiaofeng * @param u 账号 * @param p 密码 */ public boolean checkuser(string u, string p) { boolean b=false; try { //连接数据库 string mysql=select `passwd` from `users` where `username`=?; //建立连接 ct=new conndb().getconn(); //导入语句 ps=ct.preparestatement(mysql); ps.setstring(1, u); //执行语句 rs=ps.executequery(); if(rs.next()) { //取出数据库密码和p比较 string dbpasswd=rs.getstring(1); if(dbpasswd.equals(p)) { b=true; } } } catch (exception e) { // todo: handle exception e.printstacktrace(); } finally { this.close(); } return b; } /** * @author xiaofeng * @param 关闭资源 */ public void close() { try { if(!rs.isclosed()) { rs.close(); rs=null; } if(!ps.isclosed()) { ps.close(); ps=null; } if(!ct.isclosed()) { ct.close(); ct=null; } } catch (exception e) { // todo: handle exception e.printstacktrace(); } } }