数据库事务

数据库事务介绍

  • 事务：一组逻辑操作单元,使数据从一种状态变换到另一种状态。

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

  • 为确保数据库中数据的一致性，数据的操纵应当是离散的成组的逻辑单元：当它全部完成时，数据的一致性可以保持，而当这个单元中的一部分操作失败，整个事务应全部视为错误，所有从起始点以后的操作应全部回退到开始状态。

JDBC事务处理

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

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

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

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

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

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

案例

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
public void testJDBCTransaction() {
    Connection conn = null;
    try {
        // 获取数据库连接
        conn = JDBCUtils.getConnection();
        // 开启事务
        conn.setAutoCommit(false);
        // 进行数据库操作
        String sql = "update user_table set balance = balance - 100 where user = ?";
        update(conn, sql, "AA");

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

        sql = "update user_table set balance = balance + 100 where user = ?";
        update(conn, sql, "BB");
        // 若没有异常，则提交事务
        conn.commit();
    } catch (Exception e) {
        e.printStackTrace();
        // 若有异常，则回滚事务
        try {
            if (conn != null) {
                conn.rollback();
            }
        } catch (SQLException throwable) {
            throwable.printStackTrace();
        }
    } finally {
        try {
            // 恢复每次DML操作的自动提交功能
            conn.setAutoCommit(true);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        //7.关闭连接
        JDBCUtils.closeResource(conn, null, null);
    }
}

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
// 使用事务以后的通用的增删改操作
public void update(Connection conn ,String sql, Object... args) {
	PreparedStatement ps = null;
	try {
		// 获取PreparedStatement的实例 (或：预编译sql语句)
		ps = conn.prepareStatement(sql);
		// 填充占位符
		for (int i = 0; i < args.length; i++) {
			ps.setObject(i + 1, args[i]);
		}
		// 执行sql语句
		ps.execute();
	} catch (Exception e) {
		e.printStackTrace();
	} finally {
		// 关闭资源
		JDBCUtils.closeResource(null, ps);
	}
}