溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

spring 整合mybatis后用不上session緩存的原因分析

發(fā)布時(shí)間：2020-09-05 08:51:13 來(lái)源：腳本之家 閱讀：151 作者：mrr 欄目：編程語(yǔ)言

因?yàn)橐恢庇胹pring整合了mybatis，所以很少用到mybatis的session緩存。 習(xí)慣是本地緩存自己用map寫或者引入第三方的本地緩存框架ehcache，Guava

所以提出來(lái)糾結(jié)下

實(shí)驗(yàn)下（spring整合mybatis略，網(wǎng)上一堆），先看看mybatis級(jí)別的session的緩存

放出打印sql語(yǔ)句

configuration.xml 加入

<settings>
    <!-- 打印查詢語(yǔ)句 -->
    <setting name="logImpl" value="STDOUT_LOGGING" />
  </settings>

測(cè)試源代碼如下：

dao類　

/**
 * 測(cè)試spring里的mybatis為啥用不上緩存
 *
 * @author 何錦彬 2017.02.15
 */
@Component
public class TestDao {
  private Logger logger = Logger.getLogger(TestDao.class.getName());
  @Autowired
  private SqlSessionTemplate sqlSessionTemplate;
  @Autowired
  private SqlSessionFactory sqlSessionFactory;
  /**
   * 兩次SQL
   *
   * @param id
   * @return
   */
  public TestDto selectBySpring(String id) {
    TestDto testDto = (TestDto) sqlSessionTemplate.selectOne("com.hejb.TestDto.selectByPrimaryKey", id);
    testDto = (TestDto) sqlSessionTemplate.selectOne("com.hejb.TestDto.selectByPrimaryKey", id);
    return testDto;
  }
  /**
   * 一次SQL
   *
   * @param id
   * @return
   */
  public TestDto selectByMybatis(String id) {
    SqlSession session = sqlSessionFactory.openSession();
    TestDto testDto = session.selectOne("com.hejb.TestDto.selectByPrimaryKey", id);
    testDto = session.selectOne("com.hejb.TestDto.selectByPrimaryKey", id);
    return testDto;
  }
}

測(cè)試service類

@Component
public class TestService {
  @Autowired
  private TestDao testDao;
  /**
   * 未開啟事務(wù)的spring Mybatis查詢
   */
  public void testSpringCashe() {
    //查詢了兩次SQL
    testDao.selectBySpring("1");
  }
  /**
   * 開啟事務(wù)的spring Mybatis查詢
   */
  @Transactional
  public void testSpringCasheWithTran() {
    //spring開啟事務(wù)后，查詢1次SQL
    testDao.selectBySpring("1");
  }
  /**
   * mybatis查詢
   */
  public void testCash5Mybatise() {
    //原生態(tài)mybatis，查詢了1次SQL
    testDao.selectByMybatis("1");
  }
}

輸出結(jié)果：

testSpringCashe()方法執(zhí)行了兩次SQL， 其它都是一次

源碼追蹤:

先看mybatis里的sqlSession

跟蹤到最后 調(diào)用到 org.apache.ibatis.executor.BaseExecutor的query方法

