JDBC p3 事务

事务

  • 基本介绍

    1. JDBC 程序中当一个Connection对象创建时,默认情况下是自动提交事务:每次执行一个 SQL 语句时,如果执行成功,就会向数据库自动提交,而不能回滚。
    2. JDBC程序中为了多个SQL语句作为一个整体执行,需要使用事务
    3. 调用 Connection 的 setAutoCommit(false) 可以取消自动提交事务(相当与开启了事务)。
    4. 在所有的 SQL 语句都成功执行后,调用 commit(); 方法提交事务。
    5. 在其中某个操作失败或出现异常时,调用 rollback(); 方法回滚事务。
  • 案例:模拟经典的转账的业务

    MySQL代码:

    CREATE TABLE account(
    	id INT PRIMARY KEY AUTO_INCREMENT,
    	name VARCHAR(32) NOT NULL DEFAULT '',
    	balance DOUBLE NOT NULL DEFAULT 0
    ) CHARACTER SET utf8;
    
    INSERT INTO account VALUES(NULL, '马云', 3000);
    INSERT INTO account VALUES(NULL, '马化腾', 10000);
    
    SELECT * FROM account;
    

    Java代码:

    package com.hspedu.jdbc.transaction_;
    
    import com.hspedu.jdbc.utils.JDBCUtils;
    import org.junit.jupiter.api.Test;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    /**
     * Description: 演示在jdbc 中如何使用事务
     */
    public class Transaction_ {
    
        //没有使用事务,模拟银行转账出现异常
        @Test
        public void noTransaction(){
            //1. 得到连接
            Connection connection = null; //默认情况下,connection 默认自动提交, 执行一句sql语句,就会提交事务
    
            //2. SQL语句
            String sql = "update account set balance = balance - 100 where id = ?";
            String sql2 = "update account set balance = balance + 100 where id = ?";
    
            PreparedStatement preparedStatement = null;
    
            //3. 创建PreparedStatement 对象
            try {
    
                connection = JDBCUtils.getConnection();
    
                preparedStatement = connection.prepareStatement(sql);
                preparedStatement.setInt(1, 1);
                preparedStatement.executeUpdate();
    
                 int i = 1 / 0; //抛出异常接下来的语句就不会执行
                preparedStatement = connection.prepareStatement(sql2);
                preparedStatement.setInt(1, 2);
    
                preparedStatement.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                //关闭资源
                JDBCUtils.close(null, preparedStatement, connection);
            }
        }
    
    
        //使用事务
        @Test
        public void UseTransaction() {
            //1. 得到连接
            Connection connection = null; //默认情况下,connection 默认自动提交, 执行一句sql语句,就会提交事务
    
            //2. SQL语句
            String sql = "update account set balance = balance - 100 where id = ?";
            String sql2 = "update account set balance = balance + 100 where id = ?";
    
            PreparedStatement preparedStatement = null;
    
            //3. 创建PreparedStatement 对象
            try {
    
                connection = JDBCUtils.getConnection();
                connection.setAutoCommit(false);//相当与开启了事务
    
                preparedStatement = connection.prepareStatement(sql);
                preparedStatement.setInt(1, 1);
                preparedStatement.executeUpdate();
    
                int i = 1 / 0; //抛出异常接下来的语句就不会执行
                preparedStatement = connection.prepareStatement(sql2);
                preparedStatement.setInt(1, 2);
                preparedStatement.executeUpdate();
    
                //这里提交事务
                connection.commit();
            } catch (SQLException  | ArithmeticException  e) {
                System.out.println("执行发生了异常,撤销执行的SQL");
                e.printStackTrace();
                //可以在这里进行回顾,即撤销执行的sql语句
                try {
                    connection.rollback();//默认回滚到事务开始的时候,可以填入回滚点savePoint
                } catch (SQLException ex) {
                    throw new RuntimeException(ex);
                }
            } finally {
                //关闭资源
                JDBCUtils.close(null, preparedStatement, connection);
            }
        }
    }
    
    
    1. 模拟1号向2号转账100元转账异常,调用noTransaction()方法,不使用事务,可以发现结果如下:

      发生异常后,1号的存款转出了 100元,2号没有收到100元,100元没了。

    2. 如果调用的是useTransaction()方法,使用事务(connection.setAutoCommit(false) 取消事务自动提交)结果如下:

      没有变化,控制台打印了 “执行发生了异常,撤销执行的SQL”,出现了异常后try-catch并进行了事务的回滚

热门相关:总裁别再玩了   修真界败类   锦庭娇   闺范   万古至尊