2112A-ONE
/
muyu-source
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

09041958:优化同步资产结构

master
冷调 2024-09-04 19:58:18 +08:00
parent e6e4f1213a
commit 596f8c673c
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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