现在的位置: 首页 > 数据库 > 正文

c3p0数据库连接池的使用

2019年05月08日 ⁄ 数据库 ⁄ 共 4913字 ⁄ 字号 小 中 大 ⁄ 评论关闭

转自：http://blog.csdn.net/eclipser1987/article/details/5181320

据说c3p0数据库连接池是最优秀的，当然这也是我道听途说的，没有实际证实过。今天我抽空写了一个c3p0的例子，借此也总结一下。

一、jar包

老规矩，引用开源项目，自然要先下载人家的jar包，我这里有一个在云盘：c3p0-0.9.5-pre4.jar，这里面其实有三个包，是我在开源中国下载的最新的，如果你还想要更新的不妨自己到网上去搜一下。

二、配置文件

作为一个数据库连接池自然有很多参数要设置，当然就算你不设置也有默认的，不过那不一定能满足你的要求。这里的配置文件没有什么特别的要求，可以是xml也可以是properties甚至与txt都行，当然如果你愿意也可以写死在程序中。

下面是我的配置文件，我把它放在了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  
  6.   
  7. #c3p0连接池信息  
  8. c3p0.minPoolSize=3  
  9. c3p0.maxPoolSize=25  
  10.   
  11. #当连接池中的连接耗尽的时候c3p0一次同时获取的连接数  
  12. c3p0.acquireIncrement=3  
  13. #定义在从数据库获取新连接失败后重复尝试的次数  
  14. c3p0.acquireRetryAttempts=60  
  15. #两次连接中间隔时间，单位毫秒  
  16. c3p0.acquireRetryDelay=1000  
  17. #连接关闭时默认将所有未提交的操作回滚  
  18. c3p0.autoCommitOnClose=false  
  19. #当连接池用完时客户端调用getConnection()后等待获取新连接的时间，超时后将抛出SQLException,如设为0则无限期等待。单位毫秒  
  20. c3p0.checkoutTimeout=3000  
  21. #每120秒检查所有连接池中的空闲连接。Default: 0  
  22. c3p0.idleConnectionTestPeriod=120  
  23. #最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。Default: 0  
  24. c3p0.maxIdleTime=600  
  25. #如果设为true那么在取得连接的同时将校验连接的有效性。Default: false  
  26. c3p0.testConnectionOnCheckin=true  
  27. #c3p0将建一张名为c3p0TestTable的空表，并使用其自带的查询语句进行测试。  
  28. jdbc.automaticTestTable = c3p0TestTable  


配置文件中的内容我就不解释了，相信你看一眼就能很明白。

三、代码实现

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

DataSource unPooled = DataSources.unpooledDataSource(url,jdbcproperties);//这里的第二个参数放的是连接数据库的信息，包括user、password等信息

DataSource ds = DataSources.pooledDataSource(unPooled,c3propertis);//这里面的第二个参数放的是c3p0连接池的配置信息

Connection conn = ds.getConnection();

这三句代码相信大家很容易看明白，也是使用c3p0连接池的核心代码，真的很简单。

下面是我写的例子，仅供参考

[java] view
plaincopy

  1. package com.bks.db;  
  2.   
  3. import java.io.FileInputStream;  
  4. import java.sql.Connection;  
  5. import java.sql.SQLException;  
  6. import java.util.Properties;  
  7.   
  8. import javax.sql.DataSource;  
  9.   
  10. import com.mchange.v2.c3p0.DataSources;  
  11.   
  12. /** 
  13.  * c3p0连接池管理类 
  14.  * @author ICE 
  15.  * 
  16.  */  
  17. public class C3P0ConnentionProvider {  
  18.   
  19.     private static final String JDBC_DRIVER = "driverClass";  
  20.     private static final String JDBC_URL = "jdbcUrl";  
  21.       
  22.     private static DataSource ds;  
  23.     /** 
  24.      * 初始化连接池代码块 
  25.      */  
  26.     static{  
  27.         initDBSource();  
  28.     }  
  29.       
  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.         }   
  41.           
  42.         String drverClass = c3p0Pro.getProperty(JDBC_DRIVER);  
  43.         if(drverClass != null){  
  44.             try {  
  45.                 //加载驱动类  
  46.                 Class.forName(drverClass);  
  47.             } catch (ClassNotFoundException e) {  
  48.                 e.printStackTrace();  
  49.             }  
  50.               
  51.         }  
  52.           
  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.         }  
  63.           
  64.         try {  
  65.             //建立连接池  
  66.             DataSource unPooled = DataSources.unpooledDataSource(c3p0Pro.getProperty(JDBC_URL),jdbcpropes);  
  67.             ds = DataSources.pooledDataSource(unPooled,c3propes);  
  68.               
  69.         } catch (SQLException e) {  
  70.             e.printStackTrace();  
  71.         }  
  72.     }  
  73.       
  74.     /** 
  75.      * 获取数据库连接对象 
  76.      * @return 数据连接对象 
  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;  
  2.   
  3. import java.sql.Connection;  
  4. import java.sql.PreparedStatement;  
  5. import java.sql.ResultSet;  
  6. import java.sql.SQLException;  
  7.   
  8. import com.bks.db.C3P0ConnentionProvider;  
  9.   
  10. public class Demo {  
  11.   
  12.     public static void main(String[] args) {  
  13.         for(int i=0;i<30;i++){  
  14.             new Thread(new Demo2()).start();  
  15.         }  
  16.     }  
  17.   
  18. }  
  19.   
  20. class Demo2 implements Runnable{  
  21.       
  22.     public void run(){  
  23.         try {  
  24.             Connection conn = C3P0ConnentionProvider.getConnection();  
  25.             PreparedStatement pst = conn.prepareStatement("select to_char(sysdate,'hh24: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.             }  
  34.               
  35.         } catch (SQLException e) {  
  36.             e.printStackTrace();  
  37.         }  
  38.     }  
  39. }  
返回
【上篇】
【下篇】

作者:

抱歉!评论已关闭.

返回首页

Copyright © 2013-2018 学步园  保留所有权利.
软文销售 QQ客服：2265327166 点击这里给我发消息（其他合作也可洽谈）
必威体育
必威电竞