package 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();

            }

        }

    }

}

<?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>