pcaccess.java

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

/*
 * PCAccess.java
 *
 * Created on 2007年5月23日, 上午1:39
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package vincent;

import java.util.*;
import java.sql.*;
import plugin.*;

/**
 *
 * @author Virlene Cheng
 */
public class PCAccess
{
    private IDBResource dbRes;
    
    /** Creates a new instance of PCAccess */
    public PCAccess(IDBResource dbRes)
    {
	this.dbRes = dbRes;
    }

    public int insert(PersonnelChange pc)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "INSERT INTO PersonnelChange(ChangeType, EmployeeId, BeforeDeptId, AfterDeptId, Reason, ChangeDate, ExecutorId, Remark) " +
		    " VALUES(?, ?, ?, ?, ?, ?, ?, ?)";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, pc.getChangeType());
	    ps.setString(2, pc.getEmployeeId());
	    ps.setString(3, pc.getBeforeDeptId());
	    ps.setString(4, pc.getAfterDeptId());
	    ps.setString(5, pc.getReason());
	    ps.setObject(6, pc.getChangeDate());
	    ps.setString(7, pc.getExecutorId());
	    ps.setString(8, pc.getRemark());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }
    
    public int update(PersonnelChange pc)
    {
	//TODO update
	return -1;
    }
    
    public int delete(PersonnelChange pc)
    {
	//TODO delete
	return -1;
    }
    
    public ArrayList<PersonnelChange> getPersonnelChangeByEmployeeId(String employeeId)
    {	
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM PersonnelChange WHERE EmployeeId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, employeeId);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<PersonnelChange> pcs = new ArrayList<PersonnelChange>();
	    while(rs.next())
	    {
		PersonnelChange pc = new PersonnelChange();
		pc.setChangeId(rs.getInt("ChangeId"));
		pc.setChangeType(rs.getString("ChangeType"));
		pc.setEmployeeId(rs.getString("EmployeeId"));
		pc.setBeforeDeptId(rs.getString("BeforeDeptId"));
		pc.setAfterDeptId(rs.getString("AfterDeptId"));
		pc.setReason(rs.getString("Reason"));
		pc.setChangeDate(rs.getDate("ChangeDate"));
		pc.setExecutorId(rs.getString("ExecutorId"));
		pc.setRemark(rs.getString("Remark"));
		pcs.add(pc);
	    }
	    return pcs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}		
    }
    
    
    
    
    
    
}