c3p0數(shù)據(jù)庫連接池如何使用

這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)c3p0數(shù)據(jù)庫連接池如何使用，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于做網(wǎng)站、網(wǎng)站設(shè)計、軹城網(wǎng)絡(luò)推廣、小程序開發(fā)、軹城網(wǎng)絡(luò)營銷、軹城企業(yè)策劃、軹城品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務(wù)，您的肯定，是我們最大的嘉獎；創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供軹城建站搭建服務(wù)，24小時服務(wù)熱線：13518219792，官方網(wǎng)址：bm7419.com

一、jar包

引用開源項目，自然要先下載人家的jar包，我這里有一個在云盤：c3p0-0.9.5-pre4.jar，這里面其實有三個包，是我在開源中國下載的最新的，如果你還想要更新的不妨自己到網(wǎng)上去搜一下。

二、配置文件

作為一個數(shù)據(jù)庫連接池自然有很多參數(shù)要設(shè)置，當(dāng)然就算你不設(shè)置也有默認的，不過那不一定能滿足你的要求。這里的配置文件沒有什么特別的要求，可以是xml也可以是properties甚至與txt都行，當(dāng)然如果你愿意也可以寫死在程序中。

下面是我的配置文件，我把它放在了src目錄下，名字叫“c3p0.properties”

[java] view
plaincopy

  1. #jdbc基本信息  

  2. driverClass=oracle.jdbc.driver.OracleDriver  

  3. jdbcUrl=jdbc:oracle:thin:@127.0.0.1:1521/orcl  

  4. user=bctts  

  5. password=bctts123  

  7. #c3p0連接池信息  

  8. c3p0.minPoolSize=3

  9. c3p0.maxPoolSize=25

  11. #當(dāng)連接池中的連接耗盡的時候c3p0一次同時獲取的連接數(shù)  

  12. c3p0.acquireIncrement=3

  13. #定義在從數(shù)據(jù)庫獲取新連接失敗后重復(fù)嘗試的次數(shù)  

  14. c3p0.acquireRetryAttempts=60

  15. #兩次連接中間隔時間，單位毫秒  

  16. c3p0.acquireRetryDelay=1000

  17. #連接關(guān)閉時默認將所有未提交的操作回滾  

  18. c3p0.autoCommitOnClose=false

  19. #當(dāng)連接池用完時客戶端調(diào)用getConnection()后等待獲取新連接的時間，超時后將拋出SQLException,如設(shè)為0則無限期等待。單位毫秒  

  20. c3p0.checkoutTimeout=3000

  21. #每120秒檢查所有連接池中的空閑連接。Default: 0

  22. c3p0.idleConnectionTestPeriod=120

  23. #最大空閑時間,60秒內(nèi)未使用則連接被丟棄。若為0則永不丟棄。Default: 0

  24. c3p0.maxIdleTime=600

  25. #如果設(shè)為true那么在取得連接的同時將校驗連接的有效性。Default: false

  26. c3p0.testConnectionOnCheckin=true

  27. #c3p0將建一張名為c3p0TestTable的空表，并使用其自帶的查詢語句進行測試。  

  28. jdbc.automaticTestTable = c3p0TestTable  


配置文件中的內(nèi)容我就不解釋了，相信你看一眼就能很明白。

三、代碼實現(xiàn)

c3p0的使用非常簡單，基本上就是三步搞定。

DataSource unPooled = DataSources.unpooledDataSource(url,jdbcproperties);//這里的第二個參數(shù)放的是連接數(shù)據(jù)庫的信息，包括user、password等信息

DataSource ds = DataSources.pooledDataSource(unPooled,c3propertis);//這里面的第二個參數(shù)放的是c3p0連接池的配置信息

Connection conn = ds.getConnection();

這三句代碼相信大家很容易看明白，也是使用c3p0連接池的核心代碼，真的很簡單。

下面是我寫的例子，僅供參考

