解决spring结合mybatis时一级缓存失效的问题

更新时间：2020年11月27日 16:09:59 作者：iiaythi

这篇文章主要介绍了解决spring结合mybatis时一级缓存失效的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

之前了解到mybatis的一级缓存是默认开启的，作用域是sqlSession,是基 HashMap的本地缓存。不同的SqlSession之间的缓存数据区域互不影响。

当进行select、update、delete操作后并且commit事物到数据库之后，sqlSession中的Cache自动被清空

<setting name="localCacheScope" value="SESSION"/>

结论

spring结合mybatis后，一级缓存作用：

在未开启事物的情况之下，每次查询，spring都会关闭旧的sqlSession而创建新的sqlSession,因此此时的一级缓存是没有启作用的

在开启事物的情况之下，spring使用threadLocal获取当前资源绑定同一个sqlSession，因此此时一级缓存是有效的

案例

情景一:未开启事物

@Service("countryService")
public class CountryService {

 @Autowired
 private CountryDao countryDao;

 // @Transactional 未开启事物
 public void noTranSactionMethod() throws JsonProcessingException {
  CountryDo countryDo = countryDao.getById(1L);
  CountryDo countryDo1 = countryDao.getById(1L);
  ObjectMapper objectMapper = new ObjectMapper();
  String json = objectMapper.writeValueAsString(countryDo);
  String json1 = objectMapper.writeValueAsString(countryDo1);
  System.out.println(json);
  System.out.println(json1);
 }
}

测试案例:

@Test
public void transactionTest() throws JsonProcessingException {
 countryService.noTranSactionMethod();
}

结果:

[DEBUG] SqlSessionUtils Creating a new SqlSession
[DEBUG] SpringManagedTransaction JDBC Connection [com.mysql.jdbc.JDBC4Connection@14a54ef6] will not be managed by Spring
[DEBUG] getById ==> Preparing: SELECT * FROM country WHERE country_id = ?
[DEBUG] getById ==> Parameters: 1(Long)
[DEBUG] getById <==  Total: 1
[DEBUG] SqlSessionUtils Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3359c978]
[DEBUG] SqlSessionUtils Creating a new SqlSession
[DEBUG] SqlSessionUtils SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@2aa27288] was not registered for synchronization because synchronization is not active
[DEBUG] SpringManagedTransaction JDBC Connection [com.mysql.jdbc.JDBC4Connection@14a54ef6] will not be managed by Spring
[DEBUG] getById ==> Preparing: SELECT * FROM country WHERE country_id = ?
[DEBUG] getById ==> Parameters: 1(Long)
[DEBUG] getById <==  Total: 1
[DEBUG] SqlSessionUtils Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@2aa27288]
{"countryId":1,"country":"Afghanistan","lastUpdate":"2006-02-15 04:44:00.0"}
{"countryId":1,"country":"Afghanistan","lastUpdate":"2006-02-15 04:44:00.0"}

可以看到，两次查询，都创建了新的sqlSession,并向数据库查询，此时缓存并没有起效果

情景二: 开启事物

打开@Transactional注解:

@Service("countryService")
public class CountryService {

 @Autowired
 private CountryDao countryDao;

 @Transactional
 public void noTranSactionMethod() throws JsonProcessingException {
  CountryDo countryDo = countryDao.getById(1L);
  CountryDo countryDo1 = countryDao.getById(1L);
  ObjectMapper objectMapper = new ObjectMapper();
  String json = objectMapper.writeValueAsString(countryDo);
  String json1 = objectMapper.writeValueAsString(countryDo1);
  System.out.println(json);
  System.out.println(json1);
 }
}

使用原来的测试案例，输出结果:

[DEBUG] SqlSessionUtils Creating a new SqlSession
[DEBUG] SqlSessionUtils Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@109f5dd8]
[DEBUG] SpringManagedTransaction JDBC Connection [com.mysql.jdbc.JDBC4Connection@55caeb35] will be managed by Spring
[DEBUG] getById ==> Preparing: SELECT * FROM country WHERE country_id = ?
[DEBUG] getById ==> Parameters: 1(Long)
[DEBUG] getById <==  Total: 1
[DEBUG] SqlSessionUtils Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@109f5dd8]
// 从当前事物中获取sqlSession
[DEBUG] SqlSessionUtils Fetched SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@109f5dd8] from current transaction
[DEBUG] SqlSessionUtils Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@109f5dd8]
{"countryId":1,"country":"Afghanistan","lastUpdate":"2006-02-15 04:44:00.0"}
{"countryId":1,"country":"Afghanistan","lastUpdate":"2006-02-15 04:44:00.0"}

可以看到，两次查询，只创建了一次sqlSession,说明一级缓存起作用了

跟踪源码

从SqlSessionDaoSupport作为路口，这个类在mybatis-spring包下，sping为sqlSession做了代理

