我正在将Hibernate 4.3.11.Final与随附的ehcache模块一起使用。我想在JUnit(v 4.11)测试中验证我的二级缓存是否配置正确,但是我不知道如何强制这种情况。我有一个简单的方法来通过其ID检索实体,即
public T findById(final Serializable id)
{
T ret = null;
if (id != null)
{
ret = (T) m_entityManager.find(persistentClass, id);
} // if
return ret;
}
然后在我的JUnit测试中
@Test
public void testSecondLevelCache()
{
long hitCount = m_cache.getStatistics().getCacheHits();
final String countryId = m_testProps.getProperty("test.country.id");
m_countryDao.findById(countryId);
m_countryDao.findById(countryId);
但是,第二次调用将达到Hiberntae的一级缓存,而重复调用DAO方法也将达到Hibernate的一级缓存。如何强制命中二级缓存?
编辑:下面是如何在我的Spring应用程序上下文中配置事务管理器和其他相关部分的方法...
<cache:annotation-driven />
<bean id="cacheManager"
class="org.springframework.cache.ehcache.EhCacheCacheManager"
p:cacheManager-ref="ehcache"/>
<bean id="ehcache" class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean"
p:configLocation="classpath:ehcache.xml"
p:shared="true" />
<util:map id="jpaPropertyMap">
<entry key="hibernate.show_sql" value="true" />
<entry key="hibernate.dialect" value="org.mainco.subco.core.jpa.SubcoMysql5Dialect" />
<entry key="hibernate.cache.region.factory_class" value="org.hibernate.cache.ehcache.EhCacheRegionFactory" />
<entry key="hibernate.cache.provider_class" value="org.hibernate.cache.EhCacheProvider" />
<entry key="hibernate.cache.use_second_level_cache" value="true" />
<entry key="hibernate.cache.use_query_cache" value="false" />
<entry key="hibernate.generate_statistics" value="true" />
<entry key="javax.persistence.sharedCache.mode" value="ENABLE_SELECTIVE" />
</util:map>
<bean id="sharedEntityManager"
class="org.springframework.orm.jpa.support.SharedEntityManagerBean">
<property name="entityManagerFactory" ref="entityManagerFactory" />
</bean>
<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
<property name="entityManagerFactory" ref="entityManagerFactory" />
</bean>
最佳答案
更好地使用不同的会话以避免一级缓存。
首先,您需要从测试或类中删除@Transactional
批注,以便您手动控制事务。
其次,编写测试以将两个连续事务与两个EntityManager
实例一起使用。
@Test
public void testSecondLevelCache() {
long hitCount = m_cache.getStatistics().getCacheHits();
final String countryId = m_testProps.getProperty("test.country.id");
transactionTemplate.execute((TransactionCallback<Void>) transactionStatus -> {
m_countryDao.findById(countryId);
return null;
});
transactionTemplate.execute((TransactionCallback<Void>) transactionStatus -> {
m_countryDao.findById(countryId);
return null;
});
}