[java] view
plaincopy

  1. package com.bks.db;  

  3. import java.io.FileInputStream;  

  4. import java.sql.Connection;  

  5. import java.sql.SQLException;  

  6. import java.util.Properties;  

  8. import javax.sql.DataSource;  

  10. import com.mchange.v2.c3p0.DataSources;  

  12. /**

  13.  * c3p0連接池管理類

  14.  * @author ICE

  15.  *

  16.  */

  17. public class C3P0ConnentionProvider {  

  19.     private static final String JDBC_DRIVER = "driverClass";  

  20.     private static final String JDBC_URL = "jdbcUrl";  

  22.     private static DataSource ds;  

  23.     /**

  24.      * 初始化連接池代碼塊

  25.      */

  26.     static{  

  27.         initDBSource();  

  28.     }  

  30.     /**

  31.      * 初始化c3p0連接池

  32.      */

  33.     private static final void initDBSource(){  

  34.         Properties c3p0Pro = new Properties();  

  35.         try {  

  36.             //加載配置文件

  37.             c3p0Pro.load(new FileInputStream("./bin/c3p0.properties"));  

  38.         } catch (Exception e) {  

  39.             e.printStackTrace();  

  40.         }   

  42.         String drverClass = c3p0Pro.getProperty(JDBC_DRIVER);  

  43.         if(drverClass != null){  

  44.             try {  

  45.                 //加載驅(qū)動類

  46.                 Class.forName(drverClass);  

  47.             } catch (ClassNotFoundException e) {  

  48.                 e.printStackTrace();  

  49.             }  

  51.         }  

  53.         Properties jdbcpropes = new Properties();  

  54.         Properties c3propes = new Properties();  

  55.         for(Object key:c3p0Pro.keySet()){  

  56.             String skey = (String)key;  

  57.             if(skey.startsWith("c3p0.")){  

  58.                 c3propes.put(skey, c3p0Pro.getProperty(skey));  

  59.             }else{  

  60.                 jdbcpropes.put(skey, c3p0Pro.getProperty(skey));  

  61.             }  

  62.         }  

  64.         try {  

  65.             //建立連接池

  66.             DataSource unPooled = DataSources.unpooledDataSource(c3p0Pro.getProperty(JDBC_URL),jdbcpropes);  

  67.             ds = DataSources.pooledDataSource(unPooled,c3propes);  

  69.         } catch (SQLException e) {  

  70.             e.printStackTrace();  

  71.         }  

  72.     }  

  74.     /**

  75.      * 獲取數(shù)據(jù)庫連接對象

  76.      * @return 數(shù)據(jù)連接對象

  77.      * @throws SQLException 

  78.      */

  79.     public static synchronized Connection getConnection() throws SQLException{  

  80.         final Connection conn = ds.getConnection();  

  81.         conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);  

  82.         return conn;  

  83.     }  

  84. }  


下面這個是測試的例子

[java] view
plaincopy

  1. package test.demo;  

  3. import java.sql.Connection;  

  4. import java.sql.PreparedStatement;  

  5. import java.sql.ResultSet;  

  6. import java.sql.SQLException;  

  8. import com.bks.db.C3P0ConnentionProvider;  

  10. public class Demo {  

  12.     public static void main(String[] args) {  

  13.         for(int i=0;i<30;i++){  

  14.             new Thread(new Demo2()).start();  

  15.         }  

  16.     }  

  18. }  

  20. class Demo2 implements Runnable{  

  22.     public void run(){  

  23.         try {  

  24.             Connection conn = C3P0ConnentionProvider.getConnection();  

  25.             PreparedStatement pst = conn.prepareStatement("select to_char(sysdate,'hh34:mm:ss') tim from dual");  

  26.             ResultSet rs = pst.executeQuery();  

  27.             rs.next();  

  28.             System.out.println(Thread.currentThread().getName()+":"+rs.getString(1));  

  29.             try {  

  30.                 Thread.sleep(10*1000);  

  31.             } catch (InterruptedException e) {  

  32.                 e.printStackTrace();  

  33.             }  

  35.         } catch (SQLException e) {  

  36.             e.printStackTrace();  

  37.         }  

  38.     }  

  39. }  

上述就是小編為大家分享的c3p0數(shù)據(jù)庫連接池如何使用了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

分享標(biāo)題：c3p0數(shù)據(jù)庫連接池如何使用
當(dāng)前網(wǎng)址：http://bm7419.com/article26/jcicjg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供關(guān)鍵詞優(yōu)化、企業(yè)建站、定制網(wǎng)站、網(wǎng)站排名、Google、網(wǎng)站營銷

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

成都網(wǎng)站建設(shè)公司