From 8aed0049e5bd41aab09862b4bdba24a39a089346 Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Wed, 19 Nov 2025 15:57:32 +0800
Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E5=BA=93=E8=BF=9E=E6=8E=A5=E6=B1=A0=E8=8E=B7=E5=8F=96=E4=B8=8D?=
 =?UTF-8?q?=E5=88=B0=E8=BF=9E=E6=8E=A5=E6=97=B6=E8=AE=B0=E5=BD=95=E7=BA=BF?=
 =?UTF-8?q?=E7=A8=8B=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

关联 #[1551594485678080]数据库连接池获取不到连接时记录线程信息 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1551594485678080
---
 .../framework/dao/plugin/ExceptionAuditInterceptor.java     | 6 ++++--
 .../neatlogic/framework/dao/plugin/SqlCostInterceptor.java  | 2 +-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/main/java/neatlogic/framework/dao/plugin/ExceptionAuditInterceptor.java b/src/main/java/neatlogic/framework/dao/plugin/ExceptionAuditInterceptor.java
index e070ce534..65bb2f04c 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 a6cf6a169..a773855b6 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 {
-- 
Gitee