feat:资产客户端拆分连接池初始化

etl-modules/etl-data-source/etl-data-source-common/src/main/java/com/etl/data/domain/config/DataSourceConfig.java

@@ -0,0 +1,21 @@
+package com.etl.data.domain.config;
+
+import com.alibaba.druid.pool.DruidDataSource;
+
+
+/**
+ * @ClassName DataSourceConfig
+ * @Description 描述
+ * @Author YunFei.Du
+ * @Date 2024/5/10 9:44
+ */
+public class DataSourceConfig {
+    public static DruidDataSource dataSource(String ip , String name, String port , String username, String password) {
+        DruidDataSource dataSource = new DruidDataSource();
+        dataSource.setUsername(username);
+        dataSource.setPassword(password);
+        dataSource.setUrl("jdbc:mysql://"+ip+":"+port+"/"+name+"?useSSL=false");
+        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
+        return dataSource;
+    }
+}

etl-modules/etl-data-source/etl-data-source-remote/src/main/java/com/etl/data/source/remote/factory/DataSourceFactory.java

@@ -0,0 +1,25 @@
+package com.etl.data.source.remote.factory;
+
+import com.etl.common.core.domain.Result;
+import com.etl.common.core.web.page.TableDataInfo;
+import com.etl.data.domain.DataSource;
+import com.etl.data.domain.req.DataSourceQueryReq;
+import com.etl.data.source.remote.RemoteDataSourceService;
+import org.springframework.cloud.openfeign.FallbackFactory;
+
+/**
+  *   数据源熔断
+  * @author YunFei.Du
+  * @date  14:10 2024/5/10
+ */
+public class DataSourceFactory implements FallbackFactory< RemoteDataSourceService > {
+    @Override
+    public RemoteDataSourceService create(Throwable cause) {
+        return new RemoteDataSourceService (){
+            @Override
+            public Result< TableDataInfo< DataSource > > getDataSourceList(DataSourceQueryReq req) {
+                return Result.error ( new TableDataInfo<DataSource> ());
+            }
+        };
+    }
+}

etl-modules/etl-data-source/etl-data-source-server/src/main/java/com/etl/data/controller/DataSourceController.java

@@ -107,7 +107,7 @@ public class DataSourceController extends BaseController {
      * @return
      */
     @PostMapping("/DataAssetList")
-    public Result dataAssetListByDataSourceId(@RequestBody DataSource dataSource){
+    public Result<List<DataAsset>> dataAssetListByDataSourceId(@RequestBody DataSource dataSource){
         return dataSourceService.dataAssetListByDataSourceId(dataSource);
     }
 

etl-modules/etl-data-source/etl-data-source-server/src/main/java/com/etl/data/service/DataSourceService.java

@@ -2,6 +2,7 @@ package com.etl.data.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.etl.common.core.domain.Result;
+import com.etl.data.domain.DataAsset;
 import com.etl.data.domain.DataSource;
 import com.etl.data.domain.decoration.DataSourceDecoration;
 import com.etl.data.domain.req.DataSourceQueryReq;
@@ -68,7 +69,7 @@ public interface DataSourceService extends IService<DataSource> {
      * @return
      */
 
-    Result dataAssetListByDataSourceId( DataSource dataSource);
+    Result<List< DataAsset >> dataAssetListByDataSourceId(DataSource dataSource);
 
 
     /**

etl-modules/etl-data-source/etl-data-source-server/src/main/java/com/etl/data/service/impl/DataSourceServiceImpl.java

@@ -55,10 +55,9 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
 
         List< DataSource > list = this.list ( );
 
-        List< DataSourceDecoration > collect = list.stream ( ).map (DataSourceDecoration::dataSourceBuild ).toList ( );
+        List< DataSourceDecoration > dataSourceDecorationList = list.stream ( ).map ( DataSourceDecoration::dataSourceBuild ).toList ( );
-//        list.stream ( ).map ( DataSourceDecoration::dataSourceBuild).collect ( Collectors.toList ( ) );
 
-        return collect;
+        return dataSourceDecorationList;
 
     }
 
@@ -291,7 +290,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
 
 
     @Override
-    public Result dataAssetListByDataSourceId( DataSource dataSource) {
+    public Result<List<DataAsset>> dataAssetListByDataSourceId( DataSource dataSource) {
 
         List<DataAsset> dataAssetList = new ArrayList<>();