再就业管理系统

package com.dao.impl; /* * Worker表操作的dao实现类 */ import java.sql.CallableStatement; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.bean.Apply; import com.bean.Job; import com.bean.Worker; import com.dao.WorkerDao; public class WorkerDaoimpl implements WorkerDao{ private Connection conn = null ; private PreparedStatement pstmt = null ; public WorkerDaoimpl(Connection conn){ this.conn = conn ; } @Override public Worker getById(String id) throws Exception{ Worker w = new Worker(); try { String sql = "{call Selectworker(?)}"; CallableStatement cas = this.conn.prepareCall(sql); cas.setString(1, id); ResultSet rs = cas.executeQuery(); if(rs.next()){ w.setWorkerID(rs.getString(1)); w.setWorkername(rs.getString(2)); w.setSex(rs.getString(3)); w.setBirth(rs.getString(4)); w.setWorkType(rs.getString(5)); w.setTitle(rs.getString(6)); w.setWorkLife(rs.getInt(7)); w.setMajor(rs.getString(8)); w.setDegree(rs.getString(9)); } } catch (Exception e) { throw e; } return w; } @Override public boolean insert(Worker worker)throws Exception { try { this.pstmt = this.conn.prepareStatement("{call dbo.addworker(?,?,?,?,?,?,?,?,?)}"); this.pstmt.setString(1, worker.getWorkerID()) ; this.pstmt.setString(2, worker.getWorkername()); this.pstmt.setString(3, worker.getSex()); this.pstmt.setString(4, worker.getBirth()); this.pstmt.setString(5, worker.getWorkType()); this.pstmt.setString(6, worker.getTitle()); this.pstmt.setInt(7, worker.getWorkLife()); this.pstmt.setString(8, worker.getMajor()); this.pstmt.setString(9, worker.getDegree()) ; this.pstmt.executeUpdate(); } catch (Exception e) { throw e; }finally { if(this.pstmt != null) try { this.pstmt.close(); } catch (Exception e2) { throw e2; } } return true; } @Override public boolean deleteworker(String id) throws Exception{ try { this.pstmt = this.conn.prepareStatement("{call dbo.Deleteworker(?)}"); this.pstmt.setString(1, id); this.pstmt.executeUpdate(); } catch (Exception e) { throw e; }finally { if(this.pstmt != null) try { this.pstmt.close(); } catch (Exception e2) { throw e2; } } return true; } @Override public boolean update(Worker worker)throws Exception{ try { this.pstmt = this.conn.prepareStatement("{call dbo.Updateworker(?)}"); this.pstmt.setString(1, worker.getWorkername()); this.pstmt.setString(2, worker.getSex()); this.pstmt.setString(3, worker.getBirth()); this.pstmt.setString(4, worker.getWorkType()); this.pstmt.setString(5, worker.getTitle()); this.pstmt.setInt(6, worker.getWorkLife()); this.pstmt.setString(7, worker.getMajor()); this.pstmt.setString(8, worker.getDegree()) ; this.pstmt.setString(9, worker.getWorkerID()) ; this.pstmt.executeUpdate(); } catch (Exception e) { throw e; }finally { if(this.pstmt != null) try { this.pstmt.close(); } catch (Exception e2) { throw e2; } } return true; } @Override public List<Worker> listworker()throws Exception { List<Worker> all = new ArrayList<Worker>() ; try { this.pstmt = this.conn.prepareStatement("{call dbo.SelectAllworker}") ; this.pstmt.setString(1,"%%") ; ResultSet rs = this.pstmt.executeQuery() ; Worker j = null ; while(rs.next()){ j = new Worker() ; j.setWorkerID(rs.getString(1)); j.setWorkername(rs.getString(2)); j.setSex(rs.getString(3)); j.setBirth(rs.getString(4)); j.setWorkType(rs.getString(5)); j.setTitle(rs.getString(6)); j.setWorkLife(Integer.parseInt(rs.getString(7))); j.setMajor(rs.getString(8)); j.setDegree(rs.getString(9)); all.add(j) ; } }catch (Exception e) { try { throw e; } catch (Exception e1) { // TODO Auto-generated catch block e1.printStackTrace(); } }finally { if(this.pstmt != null) try { this.pstmt.close(); } catch (Exception e2) { try { throw e2; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } return all ; } @Override public boolean check(String id, String password) { String sql = "SELECT password FROM workerlogin WHERE id = ?"; boolean flag = false; String pass = null; try { this.pstmt = this.conn.prepareStatement(sql) ; this.pstmt.setString(1,id) ; ResultSet rs = this.pstmt.executeQuery() ; if(rs.next()){ pass = rs.getString(1); } this.pstmt.close() ; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } if(password.equals(pass)) flag = true; return flag ; } }