JDBC数据库事务

https://www.bilibili.com/video/BV1eJ411c7rf/?p=34

11:57之前是数据库连接及 PreparedStatement 使用小结

数据库事务介绍

• 事务：一组逻辑操作单元，使数据从一种状态变换到另一种状态
• 事务处理（事务操作）：保证所有事务都作为一个工作单元来执行，即使出现了故障，都不能改变这种这行方式。当在一个事务中执行多个操作时，要么所有的事务都被提交（commit），那么这些修改就永久地保存下来；要么数据库管理系统将放弃所作的所有修改，整个事务回滚（rollback）到最初状态。
• 为确保数据库中数据的一致性，数据的操纵应当是离散的成组的逻辑单元：当它全部完成时，数据的一致性可以保持，而当这个单元中的一部分操作失败，整个事务应全部视为错误，所有从起始点以后的操作应全部回退到开始状态。

JDBC事务处理

• 数据一旦提交，就不可回滚。
• 数据什么时候意味着提交？
  • 当一个连接对象被创建时，默认情况下是自动提交：每次执行一个 SQL 语句时，如果执行成功，就会向数据库自动提交，而不能回滚。
  • 关闭数据库连接，数据就会自动的提交。如果多个操作，每个操作使用的是自己单独的连接，则无法保证事务。即同一个事务的多个操作必须在同一个连接下。
• JDBC 程序中为了让多个 SQL 语句作为一个事务执行：
  • 调用 Connection 对象的 setAutoCommit(false); 以取消自动提交事务
  • 在所有的 SQL 语句都成功执行后，调用 commit(); 方法提交事务
  • 在出现异常时，调用 rollback(); 方法回滚事务
  • 若此时 Connection 没有被关闭，还可能被重复使用，则需要恢复其自动提交状态 setAutoCommit(true)。尤其是在使用数据库连接池技术时，执行 close() 方法前，建议恢复自动提交状态。

https://www.bilibili.com/video/BV1eJ411c7rf/?p=35

数据库事务的问题的引入

数据库准备

CREATE TABLE `user_table` (
  `user` varchar(20) NOT NULL,
  `password` varchar(45) DEFAULT NULL,
  `balance` int(11) DEFAULT NULL,
  PRIMARY KEY (`user`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

INSERT INTO `user_table` VALUES ('AA','123456',1000),('BB','654321',1000);

模拟经典的转账业务场景

    /**
     * 针对于数据表 user_table 来说：
     * AA用户给BB用户转账100
     *
     * update user_table set balance = balance - 100 where user = 'AA';
     * update user_table set balance = balance + 100 where user = 'BB';
     */
    @Test
    public void testUpdate() {
        String sql1 = "update user_table set balance = balance - 100 where user = ?";
        update(sql1, "AA");

        //模拟网络异常
        System.out.println(1 / 0);

        String sql2 = "update user_table set balance = balance + 100 where user = ?";
        update(sql2, "BB");
        System.out.println("转账成功");
    }

扣钱的操作执行成功，加钱的操作未执行。

https://www.bilibili.com/video/BV1eJ411c7rf?p=36

事务及数据库事务的处理原则

/**
 * 1.什么叫数据库事务？
 * 事务：一组逻辑操作单元，使数据从一种状态变换到另一种状态。
 *       > 一组逻辑操作单元：一个或多个 DML 操作。
 *
 * 2.事务处理的原则：保证所有事务都作为一个工作单元来执行，即使出现了故障，都不能改变这种执行方式。
 * 当在一个事务中执行多个操作时，要么所有的事务都被提交（commit），那么这些修改就永久地保存下来；
 * 要么数据库管理系统将放弃所作的修改，整个事务回滚（rollback）到最初状态。
 *
 * 3.数据一旦提交，就不可回滚
 *
 * 4.哪些操作会导致数据的自动提交？
 *     > DDL 操作一旦执行，都会自动提交。
 *         > set autocommit = false 的方式对 DDL 操作无效。
 *     > DML 操作在默认情况下，一旦执行，也会自动提交。
 *         > 可以通过 set autocommit = false 的方式取消 DML 操作默认的自动提交。
 *     > 默认在关闭连接时，会自动地提交事务。
 */

https://www.bilibili.com/video/BV1eJ411c7rf?p=37

考虑事务之后的代码实现

    //*********************考虑数据库事务后的转账操作*********************
    @Test
    public void testUpdateWithTx() {
        Connection con = null;
        try {
            con = JDBCUtils.getConnection();
            System.out.println(con.getAutoCommit());

            //取消数据的自动提交
            con.setAutoCommit(false);

            String sql1 = "update user_table set balance = balance - 100 where user = ?";
            update(con, sql1, "AA");

            //模拟网络异常
        System.out.println(1 / 0);

            String sql2 = "update user_table set balance = balance + 100 where user = ?";
            update(con, sql2, "BB");

            //提交数据
            con.commit();
            System.out.println("转账成功");
        } catch (Exception e) {
            e.printStackTrace();

            //回滚数据
            try {
                con.rollback();
            } catch (SQLException ex) {
                e.printStackTrace();
            }

        } finally {

            /*
             * 修改其为自动提交数据
             * 主要针对使用数据库连接池的使用
             */
            try {
                con.setAutoCommit(true);
            } catch (SQLException e) {
                e.printStackTrace();
            }

            JDBCUtils.closeResource(con, null);
        }

    }

    //通用的增删改查操作---version 2.0（考虑上事务）
    public int update(Connection conn, String sql, Object ...args) {//sql 中占位符的个数与可变形参的长度相同
        PreparedStatement ps = null;

        try {
            //1.预编译sql语句，返回PreparedStatement的实例
            ps = conn.prepareStatement(sql);

            //2.填充占位符
            for (int i = 0; i < args.length; i++) {
                ps.setObject(i + 1, args[i]);
            }

            //4.执行
            return ps.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.closeResource(null, ps);
        }
        return 0;
    }

https://github.com/jihch/jdbc_2/blob/main/src/main/java/io/github/jihch/transaction/TransactionTest.java

https://www.bilibili.com/video/BV1eJ411c7rf?p=38

若此时 Connection 没有被关闭，还可能被重复使用，则需要恢复其自动提交状态 setAutoCommit(true)。尤其是在使用数据库连接池技术时，执行 close() 方法前，建议恢复自动提交状态。

       } finally {

            /*
             * 修改其为自动提交数据
             * 主要针对使用数据库连接池的使用
             */
            try {
                con.setAutoCommit(true);
            } catch (SQLException e) {
                e.printStackTrace();
            }

            JDBCUtils.closeResource(con, null);
        }