09041944:优化同步资产结构

muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java

@@ -137,7 +137,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
      */
     @Override
     public Integer syncAssetStructure(DataSource etlDataScore) {
-
+        ExecutorService threadPool = Executors.newFixedThreadPool(10);
         try {
             if (etlDataScore.getDataType().equals(MYSQL)) {
                 MysqlPool mysqlPool = new MysqlPool(etlDataScore);
@@ -222,9 +222,6 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
                     //根据数据库id和表名查询数据
                     TableInfo table = tableInfoService.selectTableInfoByName(build);
 
-
-                    ExecutorService threadPool = Executors.newCachedThreadPool();
-
                     threadPool.submit(() -> {
                         syncData(conn, etlDataScore.getDatabaseName(), table);
                     });