goodsinoperate.java

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

/*
 * GoodsInOperate.java
 *
 * Created on 2007年6月4日, 上午3:50
 *
 * 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 GoodsInOperate {
    private IDBResource dbRes;
    
    /**
     * 构造函数
     * @param dbRes 数据库资源
     */
    public GoodsInOperate(IDBResource _dbRes) 
    {
        this.dbRes=_dbRes;
    }
    
    /**
     * 对GoodsInInfo表进行插入操作
     * @param gii 要插入的w物品信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int insert(GoodsInInfo gii)
    {
        try
        {
            Connection conn = dbRes.getConnection();
            String sql="INSERT INTO GoodsInInfo(GoodsInID,GoodsInDate,DepotID,GoodsID,ProviderID,"+
                    "UnitPrice,Amount,Sort,Handler,Remark,Operator)"+"VALUES(?,?,?,?,?,?,?,?,?,?,?)";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, gii.getGoodsInID());
            ps.setObject(2, gii.getGoodsInDate());
            ps.setString(3, gii.getDepotID());
            ps.setString(4, gii.getGoodsID());
            ps.setString(5, gii.getProviderID());
            ps.setFloat(6, gii.getUnitPrice());
            ps.setFloat(7, gii.getAmount());
            ps.setString(8, gii.getSort());
            ps.setString(9, gii.getHandler());
            ps.setString(10, gii.getRemark());
            ps.setString(11, gii.getOperator());
            int rs = ps.executeUpdate();
	    return rs;
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 对GoodsInInfo表进行更新操作
     * @param gii 要更新的物品信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int update(GoodsInInfo gii)
    {
        try
        {
            Connection conn = dbRes.getConnection();
            String sql="UPDATE GoodsInInfo SET GoodsInDate=?,DepotID=?,GoodsID=?,"+
                    "PrividerID=?,UnitPrice=?,Amount=?,Sort=?,Handler=?,Remark=?"+
                    "Operator=? WHERE GoodsInID";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setObject(1, gii.getGoodsInDate());
            ps.setString(2, gii.getDepotID());
            ps.setString(3, gii.getGoodsID());
            ps.setString(4, gii.getProviderID());
            ps.setFloat(5, gii.getUnitPrice());
            ps.setFloat(6, gii.getAmount());
            ps.setString(7, gii.getSort());
            ps.setString(8, gii.getHandler());
            ps.setString(9, gii.getRemark());
            ps.setString(10, gii.getOperator());
            ps.setString(11, gii.getGoodsInID());
            int rs = ps.executeUpdate();
	    return rs;
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 对GoodsInInfo表进行删除操作
     * @param gii 要删除的物品信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int delete(GoodsInInfo gii)
    {
        try
        {
            Connection conn = dbRes.getConnection();
	    String sql = "DELETE FROM GoodsInInfo WHERE GoodsInId = ?";           
	    PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, gii.getGoodsInID());
	    int rs = ps.executeUpdate();            
	    return rs;
        }
        catch(SQLException ex)
        {
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 根据Id查询GoodsInInfo表的信息
     * @param _goodsInID 入库信息的ID
     * @return 查询到的入库信息
     */
    public GoodsInInfo getGoodsInInfoByID(String _goodsInID)
    {
        try
        {
            Connection conn = dbRes.getConnection();
            String sql="SELECT * FROM GoodsInInfo WHERE GoodsInID=?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, _goodsInID);
            ResultSet rs = ps.executeQuery();
            ArrayList<GoodsInInfo> goodsInInfo = new ArrayList<GoodsInInfo>();
            readData(goodsInInfo, rs);
            if (goodsInInfo.size() != 1)
	    {
		return null;
	    }
	    return goodsInInfo.get(0);
        }
        catch (SQLException ex){
		ex.printStackTrace();
		return null;
	}
    }
    
    public ArrayList<GoodsInInfo> getGoodsBycontion(String depotID,String goodsID,
            String providerID,String sort,String handler){
        try{
            Connection conn = dbRes.getConnection();
            String sql="SELECT * FROM GoodsInInfo WHERE DepotID LIKE'%"+depotID+"%' AND GoodsID " +
                    "LIKE'%"+goodsID+"%' AND ProviderID LIKE'%"+providerID+"%' AND Sort LIKE'%" +sort
                    +"%' AND Handler LIKE'%"+handler+"%'";
            //String sql="SELECT * FROM GoodsInInfo";
            System.out.println(sql);
            PreparedStatement ps = conn.prepareStatement(sql);  
            ResultSet rs = ps.executeQuery();
            ArrayList<GoodsInInfo> goodsInInfo = new ArrayList<GoodsInInfo>();
            readData(goodsInInfo, rs);
            return goodsInInfo;            
        }catch (SQLException ex){
		ex.printStackTrace();
		return null;
	}
    }
    
    
    //读取数据
    private void readData(ArrayList<GoodsInInfo> goodsInInfo,ResultSet rs) throws SQLException
    {
        while(rs.next())
        {
            GoodsInInfo gii=new GoodsInInfo();
            gii.setGoodsInID(rs.getString("GoodsInID"));
            gii.setGoodsInDate(rs.getDate("GoodsInDate"));
            gii.setDepotID(rs.getString("DepotID"));
            gii.setGoodsID(rs.getString("GoodsID"));
            gii.setProviderID(rs.getString("ProviderID"));
            gii.setUnitPrice(rs.getFloat("UnitPrice"));
            gii.setAmount(rs.getFloat("Amount"));
            gii.setSort(rs.getString("Sort"));
            gii.setHandler(rs.getString("Handler"));
            gii.setRemark(rs.getString("Remark"));
            gii.setOperator(rs.getString("Operator"));
            goodsInInfo.add(gii);
        }
    }
}