|
2 | 2 |
|
3 | 3 | import org.minbox.framework.api.boot.plugin.datasource.ApiBootDataSource; |
4 | 4 | import org.minbox.framework.api.boot.plugin.datasource.ApiBootDataSourceFactoryBean; |
5 | | -import org.minbox.framework.api.boot.plugin.datasource.aop.interceptor.ApiBootDataSourceSwitchAnnotationInterceptor; |
6 | 5 | import org.minbox.framework.api.boot.plugin.datasource.aop.advistor.ApiBootDataSourceSwitchAdvisor; |
| 6 | +import org.minbox.framework.api.boot.plugin.datasource.aop.interceptor.ApiBootDataSourceSwitchAnnotationInterceptor; |
7 | 7 | import org.minbox.framework.api.boot.plugin.datasource.config.DataSourceConfig; |
| 8 | +import org.minbox.framework.api.boot.plugin.datasource.config.DataSourceDruidConfig; |
8 | 9 | import org.minbox.framework.api.boot.plugin.datasource.routing.ApiBootRoutingDataSource; |
| 10 | +import org.minbox.framework.api.boot.plugin.datasource.support.ApiBootDruidDataSource; |
| 11 | +import org.minbox.framework.api.boot.plugin.datasource.support.ApiBootHikariDataSource; |
9 | 12 | import org.springframework.boot.autoconfigure.AutoConfigureBefore; |
10 | 13 | import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; |
11 | 14 | import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; |
@@ -76,10 +79,13 @@ public DataSource dataSource(ApiBootDataSourceFactoryBean apiBootDataSourceFacto |
76 | 79 | dataSourceConfigMap.putAll(apiBootDataSourceSwitchProperties.getHikari()); |
77 | 80 |
|
78 | 81 | // convert all datasource config |
79 | | - dataSourceConfigMap.keySet().stream().forEach(druidPoolName -> { |
80 | | - DataSourceConfig dataSourceConfig = dataSourceConfigMap.get(druidPoolName); |
| 82 | + dataSourceConfigMap.keySet().stream().forEach(poolName -> { |
| 83 | + DataSourceConfig dataSourceConfig = dataSourceConfigMap.get(poolName); |
81 | 84 | // set data source pool name |
82 | | - dataSourceConfig.setPoolName(druidPoolName); |
| 85 | + dataSourceConfig.setPoolName(poolName); |
| 86 | + // datasource type |
| 87 | + dataSourceConfig.setDataSourceType(dataSourceConfig instanceof DataSourceDruidConfig ? ApiBootDruidDataSource.class : ApiBootHikariDataSource.class); |
| 88 | + |
83 | 89 | // after convert add to data source list |
84 | 90 | dataSourceConfigList.add(dataSourceConfig); |
85 | 91 | }); |
|
0 commit comments