JAVA中数据库连接池的动态实现

1、JAVA中数据库连接池的动态实现2010-08-18 09:11:41|分类： 数据库技术 |标签： |字号大中小订阅 首先我们先设身处地的考虑一下用户是想怎么样来使用这个数据库连接池的。用户可以通过特定的方法来获取数据库的连接，同时这个连接的类型应该是标准的java.sql.Connection。用户在获取到这个数据库连接后可以对这个连接进行任意的操作，包括关闭连接等。通过对用户使用的描述，怎样可以接管Connection.close方法就成了我们这篇文章的主题。为了接管数据库连接的close方法，我们应该有一种类似于钩子的机制。例如在Windows编程中我们可以利用Hook API来实现对

2、某个Windows API的接管。在JAVA中同样也有这样一个机制。JAVA提供了一个Proxy类和一个InvocationHandler，这两个类都在java.lang.reflect包中。SUN的API文档中关于Proxy的描述很多，这里就不罗列出来。通过文档对接口InvocationHandler的描述我们可以看到当调用一个Proxy实例的方法时会触发Invocationhanlder的invoke方法。从JAVA的文档中我们也同时了解到这种动态代理机制只能接管接口的方法，而对一般的类无效，考虑到java.sql.Connection本身也是一个接口由此就找到了解决如何接管close方法

3、的出路。首先，我们先定义一个数据库连接池参数的类，定义了数据库的JDBC驱动程序类名，连接的URL以及用户名口令等等一些信息，该类是用于初始化连接池的参数，具体定义如下: public class ConnectionParam implements Serializableprivate String driver; /数据库驱动程序 private String url; /数据连接的URL private String user; /数据库用户名 private String password; /数据库密码 private int minConnection = 0; /初始化连接数

4、private int maxConnection = 50; /最大连接数 private long timeoutValue = 600000;/连接的最大空闲时间 private long waitTime = 30000; /取连接的时候如果没有可用连接最大的等待时间其次是连接池的工厂类ConnectionFactory，通过该类来将一个连接池对象与一个名称对应起来，使用者通过该名称就可以获取指定的连接池对象，具体代码如下：/* 连接池类厂，该类常用来保存多个数据源名称合数据库连接池对应的哈希* author liusoft*/public class ConnectionFactor

5、y/该哈希表用来保存数据源名和连接池对象的关系表 static Hashtable connectionPools = null;staticconnectionPools = new Hashtable(2,0.75F);/* 从连接池工厂中获取指定名称对应的连接池对象* param dataSource 连接池对象对应的名称* return DataSource 返回名称对应的连接池对象* throws NameNotFoundException 无法找到指定的连接池*/public static DataSource lookup(String dataSource)throws Nam

6、eNotFoundExceptionObject 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 如果绑定

7、成功后返回连接池对象* throws NameAlreadyBoundException 一定名字name已经绑定则抛出该异常* throws ClassNotFoundException 无法找到连接池的配置中的驱动程序类* throws IllegalAccessException 连接池配置中的驱动程序类有误* throws InstantiationException 无法实例化驱动程序类* throws SQLException 无法正常连接指定的数据库*/public static DataSource bind(String name, ConnectionParam param

8、)throws NameAlreadyBoundException,ClassNotFoundException,IllegalAccessException,InstantiationException,SQLExceptionDataSourceImpl source = null;trylookup(name);throw new NameAlreadyBoundException(name);catch(NameNotFoundException e)source = new DataSourceImpl(param);source.initConnection();connectio

9、nPools.put(name, source);return source;/* 重新绑定数据库连接池* param name 对应连接池的名称* param param 连接池的配置参数，具体请见类ConnectionParam* return DataSource 如果绑定成功后返回连接池对象* throws NameAlreadyBoundException 一定名字name已经绑定则抛出该异常* throws ClassNotFoundException 无法找到连接池的配置中的驱动程序类* throws IllegalAccessException 连接池配置中的驱动程序类有误*

10、throws InstantiationException 无法实例化驱动程序类* throws SQLException 无法正常连接指定的数据库*/public static DataSource rebind(String name, ConnectionParam param)throws NameAlreadyBoundException,ClassNotFoundException,IllegalAccessException,InstantiationException,SQLExceptiontryunbind(name);catch(Exception e)return bi

11、nd(name, param);/* 删除一个数据库连接池对象* param name* throws NameNotFoundException*/public static void unbind(String name) throws NameNotFoundExceptionDataSource dataSource = lookup(name);if(dataSource instanceof DataSourceImpl)DataSourceImpl dsi = (DataSourceImpl)dataSource;trydsi.stop();dsi.close();catch(E

12、xception e)finallydsi = null;connectionPools.remove(name);ConnectionFactory主要提供了用户将将连接池绑定到一个具体的名称上以及取消绑定的操作。使用者只需要关心这两个类即可使用数据库连接池的功能。下面我们给出一段如何使用连接池的代码：String name = pool;String driver = sun.jdbc.odbc.JdbcOdbcDriver ;String url = jdbc:odbc:datasource;ConnectionParam param = new ConnectionParam(driv

13、er,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);tryfor(int i=0;i= connPa

14、ram.getMaxConnection()conn = getFreeConnection(connParam.getWaitTime();else/没有超过连接数，重新获取一个数据库的连接 connParam.setUser(user);connParam.setPassword(password);Connection conn2 = DriverManager.getConnection(connParam.getUrl(),user, password);/代理将要返回的连接对象 _Connection _conn = new _Connection(conn2,true);sync

15、hronized(conns)conns.add(_conn);conn = _conn.getConnection();return conn;/* 从连接池中取一个空闲的连接* param nTimeout 如果该参数值为0则没有连接时只是返回一个null* 否则的话等待nTimeout毫秒看是否还有空闲连接，如果没有抛出异常* return Connection* throws SQLException*/protected synchronized Connection getFreeConnection(long nTimeout)throws SQLExceptionConnection conn = null;Iterator iter = conns.iterator();while(iter.hasNext()_Connection _conn = (_Connection)iter.next();if(!_conn.isInUse(