[转]c3p0学习-JdbcUtil工具类

com.javaweb.jdbc; import java.sql.Connection; import java.sql.SQLException; import javax.sql.DataSource; import com.mchange.v2.c3p0.ComboPooledDataSource; public class JdbcUtil { // 饿汉式 private static DataSource ds = new ComboPooledDataSource(); /*ThreadLocal * 它为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{ 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(); } } } }

 

三、在src下创建名字必须为 c3p0-config.xml文件

　

<?xml version="1.0" encoding="UTF-8" ?>
<c3p0-config>
    <default-config>
        <!-- 四大必要属性 -->
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/db_mysqltest</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">123</property>
        
         <!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。Default: 3 -->
        <property name="acquireIncrement">3</property>
        <!-- 初始化连接池中的连接数，取值应在minPoolSize与maxPoolSize之间，默认为3-->
        <property name="initialPoolSize">10</property>
         <!-- 连接池中保留的最小连接数，默认为：3-->
        <property name="minPoolSize">2</property>
         <!--连接池中保留的最大连接数。默认值: 15 -->  
        <property name="maxPoolSize">10</property>
    </default-config>
</c3p0-config>

 

[转]c3p0学习-JdbcUtil工具类

标签：data   web   代码   jdbc   pack   开启   饿汉   关闭   oca