雇员管理—Java课程设计

package ccl.emp.dao.impl; import java.sql.Connection; import java.sql.Date; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.ArrayList; import java.util.List; import ccl.emp.dao.IEmpInfoDAO; import ccl.emp.vo.EmpInfo; import ccl.emp.vo.EmpDe; public class EmpInfoDAOImpl implements IEmpInfoDAO { private Connection conn = null; private PreparedStatement pstmt = null; public EmpInfoDAOImpl(Connection conn) { this.conn = conn; } public boolean doCreate(EmpInfo emp) throws Exception { boolean flag = false; String sql = "INSERT INTO empInfo(empno,ename,epwd,job,hiredate,salary,deptno) VALUES(?,?,?,?,?,?,?)"; pstmt = conn.prepareStatement(sql); pstmt.setInt(1, emp.getEmpno()); pstmt.setString(2, emp.getEname()); pstmt.setString(3, emp.getEpwd()); pstmt.setString(4, emp.getJob()); pstmt.setDate(5, new java.sql.Date(emp.getHiredate().getTime())); pstmt.setFloat(6, emp.getSalary()); pstmt.setInt(7, emp.getDeptno()); if (pstmt.executeUpdate() > 0) { flag = true; } pstmt.close(); return flag; } public List<EmpDe> findAll(String keyWord) throws Exception { List<EmpDe> all = new ArrayList<EmpDe>(); String sql = "SELECT empno,ename,job,hiredate,salary,deptno FROM empInfo WHERE ename LIKE ? OR job LIKE ?"; pstmt = this.conn.prepareStatement(sql); pstmt.setString(1, "%" + keyWord + "%"); pstmt.setString(2, "%" + keyWord + "%"); ResultSet rs = pstmt.executeQuery(); EmpDe emp_dept = null; while (rs.next()) { sql = "SELECT dname,location FROM Dept WHERE deptno=?"; pstmt = conn.prepareStatement(sql); pstmt.setInt(1, rs.getInt(6)); ResultSet deptrs = pstmt.executeQuery(); emp_dept = new EmpDe(); emp_dept.setEmpno(rs.getInt(1)); emp_dept.setEname(rs.getString(2)); emp_dept.setJob(rs.getString(3)); emp_dept.setHiredate(rs.getDate(4)); emp_dept.setSalary(rs.getFloat(5)); //System.out.println(deptrs.getString(1)); deptrs.next(); emp_dept.setDname(deptrs.getString(1)); //System.out.println(deptrs.getString(2)); emp_dept.setLocation(deptrs.getString(2)); all.add(emp_dept); } pstmt.close(); return all; } public EmpInfo findById(int empno) throws Exception { EmpInfo emp = null; String sql = "SELECT empno,ename,epwd,job,hiredate,salary FROM empInfo WHERE empno=?"; pstmt = conn.prepareStatement(sql); pstmt.setInt(1, empno); ResultSet rs = pstmt.executeQuery(); if (rs.next()) { emp = new EmpInfo(); emp.setEmpno(rs.getInt(1)); emp.setEname(rs.getString(2)); emp.setEpwd(rs.getString(3)); emp.setJob(rs.getString(4)); emp.setHiredate(rs.getDate(5)); emp.setSalary(rs.getFloat(6)); } pstmt.close(); return emp; } public boolean deleteById(int empno) throws Exception { // TODO Auto-generated method stub String sql = "DELETE FROM empInfo WHERE empno=?"; pstmt = conn.prepareStatement(sql); pstmt.setInt(1, empno); pstmt.executeUpdate(); pstmt.close(); return true; } public boolean updateEmp(EmpInfo emp) throws Exception { // TODO Auto-generated method stub String sql = "UPDATE empInfo SET ename=?,epwd=?,job=?,hiredate=?,salary=?,deptno=? WHERE empno=?"; pstmt = this.conn.prepareStatement(sql); pstmt.setString(1, emp.getEname()); pstmt.setString(2, emp.getEpwd()); pstmt.setString(3, emp.getJob()); pstmt.setDate(4, emp.getHiredate()); pstmt.setFloat(5, emp.getSalary()); pstmt.setInt(6, emp.getDeptno()); pstmt.setInt(7, emp.getEmpno()); pstmt.executeUpdate(); pstmt.close(); return true; } public EmpInfo findByName(String name) throws Exception { // TODO Auto-generated method stub EmpInfo emp = null; String sql = "SELECT empno,ename,epwd,job,hiredate,salary FROM empInfo WHERE ename=?"; pstmt = conn.prepareStatement(sql); pstmt.setString(1, name); ResultSet rs = pstmt.executeQuery(); if (rs.next()) { emp = new EmpInfo(); emp.setEmpno(rs.getInt(1)); emp.setEname(rs.getString(2)); emp.setEpwd(rs.getString(3)); emp.setJob(rs.getString(4)); emp.setHiredate(rs.getDate(5)); emp.setSalary(rs.getFloat(6)); } pstmt.close(); return emp; } }