@Intercepts({@Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class})})
public class CacheInterceptor implements Interceptor {
...
}
public Object intercept(Invocation invocation) throws Throwable {
Executor executorProxy = (Executor) invocation.getTarget();
MetaObject metaExecutor = MetaObject.forObject(executorProxy, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY);
// 分离代理对象链
while (metaExecutor.hasGetter("h")) {
Object object = metaExecutor.getValue("h");
metaExecutor = MetaObject.forObject(object, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY);
}
// 分离最后一个代理对象的目标类
while (metaExecutor.hasGetter("target")) {
Object object = metaExecutor.getValue("target");
metaExecutor = MetaObject.forObject(object, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY);
}
Object[] args = invocation.getArgs();
return this.query(metaExecutor, args);
}
public <E> List<E> query(MetaObject metaExecutor, Object[] args) throws SQLException {
MappedStatement ms = (MappedStatement) args[0];
Object parameterObject = args[1];
RowBounds rowBounds = (RowBounds) args[2];
ResultHandler resultHandler = (ResultHandler) args[3];
BoundSql boundSql = ms.getBoundSql(parameterObject);
// 改写key的生成
CacheKey cacheKey = createCacheKey(ms, parameterObject, rowBounds, boundSql);
Executor executor = (Executor) metaExecutor.getOriginalObject();
return executor.query(ms, parameterObject, rowBounds, resultHandler, cacheKey, boundSql);
}
private CacheKey createCacheKey(MappedStatement ms, Object parameterObject, RowBounds rowBounds, BoundSql boundSql) {
Configuration configuration = ms.getConfiguration();
pageSqlId = configuration.getVariables().getProperty("pageSqlId");
if (null == pageSqlId || "".equals(pageSqlId)) {
logger.warn("Property pageSqlId is not setted,use default '.*Page$' ");
pageSqlId = defaultPageSqlId;
}
CacheKey cacheKey = new CacheKey();
cacheKey.update(ms.getId());
cacheKey.update(rowBounds.getOffset());
cacheKey.update(rowBounds.getLimit());
List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
// 解决自动生成SQL,SQL语句为空导致key生成错误的bug
if (null == boundSql.getSql() || "".equals(boundSql.getSql())) {
String id = ms.getId();
id = id.substring(id.lastIndexOf(".") + 1);
String newSql = null;
try {
if ("select".equals(id)) {
newSql = SqlBuilder.buildSelectSql(parameterObject);
}
SqlSource sqlSource = buildSqlSource(configuration, newSql, parameterObject.getClass());
parameterMappings = sqlSource.getBoundSql(parameterObject).getParameterMappings();
cacheKey.update(newSql);
} catch (Exception e) {
logger.error("Update cacheKey error.", e);
}
} else {
cacheKey.update(boundSql.getSql());
}
MetaObject metaObject = MetaObject.forObject(parameterObject, DEFAULT_OBJECT_FACTORY, DEFAULT_OBJECT_WRAPPER_FACTORY);
if (parameterMappings.size() > 0 && parameterObject != null) {
TypeHandlerRegistry typeHandlerRegistry = ms.getConfiguration().getTypeHandlerRegistry();
if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
cacheKey.update(parameterObject);
} else {
for (ParameterMapping parameterMapping : parameterMappings) {
String propertyName = parameterMapping.getProperty();
if (metaObject.hasGetter(propertyName)) {
cacheKey.update(metaObject.getValue(propertyName));
} else if (boundSql.hasAdditionalParameter(propertyName)) {
cacheKey.update(boundSql.getAdditionalParameter(propertyName));
}
}
}
}
// 当需要分页查询时,将page参数里的当前页和每页数加到cachekey里
if (ms.getId().matches(pageSqlId) && metaObject.hasGetter("page")) {
PageParameter page = (PageParameter) metaObject.getValue("page");
if (null != page) {
cacheKey.update(page.getCurrentPage());
cacheKey.update(page.getPageSize());
}
}
return cacheKey;
}
public Object plugin(Object target) {
// 当目标类是CachingExecutor类型时,才包装目标类,否者直接返回目标本身,减少目标被代理的
// 次数
if (target instanceof CachingExecutor) {
return Plugin.wrap(target, this);
} else {
return target;
}
}
机械节能产品生产企业官网模板...
大气智能家居家具装修装饰类企业通用网站模板...
礼品公司网站模板
宽屏简约大气婚纱摄影影楼模板...
蓝白WAP手机综合医院类整站源码(独立后台)...苏ICP备2024110244号-2 苏公网安备32050702011978号 增值电信业务经营许可证编号:苏B2-20251499 | Copyright 2018 - 2025 源码网商城 (www.ymwmall.com) 版权所有