JdbcUtils（内部使用c3p0获得链接池对象datasource）的第三次修改---完成事务的处理

时间 2019-12-10

标签 jdbcutils 内部使用 c3p0 获得链接对象 datasource 第三次修改完成事务处理栏目 Java 繁體版

原文原文链接

　　把事务处理的方法从DAO层中抽离出来，写到Service层中，还有就是Service层中不能有Connection相关的东西，因此要对获得同一链接作相应的封装处理。java

进一步封装JdbcUtils,使其具备事务的功能（即，有开启事务，提交事务，回滚事务功能），而且支持多线程（ThreadLocal的应用）。sql

该数据库链接池使用c3p0数据库

1.JdbcUtils.java：

package com.xjs.jdbcutils;

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

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JdbcUtils {
    //使用文件的默认配置，要求必须给出c3p0-config.xml
    private static ComboPooledDataSource dataSource=new ComboPooledDataSource();
    //它是事务专用链接---容许多线程访问
    private static ThreadLocal<Connection> tl=new ThreadLocal<Connection>();
    
    //使用链接池返回一个链接对象
    public static Connection getConnection() throws SQLException{
        //获得本身线程的con，解决多线程问题
        Connection con=tl.get();
        //当con不为null时，说明已经调用过beginTransaction方法，表示开启了事务
        if(con != null){
            return con;
        }
        //若是是简单的获取链接的话，就返回链接池建立的链接
        return dataSource.getConnection();
    }
    
    //返回链接池对象
    public static DataSource getDataSource(){
        return dataSource;
    }
    /**
     * 开启事务
     * 1.获取一个connection,设置它的setAutoCommit(false)
     * 2.还有保证DAO中使用的链接是咱们刚刚建立的！
     * ------------------
     * 1.建立一个Connection，设置为手动提交(事务)
     * 2.把这个Connection给DAO用！
     * 3.还要让commitTransaction或rollbackTransaction能够获取到！
     * @throws SQLException 
     */
    public static void beginTransaction() throws SQLException{
        Connection con=tl.get();
        if(con != null) throw new SQLException("已经开启了事务，就不要重复开启了！");
        /*
         * 1.给con赋值！
         * 2.给con设置手动提交!
         */
        con=getConnection();
        con.setAutoCommit(false);
        
        tl.set(con);//把当前线程的；链接保存起来
    }
    /**
     * 提交事务
     * 1.获取beginTransaction提供的Connection，而后调用commit方法
     * @throws SQLException 
     */
    public static void commitTransaction() throws SQLException{
        Connection con=tl.get();//获取当前线程的专用链接
        if(con == null) throw new SQLException("尚未开启了事务，不能提交！");
        //直接使用con.commit()
        con.commit();
        con.close();//在这只是把链接归还给链接池了，这时con不为null;防止后面再次使用时出错，把con赋为null
        tl.remove();//从tl中移除链接
    }
    /**
     * 回滚事务
     * 1.获取beginTransaction提供的Connection，而后调用rollback方法
     * @throws SQLException 
     */
    public static void rollbackTransaction() throws SQLException{
        Connection con=tl.get();
        if(con == null) throw new SQLException("尚未开启了事务，不能关闭！");
        //直接使用con.rollback()
        con.rollback();
        con.close();
        //把它设置为null，表示事务已经结束了！下次在调用getConnection()返回的就不是con了！
        
        tl.remove();
    }
    /**
     * 释放链接
     * @param connection
     * @throws SQLException 
     */
    public static void releaseConnection(Connection connection) throws SQLException{
        Connection con=tl.get();
        /*
         * 判断它是否是事务专用，若是是，就不关闭！
         * 若是不是事务专用，那么就要关闭！
         */
        //若是con=null,说明如今没有事务，那么connection必定不是事务专用！
        if(con == null) connection.close();
        
        //若是con!=null,说明有事务，那么须要判断参数链接是否与con相等，若不等，说明参数链接不是事务专用链接
        if(con != connection) connection.close();
        
    }

    
}

