共计 4013 个字符,预计需要花费 11 分钟才能阅读完成。
这期内容当中丸趣 TV 小编将会给大家带来有关 c3p0 数据库连接池如何使用,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
一、jar 包
引用开源项目,自然要先下载人家的 jar 包,我这里有一个在云盘:c3p0-0.9.5-pre4.jar,这里面其实有三个包,是我在开源中国下载的最新的,如果你还想要更新的不妨自己到网上去搜一下。
二、配置文件
作为一个数据库连接池自然有很多参数要设置,当然就算你不设置也有默认的,不过那不一定能满足你的要求。这里的配置文件没有什么特别的要求,可以是 xml 也可以是 properties 甚至与 txt 都行,当然如果你愿意也可以写死在程序中。
下面是我的配置文件,我把它放在了 src 目录下,名字叫“c3p0.properties”
[java] view
plaincopy
#jdbc 基本信息
driver >
jdbcUrl=jdbc:oracle:thin:@127.0.0.1:1521/orcl
user=bctts
password=bctts123
#c3p0 连接池信息
c3p0.minPoolSize=3
c3p0.maxPoolSize=25
# 当连接池中的连接耗尽的时候 c3p0 一次同时获取的连接数
c3p0.acquireIncrement=3
# 定义在从数据库获取新连接失败后重复尝试的次数
c3p0.acquireRetryAttempts=60
# 两次连接中间隔时间,单位毫秒
c3p0.acquireRetryDelay=1000
# 连接关闭时默认将所有未提交的操作回滚
c3p0.autoCommitOnClose=false
# 当连接池用完时客户端调用 getConnection() 后等待获取新连接的时间,超时后将抛出 SQLException, 如设为 0 则无限期等待。单位毫秒
c3p0.checkoutTimeout=3000
# 每 120 秒检查所有连接池中的空闲连接。Default: 0
c3p0.idleConnectionTestPeriod=120
# 最大空闲时间,60 秒内未使用则连接被丢弃。若为 0 则永不丢弃。Default: 0
c3p0.maxIdleTime=600
# 如果设为 true 那么在取得连接的同时将校验连接的有效性。Default: false
c3p0.testConnectionOnCheckin=true
#c3p0 将建一张名为 c3p0TestTable 的空表,并使用其自带的查询语句进行测试。
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
package com.bks.db;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.DataSources;
/**
* c3p0 连接池管理类
* @author ICE
*
*/
public class C3P0ConnentionProvider {
private static final String JDBC_DRIVER = driverClass ;
private static final String JDBC_URL = jdbcUrl ;
private static DataSource ds;
/**
* 初始化连接池代码块
*/
static{
initDBSource();
}
/**
* 初始化 c3p0 连接池
*/
private static final void initDBSource(){
Properties c3p0Pro = new Properties();
try {
// 加载配置文件
c3p0Pro.load(new FileInputStream( ./bin/c3p0.properties));
} catch (Exception e) {
e.printStackTrace();
}
String drverClass = c3p0Pro.getProperty(JDBC_DRIVER);
if(drverClass != null){
try {
// 加载驱动类
Class.forName(drverClass);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
Properties jdbcpropes = new Properties();
Properties c3propes = new Properties();
for(Object key:c3p0Pro.keySet()){
String skey = (String)key;
if(skey.startsWith( c3p0.)){
c3propes.put(skey, c3p0Pro.getProperty(skey));
}else{
jdbcpropes.put(skey, c3p0Pro.getProperty(skey));
}
}
try {
// 建立连接池
DataSource unPooled = DataSources.unpooledDataSource(c3p0Pro.getProperty(JDBC_URL),jdbcpropes);
ds = DataSources.pooledDataSource(unPooled,c3propes);
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 获取数据库连接对象
* @return 数据连接对象
* @throws SQLException
*/
public static synchronized Connection getConnection() throws SQLException{
final Connection conn = ds.getConnection();
conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
return conn;
}
}
下面这个是测试的例子
[java] view
plaincopy
package test.demo;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.bks.db.C3P0ConnentionProvider;
public class Demo {
public static void main(String[] args) {
for(int i=0;i 30;i++){
new Thread(new Demo2()).start();
}
}
}
class Demo2 implements Runnable{
public void run(){
try {
Connection conn = C3P0ConnentionProvider.getConnection();
PreparedStatement pst = conn.prepareStatement(select to_char(sysdate, hh34:mm:ss) tim from dual );
ResultSet rs = pst.executeQuery();
rs.next();
System.out.println(Thread.currentThread().getName()+ : +rs.getString(1));
try {
Thread.sleep(10*1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
上述就是丸趣 TV 小编为大家分享的 c3p0 数据库连接池如何使用了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注丸趣 TV 行业资讯频道。