C3P0和dbutils数据库连接池封装的使用（一）

首先用数据库连接池管理Connection，我们就可以重复使用Connection了，有了连接池我们就可以不用自己创建Connection，

然后用完把它归还给连接池就行了，首先用c3p0数据库连接池，需要向项目中导入两个包：mchange-commons-java-0.2.11.jar和c3p0-0.9.5.2.jar，如果用的数据库是oracle的话，需要导入三个包需要再加上一个：c3p0-oracle-thin-extras-0.9.5.2.jar

这里附上我的百度云的c3p0的下载链接http://pan.baidu.com/s/1eStATf8

然后在src文件夹下放置一个c3p0-config.xml的文件，这里附上代码：

<?xml version="1.0" encoding="UTF-8" ?>
<c3p0-config>
<default-config> 33
<property name="jdbcUrl">jdbc:mysql://localhost:3306/test</property>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="user">root</property>
<property name="password">dre@mtech1012</property>

<property name="acquireIncrement">3</property>
<property name="initialPoolSize">10</property>
<property name="minPoolSize">2</property>
<property name="maxPoolSize">10</property>
</default-config>
</c3p0-config>

然后就是修改数据库连接字符串和登陆数据库的账户和密码。然后就是把每一次

要连接到数据库的代码给封装到jdbcUtils类中，这样就可以直接调用获取数据的连接对象了。下面试jdbcUtils的代码了：

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
* 使用本类的方法，必须提供c3p0-copnfig.xml文件
* @author qdmmy6
*/
public class JdbcUtils {
// 饿汉式
private static DataSource ds = new ComboPooledDataSource();

/**
* 它为null表示没有事务
* 它不为null表示有事务
* 当开启事务时，需要给它赋值
* 当结束事务时，需要给它赋值为null
* 并且在开启事务时，让dao的多个方法共享这个Connection
*/
private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();

public static DataSource getDataSource() {
return ds;
}

/**
* dao使用本方法来获取连接
* @return
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
/*
* 如果有事务，返回当前事务的con
* 如果没有事务，通过连接池返回新的con
*/
Connection con = tl.get();//获取当前线程的事务连接
if(con != null) return con;
return ds.getConnection();
}

/**
* 开启事务
* @throws SQLException
*/
public static void beginTransaction() throws SQLException {
Connection con = tl.get();//获取当前线程的事务连接
if(con != null) throw new SQLException("已经开启了事务，不能重复开启！");
con = ds.getConnection();//给con赋值，表示开启了事务
con.setAutoCommit(false);//设置为手动提交
tl.set(con);//把当前事务连接放到tl中
}

/**
* 提交事务
* @throws SQLException
*/
public static void commitTransaction() throws SQLException {
Connection con = tl.get();//获取当前线程的事务连接
if(con == null) throw new SQLException("没有事务不能提交！");
con.commit();//提交事务
con.close();//关闭连接
con = null;//表示事务结束！
tl.remove();
}

/**
* 回滚事务
* @throws SQLException
*/
public static void rollbackTransaction() throws SQLException {
Connection con = tl.get();//获取当前线程的事务连接
if(con == null) throw new SQLException("没有事务不能回滚！");
con.rollback();
con.close();
con = null;
tl.remove();
}

/**
* 释放Connection
* @param con
* @throws SQLException
*/
public static void releaseConnection(Connection connection) throws SQLException {
Connection con = tl.get();//获取当前线程的事务连接
if(connection != con) {//如果参数连接，与当前事务连接不同，说明这个连接不是当前事务，可以关闭！
if(connection != null &&!connection.isClosed()) {//如果参数连接没有关闭，关闭之！
connection.close();
}
}
}
}

下面就是导入dbutils了。