demo.zip_DEMO_site:en.pudn.com

package com.Brooklyn.demo.dao; import java.sql.*; import java.util.*; import com.Brooklyn.demo.endity.User1; /* * 查询所有商品 */ public class User1DAO extends DBHelper{ public List<User1> getAll(){ List<User1> list=new ArrayList<User1>(); String sql="select *from product"; Connection conn=null; PreparedStatement psst=null; ResultSet rs=null; try { conn=super.openConn(); psst=conn.prepareStatement(sql); rs=psst.executeQuery(); User1 u1=null; while(rs.next()){ u1=new User1(); u1.setNum(rs.getInt("productNum")); u1.setName(rs.getString("productName")); u1.setType(rs.getString("productType")); u1.setPrice(rs.getInt("productPrice")); u1.setDate(rs.getString("productDate")); u1.setAmount(rs.getInt("amount")); list.add(u1); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } /* * 根据商品编号查询 * 输入编号判断商品是否存在 */ public User1 getUser1ByproductNum(int num) { User1 u = null; String sql = "select * from product where productNum=" + num; Connection conn = null; PreparedStatement psst = null; ResultSet rs = null; try { conn = super.openConn(); psst = conn.prepareStatement(sql); rs = psst.executeQuery(); if (rs.next()) { u=new User1(); u.setNum(rs.getInt("productNum")); u.setName(rs.getString("productName")); u.setType(rs.getString("productType")); u.setPrice(rs.getInt("productPrice")); u.setDate(rs.getString("productDate")); u.setAmount(rs.getInt("amount")); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { super.closeAll(rs, psst, conn); } return u; } /* * 商品新增 */ public boolean insertUser1(int num,String name,String type, int price,String date,int amount){ boolean flag=false; String sql="insert into product(productNum,productName,productType,productPrice,productDate,amount) values ("+num+"," + "'"+name+"','"+type+"',"+price+",'"+date+"',"+amount+")"; Connection conn = null; PreparedStatement psst = null; try { conn = super.openConn(); psst = conn.prepareStatement(sql); if(psst.executeUpdate()>0){ flag=true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ super.closeAll(null, psst, conn); } return flag; } /* * 商品修改 */ public boolean updateUser1(int num,String name,String type,int price){ boolean flag=false; String sql="update product set productName='"+name+"',productType=" + "'"+type+"',productPrice="+price+" where productNum="+num; Connection conn = null; PreparedStatement psst = null; try { conn = super.openConn(); psst = conn.prepareStatement(sql); if(psst.executeUpdate()>0){ flag=true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ super.closeAll(null, psst, conn); } return flag; } public boolean updateUser1Amount(int num,int amount){ boolean flag=false; String sql="update product set amount= "+amount+" where productNum="+num; Connection conn = null; PreparedStatement psst = null; try { conn = super.openConn(); psst = conn.prepareStatement(sql); if(psst.executeUpdate()>0){ flag=true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ super.closeAll(null, psst, conn); } return flag; } /* * 根据商品编号删除商品 */ public boolean deleteUser1ByproductNum(int num){ boolean flag=false; String sql="delete from product where productNum="+num; Connection conn = null; PreparedStatement psst = null; try { conn = super.openConn(); psst = conn.prepareStatement(sql); if(psst.executeUpdate()>0){ flag=true; } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ super.closeAll(null, psst, conn); } return flag; } }