From 791b8c88d67767c9847c7c052faca3e65ec36016 Mon Sep 17 00:00:00 2001 From: zhaowenxuan <chacca165@163.com> Date: 星期五, 07 二月 2025 13:59:27 +0800 Subject: [PATCH] 配置动态切库类以及拦截器切库 --- ltkj-hosp/src/main/java/com/ltkj/db/HospDynamicDataSource.java | 9 ++++++--- 1 files changed, 6 insertions(+), 3 deletions(-) diff --git a/ltkj-hosp/src/main/java/com/ltkj/db/DynamicDataSource.java b/ltkj-hosp/src/main/java/com/ltkj/db/HospDynamicDataSource.java similarity index 67% rename from ltkj-hosp/src/main/java/com/ltkj/db/DynamicDataSource.java rename to ltkj-hosp/src/main/java/com/ltkj/db/HospDynamicDataSource.java index 8d6bb07..1cd8baa 100644 --- a/ltkj-hosp/src/main/java/com/ltkj/db/DynamicDataSource.java +++ b/ltkj-hosp/src/main/java/com/ltkj/db/HospDynamicDataSource.java @@ -1,14 +1,17 @@ package com.ltkj.db; +import org.springframework.context.annotation.Bean; import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource; +import org.springframework.stereotype.Component; import javax.sql.DataSource; import java.util.HashMap; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; -public class DynamicDataSource extends AbstractRoutingDataSource { +public class HospDynamicDataSource extends AbstractRoutingDataSource { - private final Map<Object, Object> targetDataSources = new HashMap<>(); // 瀛樺偍鎵�鏈夋暟鎹簮 + private final Map<Object, Object> targetDataSources = new ConcurrentHashMap<>(); // 瀛樺偍鎵�鏈夋暟鎹簮 @Override protected Object determineCurrentLookupKey() { @@ -18,7 +21,7 @@ // 娣诲姞鐩爣鏁版嵁婧� public void addTargetDataSource(String key, DataSource dataSource) { targetDataSources.put(key, dataSource); - super.setTargetDataSources(targetDataSources); // 鏇存柊鐩爣鏁版嵁婧� + super.setTargetDataSources(new ConcurrentHashMap<>(targetDataSources)); // 鏇存柊鐩爣鏁版嵁婧� super.afterPropertiesSet(); // 閲嶆柊鍒濆鍖栨暟鎹簮 } -- Gitblit v1.8.0