partmentdao.java

jdbc 学习质料

package src.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;

import src.Docunnents.DbException;
import src.common.DbConnection;
import src.vo.PartmentVo;

public class PartmentDao {

	
	public ArrayList getPartmentInfo(){
		Statement stmt=null;
		ResultSet set=null;
		Connection con=null;
		ArrayList list=new ArrayList();
		String sql="select * from partment";
		//DBConnectionManager manager =DBConnectionManager.getInstance();
		try{ 
			con=new DbConnection().getConnection();
			//con=manager.getConnection("oracle");
			stmt=con.createStatement();
			set=stmt.executeQuery(sql);
			PartmentVo vo=null;
			while(set.next()){
				int id=set.getInt("partment_id");
				String name=set.getString("partment_name");
				int manage=set.getInt("manager_id");
				vo=new PartmentVo(name,id,manage);
				list.add(vo);
			}
			
		}catch(Exception e){
			System.out.print(e.getMessage());
		}finally{
		//	manager.freeConnection("oracle",con);
		}
		return list;
	}
	public boolean foundPartmentBYID(int partmentid, Connection con){
		boolean flag =false;
		Statement stmt=null;
		ResultSet set=null;
		try{
			stmt=con.createStatement();
			set=stmt.executeQuery("select * from partment where partment_id="+partmentid+"");
			if(set.next()){
				flag=true;
			}
		}catch(Exception e){
			System.out.print(e.getMessage());}
		return flag;
	}
	public boolean InsertPartment(PartmentVo value) throws DbException{
		Statement stmt=null;
		Connection con=null;
		boolean flag=false;
		try{
			con=new DbConnection().getConnection();
			if(foundPartmentBYID(value.getPartmentid(),con)){
				throw new DbException("你输入的重复的内容请重新输入");
			}else{
				stmt=con.createStatement();
				String sql="insert into partment values("+value.getPartmentid()+",'"+value.getPartmentname()+"',"+value.getManageid()+")";
				int conmt=stmt.executeUpdate(sql);
				if(conmt!=0){
					flag=true;
				}
			}
		}catch(Exception e){
			System.out.print(e.getMessage());
		}
		return flag;
	}
	public void executeMultiSql(){
	    Statement stmt = null;
	    Connection con = null;
	    try{
	      con = new DbConnection().getConnection();
	      stmt = con.createStatement();
	      String insertSql = "insert into partment values('软件部',58,121)";
	      String deleteSql = "delete from partment where partment_id = 1";
	      String updateSql = "update partment set partment_name = '民政部' where partment_id = 3";
	      stmt.addBatch(insertSql);
	      stmt.addBatch(deleteSql);
	      stmt.addBatch(updateSql);
	      stmt.executeBatch();
	    }catch(Exception e){
	      System.out.println(e.getMessage());
	    }
	  }

}