employeedao.java

来自「struts做得固定资产管理系统 带毕业论文完整版」· Java 代码 · 共 227 行

package com.qrsx.appcam.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.qrsx.appcam.model.Employee;

public class EmployeeDAO extends BaseDAO {
	/**
	 * 创建员工
	 * 
	 * @param employee
	 * @throws SQLException
	 */
	public void create(Employee employee) throws SQLException {

		String sql = "Insert into employee ( code,name,roleId,deptmentId,description)values(?,?,?,?,?)";

		ps = conn.prepareStatement(sql);
		// 设置参数
		ps.setString(1, employee.getCode());
		ps.setString(2, employee.getName());
		ps.setInt(3, employee.getRoleId());
		ps.setInt(4, employee.getDeptmentId());
		ps.setString(5, employee.getDescription());
		// 执行插入操作
		ps.executeUpdate();

	}

	/**
	 * 更新员工
	 * 
	 * @param employee
	 * @throws SQLException
	 */
	public void update(Employee employee) throws SQLException {

		String sql = "Update employee set code=?,name=?,roleId=?,deptmentId=?,description=? where id=?";
		ps = conn.prepareStatement(sql);
		// 设置参数
		ps.setString(1, employee.getCode());
		ps.setString(2, employee.getName());
		ps.setInt(3, employee.getRoleId());
		ps.setInt(4, employee.getDeptmentId());
		ps.setString(5, employee.getDescription());
		ps.setInt(6, employee.getId());
		// 执行更新操作
		ps.executeUpdate();
	}

	/**
	 * 删除员工
	 * 
	 * @param employeeId
	 * @return 删除的个数
	 * @throws SQLException
	 */
	public int delete(Integer employeeId) throws SQLException {

		String sql = "Delete   from employee where id=? ";
		// 设置参数
		ps = conn.prepareStatement(sql);
		ps.setInt(1, employeeId);
		// 执行删除操作
		int count = ps.executeUpdate();
		return count;
	}

	/**
	 * 按照职工编号检索
	 * 
	 * @param employeeId
	 * @return
	 * @throws SQLException
	 */
	public Employee findById(Integer employeeId) throws SQLException {

		String sql = "select * from employee where id=?";
		// 设置参数
		ps = conn.prepareStatement(sql);
		ps.setInt(1, employeeId);
		// 执行查询操作
		ResultSet rs = ps.executeQuery();
		Employee employee = null;
		DeptmentDAO dao1 = new DeptmentDAO();
		RoleDAO dao2 = new RoleDAO();
		// 组装employee对象
		if (rs.next()) {
			employee = new Employee();
			employee.setId(rs.getInt("id"));
			employee.setCode(rs.getString("code"));
			employee.setName(rs.getString("name"));
			employee.setDeptmentId(rs.getInt("deptmentId"));
			employee.setRoleId(rs.getInt("roleId"));
			employee.setDescription(rs.getString("description"));
			employee.setDeptment(dao1.findById(rs.getInt("deptmentId")));
			employee.setRole(dao2.findById(rs.getInt("roleId")));
		}
		return employee;
	}

	public Employee isEmployee(String code) throws SQLException {

		String sql = "select * from employee where code=?";
		// 设置参数
		ps = conn.prepareStatement(sql);
		ps.setString(1, code);
		// 执行查询操作
		ResultSet rs = ps.executeQuery();
		Employee employee = null;
		DeptmentDAO dao1 = new DeptmentDAO();
		RoleDAO dao2 = new RoleDAO();
		// 组装employee对象
		if (rs.next()) {
			employee = new Employee();
			employee.setId(rs.getInt("id"));
			employee.setCode(rs.getString("code"));
			employee.setName(rs.getString("name"));
			employee.setDeptmentId(rs.getInt("deptmentId"));
			employee.setRoleId(rs.getInt("roleId"));
			employee.setDescription(rs.getString("description"));
			employee.setDeptment(dao1.findById(rs.getInt("deptmentId")));
			employee.setRole(dao2.findById(rs.getInt("roleId")));
		}
		return employee;
	}

	/**
	 * 检索所有职工
	 * 
	 * @return List<Employee>
	 * @throws SQLException
	 */
	public List<Employee> findAll() throws SQLException {

		String sql = "Select * from employee";
		// 设置参数并执行操作
		ps = conn.prepareStatement(sql);
		ResultSet rs = ps.executeQuery();

		Employee employee = null;
		DeptmentDAO dao1 = new DeptmentDAO();
		RoleDAO dao2 = new RoleDAO();
		List<Employee> list = new ArrayList<Employee>();
		// 组装employee对象
		while (rs.next()) {
			employee = new Employee();
			employee.setId(rs.getInt("id"));
			employee.setCode(rs.getString("code"));
			employee.setName(rs.getString("name"));
			employee.setDeptmentId(rs.getInt("deptmentId"));
			employee.setRoleId(rs.getInt("roleId"));
			employee.setDescription(rs.getString("description"));
			employee.setDeptment(dao1.findById(rs.getInt("deptmentId")));
			employee.setRole(dao2.findById(rs.getInt("roleId")));
			// 把employee对象加入到list中
			list.add(employee);
		}
		return list;
	}

	/**
	 * 按照条件检索职工
	 * 
	 * @param employee
	 * @return List<Employee>
	 * @throws SQLException
	 */
	public List<Employee> list(Employee employee) throws SQLException {

		String sql = "select * from employee where  1=1 ";

		// 根据职工名来组装条件
		String name = employee.getName();
		if (name != null && !name.equals("")) {
			sql += "  and  name Like '%" + name + "%'  ";
		}
		// 根据住址来组装条件
		String code = employee.getCode();
		if (code != null && !code.equals("")) {
			sql += "   and code Like '%" + code + "%'  ";
		}
		// 根据住址来组装条件
		Integer deptmentId = employee.getDeptmentId();

		if (deptmentId != null) {
			sql += "   and  deptmentId =  " + deptmentId + "  ";

		}
		// 根据住址来组装条件
		Integer roleId = employee.getRoleId();

		if (roleId != null) {
			sql += "   and  roleId =  " + roleId + "  ";

		}

		// 设置参数并执行操作
		ps = conn.prepareStatement(sql);
		ResultSet rs = ps.executeQuery();

		Employee employee1 = null;
		DeptmentDAO dao1 = new DeptmentDAO();
		RoleDAO dao2 = new RoleDAO();
		List<Employee> list = new ArrayList<Employee>();

		// 组装employee对象
		while (rs.next()) {
			employee1 = new Employee();

			employee1.setId(rs.getInt("id"));
			employee1.setCode(rs.getString("code"));
			employee1.setName(rs.getString("name"));
			employee1.setDeptmentId(rs.getInt("deptmentId"));
			employee1.setRoleId(rs.getInt("roleId"));
			employee1.setDescription(rs.getString("description"));
			employee1.setDeptment(dao1.findById(rs.getInt("deptmentId")));
			employee1.setRole(dao2.findById(rs.getInt("roleId")));
			// 把employee对象加入到list中
			list.add(employee1);
		}
		return list;
	}
}