c3p0-连接池配置.doc

<c3p0-config>
<default-config>
<!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。Default: 3 --><property name="acquireIncrement">3</property>

<!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
<property name="acquireRetryAttempts">30</property>

<!--两次连接中间隔时间，单位毫秒。Default: 1000 -->
<property name="acquireRetryDelay">1000</property>

<!--连接关闭时默认将所有未提交的操作回滚。Default: false -->
<property name="autoCommitOnClose">false</property>

<!--c3p0将建一张名为Test的空表，并使用其自带的查询语句进行测试。如果定义了这个参数那么
属性preferredTestQuery将被忽略。你不能在这张Test表上进行任何操作，它将只供c3p0测试
使用。Default: null--><property name="automaticTestTable">Test</property>

<!--获取连接失败将会引起所有等待连接池来获取连接的线程抛出异常。但是数据源仍有效
保留，并在下次调用getConnection()的时候继续尝试获取连接。如果设为true，那么在尝试
获取连接失败后该数据源将申明已断开并永久关闭。Default: false--><property name="breakAfterAcquireFailure">false</property>

<!--当连接池用完时客户端调用getConnection()后等待获取新连接的时间，超时后将抛出
SQLException,如设为0则无限期等待。单位毫秒。Default: 0 --><property name="checkoutTimeout">100</property>

<!--通过实现ConnectionTester或QueryConnectionTester的类来测试连接。类名需制定全路径。
Default: com.mchange.v2.c3p0.impl.DefaultConnectionTester--><property name="connectionTesterClassName"></property>

<!--指定c3p0 libraries的路径，如果（通常都是这样）在本地即可获得那么无需设置，默认null即可
Default: null--><property name="factoryClassLocation">null</property>

<!--Strongly disrecommended. Setting this to true may lead to subtle and bizarre bugs.
（文档原文）作者强烈建议不使用的一个属性--><property name="forceIgnoreUnresolvedTransactions">false</property>

<!--每60秒检查所有连接池中的空闲连接。Default: 0 --><property name="idleConnectionTestPeriod">60</property>

<!--初始化时获取三个连接，取值应在minPoolSize与maxPoolSize之间。Default: 3 --><property name="initialPoolSize">3</property>

<!--最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。Default: 0 --><property name="maxIdleTime">60</property>

<!--连接池中保留的最大连接数。Default: 15 --><property name="maxPoolSize">15</property>

<!--JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量。但由于预缓存的statements
属于单个connection而不是整个连接池。所以设置这个参数需要考虑到多方面的因素。
如果maxStatements与maxStatementsPerConnection均为0，则缓存被关闭。Default: 0--><property name="maxStatements">100</property>

<!--maxStatementsPerConnection定义了连接池内单个连接所拥有的最大缓存statements数。Default: 0 --><property name="maxStatementsPerConnection"></property>

<!--c3p0是异步操作的，缓慢的JDBC操作通过帮助进程完成。扩展这些操作可以有效的提升性能
通过多线程实现多个操作同时被执行。Default: 3-->
<property name="numHelperThreads">3</property>

<!--当用户调用getConnection()时使root用户成为去获取连接的用户。主要用于连接池连接非c3p0
的数据源时。Default: null--><property name="overrideDefaultUser">root</property>

<!--与overrideDefaultUser参数对应使用的一个参数。Default: null--><property name="overrideDefaultPassword">password</property>

<!--密码。Default: null--><property name="password"></property>

<!--定义所有连接测试都执行的测试语句。在使用连接测试的情况下这个一显著提高测试速度。注意：
测试的表必须在初始数据源的时候就存在。Default: null-->
<property name="preferredTestQuery">select id from test where id=1</property>

<!--用户修改系统配置参数执行前最多等待300秒。Default: 300 --><property name="propertyCycle">300</property>

<!--因性能消耗大请只在需要的时候使用它。如果设为true那么在每个connection提交的
时候都将校验其有效性。建议使用idleConnectionTestPeriod或automaticTestTable
等方法来提升连接测试的性能。Default: false --><property name="testConnectionOnCheckout">false</property>

<!--如果设为true那么在取得连接的同时将校验连接的有效性。Default: false --><property name="testConnectionOnCheckin">true</property>

<!--用户名。Default: null--><property name="user">root</property>

