interviewerdao.java

07年做得人力资源管理系统

package com.buat.hr.interviewer;

import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import com.buat.hr.share.DBConnection;
import com.buat.hr.share.ShareDAO;

public class InterviewerDAO extends ShareDAO {
	
	private DBConnection connection=new DBConnection();//共享得到连接数据库的对象
	@Override
	public ArrayList query(int startNo, int perCount, String tableName) {
		return null;
	}
	
	public static void main(String args[]){
		InterviewerDAO dao = new InterviewerDAO();
		dao.add("aa");
	}
	
	public boolean joinWarehouse(String id) {	//人库的方法
		boolean Flag=false;
		
		Connection conn=connection.getConnection();	//得到一个连接
		
		String sql="update Interviewer set selection=1 where interviewerId="+id;//主要是用于存储Interviewer类型对象
		
		try {
			PreparedStatement pps=conn.prepareStatement(sql);
			
			int row=pps.executeUpdate();
			
			pps.close();
			conn.close();
			
			if(row>0)
			{
				Flag=true;
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			//e.printStackTrace();
			return false;
		}
		
		return Flag;
	}
	
	public ArrayList quaryIsPersonAbility(int startNo, int perCount) {//查询人才库
		Connection conn=connection.getConnection();	//得到一个连接
		
		ArrayList interviewerArray=new ArrayList();//主要是用于存储人才库的信息对象
		
		String sql="select * from Interviewer where selection=1 limit "+startNo+","+perCount;
		
		try {
			
			PreparedStatement pps=conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
			
			ResultSet rst=pps.executeQuery();//声明一个结果集,并对其进行赋值
			
			while(rst.next())
			{
				Interviewer interv=new Interviewer();
							interv.setInterviewerId(Integer.parseInt(rst.getString("interviewerId")));
							
							interv.setName(rst.getString("name"));
							
							interv.setBirthday(Date.valueOf(rst.getString("birthday")));
							
							interv.setContent(rst.getString("content"));
							
							interv.setAge(Integer.parseInt(rst.getString("age")));
							
							interv.setEmail(rst.getString("email"));
							
							interv.setExperience(rst.getString("experience"));
							
							interv.setGender(rst.getString("gender"));
							
							interv.setJob(rst.getString("job"));
							
							interv.setMajor(rst.getString("major"));
							
							interv.setUniversity(rst.getString("university"));
							
							interv.setTelephone(rst.getString("telephone"));
				
					interviewerArray.add(interv);
			}
			rst.close();
			pps.close();
			conn.close();
		} catch (SQLException e) {
			//e.printStackTrace();
		}
		return interviewerArray;
		
	}
public ArrayList quaryByName(String name) {	//根据姓名查询记录
		
		Connection conn=connection.getConnection();	//得到一个连接
		
		ArrayList interviewerArray=new ArrayList();//主要是用于存储Interviewer类型对象
		
		String sql="select * from Interviewer where name='"+name.trim()+"' and selection=1";
		
		try {
			PreparedStatement pps=conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
			
			ResultSet rst=pps.executeQuery();//声明一个结果集,并对其进行赋值
			
			while(rst.next())
			{
				Interviewer interv=new Interviewer();
					
						interv.setInterviewerId(Integer.parseInt(rst.getString("interviewerId")));
							
						interv.setName(rst.getString("name"));
						
						interv.setBirthday(Date.valueOf(rst.getString("birthday")));
						
						interv.setContent(rst.getString("content"));
						
						interv.setAge(Integer.parseInt(rst.getString("age")));
						
						interv.setEmail(rst.getString("email"));
						
						interv.setExperience(rst.getString("experience"));
						
						interv.setGender(rst.getString("gender"));
						
						interv.setJob(rst.getString("job"));
						
						interv.setMajor(rst.getString("major"));
						
						interv.setUniversity(rst.getString("university"));
						
						interv.setTelephone(rst.getString("telephone"));
						System.out.print("telephone="+rst.getString("telephone"));
				interviewerArray.add(interv);
			}
			
			rst.close();
			pps.close();
			conn.close();
			
			return interviewerArray;
		} catch (SQLException e) {
			//e.printStackTrace();
			return null;
		}
		
	}
public ArrayList quaryInterviewer(int startNo, int perCount) {
	
	Connection conn=connection.getConnection();	//得到一个连接
	
	ArrayList interviewerArray=new ArrayList();//主要是用于存储Interviewer类型对象
	
	String sql="select * from Interviewer where selection=0 limit "+startNo+","+perCount;
	
	try {
		PreparedStatement pps=conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
		
		ResultSet rst=pps.executeQuery();//声明一个结果集,并对其进行赋值
		
		while(rst.next())
		{
			Interviewer interv=new Interviewer();
				
			interv.setInterviewerId(Integer.parseInt(rst.getString("interviewerId")));
			
			interv.setName(rst.getString("name"));
			
			interv.setBirthday(Date.valueOf(rst.getString("birthday")));
			
			interv.setContent(rst.getString("content"));
			
			interv.setAge(Integer.parseInt(rst.getString("age")));
			
			interv.setEmail(rst.getString("email"));
			
			interv.setExperience(rst.getString("experience"));
			
			interv.setGender(rst.getString("gender"));
			
			interv.setJob(rst.getString("job"));
			
			interv.setMajor(rst.getString("major"));
			
			interv.setUniversity(rst.getString("university"));
			
			interv.setTelephone(rst.getString("telephone"));
			
			
			interviewerArray.add(interv);
		}
		rst.close();
		pps.close();
		conn.close();
	} catch (SQLException e) {
		//e.printStackTrace();
	}
	return interviewerArray;
}

}