.#merg58688cvs

Athena酒店小组_Athena酒店管理系统

/*
 * GoodsOperate.java
 *
 * Created on 2007年6月19日, 上午12:47
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package jack;
import java.sql.*;
import java.util.*;
import plugin.*;
import helper.*;
/**
 *
 * @author zzx
 */
public class GoodsOperate {
    private IDBResource dbRes;    //数据库连接资源
    /** Creates a new instance of GoodsOperate */
    /**
     * 构造函数
     * @param dbRes 数据库资源
     */
    public GoodsOperate(IDBResource _dbRes) {
         this.dbRes=_dbRes;
    }
    
     /**
     * 对GoodsInfo表进行插入操作
     * @param GoodsInfo 要插入的物品信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int insert(GoodsInfo goodsInfo){
        try{
            Connection conn = dbRes.getConnection();
            String sql="INSERT INTO GoodsInfo(GoodsID,GoodsName,Spec,Unit,Sort,Storage," +
                    "UpperLimit,LowerLimit,Remark)"+"VALUES(?,?,?,?,?,?,?,?,?)";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, goodsInfo.getGoodsID());
            ps.setString(2, goodsInfo.getGoodsName());
            ps.setString(3, goodsInfo.getSpec());
            ps.setString(4, goodsInfo.getUnit());
            ps.setString(5, goodsInfo.getSort());
            ps.setFloat(6, goodsInfo.getStorage());
            ps.setFloat(7, goodsInfo.getUpperLimit());
            ps.setFloat(8, goodsInfo.getLowerLimit());
            ps.setString(9, goodsInfo.getRemark());
            int rs = ps.executeUpdate();
	    return rs;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 对GoodsInfo表进行更新操作
     * @param GoodsInfo 要更新的物品信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int update(GoodsInfo goodsInfo){
        try{
            Connection conn = dbRes.getConnection();
            String sql="UPDATE GoodsInfo SET GoodsName=?,Spec=?,Unit=?,Sort=?,Storage=?," +
                    "UpperLimit=?,LowerLimit=?,Remark=? WHERE GoodsID=?";
            PreparedStatement ps = conn.prepareStatement(sql);            
            ps.setString(1, goodsInfo.getGoodsName());
            ps.setString(2, goodsInfo.getSpec());
            ps.setString(3, goodsInfo.getUnit());
            ps.setString(4, goodsInfo.getSort());
            ps.setFloat(5, goodsInfo.getStorage());
            ps.setFloat(6, goodsInfo.getUpperLimit());
            ps.setFloat(7, goodsInfo.getLowerLimit());
            ps.setString(8, goodsInfo.getRemark());
            ps.setString(9, goodsInfo.getGoodsID());
            int rs = ps.executeUpdate();
	    return rs;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 对GoodsInfo表进行删除操作
     * @param GoodsInfo 要删除的物品信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int delete(GoodsInfo goodsInfo){
        try{
            Connection conn = dbRes.getConnection();
	    String sql = "DELETE FROM GoodsInfo WHERE GoodsID = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, goodsInfo.getGoodsID());
	    int rs = ps.executeUpdate();
	    return rs;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return -1;
        } 
    }
    
    /**
     * 返回GoodsInfo表的所有信息
     * @return 所有物品信息
     */
    public ArrayList<GoodsInfo> getAllGoods(){
        try{
            Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM GoodsInfo";
            PreparedStatement ps = conn.prepareStatement(sql);
	    ResultSet rs = ps.executeQuery();
            ArrayList<GoodsInfo> goods=new ArrayList<GoodsInfo>();
            readData(goods,rs);
            return goods;
        }catch(SQLException ex){
            ex.printStackTrace();
            return null;
        }
    }
    
    /**
     * 根据Id查询GoodsInfo表的信息
     * @param _goodsId 物品的ID
     * @return 查询到的物品信息
     */
    public GoodsInfo getGoodsByID(String _goodsID){
        try{
            Connection conn = dbRes.getConnection();
            String sql="SELECT * FROM GoodsInfo WHERE GoodsID=?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, _goodsID);
            ResultSet rs = ps.executeQuery();
            ArrayList<GoodsInfo> goods=new ArrayList<GoodsInfo>();
            readData(goods,rs);
            if(goods.size()!=1){
                return null;
            }
            return goods.get(0);
        }catch (SQLException ex){
		ex.printStackTrace();
		return null;
	}
    }
    
    /**
     * 根据条件查询GoodsInfo表的信息
     * @param names 条件的名称
     * @param values 条件的值
     * @return 查询到的物品信息
     */
    public ArrayList<GoodsInfo> getGoodsBycondition(String name,String values){
        try{
            Connection conn = dbRes.getConnection();
            String sql="SELECT * FROM GoodsInfo WHERE "+name+" LIKE'%"+values+"%'";
            PreparedStatement ps = conn.prepareStatement(sql);
            ResultSet rs = ps.executeQuery();
            ArrayList<GoodsInfo> goods=new ArrayList<GoodsInfo>();
            readData(goods,rs);
            return goods;
        }catch (SQLException ex){
		ex.printStackTrace();
		return null;
	}
    }    
    
    //读取数据
    private void readData(ArrayList<GoodsInfo> goods,ResultSet rs) throws SQLException{
        while(rs.next()){
            GoodsInfo gi=new GoodsInfo();
            gi.setGoodsID(rs.getString("GoodsID"));
            System.out.println("goodsID="+rs.getString("GoodsID"));
            gi.setGoodsName(rs.getString("GoodsName"));
            gi.setSpec(rs.getString("Spec"));
            gi.setUnit(rs.getString("Unit"));
            gi.setSort(rs.getString("Sort"));
            gi.setStorage(rs.getFloat("Storage"));
            gi.setUpperLimit(rs.getFloat("UpperLimit"));
            gi.setLowerLimit(rs.getFloat("LowerLimit"));
            gi.setRemark(rs.getString("Remark"));
            goods.add(gi);
        }
    }
}