<!--早期的c3p0版本对JDBC接口采用动态反射代理。在早期版本用途广泛的情况下这个参数
允许用户恢复到动态反射代理以解决不稳定的故障。最新的非反射代理更快并且已经开始
广泛的被使用，所以这个参数未必有用。现在原先的动态反射与新的非反射代理同时受到
支持，但今后可能的版本可能不支持动态反射代理。Default: false--><property name="usesTraditionalReflectiveProxies">false</property>

acquireIncrement -> 5
acquireRetryAttempts -> 30
acquireRetryDelay -> 1000
autoCommitOnClose -> false
automaticTestTable -> null

breakAfterAcquireFailure -> true
checkoutTimeout -> 0
connectionCustomizerClassName -> null
connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester

dataSourceName -> 1bqp8hc8ezqxpjc1hp9gny|704baa
debugUnreturnedConnectionStackTraces -> false
description -> null
driverClass -> com.mysql.jdbc.Driver

factoryClassLocation -> null
forceIgnoreUnresolvedTransactions -> false
identityToken -> 1bqp8hc8ezqxpjc1hp9gny|704baa
idleConnectionTestPeriod -> 60
initialPoolSize -> 5
jdbcUrl -> jdbc:mysql://localhost:3306/db_temp?useUnicode=true&characterEncoding=utf-8
lastAcquisitionFailureDefaultUser -> null
maxAdministrativeTaskTime -> 0
maxConnectionAge -> 0
maxIdleTime -> 60
maxIdleTimeExcessConnections -> 0
maxPoolSize -> 30
maxStatements -> 0
maxStatementsPerConnection -> 0
minPoolSize -> 5
numHelperThreads -> 3
numThreadsAwaitingCheckoutDefaultUser -> 0
preferredTestQuery -> null

properties -> {user=******password=******}
propertyCycle -> 0
testConnectionOnCheckin -> false
testConnectionOnCheckout -> false
unreturnedConnectionTimeout -> 0
usesTraditionalReflectiveProxies -> false

package com.paipaiestore.database.c3p0;

import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.DataSources;
/**
* 数据连接池工厂
* @author samland
* @version 1.0, 2006-11
*/
public class DBPoolFactory {

private static DBPoolFactory dbpoolFactory = new DBPoolFactory();
/**
* 连接池列表
*/
private static Map poollist = new HashMap();

private DBPoolFactory(){

}

public static DBPoolFactory getInstance(){
return dbpoolFactory;
}
/**
* 向连接池列表添加一个新的池化（Pooled）数据源
* @param key
* @param configFile 配置文件名。为了简化参数输入与便于外部维护，可以把配置好的文件传入这里分析
*/
public void add(String key, String configFile) {
//read config from file, and build a dbpool
}
/**
* 向连接池列表添加一个新的池化（Pooled）数据源
* @param key
* @param driver 数据连接驱动，如com.mysql.jdbc.Driver
* @param url 连接串， 如jdbc:mysql://localhost/samland
* @param username 数据库连接用户名，如samland
* @param password 数据库连接用户密码
* @throws Exception
*/
public void add(String key, String driver, String url, String username, String password)
throws Exception{
if (key==null) throw new Exception("DBPool 'key' CANNOT be null") ;

Class.forName(driver);
DataSource ds_unpooled = DataSources.unpooledDataSource(url, username, password);
DataSource ds_pooled = DataSources.pooledDataSource( ds_unpooled );
if (poollist.containsKey(key)){
poollist.remove(key);
}
poollist.put(key, ds_pooled);
}
/**
* 根据key字符串获取连接池
* @param key
* @return DBPool 连接池
* @throws Exception
*/
public DBPool getDBPool(String key) throws Exception{
if (key==null) throw new Exception("DBPool 'key' CANNOT be null") ;
DataSource ds = (DataSource)poollist.get(key);
DBPool dbpool = new DBPool();
dbpool.setDs_pooled(ds);
return dbpool;
}

}
///////////////////////////////////////////////////////////////

四、连接池的使用
通过DBPool来获取数据库连接 （jdbc connection）。
4.1 由DBPoolFactory工厂产生一个DBPool
4.2 同时，DBPoolFactory工厂根据传入的参数key向这个DBPool注入数据源
4.3 从DBPool产生线程内的Connection
///////////////////////////////////////////////////////////////
package com.paipaiestore.database.c3p0;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

