MySQL---第三方連線池---c3p0
阿新 • • 發佈：2018-12-11
需要jar包：c3p0-0.9.1.2.jar 還有最基本的 mysql-connector-java-5.1.35-bin.jar。
下面演示不使用配置檔案
@Test //技術入口: com.mchange.v2.c3p0.ComboPooledDataSource public void demo1() throws SQLException, PropertyVetoException { //下面這一句相當於建立了一個池 ComboPooledDataSource cpds = new ComboPooledDataSource(); //下面開始給這個池配置資訊。 cpds.setDriverClass("com.mysql.jdbc.Driver"); cpds.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8"); cpds.setUser("root"); cpds.setPassword("1234"); //接下來就可以獲取連線了,進行查詢了。 Connection con = cpds.getConnection(); Statement st = con.createStatement(); ResultSet resultSet = st.executeQuery("show databases"); while ( resultSet.next() ) { System.out.println( resultSet.getString(1) ); } System.out.println("------------------------------"); System.out.println( cpds.getMaxConnectionAge() ); System.out.println( cpds.getMaxIdleTime() ); System.out.println( cpds.getAcquireIncrement()); System.out.println( cpds.getAcquireRetryAttempts()); System.out.println( cpds.getAcquireRetryDelay()); System.out.println( cpds.getInitialPoolSize()); System.out.println( cpds.getThreadPoolSize()); System.out.println( cpds.getMaxPoolSize()); System.out.println( cpds.getMinPoolSize()); System.out.println(cpds.getThreadPoolNumActiveThreads()); }
使用配置檔案，該方式面向介面。配置檔案必須在src目錄下，而且名稱：c3p0-config.xml，c3p0寫死了！！！
配置檔案資訊：
<?xml version="1.0" encoding="UTF-8"?> <c3p0-config> <!-- 預設配置，如果沒有指定則使用這個配置 --> <default-config> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl"> <![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]> </property> <property name="user">root</property> <property name="password">1234</property> <!-- 初始化池大小 --> <property name="initialPoolSize">2</property> <!-- 最大空閒時間 --> <property name="maxIdleTime">30</property> <!-- 最多有多少個連線 --> <property name="maxPoolSize">10</property> <!-- 最少幾個連線 --> <property name="minPoolSize">2</property> <!-- 每次最多可以執行多少個批處理語句 --> <property name="maxStatements">50</property> </default-config> <!-- 命名的配置 --> <named-config name="hncu"> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl"> <![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]> </property> <property name="user">root</property> <property name="password">1234</property> <property name="acquireIncrement">5</property><!-- 如果池中資料連線不夠時一次增長多少個 --> <property name="initialPoolSize">100</property> <property name="minPoolSize">50</property> <property name="maxPoolSize">1000</property> <property name="maxStatements">0</property> <property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him --> </named-config> </c3p0-config>
演示程式碼：
@Test public void demo2() throws SQLException { //配置檔案必須在src目錄下，c3p0寫死了！！！ DataSource ds = new ComboPooledDataSource();//不帶引數時：使用的是<default-config>中的配置資訊 //DataSource cpds = new ComboPooledDataSource("hncu"); //帶引數時：使用的是配置檔案中 <named-config name="hncu">中的配置資訊 //接下來就可以獲取連線了,進行查詢了。 Connection con = ds.getConnection(); Statement st = con.createStatement(); ResultSet resultSet = st.executeQuery("show databases"); while ( resultSet.next() ) { System.out.println( resultSet.getString(1) ); } //強轉為檢視資訊 ComboPooledDataSource cpds = (ComboPooledDataSource) ds; System.out.println("------------------------------"); System.out.println( "MaxConnectionAge:"+cpds.getMaxConnectionAge() ); System.out.println( "MaxIdleTime:"+cpds.getMaxIdleTime() ); System.out.println( "AcquireIncrement:"+cpds.getAcquireIncrement()); System.out.println( "AcquireRetryAttempts:"+cpds.getAcquireRetryAttempts()); System.out.println( "AcquireRetryDelay:"+cpds.getAcquireRetryDelay()); System.out.println( "InitialPoolSize:"+cpds.getInitialPoolSize()); System.out.println( "ThreadPoolSize:"+cpds.getThreadPoolSize()); System.out.println( "MaxPoolSize:"+cpds.getMaxPoolSize()); System.out.println( "MinPoolSize:"+cpds.getMinPoolSize()); System.out.println( "ThreadPoolNumActiveThreads:"+cpds.getThreadPoolNumActiveThreads()); System.out.println("------------------------------"); for( int i = 0; i < 18; i++ ) { Connection con2 = ds.getConnection(); System.out.println(con2.hashCode()); System.out.println( "ThreadPoolNumActiveThreads:"+cpds.getThreadPoolNumActiveThreads()); if( i%2==0 ) { con2.close(); } } }
採用c3p0連線池+ThreadLocal製作一個工具類：實現一個執行緒最多隻能有一個連線。
工具類
package cn.hncu.dbPool.c3p0;
import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;
/**
*   c3p0工具<br/>
*   <b>注意</b>：必須在src下面有一個配置檔案：c3p0-config.xml，名稱和路徑都是寫死的！！！
* <br/><br/><b>CreateTime:</b><br/>   2018年9月23日 下午2:11:12
* @author 宋進宇 <a href='mailto:[email protected]'>[email protected]</a>
*/
public class C3p0Utils {
//資料庫連線池
private static DataSource ds;
//執行緒區域性變數池
private static ThreadLocal<Connection> tlPool = new ThreadLocal<Connection>();
//初始化資料庫連線池
static {
//注意：必須在src下面有一個配置檔案：c3p0-config.xml，名稱和路徑都是寫死的！！！
ds = new ComboPooledDataSource();
}
/**
* 獲得c3p0連線池
* @return c3p0連線池物件
*/
public static DataSource getDataSource() {
return ds;
}
/**
* 獲取一個數據庫連線
* @return 資料庫連線物件
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
//先從執行緒區域性變數池中獲取當前執行緒擁有資料庫連線
Connection con = tlPool.get();
//如果當前執行緒擁有的資料庫連線為null或者是closed狀態,那麼從連線池中獲取一個連線
if( con == null || con.isClosed() ) {
//從連線池中獲取一個連線
con = ds.getConnection();
//把獲取到的連線放到執行緒區域性變數池中，以便同一個執行緒共享一個數據庫連線。
tlPool.set(con);
}
return con;
}
}
詳細的配置檔案資訊
<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>
<property name="automaticTestTable">con_test</property>
<property name="checkoutTimeout">30000</property>
<property name="idleConnectionTestPeriod">30</property>
<property name="initialPoolSize">10</property>
<property name="maxIdleTime">30</property>
<property name="maxPoolSize">25</property>
<property name="minPoolSize">10</property>
<property name="maxStatements">0</property>
<user-overrides user="swaldman">
</user-overrides>
</default-config>
<named-config name="dumbTestConfig">
<property name="maxStatements">200</property>
<user-overrides user="poop">
<property name="maxStatements">300</property>
</user-overrides>
</named-config>
</c3p0-config>