Chao
/
etl-cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

style(): 修改数据接入数据,同步数据不同步

dev
chao 2024-04-23 15:34:12 +08:00
parent 2101257954
commit b89f10565f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
etl-modules/etl-modules-data-source/etl-modules-data-source-system/src/main/java/com/etl/data/source/service/impl/DataSourceServiceImpl.java
View File

@ -250,7 +250,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
assetStructureTableList.stream().forEach(assetStructureTable -> { assetStructureTableList.stream().forEach(assetStructureTable -> {
try { try {
ResultSet rs2 = st.executeQuery("select count(*) as countNum from " + assetStructureTable.getTableName()); ResultSet rs2 = st.executeQuery("select count(*) as countNum from " + assetStructureTable.getTableName());
while (rs2.next()){ while (rs2.next()) {
assetStructureTable.setTableDataCount(rs2.getLong("countNum")); assetStructureTable.setTableDataCount(rs2.getLong("countNum"));
} }
rs2.close(); rs2.close();
@ -294,18 +294,18 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
return false; return false;
} }
} else { // 如果他存在就给他修改 } else { // 如果他存在就给他修改
AssetStructure entity = AssetStructure.dataSourceUpdateBuilder(assetStructure,id, dataSource); AssetStructure entity = AssetStructure.dataSourceUpdateBuilder(assetStructure, id, dataSource);
// 修改资产结构 // 修改资产结构
assetStructureService.update( assetStructureService.update(
entity,new LambdaUpdateWrapper<AssetStructure>() entity, new LambdaUpdateWrapper<AssetStructure>()
.eq(AssetStructure::getId,entity.getId()) .eq(AssetStructure::getId, entity.getId())
); );
// 删除资产结构表信息 // 删除资产结构表信息
assetStructureTableService.remove( assetStructureTableService.remove(
new LambdaQueryWrapper<AssetStructureTable>() new LambdaQueryWrapper<AssetStructureTable>()
.eq(AssetStructureTable::getAssetStructureId,entity.getId()) .eq(AssetStructureTable::getAssetStructureId, entity.getId())
); );
String jdbcUrl = ""; String jdbcUrl = "";
@ -344,7 +344,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
assetStructureTableList.stream().forEach(assetStructureTable -> { assetStructureTableList.stream().forEach(assetStructureTable -> {
try { try {
ResultSet rs2 = st.executeQuery("select count(*) as countNum from " + assetStructureTable.getTableName()); ResultSet rs2 = st.executeQuery("select count(*) as countNum from " + assetStructureTable.getTableName());
while (rs2.next()){ while (rs2.next()) {
assetStructureTable.setTableDataCount(rs2.getLong("countNum")); assetStructureTable.setTableDataCount(rs2.getLong("countNum"));
} }
rs2.close(); rs2.close();