面试题：MySQL中的事务

GeekLiHua

发布于 2025-01-21 05:07:48

11700

代码可运行

文章被收录于专栏：JavaJava

运行总次数：0

代码可运行

MySQL中的事务

在数据库管理系统中，事务是一组数据库操作的逻辑单元，要么全部执行成功，要么全部不执行。事务可以确保数据库的数据一致性和完整性，尤其在并发访问数据库时非常重要。MySQL是一个流行的关系型数据库管理系统，它提供了强大的事务支持。

事务的特性

MySQL中的事务具有以下四个特性，通常称为ACID属性：

原子性（Atomicity）：事务中的所有操作要么全部成功执行，要么全部不执行。如果在事务执行过程中发生错误，所有的操作都将被回滚，保持数据的一致性。
一致性（Consistency）：事务在执行前后，数据库的状态必须保持一致。这意味着事务中的操作必须满足数据库的约束条件，如唯一性约束、外键约束等。
隔离性（Isolation）：并发访问数据库时，每个事务的操作应该与其他事务的操作相互隔离，互不干扰。事务应该在完全执行完之前对其他事务是不可见的。
持久性（Durability）：一旦事务提交成功，其所做的修改将永久保存在数据库中，即使系统发生故障也不会丢失。

使用事务执行银行转账

假设我们有一个名为accounts的表，其中包含用户的账户信息，包括用户ID和余额。我们想要执行一个银行转账操作，将100元从用户A的账户中扣除，并将100元存入用户B的账户中。我们可以使用MySQL的事务来确保转账过程的原子性。

以下是在MySQL中执行银行转账的SQL代码示例：

-- 开始事务
BEGIN;

-- 扣除金额
UPDATE accounts SET balance = balance - 100 WHERE user_id = 'A';

-- 增加金额
UPDATE accounts SET balance = balance + 100 WHERE user_id = 'B';

-- 提交事务
COMMIT;

在上面的代码中，我们首先使用BEGIN语句开始一个新的事务。然后，使用两个UPDATE语句分别从用户A的账户中扣除100元，并向用户B的账户中增加100元。最后，使用COMMIT语句提交事务，将所有的操作永久保存到数据库中。

如果在执行过程中发生了错误，可以使用ROLLBACK语句回滚事务，撤销所有的操作，如下所示：

-- 开始事务
BEGIN;

-- 扣除金额
UPDATE accounts SET balance = balance - 100 WHERE user_id = 'A';

-- 增加金额（出现错误）
UPDATE accounts SET balance = balance + 100 WHERE user_id = 'B';

-- 回滚事务
ROLLBACK;

在上面的代码中，如果第二个UPDATE语句执行出现错误，可以使用ROLLBACK语句回滚事务，撤销对用户A账户的金额扣除操作，保持数据的一致性。

使用JDBC执行MySQL事务

在Java中，可以使用JDBC（Java Database Connectivity）来执行MySQL事务。以下是一个简单的Java代码示例：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class TransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";
        
        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            connection.setAutoCommit(false); // 设置为手动提交事务
            
            try (Statement statement = connection.createStatement()) {
                statement.executeUpdate("UPDATE accounts SET balance = balance - 100 WHERE user_id = 'A'");
                statement.executeUpdate("UPDATE accounts SET balance = balance + 100 WHERE user_id = 'B'");
                
                connection.commit(); // 提交事务
                System.out.println("转账成功！");
            } catch (SQLException e) {
                connection.rollback(); // 回滚事务
                System.out.println("转账失败，回滚事务！");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}