一个通用的连接池Bean

　　//连接Bean ConnectionBean.java

package com.pool;
import java.io.Serializable;
import java.sql.*;
public class ConnectionBean implements java.io.Serializable
{
 private Connection vConnection=null;
 private boolean bUseState=false;
public ConnectionBean(){}
 public ConnectionBean(Connection connection)
 {
　 if(connection!=null)
　 {
　  vConnection=connection;
　 }
 }
 public Connection getConnection()
 {
　 return vConnection;
 }
 public void setConnection(Connection connection)
 {
　 vConnection=connection;
 }
 public void setUseState(boolean bUseState)
 {
　 this.bUseState=bUseState;
 }
 public boolean getUseState()
 {
　 return bUseState;
 }
 public void close()
 {
　 try
　 {
　  vConnection.close();
　 }
　 catch(SQLException sqlException)
　 {
　  System.err.println(sqlException.getMessage());
　 }
 }
}

//连接池

PoolBean.java

package com.pool;
import java.io.Serializable;
import java.sql.*;
import java.util.*;
import com.pool.ConnectionBean;
public class PoolBean implements java.io.Serializable
{
 private String strDriver=null;
 private String strURL=null;
 private int iSize=0;
 private String strUserName="";
 private String strPassword="";
 private ConnectionBean vConnectionBean=null;
 private Vector vPool=null;
public PoolBean(){}
 public void setDriver(String strDriver)
 {
　 if(strDriver!=null)
　 {
　  this.strDriver=strDriver;
　 }
 }
 public String getDriver()
 {
　 return strDriver;
 }
 public void setURL(String strURL)
 {
　 if(strURL!=null)
　 {
　  this.strURL=strURL;
　 }
 }
 public String getURL()
 {
　 return strURL;
 }
 public void setSize(int iSize)
 {
　 if(iSize>1)
　 {
　  this.iSize=iSize;
　 }
 }
 public int getSize()
 {
　 return iSize;
 }
 public String getUserName()
 {
　 return strUserName;
 }
 public void setUserName(String strUserName)
 {
　 if(strUserName!=null)
　 {
　  this.strUserName=strUserName;
　 }
 }
 public void setPassword(String strPassword)
 {
　 if(strPassword!=null)
　 {
　  this.strPassword=strPassword;
　 }
 }
 public String getPassword()
 {
　 return strPassword;
 }
 public void setConnectionBean(ConnectionBean vConnectionBean)
 {
　 if(vConnectionBean!=null)
　 {
　  this.vConnectionBean=vConnectionBean;
　 }
 }
 public ConnectionBean getConnectionBean() throws Exception
 {
　 Connection vConnection=getConnection();
　 ConnectionBean vConnectionBean=new ConnectionBean(vConnection);
　 vConnectionBean.setUseState(true);
　 return vConnectionBean;
 }
 private Connection createConnection() throws Exception
 {
　 Connection vConnection=null;
　 vConnection=DriverManager.getConnection(strURL,strUserName,strPassword);
　 return vConnection;
 }
 public synchronized void initializePool() throws Exception
 {
　 if(strDriver==null)
　 {
　  throw new Exception("没有提供驱动程序名称!");
　 }
　 if(strURL==null)
　 {
　  throw new Exception("没有提供URL!");
　 }
　 if(iSize<1)
　 {
　  throw new Exception("连接池大小小于1!");
　 }
　 try
　 {
　  Class.forName(strDriver);
　  for(int iIndex=0;iIndex<iSize;iIndex++)
　  {
　　 Connection vConnection=createConnection();
　　 if(vConnection!=null)
　　 {
　　  ConnectionBean vConnectionBean=new ConnectionBean(vConnection);
　　  addConnection(vConnectionBean);
　　 }
　  }
　 }
　 catch(Exception eException)
　 {
　  System.err.println(eException.getMessage());
　  throw new Exception(eException.getMessage());
　 }
 }
 private void addConnection(ConnectionBean vConnectionBean)
 {
　 if(vPool==null)
　 {
　  vPool=new Vector(iSize);
　 }
　 vPool.addElement(vConnectionBean);
 }
 public synchronized void releaseConnection(Connection vConnection)
 {
　 for(int iIndex=0;iIndex<vPool.size();iIndex++)
　 {
　  ConnectionBean vConnectionBean=(ConnectionBean)vPool.elementAt(iIndex);
　  if(vConnectionBean.getConnection()==vConnection)
　  {
　　 System.err.println("释放第"+iIndex+"个连接!");
　　 vConnectionBean.setUseState(false);
　　 break;
　  }
　 }
 }
 public synchronized Connection getConnection() throws Exception
 {
　 ConnectionBean vConnectionBean=null;
　 for(int iIndex=0;iIndex<vPool.size();iIndex++)
　 {
　  vConnectionBean=(ConnectionBean)vPool.elementAt(iIndex);
　  if(vConnectionBean.getUseState()==false)
　  {
　　 vConnectionBean.setUseState(true);
　　 Connection vConnection=vConnectionBean.getConnection();
　　 return vConnection;
　  }
　 }
　 try
　 {
　  Connection vConnection=createConnection();
　  vConnectionBean=new ConnectionBean(vConnection);
　  vConnectionBean.setUseState(true);
　  vPool.addElement(vConnectionBean);
　 }
　 catch(Exception eException)
　 {
　  System.err.println(eException.getMessage());
　  throw new Exception(eException.getMessage());
　 }
　 return vConnectionBean.getConnection();
 }
 public synchronized void emptyPool()
 {
　 for(int iIndex=0;iIndex<vPool.size();iIndex++)
　 {
　  System.err.println("关闭第"+iIndex+"JDBC连接!");
　  ConnectionBean vConnectionBean=(ConnectionBean)vPool.elementAt(iIndex);
　  if(vConnectionBean.getUseState()==false)
　  {
　　 vConnectionBean.close();
　  }
　  else
　  {
　　 try
　　 {
　　  java.lang.Thread.sleep(20000);
　　  vConnectionBean.close();
　　 }
　　 catch(InterruptedException interruptedException)
　　 {
　　  System.err.println(interruptedException.getMessage());
　　 }
　  }
　 }
 }
}