吴树波 1 هفته پیش
والد
کامیت
51aec15e1a
1فایلهای تغییر یافته به همراه13 افزوده شده و 1 حذف شده
  1. 13 1
      fs-qw-task/src/main/java/com/fs/framework/config/DataSourceConfig.java

+ 13 - 1
fs-qw-task/src/main/java/com/fs/framework/config/DataSourceConfig.java

@@ -33,14 +33,26 @@ public class DataSourceConfig {
     public DataSource masterDataSource() {
         return new DruidDataSource();
     }
+    @Bean
+    @ConfigurationProperties(prefix = "spring.datasource.sop.druid.read")
+    public DataSource sopReadDataSource() {
+        return new DruidDataSource();
+    }
+    @Bean
+    @ConfigurationProperties(prefix = "spring.datasource.mysql.druid.slave")
+    public DataSource readDataSource() {
+        return new DruidDataSource();
+    }
 
 
 
     @Bean
     @Primary
-    public DynamicDataSource dataSource(@Qualifier("masterDataSource") DataSource masterDataSource, @Qualifier("sopDataSource") DataSource sopDataSource) {
+    public DynamicDataSource dataSource(@Qualifier("masterDataSource") DataSource masterDataSource, @Qualifier("sopDataSource") DataSource sopDataSource, @Qualifier("sopReadDataSource") DataSource sopReadDataSource, @Qualifier("readDataSource") DataSource readDataSource) {
         Map<Object, Object> targetDataSources = new HashMap<>();
         targetDataSources.put(DataSourceType.SOP.name(), sopDataSource);
+        targetDataSources.put(DataSourceType.SLAVE.name(), readDataSource);
+        targetDataSources.put(DataSourceType.SopREAD, sopReadDataSource);
         return new DynamicDataSource(masterDataSource, targetDataSources);
     }