fix(): 修复run()方法

master
xinzirun 2024-09-21 12:01:34 +08:00
parent be2fc79d49
commit d81b53910e
1 changed files with 6 additions and 18 deletions

View File

@ -91,29 +91,17 @@ public class ManyDataSource implements ApplicationRunner {
*/ */
@Bean @Bean
public DynamicDataSource dynamicDataSource(DruidDataSourceFactory druidDataSourceFactory) { public DynamicDataSource dynamicDataSource(DruidDataSourceFactory druidDataSourceFactory) {
List<DataSourceInfo> sourceInfoList = dataSourceInfoList().stream() Map<Object, Object> dataSourceMap = dataSourceInfoList().stream()
.map(entInfo -> DataSourceInfo.hostAndPortBuild( .map(entInfo -> DataSourceInfo.hostAndPortBuild(
entInfo.getEntCode(), entInfo.getEntCode(),
entInfo.getIp(), entInfo.getIp(),
entInfo.getPort() entInfo.getPort()
) )
).toList(); )
.collect(Collectors.toMap(
Map<Object, Object> dataSourceMap = sourceInfoList.stream().collect(Collectors.toMap(
dataSourceInfo -> dataSourceInfo.getKey(), dataSourceInfo -> dataSourceInfo.getKey(),
dataSourceInfo -> druidDataSourceFactory.create(dataSourceInfo) dataSourceInfo -> druidDataSourceFactory.create(dataSourceInfo)
)); ));
// Map<Object, Object> dataSourceMap = dataSourceInfoList().stream()
// .map(entInfo -> DataSourceInfo.hostAndPortBuild(
// entInfo.getEntCode(),
// entInfo.getIp(),
// entInfo.getPort()
// )
// )
// .collect(Collectors.toMap(
// dataSourceInfo -> dataSourceInfo.getKey(),
// dataSourceInfo -> druidDataSourceFactory.create(dataSourceInfo)
// ));
//设置动态数据源 //设置动态数据源
DynamicDataSource dynamicDataSource = new DynamicDataSource(); DynamicDataSource dynamicDataSource = new DynamicDataSource();