其次是連接池的工廠類ConnectionFactory，通過該類來將一個連接池對象與一個名稱對應起來，使用者通過該名稱就可以獲取指定的連接池對象，具體代碼如下：


/**
* 連接池類廠，該類常用來保存多個數據源名稱合數據庫連接池對應的哈希
* @author liusoft
*/
public class ConnectionFactory
{
//該哈希表用來保存數據源名和連接池對象的關系表
static Hashtable connectionPools = null;
static{
connectionPools = new Hashtable(2,0.75F);
}
/**
 * 從連接池工廠中獲取指定名稱對應的連接池對象
 * @param dataSource連接池對象對應的名稱
 * @return DataSource返回名稱對應的連接池對象
 * @throws NameNotFoundException無法找到指定的連接池
 */
public static DataSource lookup(String dataSource)
throws NameNotFoundException
{
Object ds = null;
ds = connectionPools.get(dataSource);
if(ds == null !(ds instanceof DataSource))
throw new NameNotFoundException(dataSource);
return (DataSource)ds;
}

/**
 * 將指定的名字和數據庫連接配置綁定在一起并初始化數據庫連接池
 * @param name對應連接池的名稱
 * @param param連接池的配置參數，具體請見類ConnectionParam
 * @return DataSource如果綁定成功后返回連接池對象
 * @throws NameAlreadyBoundException一定名字name已經綁定則拋出該異常
 * @throws ClassNotFoundException無法找到連接池的配置中的驅動程序類
 * @throws IllegalAccessException連接池配置中的驅動程序類有誤
 * @throws InstantiationException無法實例化驅動程序類
 * @throws SQLException無法正常連接指定的數據庫
 */
public static DataSource bind(String name, ConnectionParam param)
throws NameAlreadyBoundException,ClassNotFoundException,
IllegalAccessException,InstantiationException,SQLException
{
DataSourceImpl source = null;
try{
lookup(name);
throw new NameAlreadyBoundException(name);
}catch(NameNotFoundException e){
source = new DataSourceImpl(param);
source.initConnection();
connectionPools.put(name, source);
}
return source;
}
/**
 * 重新綁定數據庫連接池
 * @param name對應連接池的名稱
 * @param param連接池的配置參數，具體請見類ConnectionParam
 * @return DataSource如果綁定成功后返回連接池對象
 * @throws NameAlreadyBoundException一定名字name已經綁定則拋出該異常
 * @throws ClassNotFoundException無法找到連接池的配置中的驅動程序類
 * @throws IllegalAccessException連接池配置中的驅動程序類有誤
 * @throws InstantiationException無法實例化驅動程序類
 * @throws SQLException無法正常連接指定的數據庫
 */
public static DataSource rebind(String name, ConnectionParam param)
throws NameAlreadyBoundException,ClassNotFoundException,
IllegalAccessException,InstantiationException,SQLException
{
try{
unbind(name);
}catch(Exception e){}
return bind(name, param);
}
/**
 * 刪除一個數據庫連接池對象
 * @param name
 * @throws NameNotFoundException
 */
public static void unbind(String name) throws NameNotFoundException
{
DataSource dataSource = lookup(name);
if(dataSource instanceof DataSourceImpl){
DataSourceImpl dsi = (DataSourceImpl)dataSource;
try{
dsi.stop();
dsi.close();
}catch(Exception e){
}finally{
dsi = null;
}
}
connectionPools.remove(name);
}

}




ConnectionFactory主要提供了用戶將將連接池綁定到一個具體的名稱上以及取消綁定的操作。使用者只需要關心這兩個類即可使用數據庫連接池的功能。下面我們給出一段如何使用連接池的代碼：


String name = "pool";
String driver = " sun.jdbc.odbc.JdbcOdbcDriver ";
String url = "jdbc:odbc:datasource";
ConnectionParam param = new ConnectionParam(driver,url,null,null);
param.setMinConnection(1);
param.setMaxConnection(5);
param.setTimeoutValue(20000);
ConnectionFactory.bind(name, param);
System.out.println("bind datasource ok.");
//以上代碼是用來登記一個連接池對象，該操作可以在程序初始化只做一次即可
//以下開始就是使用者真正需要寫的代碼
DataSource ds = ConnectionFactory.lookup(name);
try{
for(int i=0;i<10;i++){
Connection conn = ds.getConnection();
try{
testSQL(conn, sql);
}finally{
try{
conn.close();
}catch(Exception e){}
}
}
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionFactory.unbind(name);
System.out.println("unbind datasource ok.");
System.exit(0);
}




從使用者的示例代碼就可以看出，我們已經解決了常規連接池產生的兩個問題。但是我們最最關心的是如何解決接管close方法的辦法。接管工作主要在ConnectionFactory中的兩句代碼：


source = new DataSourceImpl(param);
source.initConnection();