时间：2021-07-01 10:21:17 帮助过：23人阅读
C3P0由三部分内容组成。实例化对象，各配置项的含义，以及加载配置项的方式。
实例化对象的方式有三种，第一种方式直接new ComboPooledDataSource，第二种方式使用工厂类DataSources.poolDataSource方法。第三种不常见。第一种方式是最方便的方式。
C3P0的配置项主要有：
配置项常见的加载方式有三种：
1 // 创建实例，dataSourceName指定数据源的名称 2 ComboPooledDataSource dataSource = new ComboPooledDataSource(dataSourceName); 3 // 设置数据库url 4 dataSource.setJdbcUrl("jdbc:oracle:thin:@localhost:1521:masteroracle"); 5 // 设置数据库驱动类 6 dataSource.setDriverClass("oracle.jdbc.driver.OracleDriver"); 7 // 设置用户名 8 dataSource.setUser("system"); 9 // 设置密码 10 dataSource.setPassword("password"); 11 Connection conn = dataSource.getConnection(); 12 runSQLTest(conn);
1 // 创建unpooled的数据源 2 DataSource ds_unpooled = DataSources.unpooledDataSource(jdbcUrl, user, password); 3 // pooled数据源的参数 4 Map<String,String> paramMap = new HashMap<>(); 5 DataSource pooled = DataSources.pooledDataSource(ds_unpooled,paramMap); 6 Connection conn = pooled.getConnection(); 7 runSQLTest(conn); 8 conn.close(); 9 DataSources.destroy(pooled); 10 return pooled;
C3P0各配置项的前缀为c3p0。如果指定dataSourceName，前缀为c3p0.named-configs.dataSourceName。如果存在多个用户，用户可以覆盖默认的配置项，前缀为c3p0.user-overrides.user。
Java代码方式
1 /** -----------------------配置数据源----------------------------- **/ 2 /** 3 * 配置数据源 4 * 5 * @param dataSource 6 * @return 7 * @throws PropertyVetoException 8 */ 9 public static ComboPooledDataSource configDataSource(ComboPooledDataSource dataSource) 10 throws PropertyVetoException { 11 // 连接数据库的必要属性 12 connDatabaseConfig(dataSource,"masterOracle"); 13 // 连接池的相关配置 14 connPoolConfig(dataSource); 15 // 连接对象的生命周期配置 16 connAgeConfig(dataSource); 17 // 测试连接的配置 18 connTestConfig(dataSource); 19 // statement对象的配置 20 statementConfig(dataSource); 21 // 重连配置 22 reconnConfig(dataSource); 23 // 连接的监听类配置 24 connListenerConfig(dataSource); 25 // 事务的配置 26 tranConfig(dataSource); 27 // 调试模式 28 debugMode(dataSource); 29 // 线程配置 30 threadConfig(dataSource); 31 return dataSource; 32 }
C3P0.properties的方式
##-------------------------------数据库连接属性-----------------------------------## # 驱动类名称 c3p0.driverClass=oracle.jdbc.driver.OracleDriver # 数据库实例url地址 c3p0.jdbcUrl=jdbc:oracle:thin:@localhost:1521:masteroracle # 用户名 c3p0.user=system # 密码 c3p0.password=password
代码方式
1 // 设置数据库url 2 dataSource.setJdbcUrl(jdbcUrl); 3 // 设置数据库驱动类 4 dataSource.setDriverClass(driverClassName); 5 // 设置用户名 6 dataSource.setUser(user); 7 // 设置密码 8 dataSource.setPassword(password); 9 // 输出dataSourceName，在初始化ComboPooledDataSource时，字符串参数作为数据源名称, 10 dataSource.getDataSourceName();View Code
C3P0.properties的方式
##-------------------------------连接池配置-------------------------------------## # 连接池拥有连接对象的初始值，这种情形下只是Acquire(需求)的初始值，真正创建对象会根据Acquire来按需创建 c3p0.initialPoolSize=10 # 连接池拥有连接对象的最大值,默认值为3 c3p0.maxPoolSize=20 # 连接池拥有连接对象的最小值，默认值为3 c3p0.minPoolSize=5 # 当无空闲连接时,新创建的连接数，默认值为3 c3p0.acquireIncrement=3
代码方式
1 /** 2 * 连接池的配置 initialPoolSize:连接池的初始值 maxPoolSize:连接池的最大值 minPoolSize:连接池的最小值 3 * 4 * @param dataSource 5 */ 6 private static void connPoolConfig(ComboPooledDataSource dataSource) { 7 // 连接池的初始值，默认值为3 8 dataSource.setInitialPoolSize(10); 9 // 连接池的最大值,默认值为0 10 dataSource.setMaxPoolSize(20); 11 // 连接池的最小值，最小值为3 12 dataSource.setMinPoolSize(1); 13 // 连接池的递增值,默认值为3 14 dataSource.setAcquireIncrement(5); 15 }View Code
C3P0.proerties的方式
##-------------------------------连接池中连接对象的生命周期--------------------------## # 连接对象的最大生存时间，起始时间从连接池从数据库中创建连接对象开始计算。0表示永远不销毁 c3p0.maxConnectionAge=0 # 空闲连接对象的超时时间，起始时间从连接对象状态变为空闲时起计算。 c3p0.maxIdleTime=1800 # 当连接池不处于满载状态时,空闲连接对象的最大生存时间，设置此值，可以快速的减少连接池的大小 c3p0.maxIdleTimeExcessConnections=60 # 连接对象回收的超时时间，当连接池无法在一定时间内回收连接对象时，销毁旧对象，重新创建新对象 c3p0.unreturnedConnectionTimeout=600
代码方式
/**
* 连接池生命周期配置,连接池首先从数据库中获取连接，用户请求时从连接池中获取连接。默认值为0，表示永不过期。 maxConnectionAge:
* 连接对象生命的最大值，超过此时间，连接池会销毁连接对象，连接池变小。单位为秒，建议设置1800或更多 maxIdleTime:
* 空闲连接在连接池中的超时时间，超过此时间，连接池将会销毁连接对象。单位为秒，建议设置1800或更多
* maxIdleTimeExcessConnections：当连接池不处于过载状态时，空闲连接对象生命的最大值。
* unreturnedConnectionTimeout:当连接对象在一定时间内无法回收，则创建新连接对象，销毁旧连接对象
*
* @param dataSource
*/
private static void connAgeConfig(ComboPooledDataSource dataSource) {
// 连接对象生命的最大值,它指绝对时间。从创建开始时计算,默认值为0
dataSource.setMaxConnectionAge(10 * 60 * 60);
// 空闲连接的超时时间，从连接池变为空闲状态开始计算
dataSource.setMaxIdleTime(1800);
// 空闲连接对象生命的最大值
dataSource.setMaxIdleTimeExcessConnections(60);
// 连接对象的最大使用时间,设置为2小时
dataSource.setUnreturnedConnectionTimeout(2 * 60 * 60);
}
View Code
C3P0.properties的方式
##-------------------------------测试连接配置项----------------------------------## # 从连接池中获取连接对象时进行连接测试 c3p0.testConnectionOnCheckout=true # 从连接池回收对象时进行连接测试 c3p0.testConnectionOnCheckin=true # 连接测试的间隔，在这一段时间内不进行连接测试 c3p0.idleConnectionTestPeriod=60 # 连接测试时使用的类，设置此值时忽略preferredTestQuery，automaticTestTable等属性值 #c3p0.connectionTesterClassName=com.rain.Tester.ConnectionTesterSample # 测试的SQL语句 c3p0.preferredTestQuery=select 1 # 连接测试时使用的数据库表 c3p0.automaticTestTable=test
代码方式
/** * 连接测试配置。 automaticTestTable:测试连接时使用的数据库表 ,默认值为null。connectionTesterClassName:测试连接时使用的类名称 * idleConnectionTestPeriod:测试连接间隔时间。在此段时间内不进行连接测试。 preferredTestQuery:连接测试使用的SQL语句。默认语句为select * 1 from dual。 testConnectionOnCheckin:从连接池回收连接对象时测试连接。默认值为false * testConnectionOnCheckOut:从连接池取出连接对象时测试连接。默认值为false。 * forceSynchronousCheckins:连接池回收连接对象时是同步，还是异步，默认是异步。默认值为false * * @param dataSource * @throws PropertyVetoException */ private static void connTestConfig(ComboPooledDataSource dataSource) throws PropertyVetoException { // 连接测试使用的数据库表,默认值为Null dataSource.setAutomaticTestTable("dual"); // 连接测试使用的SQL语句，默认使用Connection对象的isAlive方法，所以一般不设置此值，默认值为null dataSource.setPreferredTestQuery("select 1"); // 从连接池取出连接时测试连接，默认值为false dataSource.setTestConnectionOnCheckout(true); // 从连接池回收连接时测试连接，默认值为false。 dataSource.setTestConnectionOnCheckin(true); // 测试连接的间隔时间，默认值为0 dataSource.setIdleConnectionTestPeriod(60); // 测试连接使用的类名称 dataSource.setConnectionTesterClassName("com.rain.Tester.ConnectionTesterSample"); }View Code
C3P0.properties
##-------------------------------重新连接---------------------------------------## # 重新连接的次数 c3p0.acquireRetryAttempts=5 # 重新连接的时间间隔，单位为毫秒 c3p0.acquireRetryDelay=3000 # 等待连接响应的超时时间 c3p0.checkoutTimeout=120 # 当连接失败时,是否销毁数据源对象，true表示是,false表示否 c3p0.breakAfterAcquireFailure=true
代码方式
/**
* 当连接失败后，重新连接的配置。 acquireRetryAttempts:重连的次数。 acquireRetryDelay:重连的时间间隔。单位为毫秒
* breakAfterAcquireFailure:重连失败后，如果此值设置为false,数据源对象不会销毁，设置为false。数据源被销毁。
* checkoutTimeout:等待连接响应的时间。
*/
private static void reconnConfig(ComboPooledDataSource dataSource) {
// 设置重连次数为3，默认值为30
dataSource.setAcquireRetryAttempts(3);
// 设置重连的时间间隔为2秒，默认值为1000
dataSource.setAcquireRetryDelay(2000);
// 等待连接响应的超时时间。默认值为0表示永远不超时
dataSource.setCheckoutTimeout(4);
// 重连失败后，销毁数据源。默认值为false
dataSource.setBreakAfterAcquireFailure(true);
}
View Code
C3P0.properties的方式
##-------------------------------statement对象相关配置---------------------------## # c3p0拥有的PreparedStatement对象的总数 c3p0.maxStatements=100 # 每个连接拥有PreparedStament对象的数量 c3p0.maxStatementsPerConnection=10 # 当Connection对象关闭时，启动额外线程确保statement对象关闭 # This parameter should only be set if you observe that attempts by c3p0 to close() cached #statements freeze statementCacheNumDeferredCloseThreads=1
代码方式
1 /** 2 * 连接池中PreparedStatement对象的配置 PreparedStatement对象的配置。 maxStatements:连接池拥有PreparedStatement对象的总数。 3 * maxStatementsPerConnections:每个连接拥有PreparedStatement对象的数目。 4 * 5 * @param dataSource 6 */ 7 private static void statementConfig(ComboPooledDataSource dataSource) { 8 // 设置PreparedStatement对象的总数，默认值为0，表示关闭 9 dataSource.setMaxStatements(100); 10 // 设置每个连接拥有Statement对象的数目，默认值为0，表示关闭。 11 dataSource.setMaxStatementsPerConnection(15); 12 }View Code
C3P0.properties的方式
##-------------------------------线程池----------------------------------------## # 连接池拥有的线程数量 c3p0.numHelperThreads=5 # 线程执行的最大时间 c3p0.maxAdministrativeTaskTime=600 # 启动独立的线程来在连接被连接池回收阶段进行测试 forceSynchronousCheckins=true
代码方式
1 /** 2 * 连接池的线程设置 numHelperThread:连接池拥有的线程数量 maxAdministrativeTaskTime:线程执行的超时时间。 3 * 4 * @param dataSource 5 */ 6 private static void threadConfig(ComboPooledDataSource dataSource) { 7 // 设置线程数量为10，默认值为3 8 dataSource.setNumHelperThreads(10); 9 // 设置线程的超时时间，默认值为0，设置为5分钟 10 dataSource.setMaxAdministrativeTaskTime(5 * 60); 11 }View Code
C3P0.properties的方式
##-------------------------------事务-----------------------------------------## # 交给Spring去管理事务，默认不配置这些项 # 连接关闭时，是否自动提交事务 c3p0.autoCommitOnClose=false # 连接回收时，是否强制提交或者回滚当前连接拥有的事务，默认不配置。 c3p0.forceIgnoreUnresolvedTransactions=false
代码方式
1 /** 2 * 连接对象的事务配置 autoCommitOnClose：是否自动提交事务，true为是，false为否，默认为否 forceIgnoreUnresolvedTransactions 3 * 回收连接时，是否强制回滚或提交事务，默认为false。一般不设置此值， 例如由Spring来管理事务 4 * 5 * @param dataSource 6 */ 7 private static void tranConfig(ComboPooledDataSource dataSource) { 8 // 关闭自动提交事务，默认值为false 9 dataSource.setAutoCommitOnClose(false); 10 // 回收连接时，是否强制回滚或提交事务，设置为false。 11 dataSource.setForceIgnoreUnresolvedTransactions(false); 12 13 }View Code
C3P0.properties的方式
##-------------------------------调试模式--------------------------------------## # 当从连接池获取连接对象时，打印所有信息。 c3p0.debugUnreturnedConnectionStackTraces=true
代码方式
1 /** 2 * 调试模式的设置 debugUnreturnedConnectionStackTraces:从连接池获取连接对象时，打印所有信息 3 4 * 5 * @param dataSource 6 */ 7 private static void debugMode(ComboPooledDataSource dataSource) { 8 // 从连接池获取连接对象时，打印所有信息 9 dataSource.setDebugUnreturnedConnectionStackTraces(true); 10 }View Code
connectionCustomizerClassName：监听类的名称，监听类继承自AbstractConnectionCustomizer，监听类有四个方法
C3P0.properties的方式
##-------------------------------监听类---------------------------------------## c3p0.connectionCustomizerClassName=com.rain.Tester.ConnCustomrizerSample
代码方式
1 /** 2 * 设置连接对象的监听类,该类有四个方法 onAcquire:表示当连接池从数据库中获得连接时 onDestory:表示当连接池销毁连接对象时 onCheckOut:从连接池中获取连接对象时 3 * onCheckIn:连接池回收连接对象时。 4 */ 5 private static void connListenerConfig(ComboPooledDataSource dataSource) { 6 // 设置连接对象的监听类 7 dataSource.setConnectionCustomizerClassName("com.rain.Tester.ConnCustomrizerSample"); 8 }View Code
C3P0.properties的方式
##-------------------------------日志配置--------------------------------------## # 日志的实现方式 com.mchange.v2.log.MLog=log4j # 日志的级别,OFF,SERVER,WARNING,INFO,FINE,FINER,FINEST,ALL com.mchange.v2.log.FallbackMLog.DEFAULT_CUTOFF_LEVEL=All # 日志按包输出 com.mchange.v2.log.NameTransformer=com.mchange.v2.log.PackageNames # determine the class and method from which a log message was generated，当为true时，不打印这些日志信息 com.mchange.v2.log.jdk14logging.suppressStackWalk=true
代码方式：通过new实例化dataSource，调用setXX方法。
1 package com.rain.core; 2 3 import java.beans.PropertyVetoException; 4 import java.io.IOException; 5 import java.sql.Connection; 6 import java.sql.ResultSet; 7 import java.sql.SQLException; 8 import java.sql.Statement; 9 import java.util.HashMap; 10 import java.util.Map; 11 import javax.sql.DataSource; 12 import com.mchange.v2.c3p0.ComboPooledDataSource; 13 import com.mchange.v2.c3p0.DataSources; 14 15 public class C3P0DataSourceSample { 16 private static final String masterOraclejdbcUrl = 17 "jdbc:oracle:thin:@localhost:1521:masteroracle"; 18 private static final String orclJdbcUrl = "jdbc:oracle:thin:@localhost:1521:orcl"; 19 private static final String driverClassName = "oracle.jdbc.driver.OracleDriver"; 20 private static final String user = "system"; 21 private static final String password = "password"; 22 23 public static void main(String[] args) throws Exception { 24 // 创建数据源对象 25 ComboPooledDataSource dataSource = createByInitInstance(); 26 // 配置数据源 27 // configDataSource(dataSource); 28 // 打印数据源信息 29 printDataSourceInfo(dataSource); 30 // 运行测试用例 31 runSQLTest(dataSource); 32 } 33 34 /** -------------------------创建数据源------------------------- **/ 35 /** 36 * 通过实例化的方式来获取数据源 37 * 38 * @return 39 * @throws PropertyVetoException 40 * @throws SQLException 41 */ 42 public static ComboPooledDataSource createByInitInstance() 43 throws PropertyVetoException, SQLException { 44 // 创建实例 45 ComboPooledDataSource dataSource = new ComboPooledDataSource(""); 46 // 连接时配置 47 // dataSource = connDatabaseConfig(dataSource, "masterOracle"); 48 return dataSource; 49 } 50 51 /** 52 * 创建多个数据源，每个数据源通过名字区分 53 * 54 * @return 55 * @throws IOException 56 * @throws SQLException 57 * @throws PropertyVetoException 58 */ 59 public static ComboPooledDataSource createMultiDataSource() 60 throws IOException, SQLException, PropertyVetoException { 61 // 创建数据库实例masterOracle 62 ComboPooledDataSource masterOracleDataSource = new ComboPooledDataSource("masterOracle"); 63 // 连接时配置masterOracle数据源 64 masterOracleDataSource = connDatabaseConfig(masterOracleDataSource, "masterOracle"); 65 // 创建数据库实例orcl 66 ComboPooledDataSource orclDataSource = new ComboPooledDataSource("orcl"); 67 // 连接时配置orcl数据源 68 orclDataSource = connDatabaseConfig(orclDataSource, "orcl"); 69 // 执行测试语句 70 runSQLTest(masterOracleDataSource); 71 // 执行测试语句 72 runSQLTest(orclDataSource); 73 return masterOracleDataSource; 74 } 75 76 /** 77 * 通过DataSources工厂方式建立连接 78 * 79 * @return 80 * @throws SQLException 81 */ 82 public static DataSource createByFactory() throws SQLException { 83 // 创建unpooled的数据源 84 DataSource ds_unpooled = 85 DataSources.unpooledDataSource(masterOraclejdbcUrl, user, password); 86 // pooled数据源的参数 87 Map<String, String> paramMap = new HashMap<>(); 88 ComboPooledDataSource pooled = 89 (ComboPooledDataSource) DataSources.pooledDataSource(ds_unpooled, paramMap); 90 runSQLTest(pooled); 91 pooled.close(); 92 DataSources.destroy(pooled); 93 return pooled; 94 } 95 96 /** -----------------------配置数据源----------------------------- **/ 97 /** 98 * 配置数据源 99 * 100 * @param dataSource 101 * @return 102 * @throws PropertyVetoException 103 */ 104 public static ComboPooledDataSource configDataSource(ComboPooledDataSource dataSource) 105 throws PropertyVetoException { 106 // 连接数据库的必要属性 107 connDatabaseConfig(dataSource,"masterOracle"); 108 // 连接池的相关配置 109 connPoolConfig(dataSource); 110 // 连接对象的生命周期配置 111 connAgeConfig(dataSource); 112 // 测试连接的配置 113 connTestConfig(dataSource); 114 // statement对象的配置 115 statementConfig(dataSource); 116 // 重连配置 117 reconnConfig(dataSource); 118 // 连接的监听类配置 119 connListenerConfig(dataSource); 120 // 事务的配置 121 tranConfig(dataSource); 122 // 调试模式 123 debugMode(dataSource); 124 // 线程配置 125 threadConfig(dataSource); 126 return dataSource; 127 } 128 129 130 131 /** 132 * 连接池的配置 initialPoolSize:连接池的初始值 maxPoolSize:连接池的最大值 minPoolSize:连接池的最小值 133 * 134 * @param dataSource 135 */ 136 private static void connPoolConfig(ComboPooledDataSource dataSource) { 137 // 连接池的初始值，默认值为3 138 dataSource.setInitialPoolSize(10); 139 // 连接池的最大值,默认值为0 140 dataSource.setMaxPoolSize(20); 141 // 连接池的最小值，最小值为3 142 dataSource.setMinPoolSize(1); 143 // 连接池的递增值,默认值为3 144 dataSource.setAcquireIncrement(5); 145 } 146 147 /** 148 * 连接池生命周期配置,连接池首先从数据库中获取连接，用户请求时从连接池中获取连接。默认值为0，表示永不过期。 maxConnectionAge: 149 * 连接对象生命的最大值，超过此时间，连接池会销毁连接对象，连接池变小。单位为秒，建议设置1800或更多 maxIdleTime: 150 * 空闲连接在连接池中的超时时间，超过此时间，连接池将会销毁连接对象。单位为秒，建议设置1800或更多 151 * maxIdleTimeExcessConnections：当连接池不处于过载状态时，空闲连接对象生命的最大值。 152 * unreturnedConnectionTimeout:当连接对象在一定时间内无法回收，则创建新连接对象，销毁旧连接对象 153 * 154 * @param dataSource 155 */ 156 private static void connAgeConfig(ComboPooledDataSource dataSource) { 157 // 连接对象生命的最大值,它指绝对时间。从创建开始时计算,默认值为0 158 dataSource.setMaxConnectionAge(10 * 60 * 60); 159 // 空闲连接的超时时间，从连接池变为空闲状态开始计算 160 dataSource.setMaxIdleTime(1800); 161 // 空闲连接对象生命的最大值 162 dataSource.setMaxIdleTimeExcessConnections(60); 163 // 连接对象的最大使用时间,设置为2小时 164 dataSource.setUnreturnedConnectionTimeout(2 * 60 * 60); 165 } 166 167 168 /** 169 * 连接测试配置。 automaticTestTable:测试连接时使用的数据库表 ,默认值为null。connectionTesterClassName:测试连接时使用的类名称 170 * idleConnectionTestPeriod:测试连接间隔时间。在此段时间内不进行连接测试。 preferredTestQuery:连接测试使用的SQL语句。默认语句为select 171 * 1 from dual。 testConnectionOnCheckin:从连接池回收连接对象时测试连接。默认值为false 172 * testConnectionOnCheckOut:从连接池取出连接对象时测试连接。默认值为false。 173 * forceSynchronousCheckins:连接池回收连接对象时是同步，还是异步，默认是异步。默认值为false 174 * 175 * @param dataSource 176 * @throws PropertyVetoException <