一种完成数据库连接池的方法(2)

其次是连接池的工厂类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();

……