溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
因為一直用spring整合了mybatis，所以很少用到mybatis的session緩存。 習慣是本地緩存自己用map寫或者引入第三方的本地緩存框架ehcache，Guava
所以提出來糾結下
實驗下（spring整合mybatis略，網上一堆），先看看mybatis級別的session的緩存
放出打印sql語句
configuration.xml 加入
<settings>
<!-- 打印查詢語句 -->
<setting name="logImpl" value="STDOUT_LOGGING" />
</settings>
測試源代碼如下：
dao類
/**
* 測試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;
}
}
測試service類
@Component
public class TestService {
@Autowired
private TestDao testDao;
/**
* 未開啟事務的spring Mybatis查詢
*/
public void testSpringCashe() {
//查詢了兩次SQL
testDao.selectBySpring("1");
}
/**
* 開啟事務的spring Mybatis查詢
*/
@Transactional
public void testSpringCasheWithTran() {
//spring開啟事務后，查詢1次SQL
testDao.selectBySpring("1");
}
/**
* mybatis查詢
*/
public void testCash5Mybatise() {
//原生態mybatis，查詢了1次SQL
testDao.selectByMybatis("1");
}
}
輸出結果：
testSpringCashe()方法執行了兩次SQL， 其它都是一次
源碼追蹤:
先看mybatis里的sqlSession
跟蹤到最后 調用到 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);
}
貼下是怎么取出緩存數據的代碼
private void handleLocallyCachedOutputParameters(MappedStatement ms, CacheKey key, Object parameter, BoundSql boundSql) {
if (ms.getStatementType() == StatementType.CALLABLE) {
final Object cachedParameter = localOutputParameterCache.getObject(key);//從localOutputParameterCache取出緩存對象
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);
}
}
}
}
}
發現就是從localOutputParameterCache就是一個PerpetualCache, PerpetualCache維護了個map,就是session的緩存本質了。
重點可以關注下面兩個累的邏輯
PerpetualCache ， 兩個參數， id和map
CacheKey，map中存的key，它有覆蓋equas方法，當獲取緩存時調用.
這種本地map緩存獲取對象的缺點，就我踩坑經驗（以前我也用map去實現的本地緩存），就是獲取的對象非clone的，返回的兩個對象都是一個地址
而在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中執行SQL的session都是通過sqlSessionProxy來，sqlSessionProxy的生成在構造函數中賦值，如下：
this.sqlSessionProxy = (SqlSession) newProxyInstance(
SqlSessionFactory.class.getClassLoader(),
new Class[] { SqlSession.class },
new SqlSessionInterceptor());
sqlSessionProxy通過JDK的動態代理方法生成的一個代理類，主要邏輯在InvocationHandler對執行的方法進行了前后攔截，主要邏輯在invoke中，包好了每次執行對sqlsesstion的創建，common，關閉
代碼如下：
private class SqlSessionInterceptor implements InvocationHandler {
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
// 每次執行前都創建一個新的sqlSession
SqlSession sqlSession = getSqlSession(
SqlSessionTemplate.this.sqlSessionFactory,
SqlSessionTemplate.this.executorType,
SqlSessionTemplate.this.exceptionTranslator);
try {
// 執行方法
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);
}
}
}
}
因為每次都進行創建，所以就用不上sqlSession的緩存了.
對于開啟了事務為什么可以用上呢， 跟入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;
}
在里面維護了個SqlSessionHolder，關聯了事務與session，如果存在則直接取出，否則則新建個session，所以在有事務的里，每個session都是同一個，故能用上緩存了
以上所述是小編給大家介紹的spring 整合mybatis后用不上session緩存的原因分析，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對億速云網站的支持！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