public class DBPool {
/**
* 数据库连接。同一个线程使用同一个连接。
*/
protected static ThreadLocal connection = new ThreadLocal();
/**
* 数据源，需由DBPoolFactory工厂注入
*/
private DataSource ds_pooled;

/**
* 不能独立构造，必须从DBPoolFactory工厂产生
*/
protected DBPool(){}

/**
* get 数据源
* @return
*/
public DataSource getDs_pooled() {
return ds_pooled;
}

/**
* 注入数据源
* @param ds_pooled
*/
public void setDs_pooled(DataSource ds_pooled) {
this.ds_pooled = ds_pooled;
}

/**
* 获得数据库连接
* 同一个线程只返回相同的一个连接。
* @return Connection
* @throws SQLException
*/
public Connection getConnection() throws SQLException{
Connection con = (Connection)connection.get();
if (con==null) {
con = ds_pooled.getConnection();
connection.set(con);
}
return con;
}
}
///////////////////////////////////////////////////////////////

五、改进线程内数据库连接的使用
为了适应程序已经使用开的jdbc事务管理，因此需要改进DBPool成为Transaction类，
而原来的DBPool则缩减为如下代码：
///////////////////////////////////////////////////////////////
public class DBPool {
private DataSource ds_pooled;
protected DBPool(){}
public DataSource getDs_pooled() {
return ds_pooled;
}
public void setDs_pooled(DataSource ds_pooled) {
this.ds_pooled = ds_pooled;
}
}
///////////////////////////////////////////////////////////////
package com.paipaiestore.database.c3p0;

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

import javax.sql.DataSource;

public class Transaction {
/**
* 数据库连接。同一个线程使用同一个连接。
*/
protected static ThreadLocal connection = new ThreadLocal();
protected static boolean isInUsed = false;
/**
* 开始一个事务
* 如果当前线程的数据库连接不存在，则会新获得一个数据库连接
* @param key
* @throws Exception
*/
public static void beginTransaction(String key) throws Exception{
Connection conn = (Connection)connection.get();
if (conn==null) {
conn = createConnection(key);
setConnection(conn);
}
conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
conn.setAutoCommit(false);
isInUsed = true;
}
/**
* 提交一个事务
* @throws SQLException
*/
public static void commitTransaction() throws SQLException {
Connection conn = (Connection)connection.get();
mit();
}
/**
* 回滚一个事务
* @throws SQLException
*/
public static void rollbackTransaction() throws SQLException {
Connection conn = (Connection)connection.get();
conn.rollback();
}
public static boolean getIsInUsed() {
return isInUsed;
}
private static void closeConnection() {
try {
Connection conn = (Connection)connection.get();
if (conn!=null) {
connection.set(null);
conn.close();
}
}catch(SQLException sqlexception) {

}
}
private static void close(ResultSet rs){
try
{
Statement st = rs.getStatement();
Connection conn = st.getConnection();
rs.close();
st.close();
conn.close();
}
catch(Exception exception) { }
}
/**
* 获得数据库连接
* 同一个线程只返回相同的一个连接。
* @return
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
Connection conn = null;
conn = (Connection)connection.get();
if(conn == null)
throw new NullPointerException();
else
return conn;
}

private static void setConnection(Connection conn){
connection.set(conn);
}
/**
* 获得一个新的数据库连接
* @param key
* @return Connection
* @throws Exception
*/
private static Connection createConnection(String key)
throws Exception {
DBPoolFactory df = DBPoolFactory.getInstance();
DataSource ds_pooled = df.getDBPool(key).getDs_pooled() ;
Connection conn = ds_pooled.getConnection();
df = null;
return conn;
}
}
///////////////////////////////////////////////////////////////
六、测试
///////////////////////////////////////////////////////////////
package samland;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;

import com.paipaiestore.database.c3p0.DBPoolFactory;
import com.paipaiestore.database.c3p0.Transaction;

public class TestTransaction {

/**
* @param args
*/
public static void main(String[] args) {
DBPoolFactory df = DBPoolFactory.getInstance();

Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try {
df.add("jxc","com.mysql.jdbc.Driver","jdbc:mysql://

Transaction.beginTransaction("samland");
con = Transaction.getConnection();
stmt = con.createStatement();
rs = stmt.executeQuery("SELECT * FROM users");
while (rs.next())
{
System.out.print( rs.getString(1) );
System.out.print( rs.getString(2) );
System.out.println( rs.getString(3) );
}
TmitTransaction();
df = null;
} catch (Exception e) {
e.printStackTrace();
}
}
}