配置动态切库类以及拦截器切库

zhaowenxuan

2025-02-07 791b8c88d67767c9847c7c052faca3e65ec36016

 ltkj-hosp/src/main/java/com/ltkj/db/DataSourceConfig.java

@@ -1,47 +1,49 @@
package com.ltkj.db;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;

//@Configuration
@Configuration
public class DataSourceConfig {

    // 使用代码
//    try {
//        long id = Long.parseLong(request.getAttribute("id").toString());
//        DataSourceContextHolder.setDataSourceKey(String.valueOf(id));
//        dataSourceConfig.addDataSource(String.valueOf(id)); // 确保数据源已注册
//        if (log.getSize()>50) log.setSize(50);
//        if (log.getLang().equals("zh-cn")) log.setLang("zh");
//        return serverLogService.getLog(log,id);
//    }finally {
//        DataSourceContextHolder.setDataSourceKey("default"); // 切换回主库
//    }

    private static final String DEFAULT_DATA_SOURCE_KEY = "default"; // 主库的标识
    private final Map<String, DataSource> dataSourceCache = new HashMap<>(); // 数据源缓存

    @Value("${config.properties}")
    private String url;

    @Value("${config.path}")
    private String path;

    // 从 application.yml 中读取主库的配置
    @Value("${spring.datasource.url}")
//    @Value("${spring.datasource.url}")
    private String primaryUrl;

    @Value("${spring.datasource.username}")
    private String primaryPort;

    //    @Value("${spring.datasource.username}")
    private String primaryUsername;

    @Value("${spring.datasource.password}")
    //    @Value("${spring.datasource.password}")
    private String primaryPassword;

    @Value("${dbUrl}")
    //    @Value("${dbUrl}")
    private String dbUrl;

    @Bean
    public DataSource dynamicDataSource() {
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
    @Bean(name = "hospDynamicDataSources")
    public DataSource hospDynamicDataSources() {
        HospDynamicDataSource dynamicDataSource = new HospDynamicDataSource();

        // 初始化默认数据源为主库
        dynamicDataSource.addTargetDataSource(DEFAULT_DATA_SOURCE_KEY, createDataSource(primaryUrl, primaryUsername, primaryPassword));
@@ -60,15 +62,30 @@
    }

    // 根据用户 ID 动态获取数据源
    public void addDataSource(String userId) {
        String dbName = "scum_admin_user_" + userId;
    public void addDataSource(String dbName) {
        FileInputStream fis = null;
        Properties props = new Properties();
        try {
            fis = new FileInputStream(url);
            props.load(fis);
            fis.close();
            dbUrl = props.getProperty("ip");
            primaryPassword = props.getProperty("password");
            primaryPort = props.getProperty("prot");
            primaryUsername = props.getProperty("username");
        } catch (IOException e) {
            throw new RuntimeException("读取配置文件失败", e);
        }

        // 检查缓存中是否已经存在该数据源
        if (!dataSourceCache.containsKey(userId)) {
            String url = "jdbc:mysql://"+dbUrl+":3306/"+dbName;
            DataSource dataSource = createDataSource(url, primaryUsername, primaryPassword);
            dataSourceCache.put(userId, dataSource);
            DynamicDataSource dynamicDataSource = (DynamicDataSource) dynamicDataSource();
            dynamicDataSource.addTargetDataSource(userId, dataSource);
        if (!dataSourceCache.containsKey(dbName)) {
            synchronized (this) {
                String url = "jdbc:mysql://" + dbUrl + ":" + primaryPort + "/" + dbName;
                DataSource dataSource = createDataSource(url, primaryUsername, primaryPassword);
                dataSourceCache.put(dbName, dataSource);
                HospDynamicDataSource dynamicDataSource = (HospDynamicDataSource) hospDynamicDataSources();
                dynamicDataSource.addTargetDataSource(dbName, dataSource);
            }
        }
    }
}