From d9006551fff47c172ea6a0672af7dd21df34f28f Mon Sep 17 00:00:00 2001
From: zhaowenxuan <chacca165@163.com>
Date: 星期六, 15 二月 2025 15:05:45 +0800
Subject: [PATCH] 20250215
---
ltkj-framework/src/main/java/com/ltkj/framework/aspectj/DataSourceAspect.java | 13 +++++++++++++
1 files changed, 13 insertions(+), 0 deletions(-)
diff --git a/ltkj-framework/src/main/java/com/ltkj/framework/aspectj/DataSourceAspect.java b/ltkj-framework/src/main/java/com/ltkj/framework/aspectj/DataSourceAspect.java
index 1dccc09..71e06a4 100644
--- a/ltkj-framework/src/main/java/com/ltkj/framework/aspectj/DataSourceAspect.java
+++ b/ltkj-framework/src/main/java/com/ltkj/framework/aspectj/DataSourceAspect.java
@@ -2,6 +2,7 @@
import java.util.Objects;
+import com.ltkj.db.DataSourceContextHolder;
import com.ltkj.framework.datasource.DynamicDataSourceContextHolder;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
@@ -35,6 +36,10 @@
@Around("dsPointCut()")
public Object around(ProceedingJoinPoint point) throws Throwable {
+ String key = DataSourceContextHolder.getDataSourceKey();
+ logger.info("鎵ц涔嬪墠");
+ logger.info("DataSourceContextHolder ->{}",key);
+ logger.info("DynamicDataSourceContextHolder ->{}",DynamicDataSourceContextHolder.getDataSourceType());
DataSource dataSource = getDataSource(point);
if (StringUtils.isNotNull(dataSource)) {
@@ -44,8 +49,16 @@
try {
return point.proceed();
} finally {
+ logger.info("鎵ц涔嬪悗");
+ logger.info("DataSourceContextHolder ->{}",key);
+ logger.info("DynamicDataSourceContextHolder ->{}",DynamicDataSourceContextHolder.getDataSourceType());
// 閿�姣佹暟鎹簮 鍦ㄦ墽琛屾柟娉曚箣鍚�
DynamicDataSourceContextHolder.clearDataSourceType();
+// DataSourceContextHolder.setDataSourceKey(key);
+// DynamicDataSourceContextHolder.setDataSourceType(key);
+ logger.info("鎵ц涔嬪悗 clear涔嬪悗");
+ logger.info("DataSourceContextHolder ->{}",key);
+ logger.info("DynamicDataSourceContextHolder ->{}",DynamicDataSourceContextHolder.getDataSourceType());
}
}
--
Gitblit v1.8.0