provideroperate.java

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

/*
 * ProviderOperate.java
 *
 * Created on 2007年6月19日, 上午11:09
 *
 * 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 ProviderOperate {
    private IDBResource dbRes;     /*数据库连接资源*/
    /** Creates a new instance of ProviderOperate */
    /**
     * 构造函数
     * @param dbRes 数据库资源
     */
    public ProviderOperate(IDBResource _dbRes) {
        this.dbRes=_dbRes;
    }
    
    /**
     * 对ProviderInfo表进行插入操作
     * @param providerInfo 要插入的信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int insert(ProviderInfo providerInfo){
        try{
            Connection conn = dbRes.getConnection();
            String sql="INSERT INTO ProviderInfo(ProviderID,ProviderName,Linkman,Tel," +
                    "Address,Postalcode,Remark)"+"VALUES(?,?,?,?,?,?,?)";
            PreparedStatement ps = conn.prepareStatement(sql);
             ps.setString(1, providerInfo.getProviderID());
             ps.setString(2, providerInfo.getProviderName());
             ps.setString(3, providerInfo.getLinkman());
             ps.setString(4, providerInfo.getTel());
             ps.setString(5, providerInfo.getAddress());
             ps.setString(6, providerInfo.getPostalcode());
             ps.setString(7, providerInfo.getRemark());
             int rs = ps.executeUpdate();
	    return rs;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 对ProviderInfo表进行更新操作
     * @param providerInfo 要更新的信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int update(ProviderInfo providerInfo){
        try{
            Connection conn = dbRes.getConnection();
            String sql="UPDATE ProviderInfo SET ProviderName=?,Linkman=?,Tel=?," +
                    "Address=?,Postalcode=?,Remark=? WHERE ProviderID=?";
            PreparedStatement ps = conn.prepareStatement(sql);             
             ps.setString(1, providerInfo.getProviderName());
             ps.setString(2, providerInfo.getLinkman());
             ps.setString(3, providerInfo.getTel());
             ps.setString(4, providerInfo.getAddress());
             ps.setString(5, providerInfo.getPostalcode());
             ps.setString(6, providerInfo.getRemark());
             ps.setString(7, providerInfo.getProviderID());
             System.out.println(sql);
             int rs = ps.executeUpdate();
	    return rs;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 对ProviderInfo表进行删除操作
     * @param providerInfo 要删除的信息
     * @return 影响的行数，如果发生错误，则返回-1
     */
    public int delete(ProviderInfo providerInfo){
        try{
            Connection conn = dbRes.getConnection();
            String sql="DELETE FROM ProviderInfo WHERE ProviderID=?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1,providerInfo.getProviderID());
            int rs = ps.executeUpdate();
	    return rs;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return -1;
        }
    }
    
    /**
     * 返回ProviderInfo表的所有信息
     * @return 所有供应商信息
     */
    public ArrayList<ProviderInfo> getAllProvider(){
        try{
            Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM ProviderInfo";
            PreparedStatement ps = conn.prepareStatement(sql);
	    ResultSet rs = ps.executeQuery();
            ArrayList<ProviderInfo> providers=new ArrayList<ProviderInfo>();
            readData(providers,rs);
            return providers;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return null;
        }
    }
    
    /**
     * 根据Id查询ProviderInfo表的信息
     * @param _providerID 仓库的ID
     * @return 查询到的仓库信息
     */
    public ProviderInfo getProviderByID(String _providerID){
        try{
            Connection conn = dbRes.getConnection();
            String sql="SELECT * FROM ProviderInfo WHERE ProviderID=?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, _providerID);
            ResultSet rs = ps.executeQuery();
            ArrayList<ProviderInfo> providers=new ArrayList<ProviderInfo>();
            readData(providers,rs);
            if(providers.size()!=1){
                return null;
            }
            return providers.get(0);
        }catch(SQLException ex){
            ex.printStackTrace();
	    return null;
        }
    }
    
    /**
     * 根据条件查询ProviderInfo表的信息
     * @param name 条件的名称
     * @param values 条件的值
     * @return 查询到的仓库信息
     */
    public ArrayList<ProviderInfo> getProviderBycondition(String name,String values){
        try{
            Connection conn = dbRes.getConnection();
            String sql="SELECT * FROM ProviderInfo WHERE "+name+" LIKE'%"+values+"%'";
            PreparedStatement ps = conn.prepareStatement(sql);
            ResultSet rs = ps.executeQuery();
            ArrayList<ProviderInfo> providers=new ArrayList<ProviderInfo>();
            readData(providers,rs);
            return providers;
        }catch(SQLException ex){
            ex.printStackTrace();
	    return null;
        }
    }   
    
    //读取数据
    private void readData(ArrayList<ProviderInfo> providers,ResultSet rs) throws SQLException{
        while(rs.next()){
            ProviderInfo pi=new ProviderInfo();
            pi.setProviderID(rs.getString("ProviderID"));
            pi.SetProviderName(rs.getString("ProviderName"));
            pi.setLinkman(rs.getString("Linkman"));
            pi.setTel(rs.getString("Tel"));
            pi.setAddress(rs.getString("Address"));
            pi.setPostalcode(rs.getString("Postalcode"));
            pi.setRemark(rs.getString("Remark"));
            providers.add(pi);
        }
    }
}