线上定时任务，在执行时，计算出合同金额不对；
查看日志
2.13 cron
2020-02-13 01:10:00.004 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-6] [com.tangdi.jump.bp.service.sqlmap.support.SqlSessionUtils] DEBUG Fetched SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@12af9e28] from current transaction
2020-02-13 01:10:00.004 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-6] [com.tangdi.jump.bp.service.sqlmap.impl.SqlMapImpl] DEBUG Opened SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@12af9e28] for iBATIS operation
2020-02-13 01:10:00.004 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-6] [com.tangdi.jump.bp.service.sqlmap.support.SqlSessionUtils] DEBUG Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@12af9e28]
2020-02-13 01:10:00.004 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-6] [net.tangdi.gxseas.service.AutoRecon] INFO === 日切日期： 2020-02-07
2020-02-13 01:10:00.004 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-6] [net.tangdi.gxseas.service.AutoRecon] INFO 任务号:A,任务执行步骤:A01,日切日期:20200207
定时任务是执行了，切定时记录时间正确是4月13日，但是应该执行4.12日的,为什么执行了4.07日的
一筹莫展后翻看了mybatis的源码，找到BaseExecutor，代码如下
// Flush the internal cache is force is trueif(ms.isFlushCacheRequired()) {clearLocalCache(); }
List list;
try{ queryStack++;
CacheKey key = createCacheKey(ms,parameter,rowBounds);
list= resultHandler == null ? (List) localCache.getObject(key): null;
if(list!= null) { handleLocallyCachedOutputParameters(ms,key,parameter); }
else{list= queryFromDatabase(ms,parameter,rowBounds,resultHandler,key); } }
finally { queryStack--; }
if(queryStack == 0) {for(DeferredLoad deferredLoad : deferredLoads) { deferredLoad.load(); } }
returnlist;}
resultHandler传入的默认全是null,说明它会缓存拿.最后在日志找到几天的sqlSession都是一样的，证实了缓存猜测；localCache是SqlSession的成员变量.那么就可以断定如果相同的sql在同一个SqlSession执行,就会命中缓存。
解决办法：sql单个查询取消默认缓存
<select id="queryTrastatusDateMax" resultType="String" flushCache="true">
<![CDATA[ SELECT TO_CHAR(MAX(DT),'YYYY-MM-DD') FROM WORK_HOLIDAY WHERE TRASTATUS = '1' ]]>
</select>
mybatis->configuration.xml->setting标签添加：
<setting name="localCacheScope" value="STATEMENT" />
或者
用插件，添加全局拦截
<plugins>
<plugin interceptor="com.xxxxx.interceptor.FlushCacheInterceptor" />
</plugins>
import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Plugin;
import org.apache.ibatis.plugin.Signature;
import org.apache.ibatis.session.ResultHandler;
import org.apache.ibatis.session.RowBounds;
import java.util.Properties;
/**
* 关掉Mybatis所有查询的一级缓存
* Created by mumubin 2017/4/13.
*/
@Intercepts(@Signature(method = "query", type = Executor.class, args = {MappedStatement.class, Object.class,
RowBounds.class, ResultHandler.class}))
public class FlushCacheInterceptor implements Interceptor {
@Override
public Object intercept(Invocation invocation) throws Throwable {
MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];
MappedStatement copy = copyMappedStatementFlushCache(mappedStatement);
invocation.getArgs()[0] = copy;
return invocation.proceed();
}
/**
* 复制MappedStatement 并设置FlushCache=true
* @param mappedStatement
* @return
*/
private MappedStatement copyMappedStatementFlushCache(MappedStatement mappedStatement) {
MappedStatement.Builder builder = new MappedStatement.Builder(mappedStatement.getConfiguration(),
mappedStatement.getId(), mappedStatement.getSqlSource(), mappedStatement.getSqlCommandType());
builder.resource(mappedStatement.getResource());
builder.fetchSize(mappedStatement.getFetchSize());
builder.statementType(mappedStatement.getStatementType());
builder.keyGenerator(mappedStatement.getKeyGenerator());
builder.keyProperty(mappedStatement.getKeyProperty());
builder.timeout(mappedStatement.getTimeout());
builder.resultMaps(mappedStatement.getResultMaps());
builder.resultSetType(mappedStatement.getResultSetType());
builder.cache(mappedStatement.getCache());
builder.useCache(mappedStatement.isUseCache());
builder.parameterMap(mappedStatement.getParameterMap());
builder.flushCacheRequired(true);
return builder.build();
}
@Override
public Object plugin(Object o) {
return Plugin.wrap(o, this);
}
@Override
public void setProperties(Properties properties) {
}
}
