java购物车项目源码

package www.mary.access; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import www.mary.Bean.ItemBean; import www.mary.database.BaseDAO; import www.mary.Bean.*; //一些通用的数据展现方法 public class PowerAccess { public PowerAccess() { super(); } //------------------------------------------------------------------------------------ //展现产品大类所有的大类名称，先给Categorybean赋值，然后存放倒List里面 public static List getCategoryName(){ List list=new ArrayList(); String sql="select * from category"; System.out.println("------"+sql); BaseDAO dao=new BaseDAO(); ResultSet rs=dao.executeQuery(sql); try { while(rs.next()){ CategoryBean catename=new CategoryBean(rs.getString(1),rs.getString(2),rs.getString(3)); list.add(catename); } }catch (SQLException e) { e.printStackTrace(); }finally{ dao.Close(); } return list; } //------------------------------------------------------------------------------------ //展现产品大类catid所对应的产品名称，传递一个catid值 public static List getProductList(String catid){ List list=new ArrayList(); String sql="select * from product where catid="+catid; System.out.println("------"+sql); BaseDAO dao=new BaseDAO(); ResultSet rs=dao.executeQuery(sql); try { while(rs.next()){ ProductBean product=new ProductBean(rs.getString(1),rs.getString(2),rs.getString(3),rs.getString(4)); list.add(product); } }catch (SQLException e) { e.printStackTrace(); }finally{ dao.Close(); } return list; } //------------------------------------------------------------------------------------ //展现productid对应的产品项目，传递一个productid值 public static List getItemlist(String productid){ List list=new ArrayList(); String sql="select itemid,productid,listprice,attr1 from item where productid="+productid; System.out.println("------"+sql); BaseDAO dao=new BaseDAO(); ResultSet rs=dao.executeQuery(sql); try { while(rs.next()){ ItemBean item=new ItemBean(rs.getString(1),rs.getString(2),rs.getDouble(3),rs.getString(4)); list.add(item); } }catch (SQLException e) { e.printStackTrace(); }finally{ dao.Close(); } return list; } //------------------------------------------------------------------------------------ //展现itemid对应的产品项目的价格，状态，库存，传递一个itemid值 public static List getlineitemlist(String itemid){ List list=new ArrayList(); String sql="select A.descn,B.listprice,B.status,C.qty from product A,item B,inventory C where A.productid=B.productid and B.itemid=C.itemid and B.itemid='"+itemid+"'"; System.out.println("------"+sql); BaseDAO dao=new BaseDAO(); ResultSet rs=dao.executeQuery(sql); try { while(rs.next()){ ItemInventoryBean one=new ItemInventoryBean(rs.getString(1),rs.getInt(2),rs.getString(3),rs.getInt(4)); list.add(one); } }catch (SQLException e) { e.printStackTrace(); }finally{ dao.Close(); } return list; } //------------------------------------------------------------------------------------ //展现购物车中对应的产品项目编号，产品编号，描述，是否有库存，数量，价格，传递一个itemad值 public static List getcartlist(String itemid){ List list=new ArrayList(); String sql="select B.itemid,A.productid,B.attr1,B.status,C.qty,B.listprice from product A,item B,inventory C where A.productid=B.productid and B.itemid=C.itemid and B.itemid='"+itemid+"'"; System.out.println("------"+sql); BaseDAO dao=new BaseDAO(); ResultSet rs=dao.executeQuery(sql); try { while(rs.next()){ ProitemBean one=new ProitemBean(rs.getString(1),rs.getString(2),rs.getString(3),rs.getString(4),rs.getInt(5)); list.add(one); } }catch (SQLException e) { e.printStackTrace(); }finally{ dao.Close(); } return list; } public static ProitemBean getcart(String itemid){ ProitemBean one=null; String sql="select B.itemid,A.productid,B.attr1,B.status,B.listprice from product A,item B,inventory C where A.productid=B.productid and B.itemid=C.itemid and B.itemid='"+itemid+"'"; System.out.println("------"+sql); BaseDAO dao=new BaseDAO(); ResultSet rs=dao.executeQuery(sql); try { while(rs.next()){ one=new ProitemBean(rs.getString(1),rs.getString(2),rs.getString(3),rs.getString(4),rs.getInt(5)); } }catch (SQLException e) { e.printStackTrace(); }finally{ dao.Close(); } return one; } //------------------------------------------------------------------------------------ //------------------------------------------------------------------------------------ //这是通用的校验用户合法性的程序 public static boolean validateUser(String uname,String pword) { boolean isCorrect=false; String sql="select * from signon where username='"+uname+"' and password='"+pword+"'"; //建立数据库连接，进行查询 BaseDAO dao=new BaseDAO(); //得到结果集合 ResultSet rs=dao.executeQuery(sql); //如果查到了结果集合就不为空 try { if(rs.next()){ //在这里标签赋值乘true isCorrect=true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } dao.Close(); return isCorrect; } //------------------------------------------------------------------------------------ public static ItemBean getOneItem(String itemid) { ItemBean one=null; String sql="select * from item where itemid='"+itemid+"'"; BaseDAO dao=new BaseDAO(); ResultSet rs=dao.executeQuery(sql); try{ if(rs.next()) { one=new ItemBean(rs.getString(1),rs.getString(2),rs.getInt(3),rs.getDouble(4),rs.getDouble(5),rs.getString(6), rs.getString(7),rs.getString(8),rs.getString(9),rs.getString(10),rs.getString(11)); } }catch (SQLException e){ e.printStackTrace(); } dao.Close(); return one; } }