[转]c3p0学习-JdbcUtil工具类

Posted sungong1987

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了[转]c3p0学习-JdbcUtil工具类相关的知识,希望对你有一定的参考价值。

原文:https://www.cnblogs.com/jonny-xu/p/6374163.html

 

一、需要jar包: 

  c3p0-0.9.1.2.jar  

  mysql-connector-java-5.1.20-bin.jar

二、Java代码:

  

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

 

三、在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工具类的主要内容,如果未能解决你的问题,请参考以下文章

Java-jdbc工具类jdbcUtil

玩转JDBC打造数据库操作万能工具类JDBCUtil,加入了高效的数据库连接池,利用了参数绑定有效防止SQL注入

玩转JDBC打造数据库操作万能工具类JDBCUtil,加入了高效的数据库连接池,利用了参数绑定有效防止SQL注入

Mysqlutil.JDBCutil.Dtabaseutil数据库操作工具类[批量操作]

知了堂学习心得浅谈c3p0连接池和dbutils工具类的使用

网上图书商城项目学习笔记-035工具类之JdbcUtils及TxQueryRunner及C3P0配置