【Java 进阶篇】JDBC 管理事务详解

在这里插入图片描述

在数据库操作中，事务是一个非常重要的概念。事务可以确保一系列的数据库操作要么全部成功执行，要么全部失败回滚，以保持数据库的一致性和完整性。在 Java 中，我们可以使用 JDBC 来管理事务。本文将详细介绍 JDBC 管理事务的方法和示例代码，同时面向基础小白，以简单明了的语言进行讲解。

什么是事务

在数据库中，事务是一组 SQL 操作，这些操作被视为一个单一的工作单元。事务具有以下四个关键属性，通常被称为 ACID 特性：

原子性（Atomicity）：事务是原子的，它要么全部成功执行，要么全部失败回滚。如果其中一个操作失败，整个事务都将失败，不会留下部分修改。
一致性（Consistency）：事务在执行前后，数据库从一个一致的状态转移到另一个一致的状态。这意味着事务必须遵循数据库的完整性约束，如主键、唯一性约束等。
隔离性（Isolation）：多个事务可以并发执行，但彼此之间不能互相干扰。一个事务的修改在提交之前对其他事务是不可见的。
持久性（Durability）：一旦事务提交成功，它的结果将永久保存在数据库中，即使系统发生故障也不会丢失。

JDBC 事务管理

JDBC（Java Database Connectivity）是 Java 中用于与数据库进行交互的 API。JDBC 提供了一种在 Java 程序中管理数据库事务的方式。

开启事务

要在 JDBC 中开启一个事务，您需要执行以下步骤：

创建一个数据库连接（Connection）对象。
将连接的自动提交模式设置为 false，这意味着事务不会自动提交。
在事务中执行一系列的 SQL 操作。
最后，根据操作的成功或失败，选择提交事务（commit）或回滚事务（rollback）。

以下是一个示例代码，演示如何开启一个 JDBC 事务：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;public class TransactionExample {public static void main(String[] args) {String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "password";try (Connection connection = DriverManager.getConnection(jdbcUrl, username, password)) {// 关闭自动提交，开启事务connection.setAutoCommit(false);// 执行一系列数据库操作// 提交事务connection.commit();} catch (SQLException e) {e.printStackTrace();// 发生异常，回滚事务connection.rollback();}}
}

在上述代码中，我们通过 setAutoCommit(false) 方法关闭了自动提交模式，然后在 try 块中执行一系列数据库操作。如果发生异常，我们在 catch 块中调用 rollback() 方法来回滚事务。

提交事务和回滚事务

在 JDBC 中，要提交事务，可以使用 commit() 方法，如上面的示例所示。提交事务后，其中的所有操作将成为数据库的一部分。

如果在事务过程中出现了问题，您可以使用 rollback() 方法来回滚事务，撤销所有未提交的更改，将数据库恢复到事务开始之前的状态。在上述示例中，我们在 catch 块中调用了 rollback() 方法来回滚事务。

设置事务隔离级别

在 JDBC 中，您可以设置事务的隔离级别，以控制多个事务之间的相互影响程度。JDBC 支持以下四个事务隔离级别，从低到高分别是：

TRANSACTION_NONE：不支持事务。每个 SQL 语句都将自动提交，不会回滚。
TRANSACTION_READ_UNCOMMITTED：允许读取未提交的数据更改。这意味着一个事务可以看到另一个事务未提交的数据。
TRANSACTION_READ_COMMITTED：只允许读取已提交的数据更改。这是大多数数据库系统的默认隔离级别。
TRANSACTION_REPEATABLE_READ：确保在事务中多次读取相同的数据时，数据不会发生更改。但是，其他事务仍然可以插入新的数据。
TRANSACTION_SERIALIZABLE：最高隔离级别，确保事务之间完全隔离，不允许并发访问。

要设置事务隔离级别，可以使用 setTransactionIsolation() 方法。以下是一个示例代码：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;public class TransactionIsolationExample {public static void main(String[] args) {String jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase";String username = "root";String password = "password";try (Connection connection = DriverManager.getConnection(jdbcUrl, username, password)) {// 设置事务隔离级别为 TRANSACTION_SERIALIZABLEconnection.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);// 关闭自动提交，开启事务connection.setAutoCommit(false);// 执行一系列数据库操作// 提交事务connection.commit();} catch (SQLException e) {e.printStackTrace();// 发生异常，回滚事务connection.rollback();}}
}