public abstract class SqlSessionDaoSupport extends DaoSupport {

 private SqlSession sqlSession;

 private boolean externalSqlSession;

 public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
 if (!this.externalSqlSession) {
  this.sqlSession = new SqlSessionTemplate(sqlSessionFactory);
 }
 }
 //....omit
}

创建了SqlSessionTemplate后,在SqlSessionTemplate中:

public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory, ExecutorType executorType,
 PersistenceExceptionTranslator exceptionTranslator) {

 notNull(sqlSessionFactory, "Property 'sqlSessionFactory' is required");
 notNull(executorType, "Property 'executorType' is required");

 this.sqlSessionFactory = sqlSessionFactory;
 this.executorType = executorType;
 this.exceptionTranslator = exceptionTranslator;
 //代理了SqlSession
 this.sqlSessionProxy = (SqlSession) newProxyInstance(
  SqlSessionFactory.class.getClassLoader(),
  new Class[] { SqlSession.class },
  new SqlSessionInterceptor());
}

再看SqlSessionInterceptor,SqlSessionInterceptor是SqlSessionTemplate的内部类:

public class SqlSessionTemplate implements SqlSession, DisposableBean {
 // ...omit..
 private class SqlSessionInterceptor implements InvocationHandler {
  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
  SqlSession sqlSession = getSqlSession(
   SqlSessionTemplate.this.sqlSessionFactory,
   SqlSessionTemplate.this.executorType,
   SqlSessionTemplate.this.exceptionTranslator);
  try {
   Object result = method.invoke(sqlSession, args);
   //如果尚未开启事物(事物不是由spring来管理)，则sqlSession直接提交
   if (!isSqlSessionTransactional(sqlSession, SqlSessionTemplate.this.sqlSessionFactory)) {
   // force commit even on non-dirty sessions because some databases require
   // a commit/rollback before calling close()
   // 手动commit
   sqlSession.commit(true);
   }
   return result;
  } catch (Throwable t) {
   Throwable unwrapped = unwrapThrowable(t);
   if (SqlSessionTemplate.this.exceptionTranslator != null && unwrapped instanceof PersistenceException) {
   // release the connection to avoid a deadlock if the translator is no loaded. See issue #22
   closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
   sqlSession = null;
   Throwable translated = SqlSessionTemplate.this.exceptionTranslator.translateExceptionIfPossible((PersistenceException) unwrapped);
   if (translated != null) {
    unwrapped = translated;
   }
   }
   throw unwrapped;
  } finally {
   //一般情况下，默认都是关闭sqlSession
   if (sqlSession != null) {
   closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
   }
  }
  }
 }
}

再看getSqlSession方法，这个方法是在SqlSessionUtils.java中的：

public static SqlSession getSqlSession(SqlSessionFactory sessionFactory, ExecutorType executorType, PersistenceExceptionTranslator exceptionTranslator) {

 notNull(sessionFactory, NO_SQL_SESSION_FACTORY_SPECIFIED);
 notNull(executorType, NO_EXECUTOR_TYPE_SPECIFIED);
 //获取holder
 SqlSessionHolder holder = (SqlSessionHolder) TransactionSynchronizationManager.getResource(sessionFactory);
 //从sessionHolder中获取SqlSession
 SqlSession session = sessionHolder(executorType, holder);
 if (session != null) {
 return session;
 }

 if (LOGGER.isDebugEnabled()) {
 LOGGER.debug("Creating a new SqlSession");
 }

 //如果sqlSession不存在，则创建一个新的
 session = sessionFactory.openSession(executorType);
 //将sqlSession注册在sessionHolder中
 registerSessionHolder(sessionFactory, executorType, exceptionTranslator, session);

 return session;
}

