diff --git a/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditManager.java b/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditManager.java index a94a85ce..56d6565a 100644 --- a/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditManager.java +++ b/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditManager.java @@ -16,6 +16,7 @@ package com.mybatisflex.core.audit; import com.mybatisflex.core.FlexConsts; +import com.mybatisflex.core.FlexGlobalConfig; import com.mybatisflex.core.datasource.DataSourceKey; import com.mybatisflex.core.util.StringUtil; import org.apache.ibatis.mapping.BoundSql; @@ -102,9 +103,12 @@ public class AuditManager { return supplier.execute(); } String key = DataSourceKey.get(); - if (StringUtil.isNotBlank(key)) { - auditMessage.setDsName(key); + if (StringUtil.isBlank(key)) { + key = FlexGlobalConfig.getDefaultConfig() + .getDataSource() + .getDefaultDataSourceKey(); } + auditMessage.setDsName(key); auditMessage.setQueryTime(clock.getTick()); try { T result = supplier.execute(); diff --git a/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditMessage.java b/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditMessage.java index b7f9585c..affc0fd4 100644 --- a/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditMessage.java +++ b/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/AuditMessage.java @@ -96,7 +96,7 @@ public class AuditMessage implements Serializable { private long elapsedTime; /** - * 数据库名称 + * 数据库名称。 */ private String dsName;