dao.java

企业员工信息管理C/S模式

	public static ResultSet getDutyName(){
		String sql = "select dutyname from tb_duty";
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	/**
	 * 查询员工出生日期
	 * @return
	 */
	public static ResultSet getEmployeeAge(){
		String sql = "select birthday from tb_employee";
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	/**
	 * 查询职称
	 * @return
	 */
	public static ResultSet  getSpecialDuty(){
		String sql = "select sdname from tb_specialduty";
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	/**
	 * 查询受聘日期
	 * @return
	 */
	public static ResultSet getHiredate(){
		String sql = "select beginworkdate from tb_employee";
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	/**
	 * 查询民族
	 * @return
	 */
	public static ResultSet getNation(){
		String sql = "select nation from tb_nation";
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	/**
	 * 查询籍贯
	 * @return
	 */
	public static ResultSet getNativePlace(){
		String sql ="select npname from tb_nativeplace";
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	/**
	 * 查询学位
	 * @return
	 */
	public static ResultSet getDegree(){
		String sql ="select degree from tb_degree";
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	
	
	/**
	 * 条件查询
	 * @param col
	 * @param val
	 * @return
	 */
	public static ResultSet getConditionEmp(String col,String val){
		String sql ="select * from tb_employee where ";
		if(col.equals("人员编码")){
			sql = sql+"empid='"+val+"'";
		}else if(col.equals("姓名")){
			sql = sql + "ename='"+val+"'";
		}else if(col.equals("职务")){
			sql = sql+"dutyname='"+val+"'";
		}else if(col.equals("出生日期")){
			sql = sql+"birthday='"+val+"'";
		}else if(col.equals("职称")){
			sql = sql+"specialname='"+val+"'";
		}else if(col.equals("受聘日期")){
			sql = sql+"beginworkdate='"+val+"'";
		}else if(col.equals("籍贯")){
			sql = sql+"nativeplacce='"+val+"'";
		}else if(col.equals("学位")){
			sql = sql+"degree='"+val+"'";
		}else if(col.equals("性别")){
			sql = sql+"sex='"+val+"'";
		}else{
			sql = sql+"polityface='"+val+"'";
		}
		ResultSet rs = getResultSet(sql);
		return rs;
	}
	/**
	 * 执行查询
	 * @param sql
	 * @return
	 */
	private static ResultSet getResultSet(String sql){
		ResultSet rs = null;
		Statement stmt = null;
		conn = DAO.getConnection();
		try{
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
		}catch(Exception ex){
			System.out.println(ex.getMessage());
		}
		return rs;
	}
	
	/**
	 * 插入员工信息
	 * @param info
	 * @return
	 */
	public static boolean addEmployee(TbEmployeeInfo info){
		conn = DAO.getConnection();
		Statement stmt = null;
		String sql = "insert into tb_employee values('"+info.getEname()+
		"','"+info.getEyname()+"','"+info.getSex()+"','"+info.getBirthday()+
		"','"+info.getNativeplace()+"','"+info.getNation()+"','"+info.getHkszd()+
		"','"+info.getBornaddress()+"','"+info.getCommnityname()+"','"+info.getFirstedu()+
		"','"+info.getEducation()+"','"+info.getSchool()+"','"+info.getSpecialname()+
		"','"+info.getIntoschooldate()+"','"+info.getGraduatedate()+"','"+info.getIsfirstedu()+
		"','"+info.getDegree()+"',"+info.getEduyears()+",'"+info.getStudyway()+"','"+
		info.getPolityface()+"','"+info.getIntopartydate()+"','"+info.getWorkway()+
		"','"+info.getDutyname()+"','"+info.getStationname()+"','"+info.getSpedutyname()+"','"+info.getBeginworkdate()+
		"','"+info.getIntodeptdate()+"','"+info.getWorkstate()+"','"+info.getRetireddate()+
		"','"+info.getGrsf()+"','"+info.getBgphone()+"','"+info.getSjphone()+"','"+info.getHomephone()+
		"','"+info.getFyzymark()+"','"+info.getIdcard()+"','"+info.getXxdate()+"','"+info.getLdhtid()+
		"',"+info.getDeptno()+",'"+info.getClassname()+"','"+info.getMenu()+"')";
		try{
			stmt = conn.createStatement();
			int count = stmt.executeUpdate(sql);
			if(count>0)
				return true;
			else 
				return false;
		}catch(Exception ex){
			System.out.println(ex.getMessage());
			return false;
		}
	}
	/**
	 * 删除员工信息
	 * @param name
	 * @return
	 */
	public  static boolean deleteEmployee(String name){
		conn = DAO.getConnection();
		Statement stmt = null;
		try{
			stmt = conn.createStatement();
			int count = stmt.executeUpdate("delete from tb_employee where ename='"+name+"'");
			if(count>0)
				return true;
			else 
				return false;
		}catch(Exception ex){
			System.out.println(ex.getMessage());
			return false;
		}
	}
	/**
	 * 添加学历
	 */
	public static boolean addDegree(String xl){
		conn = DAO.getConnection();
		try{
			Statement stmt = conn.createStatement();
			//判断是否已存在
			ResultSet rs = stmt.executeQuery("select * from tb_degree where degree='"+xl+"'");
			if(rs.next())
				return false;
			int count = stmt.executeUpdate("insert into tb_degree values('"+xl+"')");
			if(count>0)
				return true;
			else 
				return false;
		}catch(Exception ex){
			System.out.println(ex.getMessage());
			return false;
		}
	}
	/**
	 * 添加职务
	 * @param duty
	 * @return
	 */
	public static boolean addduty(TbDutyInfo info){
		conn = DAO.getConnection();
		try{
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery("select * from tb_duty where dutyname='"+info.getDutyname()+"'");
			if(rs.next())
				return false;
			int count = stmt.executeUpdate("insert into tb_duty values('"+info.getDutyname()+"',"+info.getDutygrade()+
					",'"+info.getHiredate()+"','"+info.getFiredate()+"')");
			if(count>0)
				return true;
			else 
				return false;
		}catch(Exception ex){
			System.out.println(ex.getMessage());
			return false;
		}
	}
	/**
	 * 查询职称等级
	 * @return
	 */
	public static ResultSet getSpecialDutygrade(){
		String sql = "select sdgrade from tb_specialdutygrade";
		ResultSet rs = DAO.getResultSet(sql);
		return rs;
	}
	/**
	 * 查询职称序列
	 * @return
	 */
	public static ResultSet getSpecialserial(){
		String sql = "select sdsid from tb_specialdutyserial";
		ResultSet rs = DAO.getResultSet(sql);
		return rs;
	}
	/**
	 * 添加职称
	 * @param info
	 * @return
	 */
	public static boolean addSpecialduty(TbSpecialdutyInfo info){
		conn = DAO.getConnection();
		try{
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery("select * from tb_specialduty where sdname='"+info.getSdname()+"'");
			if(rs.next())
				return false;
			int count = stmt.executeUpdate("insert into tb_specialduty values('"+info.getSdname()+
					"',"+info.getSdgrade()+","+info.getSdsid()+",'"+info.getHiremark()+
					"','"+info.getHiredate()+"','"+info.getFiredate()+"',"+info.getSdsalgrade()+
					","+info.getSdsal()+",'"+info.getSdsalmoddate()+"')");
			if(count > 0)
				return true;
			else
				return false;
		}catch(Exception ex){
			System.out.println(ex.getMessage());
			return false;
		}
	}
	/**
	 * 查询岗位等级
	 * @return
	 */
	public static ResultSet getStationkind(){
		String sql = "select stkindid from tb_stationkind";
		ResultSet rs = DAO.getResultSet(sql);
		return rs;
	}
	/**
	 * 添加岗位
	 * @param info
	 * @return
	 */
	public static boolean addStation(TbStation info){
		conn = DAO.getConnection();
		try{
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery("select * from tb_stationinfo where stationname='"+info.getStationname()+"'");
			if(rs.next())
				return false;
			int count = stmt.executeUpdate("insert into tb_stationinfo values('"+info.getStationname()+
					"',"+info.getStkindid()+","+info.getStsal()+",'"+info.getStsalmoddate()+"')");
			if(count>0)
				return true;
			else
				return false;
		}catch(Exception ex){
			System.out.println(ex.getMessage());
			return false;
		}
	}
	/**
	 * 关闭数据源
	 *
	 */
	/*public static void closeconn(){
		if(rs!=null){
			try{
				rs.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
		if(stmt!=null){
			try{
				stmt.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
		if(conn!=null){
			try{
				conn.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
	}*/

}