当前位置：首页 > news >正文

幻读是什么项目中是怎么保证不会出现幻读

news 来源：原创 2025/4/26 14:44:03

幻读（Phantom Read）是数据库并发控制中的一种现象，指的是在事务处理中，一个事务在读取某个数据范围时，另一个事务插入、删除或者修改了该数据范围，导致第一个事务再次读取数据时，看到的数据发生了变化。具体来说，幻读表现为：

第一个事务读取了一个符合某个条件的数据集。
第二个事务对符合该条件的数据进行了插入、删除或者修改。
第一个事务再次读取时，发现数据集的内容发生了变化（即看到的幻像数据）。

幻读与不可重复读不同，不可重复读指的是同一事务内，读取的同一数据发生了变化，而幻读指的是数据集本身的变化。

解决幻读问题的方式

为了解决幻读问题，通常我们使用数据库的隔离级别来保证数据的完整性和一致性。数据库的隔离级别有4种，它们分别是：

读未提交（Read Uncommitted）
读已提交（Read Committed）
可重复读（Repeatable Read）
串行化（Serializable）

为了避免幻读问题，通常需要使用 Serializable（串行化） 隔离级别，这是一种最强的隔离级别，它可以避免幻读的发生。尽管 Serializable 能够防止幻读，但它的性能开销较大，通常只有在需要严格保证数据一致性时才会使用。

解决幻读问题的技术实现（数据库层面）

对于数据库事务管理，解决幻读问题的常见方式是通过设置隔离级别为 Serializable，或使用数据库锁（如排它锁）。

示例：使用 `Serializable` 隔离级别防止幻读

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class PhantomReadExample {public static void main(String[] args) {try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "user", "password")) {// 设置事务隔离级别为串行化，防止幻读conn.setAutoCommit(false);conn.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);// 开始事务 1：读取符合条件的数据PreparedStatement stmt1 = conn.prepareStatement("SELECT * FROM accounts WHERE balance > 1000");ResultSet rs1 = stmt1.executeQuery();System.out.println("Transaction 1 - Initial Data:");while (rs1.next()) {System.out.println("Account ID: " + rs1.getInt("account_id") + ", Balance: " + rs1.getInt("balance"));}// 在事务 1 进行的同时，事务 2 插入了新的数据new Thread(() -> {try (Connection conn2 = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "user", "password")) {conn2.setAutoCommit(false);PreparedStatement stmt2 = conn2.prepareStatement("INSERT INTO accounts (account_id, balance) VALUES (?, ?)");stmt2.setInt(1, 4); // 插入一条新的数据stmt2.setInt(2, 1500); // 余额大于 1000stmt2.executeUpdate();conn2.commit();} catch (SQLException e) {e.printStackTrace();}}).start();// 在事务 1 继续读取数据时，应该不会看到幻读（由于事务隔离级别为 Serializable）Thread.sleep(2000); // 等待事务 2 插入数据rs1.beforeFirst(); // 将游标重置到查询结果的开头System.out.println("Transaction 1 - Data After Second Read:");while (rs1.next()) {System.out.println("Account ID: " + rs1.getInt("account_id") + ", Balance: " + rs1.getInt("balance"));}conn.commit();} catch (SQLException | InterruptedException e) {e.printStackTrace();}}
}