c3p0連接池配置

1、3301000falseTestfalse100nullfalse60360151003rootpasswordselect id from test where id=1300falsetruerootfalseacquireIncrement - 5 acquireRetryAttempts - 30 acquireRetryDelay - 1000 autoCommitOnClose - false automaticTestTable - null breakAfterAcquireFailure - true checkoutTimeout - 0 connectionCustomi

2、zerClassName - null connectionTesterClassName - com.mchange.v2.c3p0.impl.DefaultConnectionTester dataSourceName - 1bqp8hc8ezqxpjc1hp9gny|704baa debugUnreturnedConnectionStackTraces - false description - null driverClass - com.mysql.jdbc.Driver factoryClassLocation - null forceIgnoreUnresolvedTransac

3、tions - 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 -

4、 60 maxIdleTimeExcessConnections - 0 maxPoolSize - 30 maxStatements - 0 maxStatementsPerConnection - 0 minPoolSize - 5 numHelperThreads - 3 numThreadsAwaitingCheckoutDefaultUser - 0 preferredTestQuery - null properties - user=*password=* propertyCycle - 0 testConnectionOnCheckin - false testConnecti

5、onOnCheckout - false unreturnedConnectionTimeout - 0 usesTraditionalReflectiveProxies - falsepackage 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;/* 數(shù)據(jù)連接池

6、工廠* 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）數(shù)據(jù)

7、源* param key* param configFile 配置文件名。為了簡化參數(shù)輸入與便于外部維護，可以把配置好的文件傳入這里分析*/public void add(String key, String configFile) /read config from file, and build a dbpool/* 向連接池列表添加一個新的池化（Pooled）數(shù)據(jù)源* param key* param driver 數(shù)據(jù)連接驅(qū)動，如com.mysql.jdbc.Driver* param url 連接串， 如jdbc:mysql:/localhost/samland* param use

8、rname 數(shù)據(jù)庫連接用戶名，如samland* param password 數(shù)據(jù)庫連接用戶密碼* throws Exception*/public void add(String key, String driver, String url, String username, String password)throws Exceptionif (key=null) throw new Exception(DBPool key CANNOT be null) ;Class.forName(driver);DataSource ds_unpooled = DataSources.unpool

9、edDataSource(url, username, password);DataSource ds_pooled = DataSources.pooledDataSource( ds_unpooled );if (poollist.containsKey(key)poollist.remove(key);poollist.put(key, ds_pooled);/* 根據(jù)key字符串獲取連接池* param key* return DBPool 連接池* throws Exception*/public DBPool getDBPool(String key) throws Excepti

10、onif (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來獲取數(shù)據(jù)庫連接 （jdbc connection）。4.1 由DBPoolFactory工廠產(chǎn)生一個DBPool4.2 同時，DBPoolFactory工廠根據(jù)傳入的參數(shù)key向這個DBPool注入數(shù)據(jù)源4.3

11、 從DBPool產(chǎn)生線程內(nèi)的Connection/package com.paipaiestore.database.c3p0;import java.sql.Connection;import java.sql.SQLException;import javax.sql.DataSource;public class DBPool /* 數(shù)據(jù)庫連接。同一個線程使用同一個連接。*/protected static ThreadLocal connection = new ThreadLocal();/* 數(shù)據(jù)源，需由DBPoolFactory工廠注入*/private DataSource d

12、s_pooled;/* 不能獨立構造，必須從DBPoolFactory工廠產(chǎn)生*/protected DBPool()/* get 數(shù)據(jù)源* return*/public DataSource getDs_pooled() return ds_pooled;/* 注入數(shù)據(jù)源* param ds_pooled*/public void setDs_pooled(DataSource ds_pooled) this.ds_pooled = ds_pooled;/* 獲得數(shù)據(jù)庫連接* 同一個線程只返回相同的一個連接。* return Connection* throws SQLException*/

13、public Connection getConnection() throws SQLExceptionConnection con = (Connection)connection.get();if (con=null) con = ds_pooled.getConnection();connection.set(con);return con;/五、改進線程內(nèi)數(shù)據(jù)庫連接的使用為了適應程序已經(jīng)使用開的jdbc事務管理，因此需要改進DBPool成為Transaction類，而原來的DBPool則縮減為如下代碼：/public class DBPool private DataSource d

14、s_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;i

15、mport javax.sql.DataSource;public class Transaction /* 數(shù)據(jù)庫連接。同一個線程使用同一個連接。*/protected static ThreadLocal connection = new ThreadLocal();protected static boolean isInUsed = false;/* 開始一個事務* 如果當前線程的數(shù)據(jù)庫連接不存在，則會新獲得一個數(shù)據(jù)庫連接* param key* throws Exception*/public static void beginTransaction(String key) thro

16、ws ExceptionConnection 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 commitTransactio

17、n() 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

18、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)tryStatement st = rs.getStatement();Connection conn = st.getConnection();rs.close();st.close();conn.clos

19、e();catch(Exception exception) /* 獲得數(shù)據(jù)庫連接* 同一個線程只返回相同的一個連接。* return* throws SQLException*/public static Connection getConnection() throws SQLException Connection conn = null;conn = (Connection)connection.get();if(conn = null)throw new NullPointerException();elsereturn conn;private static void setCon

20、nection(Connection conn)connection.set(conn);/* 獲得一個新的數(shù)據(jù)庫連接* 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;