gooddao.java

网上购物系统

package eshopsys.good.model;

import java.sql.*;
import java.util.*;
import eshopsys.tools.base.BaseDao;
import eshopsys.tools.base.BaseEntity;
import eshopsys.tools.database.DataBaseTool;
import eshopsys.good.model.*;

public class GoodDao extends BaseDao {
//////////////////////////////////////////////////////////////////////////
	protected BaseEntity[] pack(ResultSet resultset) throws SQLException {
		 ArrayList result = new ArrayList();
		 GoodEntity[] goods = null;
		    while (resultset.next()) {
		      GoodEntity good = new GoodEntity();
		      good.setGoodId(resultset.getInt("goodid"));
		      good.setGoodTypeId(resultset.getInt("goodtypeid"));
		      good.setGoodName(resultset.getString("goodname"));
		      good.setGoodUnitPrice(resultset.getFloat("goodunitprice"));
		      good.setGoodPromotionPrice(resultset.getFloat("goodpromotionprice"));
		      good.setGoodStorageNum(resultset.getInt("goodstoragenum"));
		      good.setGoodPlace(resultset.getString("goodplace"));
		      good.setGoodImage(resultset.getString("goodimage"));
		      good.setGoodIntroduction(resultset.getString("goodintroduction"));
		      result.add(good);
		    }
		    if (result.size() > 0) {
		      goods= new GoodEntity[result.size()];
		      result.toArray(goods);
		    }
		    return goods;

	}
//////////////////////////////////////////////////////////////////////////	
	public void insert(GoodEntity good) throws
    SQLException {
    PreparedStatement ps = null;
    StringBuffer buffer = new StringBuffer();
    try {
    //构造添加sql语句
    buffer.append("INSERT INTO tbl_good(goodid,goodtypeid,goodname,goodunitprice,goodpromotionprice,goodstoragenum,goodplace,goodimage,goodintroduction)");
    buffer.append(" VALUES(?,?,?,?,?,?,?,?,?)");

    ps = con.prepareStatement(buffer.toString());
    //设置sql语句的参数
    int index = 1;
    int currentId=getMaxPrimaryId("tbl_good","goodid");
    ps.setInt(index++,currentId);
    ps.setInt(index++, good.getGoodTypeId());
    ps.setString(index++, good.getGoodName());
    ps.setFloat(index++, good.getGoodUnitPrice());
    ps.setFloat(index++, good.getGoodPromotionPrice());
    ps.setInt(index++, good.getGoodStorageNum());
    ps.setString(index++, good.getGoodPlace());
    ps.setString(index++, good.getGoodImage());
    ps.setString(index++, good.getGoodIntroduction());
    
    //执行sql语句
    ps.executeUpdate();
  }
  catch (Exception e) {
    throw new SQLException("向表(tbl_good)中插入数据发生异常 ： " + e.getMessage());
  }
  finally {
    DataBaseTool.close(ps);
  }
 }
//////////////////////////////////////////////////////////////////////////
	//更新一条会员记录
	  public void update(GoodEntity good) throws     
	 SQLException {
	    PreparedStatement ps = null;
	    StringBuffer buffer = new StringBuffer();
	    try {
	      //构造更新sql语句
	      buffer.append("UPDATE tbl_good SET ");
	      buffer.append("goodid=?,goodtypeid=?,goodname=?,goodunitprice=?,goodpromotionprice=?,goodstoragenum=?,goodplace=?,goodimage=?,goodintroduction=?");
	      buffer.append(" WHERE goodid = ?");
	      ps = con.prepareStatement(buffer.toString());

	      //设置参数
	      int index = 1;
	      ps.setInt(index++, good.getGoodId());
	      ps.setInt(index++, good.getGoodTypeId());
	      ps.setString(index++, good.getGoodName());
	      ps.setFloat(index++, good.getGoodUnitPrice());
	      ps.setFloat(index++, good.getGoodPromotionPrice());
	      ps.setInt(index++, good.getGoodStorageNum());
	      ps.setString(index++, good.getGoodPlace());
	      ps.setString(index++, good.getGoodImage());
	      ps.setString(index++, good.getGoodIntroduction());
	      ps.setInt(index++, good.getGoodId());
	      //执行
	      ps.executeUpdate();
	    }
	    catch (Exception e) {
	      throw new SQLException("更新表(tbl_good)时发生异常 : " + e.getMessage());
	    }
	    finally {
	      DataBaseTool.close(ps);
	    }
	  }

}