[面试] InnoDB中如何解决幻读?

幻读是通过 MVCC 机制来解决的, MVCC 类似于一种乐观锁的机制，通过版本的方式来区分不同的并发事务，避免幻读问题!

什么是幻读?

事务A前后两次读取同一个范围的数据，在事务A两次读取的过程之间，事务B新增了数据，导致事务A后一次读取到前一次查询没有看到的行(数据)。幻读强调的是集合的增减，而不是单条数据的更新。如下图示例:
在这里插入图片描述

所以幻读会带来数据一致性的问题!

如何解决幻读问题?

调整事务隔离级别：将事务隔离级别设置为可重复读或串行化，这可以防止幻读。在这些隔离级别下，事务会锁定读取的数据，直到事务结束。
使用行级锁：行级锁可以在读取或修改数据时锁定单独的行，而不是整个表。这有助于避免幻读。可以使用SELECT ... FOR UPDATE语句来获取行级锁
使用间隙锁：间隙锁是一种特殊类型的锁，用于防止幻读。它会锁定一个范围内的数据，而不仅仅是单个行, 在InnoDB存储引擎中，使用SELECT ... LOCK IN SHARE MODE语句可以获取间隙锁。(MyISAM引擎不支持间隙锁)
使用乐观锁：乐观锁不会阻塞其他事务，而是在更新数据时检查是否有其他事务已经修改了相同的数据。通常，乐观锁使用版本号或时间戳来实现。

乐观锁解决幻读代码案例

CREATE TABLE account (id INT AUTO_INCREMENT PRIMARY KEY,deposit DECIMAL(10, 2) NOT NULL DEFAULT 0.00,version INT NOT NULL DEFAULT 0
);

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.mapper.AccountMapper"><select id="selectById" resultType="com.example.model.Account">SELECT * FROM account WHERE id = #{id}</select><update id="updateDeposit" keyProperty="id" parameterType="com.example.model.Account">UPDATE account SET deposit = #{deposit}, version = version + 1 WHERE id = #{id} AND version = #{version}</update></mapper>

@Data
public class Account {private int id;private BigDecimal deposit;private int version;
}

@Slf4j
@Service
public class AccountService {@Resourceprivate AccountMapper accountMapper;// ...其他属性和方法...// 使用乐观锁实现转账操作@Transactional(isolation = Isolation.REPEATABLE_READ)public Result transferOptimistic(int fromId, int toId, BigDecimal value) {Account from = accountMapper.selectById(fromId);Account to = accountMapper.selectById(toId);//检查账户中的余额是否足够,如果账户余额不足，回滚当前的事务，即撤销之前的操作。if (!isDepositEnough.test(from.getDeposit(), value)) {TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();return Result.DEPOSIT_NOT_ENOUGH;}from.setDeposit(from.getDeposit().subtract(value));to.setDeposit(to.getDeposit().add(value));int r1 = accountMapper.updateDepositWithVersion(from);int r2 = accountMapper.updateDepositWithVersion(to);if (r1 < 1 || r2 < 1) {throw new RetryException("Transfer failed, retry.");} else {return Result.SUCCESS;}}
}