hr.rar_人事管理_人事管理jsp_人事管理系统_人事系统

package com.icss.hr.emp.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.ArrayList; import com.icss.hr.common.ConnFactory; import com.icss.hr.common.Pager; import com.icss.hr.dept.dto.Departments; import com.icss.hr.dept.service.impl.DepartmentsServiceImpl; import com.icss.hr.emp.dao.EmpDao; import com.icss.hr.emp.dto.Employees; import com.icss.hr.job.dto.Jobs; import com.icss.hr.job.service.impl.JobsServiceImpl; public class EmpDaoImpl implements EmpDao { public void addEmp(Employees emp) throws Exception { Connection conn = ConnFactory.getConnection(); String sql = "insert into employees values(emp_seq.nextval,?,?,?,?,?,?,?)"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, emp.getEmpName()); pstmt.setString(2, emp.getEmail()); pstmt.setString(3, emp.getPhoneNumber()); pstmt.setDate(4, emp.getHireDate()); pstmt.setString(5, emp.getJob().getJobId()); pstmt.setInt(6, emp.getSalary()); pstmt.setInt(7, emp.getDepartment().getDepartmentId()); pstmt.executeUpdate(); pstmt.close(); conn.close(); } public void updateEmp(Employees emp) throws Exception { Connection conn = ConnFactory.getConnection(); String sql = "update employees set emp_name=?, email=? ,phone_number=? ,hire_date=?,job_id=? ,salary=?,department_id=? where employee_id=?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, emp.getEmpName()); pstmt.setString(2, emp.getEmail()); pstmt.setString(3, emp.getPhoneNumber()); pstmt.setDate(4, emp.getHireDate()); pstmt.setString(5, emp.getJob().getJobId()); pstmt.setInt(6, emp.getSalary()); pstmt.setInt(7, emp.getDepartment().getDepartmentId()); pstmt.setInt(8, emp.getEmployeeId()); pstmt.executeUpdate(); pstmt.close(); conn.close(); } public void deleteEmp(int employeeId) throws Exception { Connection conn = ConnFactory.getConnection(); String sql = "delete from employees where employee_id = ?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1, employeeId); pstmt.executeUpdate(); pstmt.close(); conn.close(); } public Employees queryById(int employeeId) throws Exception { Connection conn = ConnFactory.getConnection(); String sql = "select * from employees where employee_id = ?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1, employeeId); ResultSet rs = pstmt.executeQuery(); Employees emp = null; while (rs.next()) { String jobId = rs.getString(6); JobsServiceImpl service = new JobsServiceImpl(); Jobs job = service.queryById(jobId); int departmentId = rs.getInt(8); DepartmentsServiceImpl service2 = new DepartmentsServiceImpl(); Departments department = service2.queryById(departmentId); emp = new Employees(rs.getInt(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getDate(5), job, rs.getInt(7), department); } rs.close(); pstmt.close(); conn.close(); return emp; } public ArrayList<Employees> queryAll(Pager pager) throws Exception { Connection conn = ConnFactory.getConnection(); String sql = "select * from employees"; PreparedStatement pstmt = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); ResultSet rs = pstmt.executeQuery(); ArrayList<Employees> empList = new ArrayList<Employees>(); if (rs.absolute(pager.getStart())) { for (int i = 1; i <= pager.getPageSize(); i++) { String jobId = rs.getString(6); JobsServiceImpl service = new JobsServiceImpl(); Jobs job = service.queryById(jobId); int departmentId = rs.getInt(8); DepartmentsServiceImpl service2 = new DepartmentsServiceImpl(); Departments department = service2.queryById(departmentId); Employees emp = new Employees(rs.getInt(1), rs.getString(2), rs .getString(3), rs.getString(4), rs.getDate(5), job, rs .getInt(7), department); empList.add(emp); if (!rs.next()) break; } } rs.close(); pstmt.close(); conn.close(); return empList; } public int getCount() throws Exception { Connection conn = ConnFactory.getConnection(); String sql = "select count(*) from employees"; PreparedStatement pstmt = conn.prepareStatement(sql); ResultSet rs = pstmt.executeQuery(); rs.next(); int count = rs.getInt(1); rs.close(); pstmt.close(); conn.close(); return count; } }