到目前为目JDBC的连结池只是一个接口没有真正的实现JDBC正在开发中据报已经支持连结池但JDBC用了JNDI技术连结池的配置可以让一个高手都烦死
目前第三方已经实现的连结池当然是poolman版对一般用户来说已经足够用了配置也简单版虽然增加了一些功能但配置也是采用JNDI对RMI和EJB不懂的朋友可能很烦建议用的了
如果有兴趣自己也可以实现连结池最关键的技术也就是把连结作为参数传给一个BEAN用完后返回这个参数连结而不是关闭
下面是一个简单的实现:
DBConnectionManagerjava程序清单如下
import javaio*;
import javasql*;
import javautil*;
import javautilDate;
/**
* 管理类DBConnectionManager支持对一个或多个由属性文件定义的数据库连接
* 池的访问客户程序可以调用getInstance()方法访问本类的唯一实例
*/
public class DBConnectionManager {
static private DBConnectionManager instance; // 唯一实例
static private int clients;
private Vector drivers = new Vector();
private PrintWriter log;
private Hashtable pools = new Hashtable();
/**
* 返回唯一实例如果是第一次调用此方法则创建实例
*
* @return DBConnectionManager 唯一实例
*/
static synchronized public DBConnectionManager getInstance() {
if (instance == null) {
instance = new DBConnectionManager();
}
clients++;
return instance;
}
/**
* 建构函数私有以防止其它对象创建本类实例
*/
private DBConnectionManager() {
init();
}
/**
* 将连接对象返回给由名字指定的连接池
*
* @param name 在属性文件中定义的连接池名字
* @param con 连接对象\\r
*/
public void freeConnection(String name Connection con) {
DBConnectionPool pool = (DBConnectionPool) poolsget(name);
if (pool != null) {
poolfreeConnection(con);
}
}
/**
* 获得一个可用的(空闲的)连接如果没有可用连接且已有连接数小于最大连接数
* 限制则创建并返回新连接
*
* @param name 在属性文件中定义的连接池名字
* @return Connection 可用连接或null
*/
public Connection getConnection(String name) {
DBConnectionPool pool = (DBConnectionPool) poolsget(name);
if (pool != null) {
return poolgetConnection();
}
return null;
}
/**
* 获得一个可用连接若没有可用连接且已有连接数小于最大连接数限制
* 则创建并返回新连接否则在指定的时间内等待其它线程释放连接
*
* @param name 连接池名字
* @param time 以毫秒计的等待时间\\r
* @return Connection 可用连接或null
*/
public Connection getConnection(String name long time) {
DBConnectionPool pool = (DBConnectionPool) poolsget(name);
if (pool != null) {
return poolgetConnection(time);
}
return null;
}
/**
* 关闭所有连接撤销驱动程序的注册\\r
*/
public synchronized void release() {
// 等待直到最后一个客户程序调用
if (clients != ) {
return;
}
Enumeration allPools = poolselements();
while (allPoolshasMoreElements()) {
DBConnectionPool pool = (DBConnectionPool) allPoolsnextElement();
poolrelease();
}
Enumeration allDrivers = driverselements();
while (allDrivershasMoreElements()) {
Driver driver = (Driver) allDriversnextElement();
try {
DriverManagerderegisterDriver(driver);
log(撤销JDBC驱动程序 + drivergetClass()getName()+的注册\\\);
}
catch (SQLException e) {
log(e 无法撤销下列JDBC驱动程序的注册: + drivergetClass()getName());
}
}
}
/**
* 根据指定属性创建连接池实例
*
* @param props 连接池属性
*/
private void createPools(Properties props) {
Enumeration propNames = propspropertyNames();
while (propNameshasMoreElements()) {
String name = (String) propNamesnextElement();
if (nameendsWith(url)) {
String poolName = namesubstring( namelastIndexOf());
String url = propsgetProperty(poolName + url);
if (url == null) {
log(没有为连接池 + poolName + 指定URL);
continue;
}
String user = propsgetProperty(poolName + user);
String password = propsgetProperty(poolName + password);
String maxconn = propsgetProperty(poolName + maxconn );
int max;
try {
max = IntegervalueOf(maxconn)intValue();
}
catch (NumberFormatException e) {
log(错误的最大连接数限制: + maxconn + 连接池: + poolName);
max = ;
}
DBConnectionPool pool =
new DBConnectionPool(poolName url user password max);
poolsput(poolName pool);
log(成功创建连接池 + poolName);
}
}
}
/**
* 读取属性完成初始化
*/
private void init() {
InputStream is = getClass()getResourceAsStream(/dbproperties);
Properties dbProps = new Properties();
try {
dbPropsload(is);
}
catch (Exception e) {
Systemerrprintln(不能读取属性文件 +
请确保dbproperties在CLASSPATH指定的路径中);
return;
}
String logFile = dbPropsgetProperty(logfile DBConnectionManagerlog);
try {
log = new PrintWriter(new FileWriter(logFile true) true);
}
catch (IOException e) {
Systemerrprintln(无法打开日志文件: + logFile);
log = new PrintWriter(Systemerr);
}
loadDrivers(dbProps);
createPools(dbProps);
}
/**
* 装载和注册所有JDBC驱动程序\\r
*
* @param props 属性
*/
private void loadDrivers(Properties props) {
String driverClasses = propsgetProperty(drivers);
StringTokenizer st = new StringTokenizer(driverClasses);
while (sthasMoreElements()) {
String driverClassName = stnextToken()trim();
try {
Driver driver = (Driver)
ClassforName(driverClassName)newInstance();
DriverManagerregisterDriver(driver);
driversaddElement(driver);
log(成功注册JDBC驱动程序\\\ + driverClassName);
}
catch (Exception e) {
log(无法注册JDBC驱动程序: +
driverClassName + 错误: + e);
}
}
}
/**
* 将文本信息写入日志文件
*/
private void log(String msg) {
logprintln(new Date() + : + msg);
}
/**
* 将文本信息与异常写入日志文件
*/
private void log(Throwable e String msg) {
logprintln(new Date() + : + msg);
eprintStackTrace(log);
}
/**
* 此内部类定义了一个连接池它能够根据要求创建新连接直到预定的最\\r