private static void registerSessionHolder(SqlSessionFactory sessionFactory, ExecutorType executorType,
  PersistenceExceptionTranslator exceptionTranslator, SqlSession session) {
 SqlSessionHolder holder;
 //在开启事物的情况下
 if (TransactionSynchronizationManager.isSynchronizationActive()) {
  Environment environment = sessionFactory.getConfiguration().getEnvironment();

  //由spring来管理事物的情况下
  if (environment.getTransactionFactory() instanceof SpringManagedTransactionFactory) {
  if (LOGGER.isDebugEnabled()) {
   LOGGER.debug("Registering transaction synchronization for SqlSession [" + session + "]");
  }

  holder = new SqlSessionHolder(session, executorType, exceptionTranslator);
  //将sessionFactory绑定在sessionHolde相互绑定
  TransactionSynchronizationManager.bindResource(sessionFactory, holder);
  TransactionSynchronizationManager.registerSynchronization(new SqlSessionSynchronization(holder, sessionFactory));
  holder.setSynchronizedWithTransaction(true);
  holder.requested();
  } else {
  if (TransactionSynchronizationManager.getResource(environment.getDataSource()) == null) {
   if (LOGGER.isDebugEnabled()) {
   LOGGER.debug("SqlSession [" + session + "] was not registered for synchronization because DataSource is not transactional");
   }
  } else {
   throw new TransientDataAccessResourceException(
    "SqlSessionFactory must be using a SpringManagedTransactionFactory in order to use Spring transaction synchronization");
  }
  }
 } else {
  if (LOGGER.isDebugEnabled()) {
  LOGGER.debug("SqlSession [" + session + "] was not registered for synchronization because synchronization is not active");
  }
 }

再看TransactionSynchronizationManager.bindResource的方法:

public abstract class TransactionSynchronizationManager {

 //omit...
 private static final ThreadLocal<Map<Object, Object>> resources =
   new NamedThreadLocal<Map<Object, Object>>("Transactional resources");

  // key:sessionFactory, value:SqlSessionHolder(Connection)
  public static void bindResource(Object key, Object value) throws IllegalStateException {
  Object actualKey = TransactionSynchronizationUtils.unwrapResourceIfNecessary(key);
  Assert.notNull(value, "Value must not be null");
  //从threadLocal类型的resources中获取与当前线程绑定的资源，如sessionFactory，Connection等等
  Map<Object, Object> map = resources.get();
  // set ThreadLocal Map if none found
  if (map == null) {
   map = new HashMap<Object, Object>();
   resources.set(map);
  }
  Object oldValue = map.put(actualKey, value);
  // Transparently suppress a ResourceHolder that was marked as void...
  if (oldValue instanceof ResourceHolder && ((ResourceHolder) oldValue).isVoid()) {
   oldValue = null;
  }
  if (oldValue != null) {
   throw new IllegalStateException("Already value [" + oldValue + "] for key [" +
    actualKey + "] bound to thread [" + Thread.currentThread().getName() + "]");
  }
  if (logger.isTraceEnabled()) {
   logger.trace("Bound value [" + value + "] for key [" + actualKey + "] to thread [" +
    Thread.currentThread().getName() + "]");
  }
  }
}

这里可以看到，spring是如何做到获取到的是同一个SqlSession,前面的长篇大论，就是为使用ThreadLocal将当前线程绑定创建SqlSession相关的资源，从而获取同一个sqlSession

以上这篇解决spring结合mybatis时一级缓存失效的问题就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

JAVA解决在@autowired,@Resource注入为null的情况
这篇文章主要介绍了JAVA解决在@autowired,@Resource注入为null的情况，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-10-10
Spring Boot+微信小程序开发平台保存微信登录者的个人信息
这篇文章主要介绍了Spring Boot+微信小程序开发平台保存微信登录者的个人信息,本文主要介绍 wx.login和wx.getProfile接口，因篇幅所限，不能对其它接口做详细介绍，有兴趣者可以查阅官方文档
2022-05-05
Intellij IDEA如何查看所有断点
这篇文章主要介绍了Intellij IDEA如何查看所有断点问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-03-03
Java 静态数据初始化的示例代码
这篇文章主要介绍了Java 静态数据初始化的示例代码，帮助大家更好的理解和学习Java，感兴趣的朋友可以了解下
2020-09-09
idea插件篇之java内存分析工具(JProfiler)的使用
这篇文章主要介绍了idea插件篇之java内存分析工具(JProfiler)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-09-09
解决java执行cmd命令调用ffmpeg报错Concat error - No such filter ''[0,0]
这篇文章主要介绍了java执行cmd命令，调用ffmpeg报错Concat error - No such filter '[0,0]'解决方法,本文通过截图实例代码说明给大家介绍的非常详细，对大家的工作或学习有一定的参考借鉴价值，需要的朋友可以参考下
2020-03-03
Spring Boot 如何生成微信小程序短连接及发送短信在短信中打开小程序操作
最近遇到这样的需求需要发送短信,通过短信中的短连接打开小程序操作,下面小编给大家分享Spring Boot 如何生成微信小程序短连接发送短信在短信中打开小程序操作,感兴趣的朋友跟随小编一起看看吧
2024-03-03
SpringDataJpa如何使用union多表分页条件查询
这篇文章主要介绍了SpringDataJpa如何使用union多表分页条件查询，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-02-02
Java程序中实现调用Python脚本的方法详解
这篇文章主要介绍了Java程序中实现调用Python脚本的方法,结合实例形式分析了eclipse环境中使用Java调用Python脚本的相关操作技巧与注意事项,需要的朋友可以参考下
2018-03-03
2种Java删除ArrayList中的重复元素的方法
这篇文章主要介绍了2种Java删除ArrayList中的重复元素的方法,感兴趣的朋友可以参考下
2015-08-08

解决spring结合mybatis时一级缓存失效的问题

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具