employeeinfodao.java

老牌java开发的物流管理系统 详细的我也没有怎么看 好像是恒基的

package com.wl.dao;
/**
 * @author tianxiaoshun
 * 封装职员信息方法
 */
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.wl.dbconnection.DBManager;

import com.wl.entity.EmployeeInfo;
/**
 * 封装职员DAO方法
 * @author tianxiaoshun
 *
 */
public class EmployeeinfoDAO {
    DBManager dbmanager =new DBManager();
    boolean flage;
 /**
  * 封装插入职员信息方法
  * @param employeeinfo
  * @return boolean
  */
	public boolean insertEmployee(EmployeeInfo employeeinfo){
      flage=dbmanager.openDB();
      if(flage){
    	  try{
    	  String sql = "insert into employeeinfotable values(?,?,?,?,?,?,?,?,?,?,?,?,?)";
    	  dbmanager.ps=dbmanager.conn.prepareStatement(sql);     
    	  dbmanager.ps.setString(1,employeeinfo.getEmployeeId());
    	  dbmanager.ps.setString(2,employeeinfo.getEmployeeName());
    	  dbmanager.ps.setString(3,employeeinfo.getEmployeeSex());
    	  dbmanager.ps.setInt(4,employeeinfo.getEmployeeAge());
    	  dbmanager.ps.setString(5,employeeinfo.getEmployeeIdenCard());
    	  dbmanager.ps.setString(6,employeeinfo.getEmployeeBirthDate());
    	  dbmanager.ps.setString(7,employeeinfo.getEmployeeDiploma());
    	  dbmanager.ps.setString(8,employeeinfo.getEmployeeJoinDate());
    	  dbmanager.ps.setString(9,employeeinfo.getEmployeeAdd());
    	  dbmanager.ps.setString(10,employeeinfo.getEmployeePhone());
    	  dbmanager.ps.setString(11,employeeinfo.getEmployeeMobile());
    	  dbmanager.ps.setInt(12,employeeinfo.getDepartmentId());
    	  dbmanager.ps.setInt(13,employeeinfo.getJobsId());
    	  dbmanager.ps.executeUpdate();
    	  }
    	  catch(Exception e){
    		  return false;
    	  }
    	  finally{
    		  dbmanager.closeDB();
    	  }
    	  return true;
      }
      else{
    	  return false;
      }
    }
	/**
	 * 封装查询所有职员信息方法
	 * @return list
	 */
  public List<EmployeeInfo> selectEmployeeInfo(){
	  List<EmployeeInfo> list=new ArrayList<EmployeeInfo>();
	  flage=dbmanager.openDB();
	  EmployeeInfo employeeinfo=null;
	  String sql = "select e.id,employeeid,employeename,employeesex,employeeage,employeeidencard,employeediploma,employeeadd,departmentname,jobsname from employeeinfotable as e join departmentinfotable as d on e.DepartmentId=d.Id join jobsinfotable as j on e.JobsId=j.Id";
	  if(flage){
		try{
	  dbmanager.ps=dbmanager.conn.prepareStatement(sql);
	  ResultSet st=dbmanager.ps.executeQuery();
	  while(st.next()){
		employeeinfo =new EmployeeInfo(st.getInt(1),st.getString(2),st.getString(3),st.getString(4),st.getInt(5),st.getString(6),
		st.getString(7),st.getString(8),st.getString(9),st.getString(10));
	    list.add(employeeinfo);
	  }
		}
		catch(Exception e){
			System.out.print("查询错误！");
		}
		finally{
			dbmanager.closeDB();
		}
	  }
	  else{
		  System.out.print("数据库打开失败！");
	  }
	  return list;
  }
  /**
   * 封装按照id查询职员信息方法
   * @param id
   * @return list
   */
  public EmployeeInfo selectEmployeeInfoById(int id){
	  flage=dbmanager.openDB();
	  EmployeeInfo employeeinfo=null;
	  if(flage){
		try{
	  dbmanager.ps=dbmanager.conn.prepareStatement("select * from employeeinfotable where Id=?");
	  dbmanager.ps.setInt(1, id);
	  ResultSet st=dbmanager.ps.executeQuery();
	  while(st.next()){
		employeeinfo=new EmployeeInfo(st.getInt(1),st.getString(2),st.getString(3),st.getString(4),st.getInt(5),st.getString(6),
		st.getString(7),st.getString(8),st.getString(9),st.getString(10),st.getString(11),st.getString(12),st.getInt(13),st.getInt(14));
	  }
		}
		catch(Exception e){
			System.out.print("查询错误！");
		}
		finally{
			dbmanager.closeDB();
		}
	  }
	  else{
		  System.out.print("数据库打开失败！");
	  }
	  return employeeinfo;
  }
  public int UpdateEmployee(EmployeeInfo e){
	  int rows= 0;
	  flage = dbmanager.openDB();
	  String sql = "update employeeinfotable set employeeId=?,employeeName=?,employeeSex=?,employeeAge=?,employeeIdenCard=?,employeeDiploma=?,employeeAdd=?,departmentId=?,jobsId=? where id=?";
	  if(flage){
		  try {
			dbmanager.ps = dbmanager.conn.prepareStatement(sql);
			dbmanager.ps.setString(1, e.getEmployeeId());
			dbmanager.ps.setString(2, e.getEmployeeName());
			dbmanager.ps.setString(3, e.getEmployeeSex());
			dbmanager.ps.setInt(4, e.getEmployeeAge());
			dbmanager.ps.setString(5, e.getEmployeeIdenCard());
			dbmanager.ps.setString(6, e.getEmployeeDiploma());
			dbmanager.ps.setString(7, e.getEmployeeAdd());
		    dbmanager.ps.setInt(8, e.getDepartmentId());
		    dbmanager.ps.setInt(9, e.getJobsId());
		    dbmanager.ps.setInt(10, e.getId());
		    rows = dbmanager.ps.executeUpdate();
		} catch (SQLException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		finally{
			dbmanager.closeDB();
		}  
	  }
	return rows;
  }
  /**
   * 封装按照职员名称查询职员信息方法
   * @param name
   * @return EmployeeInfo
   */
  public List<EmployeeInfo> selectEmployeeInfoByName(String name){
	  List<EmployeeInfo> list=new ArrayList<EmployeeInfo>();
	  flage=dbmanager.openDB();
	  EmployeeInfo employeeinfo=null;
	  if(flage){
		try{
	  dbmanager.ps=dbmanager.conn.prepareStatement("select * from employeeinfotable where EmployeeName=?");
	  dbmanager.ps.setString(1, name);
	  ResultSet st=dbmanager.ps.executeQuery();
	  while(st.next()){
		employeeinfo=new EmployeeInfo(st.getInt(1),st.getString(2),st.getString(3),st.getString(4),st.getInt(5),st.getString(6),
		st.getString(7),st.getString(8),st.getString(9),st.getString(10),st.getString(11),st.getString(12),st.getInt(13),st.getInt(14));
		list.add(employeeinfo);
	    }
		}
		catch(Exception e){
			System.out.print("查询错误！");
		}
		finally{
			dbmanager.closeDB();
		}
	  }
	  else{
		  System.out.print("数据库打开失败！");
	  }
	  return list;
  }
  /**
   * 封装删除职员信息方法
   * @param employeeId
   * @return boolean
   */
  public boolean deleteEmployeeInfo(int employeeId){
	  flage=dbmanager.openDB();
	  if(flage){
		  try{
		dbmanager.ps=dbmanager.conn.prepareStatement("delete Employeeinfotable where id=?"); 
		dbmanager.ps.setInt(1, employeeId);
		dbmanager.ps.executeUpdate(); 
		  }
		catch(Exception e){
			  System.out.print(45454);;
		  }
		return true;
	  }
	  else{
	   return false;	  
	  }	  
  }
  /**
	 * 分页查询职员信息
	 */
	public List<EmployeeInfo> selectemployeeinfoPage(int pageSize, int pageNum){
		 flage=dbmanager.openDB();
		 List<EmployeeInfo> list = new  ArrayList<EmployeeInfo>();
		 if(flage){
			 try{
				 String sql="select top " + pageSize
					+ " e.id,employeeid,employeename,employeesex,employeeage,employeeidencard,employeediploma,employeeadd,d.departmentname,j.jobsname from employeeinfotable as e join departmentinfotable as d on e.DepartmentId=d.Id join jobsinfotable as j on e.JobsId=j.Id where e.Id not in(select top "
					+ pageSize * pageNum
					+ " e.Id from employeeinfotable as e join departmentinfotable as d on e.DepartmentId=d.Id join jobsinfotable as j on e.JobsId=j.Id order by e.Id)order by e.Id";
				 dbmanager.ps = dbmanager.conn.prepareStatement(sql);
				 ResultSet st=dbmanager.ps.executeQuery();
				 while(st.next()){
						EmployeeInfo employeeinfo =new EmployeeInfo(st.getInt(1),st.getString(2),st.getString(3),st.getString(4),st.getInt(5),st.getString(6),
						st.getString(7),st.getString(8),st.getString(9),st.getString(10));
						list.add(employeeinfo);
				 }
			 }catch(Exception e){
				 System.out.print("数据库连接失败!！");
			 }finally {
					dbmanager.closeDB();// 关闭数据库
				}
		 }
			return list;
			 
			}
//			public static void main(String[] args) {
//				EmployeeinfoDAO d = new EmployeeinfoDAO();
//				System.out.println(d.selectEmployeeInfo());
//			}
	/**
	 * 通过页面大小获取总页数
	 * @param pageSize
	 * @return num
	 */
	public int getPageNum(int pageSize) {
		int num = 0;
		 dbmanager.openDB();// 打开数据库
			try {
				dbmanager.ps=dbmanager.conn.prepareStatement("select count(*) from employeeinfotable");
				ResultSet rs = dbmanager.ps.executeQuery();
				while(rs.next()){
					num = rs.getInt(1);
				}
				if (num % pageSize == 0) {
					return num / pageSize;
				} else {
					return num / pageSize + 1;
				}
			} catch (SQLException e) {
				System.out.println("数据库连接失败！");
				e.printStackTrace();
			}finally{
				dbmanager.closeDB();
			}
			return num;
		}
	
//public static void main(String[] args) {
//	EmployeeinfoDAO d = new EmployeeinfoDAO();
//	List<EmployeeInfo> l = new ArrayList<EmployeeInfo>();
//	l=d.selectEmployeeInfo();
//	System.out.println(l);
//}
}