Commit d4b187ae by mahx

修复分页错误

parent 53eec167
...@@ -638,13 +638,14 @@ public class MetadataServiceImpl implements IMetadataService { ...@@ -638,13 +638,14 @@ public class MetadataServiceImpl implements IMetadataService {
int page = 0, pageSize = 500; int page = 0, pageSize = 500;
long totalElement = mongoDbServiceImpl.countTempRelation(PageRequest.of(page, pageSize), catalogName); long totalElement = mongoDbServiceImpl.countTempRelation(PageRequest.of(page, pageSize), catalogName);
Map<String, Long> nameIdMap = new HashMap<>(); Map<String, Long> nameIdMap = new HashMap<>();
for (; page < totalElement; page += pageSize) { long tatalPage = Math.round(Math.ceil(totalElement / (pageSize + 0.0)));
for (; page < tatalPage; page++) {
List<JSONObject> list = mongoDbServiceImpl.findTempRelationByPage(PageRequest.of(page, pageSize, Sort.by("etlJobId")), catalogName); List<JSONObject> list = mongoDbServiceImpl.findTempRelationByPage(PageRequest.of(page, pageSize, Sort.by("etlJobId")), catalogName);
for (JSONObject relation : list) { for (JSONObject relation : list) {
String sqlId = relation.getString("etlSqlId"); String sqlId = relation.getString("etlSqlId");
String etlScriptId = relation.getString("etlScriptId"); String etlScriptId = relation.getString("etlScriptId");
String etlJobId = relation.getString("etlJobId"); String etlJobId = relation.getString("etlJobId");
deleteTempNodeByCatalogName(sqlId); //deleteTempNodeByCatalogName(sqlId);
MetaData metadata = metadataRepository.findMetaDataByMetadataId(sqlId); MetaData metadata = metadataRepository.findMetaDataByMetadataId(sqlId);
if (metadata == null) { if (metadata == null) {
logger.error("id : {} is not found", sqlId); logger.error("id : {} is not found", sqlId);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment