java多数据源案例使用项目

package com.xiaoming.dds.config; import com.xiaoming.dds.enums.DynamicDbEnum; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.jdbc.DataSourceBuilder; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import javax.sql.DataSource; import java.util.HashMap; @Configuration public class DatabaseConfig { @Autowired private DataSourceDB2Property dataSourceDB2Property; @Autowired private DataSourceDB1Property dataSourceDB1Property; /** * 子公司1员工数据库 * @return */ @Bean(name = "DataSource1") @Qualifier("DataSource1") public DataSource dataSource1(){ return DataSourceBuilder.create() .driverClassName(dataSourceDB1Property.getDriverClassName()) .url(dataSourceDB1Property.getUrl()) .username(dataSourceDB1Property.getUsername()) .password(dataSourceDB1Property.getPassword()) .build(); } /** * 子公司2员工数据库 * @return */ @Bean(name = "DataSource2") @Qualifier("DataSource2") public DataSource dataSource2(){ return DataSourceBuilder.create() .driverClassName(dataSourceDB2Property.getDriverClassName()) .url(dataSourceDB2Property.getUrl()) .username(dataSourceDB2Property.getUsername()) .password(dataSourceDB2Property.getPassword()) .build(); } @Bean(name = "dynamicDataSource") @Primary //配置优先生效 public DataSource dynamicDataSource() { CustomDynamicDatasource datasource = new CustomDynamicDatasource(); //设置数据源 datasource.dataSourceMap = new HashMap<>(); datasource.dataSourceMap.put(DynamicDbEnum.DB1.getDbCode(),dataSource1()); datasource.dataSourceMap.put(DynamicDbEnum.DB2.getDbCode(),dataSource2()); //存放所有数据源 datasource.setTargetDataSources(datasource.dataSourceMap); //设置默认数据源 datasource.setDefaultTargetDataSource(dataSource1()); //存储数据源编码 CustomDynamicDataSourceContextHolder.dataSourceList.addAll(datasource.dataSourceMap.keySet()); return datasource; } }