SpringBoot多数据源处理方案、多租户实战

在Spring Boot中实现多租户通常涉及到动态数据源的切换。以下是一个简化的例子，展示了如何在Spring Boot应用中实现多租户数据源的动态切换：

@Configuration
public class DataSourceConfig {
 
    @Bean
    public DataSourceRouting dynamicDataSource(@Qualifier("tenantDatabaseMap") Map<String, DataSource> tenantDatabaseMap) {
        return new DataSourceRouting(tenantDatabaseMap);
    }
 
    @Bean
    @Primary
    public TenantDatabaseContext tenantDatabaseContext() {
        return new TenantDatabaseContext();
    }
 
    @Bean
    public TenantDatabaseHandler tenantDatabaseHandler() {
        return new TenantDatabaseHandler();
    }
 
    @Bean
    public SqlSessionFactory sqlSessionFactory(DataSource dynamicDataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dynamicDataSource);
        return sqlSessionFactoryBean.getObject();
    }
 
    @Bean
    public PlatformTransactionManager transactionManager(DataSource dynamicDataSource) {
        return new DataSourceTransactionManager(dynamicDataSource);
    }
}
 
public class DataSourceRouting implements DataSource {
 
    private final Map<String, DataSource> dataSourceMap;
    private DataSource currentDataSource;
 
    public DataSourceRouting(Map<String, DataSource> dataSourceMap) {
        this.dataSourceMap = dataSourceMap;
    }
 
    public void switchTenant(String tenantId) {
        currentDataSource = dataSourceMap.get(tenantId);
    }
 
    // Delegate data source methods to the current data source
    @Override
    public Connection getConnection() throws SQLException {
        return currentDataSource.getConnection();
    }
 
    @Override
    public Connection getConnection(String username, String password) throws SQLException {
        return currentDataSource.getConnection(username, password);
    }
 
    // ... other data source methods
}
 
public class TenantDatabaseContext implements ApplicationContextAware {
 
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
 
    public static void setCurrentTenant(String tenantId) {
        contextHolder.set(tenantId);
    }
 
    public static String getCurrentTenant() {
        return contextHolder.get();
    }
 
    public static void clear() {
        contextHolder.remove();
    }
 
    // ... ApplicationContextAware implementation
}
 
public class TenantDatabaseHandl