diff --git a/src/main/java/neatlogic/framework/dao/plugin/ExceptionAuditInterceptor.java b/src/main/java/neatlogic/framework/dao/plugin/ExceptionAuditInterceptor.java index e070ce534b006e22345ac7c5132fe8ba81102543..65bb2f04ccdeed869e9d941cb84b39cdd260b475 100644 --- a/src/main/java/neatlogic/framework/dao/plugin/ExceptionAuditInterceptor.java +++ b/src/main/java/neatlogic/framework/dao/plugin/ExceptionAuditInterceptor.java @@ -55,8 +55,10 @@ public class ExceptionAuditInterceptor implements Interceptor { String key = Thread.currentThread().getName() + "#" + SnowflakeUtil.uniqueLong(); try { MappedStatement mappedStatement = mappedStatementThreadLocal.get(); - String sqlId = mappedStatement.getId(); - SQLTransientConnectionExceptionAudit.putExecutingSQL(key, sqlId); + if (mappedStatement != null) { + String sqlId = mappedStatement.getId(); + SQLTransientConnectionExceptionAudit.putExecutingSQL(key, sqlId); + } return invocation.proceed(); } finally { SQLTransientConnectionExceptionAudit.removeExecutingSQL(key); diff --git a/src/main/java/neatlogic/framework/dao/plugin/SqlCostInterceptor.java b/src/main/java/neatlogic/framework/dao/plugin/SqlCostInterceptor.java index a6cf6a16992c0ab29639accd7df3be0d5e00f0b0..a773855b69bbd3299a7985b3add5dab4dd0333fe 100644 --- a/src/main/java/neatlogic/framework/dao/plugin/SqlCostInterceptor.java +++ b/src/main/java/neatlogic/framework/dao/plugin/SqlCostInterceptor.java @@ -162,7 +162,7 @@ public class SqlCostInterceptor implements Interceptor { // 执行完上面的任务后,不改变原有的sql执行过程 Object val = invocation.proceed(); if (sqlAuditVo != null) { - if (QUERY_FROM_DATABASE_INSTANCE.get()) { + if (Boolean.TRUE.equals(QUERY_FROM_DATABASE_INSTANCE.get())) { // sql语句被执行,没有使用到缓存 sqlAuditVo.setUseCacheLevel(StringUtils.EMPTY); } else {