try {
   queryStack++;
   list = resultHandler == null ? (List<E>) localCache.getObject(key) : null; //先從緩存中取
   if (list != null) {
    handleLocallyCachedOutputParameters(ms, key, parameter, boundSql); //注意里面的key是CacheKey
   } else {
    list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
   }

貼下是怎么取出緩存數(shù)據(jù)的代碼

private void handleLocallyCachedOutputParameters(MappedStatement ms, CacheKey key, Object parameter, BoundSql boundSql) {
  if (ms.getStatementType() == StatementType.CALLABLE) {
   final Object cachedParameter = localOutputParameterCache.getObject(key);//從localOutputParameterCache取出緩存對(duì)象
   if (cachedParameter != null && parameter != null) {
    final MetaObject metaCachedParameter = configuration.newMetaObject(cachedParameter);
    final MetaObject metaParameter = configuration.newMetaObject(parameter);
    for (ParameterMapping parameterMapping : boundSql.getParameterMappings()) {
     if (parameterMapping.getMode() != ParameterMode.IN) {
      final String parameterName = parameterMapping.getProperty();
      final Object cachedValue = metaCachedParameter.getValue(parameterName);
      metaParameter.setValue(parameterName, cachedValue);
     }
    }
   }
  }
 }

　

發(fā)現(xiàn)就是從localOutputParameterCache就是一個(gè)PerpetualCache, PerpetualCache維護(hù)了個(gè)map,就是session的緩存本質(zhì)了。

重點(diǎn)可以關(guān)注下面兩個(gè)累的邏輯

PerpetualCache ， 兩個(gè)參數(shù)， id和map

CacheKey，map中存的key，它有覆蓋equas方法，當(dāng)獲取緩存時(shí)調(diào)用.

這種本地map緩存獲取對(duì)象的缺點(diǎn)，就我踩坑經(jīng)驗(yàn)（以前我也用map去實(shí)現(xiàn)的本地緩存），就是獲取的對(duì)象非clone的，返回的兩個(gè)對(duì)象都是一個(gè)地址

而在spring中一般都是用sqlSessionTemplate，如下

<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <property name="configLocation" value="classpath:configuration.xml" />
    <property name="mapperLocations">
      <list>
        <value>classpath*:com/hejb/sqlmap/*.xml</value>
      </list>
    </property>
  </bean>
  <bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
    <constructor-arg ref="sqlSessionFactory" />
  </bean>

在SqlSessionTemplate中執(zhí)行SQL的session都是通過(guò)sqlSessionProxy來(lái)，sqlSessionProxy的生成在構(gòu)造函數(shù)中賦值，如下：

this.sqlSessionProxy = (SqlSession) newProxyInstance(
    SqlSessionFactory.class.getClassLoader(),
    new Class[] { SqlSession.class },
    new SqlSessionInterceptor());

sqlSessionProxy通過(guò)JDK的動(dòng)態(tài)代理方法生成的一個(gè)代理類，主要邏輯在InvocationHandler對(duì)執(zhí)行的方法進(jìn)行了前后攔截，主要邏輯在invoke中，包好了每次執(zhí)行對(duì)sqlsesstion的創(chuàng)建，common，關(guān)閉

代碼如下：

private class SqlSessionInterceptor implements InvocationHandler {
  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
   // 每次執(zhí)行前都創(chuàng)建一個(gè)新的sqlSession
   SqlSession sqlSession = getSqlSession(
     SqlSessionTemplate.this.sqlSessionFactory,
     SqlSessionTemplate.this.executorType,
     SqlSessionTemplate.this.exceptionTranslator);
   try {
   // 執(zhí)行方法
    Object result = method.invoke(sqlSession, args);
    if (!isSqlSessionTransactional(sqlSession, SqlSessionTemplate.this.sqlSessionFactory)) {
     // force commit even on non-dirty sessions because some databases require
     // a commit/rollback before calling close()
     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 {
    if (sqlSession != null) {
     closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
    }
   }
  }
 }

因?yàn)槊看味歼M(jìn)行創(chuàng)建，所以就用不上sqlSession的緩存了.

對(duì)于開啟了事務(wù)為什么可以用上呢， 跟入getSqlSession方法

如下：

public static SqlSession getSqlSession(SqlSessionFactory sessionFactory, ExecutorType executorType, PersistenceExceptionTranslator exceptionTranslator) {
  notNull(sessionFactory, NO_SQL_SESSION_FACTORY_SPECIFIED);
  notNull(executorType, NO_EXECUTOR_TYPE_SPECIFIED);
  SqlSessionHolder holder = (SqlSessionHolder) TransactionSynchronizationManager.getResource(sessionFactory);
  // 首先從SqlSessionHolder里取出session
  SqlSession session = sessionHolder(executorType, holder);
  if (session != null) {
   return session;
  }
  if (LOGGER.isDebugEnabled()) {
   LOGGER.debug("Creating a new SqlSession");
  }
  session = sessionFactory.openSession(executorType);
  registerSessionHolder(sessionFactory, executorType, exceptionTranslator, session);
  return session;
 }

在里面維護(hù)了個(gè)SqlSessionHolder，關(guān)聯(lián)了事務(wù)與session，如果存在則直接取出，否則則新建個(gè)session，所以在有事務(wù)的里，每個(gè)session都是同一個(gè)，故能用上緩存了

以上所述是小編給大家介紹的spring 整合mybatis后用不上session緩存的原因分析，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)億速云網(wǎng)站的支持！

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手