　　QueryRunner类是apache对数据库操做进行的封装，对事务的实现不完善，本身写一个TxQueryRunner类继承QueryRunner类，重写父类中（参数中带Connection）的方法。在开启事务以后，TxQueryRunner类中的方法都已经获得事务专用的connection（使用时都须要传递参数Connection）都支持事务。apache

2.TxQueryRunner.java：

package com.xjs.jdbcutils;

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

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;

/**
 * 这个类中的方法，本身类处理链接的问题
 * 无需外界传递！
 * 怎样处理的呢？
 *     经过JdbcUtils.getConnection()获得链接！又多是事务链接，也有多是普通链接！
 *     JdbcUtils.releaseConnection()完成对链接的释放！若是是普通链接，关闭之（即把con归还给池）！
 * @author hp
 *
 */
public class TxQueryRunner extends QueryRunner{

    /**
     * 继承父类，重写父类中不带connection参数的方法，本身给那些不带con参数的方法加上con,
     * 在方法前面获得con,方法后面释放con
     * 这样能保证这个类中的全部方法都使用Connection对象
     */
    @Override
    public int[] batch(String sql, Object[][] params) throws SQLException {
        /*
         * 1.获得链接
         * 2.执行父类方法，传递链接对象
         * 3.释放链接
         * 4.返回值
         */ 
        Connection con=JdbcUtils.getConnection();
        int[] result=super.batch(con, sql, params);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public <T> T query(String sql, Object param, ResultSetHandler<T> rsh)
            throws SQLException {
        Connection con=JdbcUtils.getConnection();
        T result=super.query(con, sql, param, rsh);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public <T> T query(String sql, Object[] params, ResultSetHandler<T> rsh)
            throws SQLException {
        Connection con=JdbcUtils.getConnection();
        T result=super.query(con, sql, params, rsh);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public <T> T query(String sql, ResultSetHandler<T> rsh, Object... params)
            throws SQLException {
        Connection con=JdbcUtils.getConnection();
        T result=super.query(con, sql, rsh, params);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public <T> T query(String sql, ResultSetHandler<T> rsh) throws SQLException {
        Connection con=JdbcUtils.getConnection();
        T result=super.query(con, sql, rsh);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public int update(String sql) throws SQLException {
        Connection con=JdbcUtils.getConnection();
        int result=super.update(con, sql);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public int update(String sql, Object param) throws SQLException {
        Connection con=JdbcUtils.getConnection();
        int result=super.update(con, sql, param);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public int update(String sql, Object... params) throws SQLException {
        Connection con=JdbcUtils.getConnection();
        int result=super.update(con, sql, params);
        JdbcUtils.releaseConnection(con);
        return result;
    }
}

3.模拟Dao层：

package com.xjs.jdbcutils;

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

import org.apache.commons.dbutils.QueryRunner;
//Dao层--转帐
public class AccountDao {

    public static void update(String name,double money) throws SQLException{
        //使用QueryRunner(对操做数据库一些相同步骤进行了封装)，完成对数据库的操做---使用commons-dbutils包中的类
        QueryRunner qr=new TxQueryRunner();
        String sql="update account set balance=balance+? where name=?";
        Object[] params={money,name};
        qr.update(sql, params);//没有con,在方法的内部有con
    }
}

该Dao层中使用的TxQueryRunner类中的方法，其方法中有事务专用的链接con，以及con的释放。注意：（其实在这的这个事务专用链接con没有关闭，也没有归还给池。由于在下边的其余方法中还需用到它对数据库操做。）多线程

4.模拟service层：---调用dao层

package com.xjs.jdbcutils;

import java.sql.SQLException;

import org.junit.Test;

//模拟service层
public class Demo1 {
    private AccountDao dao = new AccountDao();

    @Test
    public void serviceMethod() throws Exception {
        try {
            JdbcUtils.beginTransaction();

            dao.update("zs", -100);
            /*if (true){
                throw new RuntimeException("抛出异常。。。");
            }*/
            dao.update("ls", 100);

            JdbcUtils.commitTransaction();
        } catch (Exception e) {
            try {
                JdbcUtils.rollbackTransaction();
            } catch (SQLException e1) {
            }
            throw e;
        }
    }
}

这样能够完成一次转帐的操做。ide

数据库：spa

各种的使用：线程