c3p0连接池使用

      在实际开发中，使用JDBC连接数据库的情况时有出现，在多层结构的应用中，使用DriverManager获取连接时，一个需要连接的操作对应一个数据库物理连接，每一次操作都会重新打开一个连接，在使用完毕后立即关闭。而频繁打开、关闭连接会造成系统及其不稳定，并发操作时经常会出现连接不足甚至是根本无法获取连接的情况。

      c3p0连接池很好地解决了这个问题，解决思路是：在应用程序启动时，即建立足够的数据库连接用于待命，并将这些连接存放在池中等待使用。每次其它服务请求数据库连接时，不需要重新打开数据库连接，而是从池中取出已有的连接，使用完毕后，这个连接也不会被关闭，而是重新放入连接池。JDBC2.0引入了数据库连接池技术以解决共享连接问题，使用java.sql.DataSource接口实现，而c3p0是一个开源的实现，商用服务器也提供连接池实现（如WebLogic、WebSphere）。

      本文使用一个工具类来读取配置文件，具体代码如下：

package com.any.util;

import java.util.ArrayList;
import java.util.Enumeration;
import java.util.Locale;
import java.util.ResourceBundle;

/**
* @ClassName: ConfigUtil
* @author Helen
* @date 2015年8月13日 上午10:46:39
*/

public class ConfigUtil {
private String resourcePath = "com.any.config";
private ResourceBundle bundle;
private ArrayList<String> keyList;

private ConfigUtil(){
loadFile();
}
public static ConfigUtil getInstanceConfig(){
return new ConfigUtil();
}
protected void loadFile(){
bundle = ResourceBundle.getBundle(resourcePath, Locale.CHINA);
if(bundle!=null){
Enumeration<String> eumObj = bundle.getKeys();
keyList = new ArrayList<String>();
while (eumObj.hasMoreElements()) {
keyList.add(eumObj.nextElement());
}
} else {
System.out.println("Config file not exists!");
System.exit(2);
}
}
private boolean isKeyExists(String key){
return keyList.contains(key);
}
public String getString(String key){
if(isKeyExists(key)){
return bundle.getString(key);
}
return null;
}
public int getInt(String key){
if(isKeyExists(key)){
return Integer.valueOf(bundle.getString(key));
}
return 0;
}
}

     该工具类仅用于从properties文件中读取数据，该文件中通常会存放应用系统的常用配置参数：如数据库信息、资源路径信息、国际化资源等。使用C3P0获取连接池的关键代码如下：

package com.any.util;

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
* @ClassName: DBPool
* @author Helen
* @date 2015年8月13日 上午10:19:44
*/

public class DBPool {
public static Connection getConnection(){
ComboPooledDataSource ds = new ComboPooledDataSource();
ConfigUtil config = ConfigUtil.getInstanceConfig();
try {
ds.setDriverClass("com.mysql.jdbc.Driver");
ds.setJdbcUrl(config.getString("url"));
ds.setUser(config.getString("user"));
ds.setPassword(config.getString("password"));
ds.setMaxPoolSize(60);
ds.setMinPoolSize(3);
ds.setInitialPoolSize(10);
ds.setMaxStatements(200);
return ds.getConnection();
} catch (PropertyVetoException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
}

      注意，需要引入C3P0对应版本的jar包，通过设置最大连接数、最小连接数等，即可创建一个连接池，C3P0还能很好地管理连接池，也能自动清理不再使用的Statement和ResultSet。

      使用以下代码测试：

package com.any;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.any.util.DBPool;

/**
* @ClassName: TestPool
* @Description: (这里用一句话描述这个类的作用)
* @author Helen
* @date 2015年8月13日 上午10:30:43
*/

public class TestPool {
public static void main(String[] args) {
Connection conn = DBPool.getConnection();
try {
PreparedStatement psmt=conn.prepareStatement("select * from emp");
ResultSet rs = psmt.executeQuery();
while(rs.next()){
System.out.println("result:"+rs.getString("ename"));
}
} catch (SQLException e) {
e.printStackTrace();
}

}
}

     由于引入了日志组件，因此运行时可以看到控制台打印出的如下日志信息：

八月 13, 2015 11:05:48 上午 com.mchange.v2.log.MLog <clinit>
INFO: MLog clients using java 1.4+ standard logging.
八月 13, 2015 11:05:48 上午 com.mchange.v2.c3p0.C3P0Registry banner
INFO: Initializing c3p0-0.9.1.2 [built 21-May-2007 15:04:56; debug? true; trace: 10]
八月 13, 2015 11:05:48 上午 com.mchange.v2.c3p0.impl.AbstractPoolBackedDataSource getPoolManager
INFO: Initializing c3p0 pool... com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 3, acquireRetryAttempts -> 30, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 0, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, dataSourceName -> 1hge48x9ba9sf7i1qnzmj8|4544c134, debugUnreturnedConnectionStackTraces -> false, description -> null, driverClass -> com.mysql.jdbc.Driver, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, identityToken -> 1hge48x9ba9sf7i1qnzmj8|4544c134, idleConnectionTestPeriod -> 0, initialPoolSize -> 10, jdbcUrl -> jdbc:mysql://127.0.0.1:3306/test, maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 0, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 60, maxStatements -> 200, maxStatementsPerConnection -> 0, minPoolSize -> 3, numHelperThreads -> 3, numThreadsAwaitingCheckoutDefaultUser -> 0, preferredTestQuery -> null, properties -> {user=******, password=******}, propertyCycle -> 0, testConnectionOnCheckin -> false, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, usesTraditionalReflectiveProxies -> false ]
result:abc