admin/mybatis-flex
1
0
Fork 0
mirror of https://gitee.com/mybatis-flex/mybatis-flex.git synced 2025-12-06 16:48:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: fix and close #ICLQQ3

Browse Source
This commit is contained in:
Michael Yang 2025-07-14 12:48:51 +08:00
parent 97bf853364
commit cc2ca249e0
1 changed files with 4 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
mybatis-flex-core/src/main/java/com/mybatisflex/core/datasource/DataSourceKey.java
View File

@ -34,9 +34,11 @@ public class DataSourceKey {
public static void use(String dataSourceKey) { public static void use(String dataSourceKey) {
Deque<String> deque = lookup.get(); Deque<String> deque = lookup.get();
if (deque != null) { if (deque == null) {
deque.push(dataSourceKey); deque = new ArrayDeque<>(1);
lookup.set(deque);
} }
deque.push(dataSourceKey);
} }
public static String get() { public static String get() {
@ -95,31 +97,4 @@ public class DataSourceKey {
return shardingDsKey != null ? shardingDsKey : dataSource; return shardingDsKey != null ? shardingDsKey : dataSource;
} }
// === For Removal ===
@Deprecated
public static String getByManual() {
throw new UnsupportedOperationException("使用 DataSource.get() 代替。");
}
@Deprecated
public static String getByAnnotation() {
throw new UnsupportedOperationException("使用 DataSource.get() 代替。");
}
@Deprecated
public static void useWithAnnotation(String dataSourceKey) {
throw new UnsupportedOperationException("使用 DataSource.use(String) 代替。");
}
@Deprecated
public static void setAnnotationKeyThreadLocal(ThreadLocal<String> annotationKeyThreadLocal) {
throw new UnsupportedOperationException("使用 DataSource.setThreadLocal(ThreadLocal<Deque<String>>) 代替。");
}
@Deprecated
public static void setManualKeyThreadLocal(ThreadLocal<String> manualKeyThreadLocal) {
throw new UnsupportedOperationException("使用 DataSource.setThreadLocal(ThreadLocal<Deque<String>>) 代替。");
}
} }