c3p0数据库连接池如何使用-编程学习网

这期内容当中小编将会给大家带来有关c3p0数据库连接池如何使用，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。

一、jar包

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

二、配置文件

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

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

[java] view
plaincopy

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

三、代码实现

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;
public class C3P0ConnentionProvider {
private static final String JDBC_DRIVER = "driverClass";
private static final String JDBC_URL = "jdbcUrl";
private static DataSource ds;
static{
initDBSource();
}
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();
}
}
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();
}
}
}

上述就是小编为大家分享的c3p0数据库连接池如何使用了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注亿速云行业资讯频道。

文章详情