JDBC事务

Posted 2021-10-23 王六六的IT日常

JDBC完结撒花~~~~~~~~

【JDBC】事务

1. 数据库事务：一组逻辑操作单元,使数据从一种状态变换到另一种状态。
2. 事务处理的原则：保证所有事务都作为一个工作单元来执行，即使出现了故障，都不能改变这种执行方式。当在一个事务中执行多个操作时，要么所有的事务都被提交(commit)，那么这些修改就永久地保存下来；要么数据库管理系统将放弃所作的所有修改，整个事务回(rollback)到最初状态。

JDBC事务处理

• 数据一旦提交，就不可回滚。

数据什么时候意味着提交？

• 当一个连接对象被创建时，默认情况下是自动提交事务：每次执行一个 SQL 语句时，如果执行成功，就会向数据库自动提交，而不能回滚。
• 关闭数据库连接，数据就会自动的提交。如果多个操作，每个操作使用的是自己单独的连接，则无法保证事务。即同一个事务的多个操作必须在同一个连接下。

JDBC程序中为了让多个 SQL 语句作为一个事务执行：

• 调用 Connection 对象的 setAutoCommit(false); 以取消自动提交事务
• 在所有的 SQL 语句都成功执行后，调用 commit(); 方法提交事务
• 在出现异常时，调用 rollback(); 方法回滚事务

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

【案例：用户AA向用户BB转账100】

public class TransactionTest {

    /*
     * 场景： AA 给 BB 转账 100
     *
     * 操作1：update user_table set balance = balance - 100 where user = 'AA'
     *
     * 操作2：update user_table set balance = balance + 100 where user = 'BB'
     * */

    @Test
    public void test() { //一个事务一个连接

        Connection connection = null;
        try {

            //获取连接
            connection = JDBCUtils.getConnection();
            QueryRunner runner = new QueryRunner();

            //1.设置数据不能自动提交
            connection.setAutoCommit(false);

            //操作1：
            String sql1 = "update user_table set balance = balance - 100 where user = ?";
            runner.update(connection, sql1, "AA");
            System.out.println("AA转出成功");

            //模拟异常的出现  java.lang.ArithmeticException: / by zero
            System.out.println( 10 / 0);

            //操作2：
            String sql2 = "update user_table set balance = balance + 100 where user = ?";
            runner.update(connection, sql2, "BB");
            System.out.println("BB转入成功");

            //2. 提交数据
            connection.commit();

        } catch (Exception e) {
            e.printStackTrace();

            //3.回滚数据
            try {
                if(connection != null)
                    connection.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }

        } finally {
            //关闭
            JDBCUtils.close(connection);
        }
    }
}

其中，对数据库操作的方法为：

其他详见：【MySQL】５.TCL语言