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

在一个事务里面死循环select一条数据，当我开启事务时，数据是1，每过5秒我就select一次，这个时候mybatis的一级缓存起作用了，所以不会去数据库查数据，等别的线程更新了数据表的数据，会使m

news 2026/6/28 18:52:42

这个问题涉及到 MyBatis 一级缓存、事务隔离级别和数据库的并发控制。让我详细分析一下：

1. MyBatis 一级缓存的行为

MyBatis 一级缓存（Local Cache）是SqlSession 级别 的缓存：

在同一个 SqlSession 中执行相同的查询，MyBatis 会返回缓存中的结果
默认情况下，一级缓存是开启的

2. 重要结论

不会失效，原因如下：

2.1 MyBatis 一级缓存的失效条件

MyBatis 一级缓存会在以下情况下失效：

执行了 INSERT/UPDATE/DELETE 操作
调用了sqlSession.clearCache()方法
执行了带有flushCache="true"的查询
SqlSession 关闭

但是，其他线程的更新不会导致当前线程的 MyBatis 一级缓存失效，因为一级缓存是 SqlSession 私有的。

3. 实际演示代码

@Service public class DemoService { @Autowired private SqlSessionFactory sqlSessionFactory; // 线程1：在事务中循环查询 public void thread1Transaction() { SqlSession sqlSession = sqlSessionFactory.openSession(TransactionIsolationLevel.READ_COMMITTED); try { for (int i = 0; i < 10; i++) { // 每次查询都会从一级缓存获取 User user = sqlSession.selectOne("com.example.mapper.UserMapper.selectById", 1L); System.out.println("Thread1 - 查询结果: " + user.getCount()); Thread.sleep(5000); // 等待5秒 } } finally { sqlSession.close(); } } // 线程2：更新数据 public void thread2Update() { SqlSession sqlSession = sqlSessionFactory.openSession(); try { sqlSession.update("com.example.mapper.UserMapper.incrementCount", 1L); sqlSession.commit(); // 提交事务 } finally { sqlSession.close(); } } }

4. 解决方案

如果你希望看到其他线程的更新，有以下几种方式：

4.1 关闭 MyBatis 一级缓存（针对特定查询）

<!-- 在mapper.xml中 --> <select id="selectById" resultType="User" flushCache="true"> SELECT * FROM user WHERE id = #{id} </select>

4.2 手动清除缓存

// 在查询前清除缓存 sqlSession.clearCache(); User user = sqlSession.selectOne("com.example.mapper.UserMapper.selectById", 1L);

4.3 使用不同的 SqlSession

// 每次查询创建新的 SqlSession for (int i = 0; i < 10; i++) { try (SqlSession newSession = sqlSessionFactory.openSession()) { User user = newSession.selectOne("com.example.mapper.UserMapper.selectById", 1L); System.out.println("查询结果: " + user.getCount()); } Thread.sleep(5000); }

4.4 配置二级缓存（不推荐用于此场景）

二级缓存是 Mapper 级别的，可以被多个 SqlSession 共享，但需要考虑同步问题。

5. 事务隔离级别的影响

即使 MyBatis 每次都去数据库查询，事务隔离级别也会影响你看到的数据：

// 设置事务隔离级别为 READ_COMMITTED @Transactional(isolation = Isolation.READ_COMMITTED) public void queryInTransaction() { for (int i = 0; i < 10; i++) { User user = userMapper.selectById(1L); System.out.println("查询结果: " + user.getCount()); Thread.sleep(5000); } }

事务隔离级别：

REPEATABLE_READ（MySQL默认）：同一事务中多次读取相同数据，结果一致
READ_COMMITTED：可以读取到其他事务已提交的修改

6. 推荐做法

如果需要在长事务中看到其他线程的更新：

使用 READ_COMMITTED 隔离级别
关闭 MyBatis 一级缓存 或每次查询前清空缓存
或者使用新的 SqlSession 查询

@Transactional(isolation = Isolation.READ_COMMITTED) public void queryWithLatestData() { for (int i = 0; i < 10; i++) { // 方案1：清空缓存 clearCacheAndQuery(); // 方案2：新建SqlSession查询 queryWithNewSession(); Thread.sleep(5000); } }

核心要点：MyBatis 一级缓存只在当前 SqlSession 内有效，其他线程的操作不会使其失效。如果需要看到最新数据，需要主动绕过缓存机制。

查看全文

http://www.cnnetsun.cn/news/94319.html