www.pudn.com > BeiJie.rar > EmployeeOperation.java

package operation; 
 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.util.ArrayList; 
import java.util.Collection; 
 
import entity.*; 
 
import dataBase.DataBase; 
 
public class EmployeeOperation 
{ 
	public EmployeeOperation() 
	{ 
		db = new DataBase(); 
	} 
 
	//获得员工编号 
	public int addEmployeeID() 
	{ 
		try 
		{ 
			sql1 = "select * from EmployeeInfo"; 
			rs = db.getResult(sql1); 
			rs.last(); 
			EmployeeID = rs.getRow()+1; 
			sql6 = "select * from EmployeeInfo"; 
			rs=db.getResult(sql6); 
			//为了防止删除用户之后再添加信息时，员工编号重复，而将新录入的员工编号与数据库中的编号比较 
			while(rs.next()) 
			{ 
				EmployeeInfo employee = new EmployeeInfo(); 
				int id = Integer.parseInt(rs.getString("employeeID")); 
				if (EmployeeID <= id) 
				{ 
					EmployeeID = id + 1; 
				} 
			} 
		} 
		catch(SQLException e) 
		{ 
			e.printStackTrace(); 
		} 
		return EmployeeID; 
	} 
	 
	//录入员工信息 
	public void addEmployeeInfo(boolean flag,int employeeID,String employeeName,String password,String employeeClass) 
	{ 
		if (flag == true) 
		{ 
			sql2 = "insert into EmployeeInfo values('"+employeeID+"','"+employeeName+"','"+password+"','"+employeeClass+"')"; 
			db.ExeQuery(sql2); 
		} 
	} 
	 
	//员工信息查询 
	public Collection EmployeeSearch() 
	{ 
		sql3 = "select * from EmployeeInfo"; 
		rs=db.getResult(sql3); 
		Collection ret=new ArrayList(); 
		 
		try 
		{ 
			while(rs.next()) 
			{ 
				EmployeeInfo employee = new EmployeeInfo(); 
				String id = rs.getString("employeeID"); 
				employee.setEmployeeID(Integer.parseInt(id)); 
				employee.setEmployeeName(rs.getString("employeeName")); 
				employee.setPassword(rs.getString("password")); 
				employee.setEmployeeClass(rs.getString("employeeClass")); 
				ret.add(employee); 
			} 
		 
		} 
		catch(Exception e) 
		{ 
			e.printStackTrace(); 
		} 
		return ret; 
	} 
	 
	//员工信息修改 
	public void modifyEmployeeInfo(int employeeID,String employeeName,String password,String employeeClass) 
	{ 
		sql4 = "update EmployeeInfo set employeeName = '"+employeeName+"' , password = '"+password+"', employeeClass = '"+employeeClass+"' where employeeID = '"+employeeID+"'"; 
		db.ExeQuery(sql4); 
	} 
	 
	//员工信息删除 
	public void deleteEmployeeInfo(int employeeID) 
	{ 
		sql5 = "delete from EmployeeInfo where employeeID = '"+employeeID+"'"; 
		db.ExeQuery(sql5); 
	} 
	 
	//关闭连接 
	public void close() 
	{ 
		db.shut(); 
	} 
	private DataBase db = null; 
	private String sql1 = ""; 
	private ResultSet rs = null; 
	private int EmployeeID = 0; 
	private String sql2 = ""; 
	private String sql3 = ""; 
	private String sql4 = ""; 
	private String sql5 = ""; 
	private String sql6 = ""; 
}