institutiondao.java

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

package com.buat.hr.institution;

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


public class InstitutionDAO implements IInstitutionDAO{
	DBConnection db=new DBConnection(); //保存sql语句
   
     //添加奖惩
	public boolean addInstitution(Institution institution ){
		
		
		PreparedStatement ps=null;
		ResultSet rs=null;
		Connection con=db.getConnection();
		boolean successful=false;
		String name=institution.getName();
		String reason=institution.getReason();
		String explains=institution.getExplains();
		String instr="insert into institution (name,reason,explains) values(?,?,?)";
		try {
			ps=con.prepareStatement(instr);		
			ps.setString(1,name);
			ps.setString(2,reason);
			ps.setString(3, explains);			
			int i=ps.executeUpdate();
			if(i>0)
				successful=true;
		} catch (SQLException e) {
			
		}
		finally{
			try {
				if(rs!=null)
					rs.close();
				if(ps!=null)
					ps.close();									
				if(con!=null)
					con.close();
			} catch (SQLException e) {				
			}
			
		}
		return successful;		
	}
   //删除奖惩
	public boolean deleteInstitution(int id){
		PreparedStatement ps=null;
		ResultSet rs=null;
		Connection con=db.getConnection();
		boolean successful=false;		
		try {
			ps=con.prepareStatement("delete from institution where institutionId= ? ");
			ps.setInt(1,id);
			int i = ps.executeUpdate();
			if(i>0)
				successful=true;
		} catch (SQLException e) {	
		}
		finally{
			try {
				if(rs!=null)
					rs.close();
				if(ps!=null)
					ps.close();									
				if(con!=null)
					con.close();
			} catch (SQLException e) {				
			}			
		}
		return successful;
		
	}
   //修改奖惩
	public boolean updateInstitution(Institution institution, int id){
		PreparedStatement ps=null;
		ResultSet rs=null;
	
		Connection con=db.getConnection();
		boolean successful=false;
		try {
			ps=con.prepareStatement("update institution set name=?,reason=?,explains=? where institutionId=?");
			ps.setString(1, institution.getName());
			ps.setString(2, institution.getReason());
			ps.setString(3, institution.getExplains());
			ps.setInt(4, id);
     		int i=ps.executeUpdate();
			if(i>0)
				successful=true;
		} catch (SQLException e) {
		}
		return successful;	
	}
	//根据id查询奖惩
	public Institution searchInstitution(int id){
		PreparedStatement ps=null;
		ResultSet rs=null;
	
		Connection con=db.getConnection();
		Institution institution =new Institution();
		try {
			ps=con.prepareStatement("select * from institution where institutionId=?");
			ps.setInt(1,id);
			rs=ps.executeQuery();
			while(rs.next()){
				institution.setInstitutionId(rs.getInt("InstitutionId"));
				institution.setName(rs.getString("name"));
				institution.setReason(rs.getString("reason"));
				institution.setExplains(rs.getString("explains"));
			}
		} catch (SQLException e) {
		}finally{
			
				try {
					if(rs!=null)
						rs.close();
					if(ps!=null)
						ps.close();										
					if(con!=null)
						con.close();
				} catch (SQLException e) {
				}			
		}		
		return institution;
	}
	//查询奖惩
	public ArrayList searchInsitution(){
		PreparedStatement ps=null;
		ResultSet rs=null;
	
		Connection con=db.getConnection();	
		ArrayList arraylistins=new ArrayList();
		try {
			ps=con.prepareStatement("select * from institution");
			rs=ps.executeQuery();
			while(rs.next()){
				Institution institution=new Institution();
				institution.setInstitutionId(rs.getInt("institutionId"));
				institution.setName(rs.getString("name"));
			    arraylistins.add(institution);			    
			}			
		} catch (SQLException e1) {
		}finally{		
				try {
					if(rs!=null)
						rs.close();
					if(ps!=null)
						ps.close();										
					if(con!=null)
						con.close();
				} catch (SQLException e) {					
				}			
		}		
		return arraylistins;
	}
	//获得Institution表的总数
	public int selectCount(){
		PreparedStatement ps=null;
		ResultSet rs=null;
		Connection con=db.getConnection();
		int count=0;
		try {
			ps=con.prepareStatement("select count(*) from Institution");
			rs=ps.executeQuery();
			if(rs.next()){
				count=rs.getInt(1);
			}
		} catch (SQLException e) {
		}	finally{			
			try {
				if(rs!=null)
				    rs.close();
				if(ps!=null)
					ps.close();
				if(con!=null)
					con.close();
			} catch (SQLException e) {
			}		
	}	return count;		
	}
	//翻页查询
	public ArrayList serchInstitution(int beginIndex,int endIndex){
		PreparedStatement ps=null;
		ResultSet rs=null;
		Connection con=db.getConnection();
		ArrayList arraylistInstituton=new ArrayList();
		try {
			ps=con.prepareStatement("select * from Institution limit ? ,?")	;
			//int maxLength=(endIndex-beginIndex)+1;
			int maxLength = endIndex;
			ps.setInt(1,beginIndex);
			ps.setInt(2,maxLength);
			rs=ps.executeQuery();
			while(rs.next()){
				Institution institution=new Institution();
			   institution.setInstitutionId(rs.getInt(1));
			   institution.setName(rs.getString(2));
			   institution.setReason(rs.getString(3));
			   institution.setExplains(rs.getString(4));
			   arraylistInstituton.add(institution);
			}
		} catch (SQLException e) {
		}	finally{
            try {
            	if(rs!=null)
 				   rs.close();
				if(ps!=null)
				   ps.close();
				if (con!=null)
					con.close();
			} catch (SQLException e) {
			}			
	}    return arraylistInstituton;		
	}
}