Commit e4540a48 by qiuchaofei

修改从mongo取数的分页方法

parent 6cf3606a
......@@ -1464,7 +1464,10 @@ public class MetadataServiceImpl implements IMetadataService {
//根据schema获取表级数据,再按照类型分类:表,视图,作业,函数等
int page =0,pageSize = 300;
long totalElement = mongoDbServiceImpl.countDocumentByParentId(PageRequest.of(page,pageSize),catalogName,schemaId);
for(; page< totalElement;page+= pageSize){
int totalPageCount = ((int)totalElement/pageSize)+1;
for(; page< totalPageCount;page++ ){
List<Document> tableDocumentList = mongoDbServiceImpl.getDocumentByparentIdByPage(PageRequest.of(page,pageSize,Sort.by("_id")),catalogName,schemaId);
for(Document tableDocument :tableDocumentList){
String metadataId =(String) tableDocument.get("_id");
......@@ -1656,7 +1659,11 @@ public class MetadataServiceImpl implements IMetadataService {
Map<String,String> edgeIdMap = new HashMap<>();
int page =0,pageSize = 300;
long totalElement = mongoDbServiceImpl.countRelation(PageRequest.of(page,pageSize),catalogName);
for(; page< totalElement;page+= pageSize){
int totalPageCount = ((int)totalElement/pageSize)+1;
for(; page< totalPageCount;page++){
List<Document> relationList = mongoDbServiceImpl.findRelationByPage(PageRequest.of(page,pageSize,Sort.by("_id")),catalogName);
for(Document relation :relationList){
......@@ -2257,7 +2264,9 @@ public class MetadataServiceImpl implements IMetadataService {
int page = 0, pageSize = 500;
long totalElement = mongoDbServiceImpl.countTempRelation(PageRequest.of(page, pageSize), catalogName);
Map<String, Long> nameIdMap = new HashMap<>();
for (; page < totalElement; page += pageSize) {
int totalPageCount = ((int)totalElement/pageSize)+1;
for (; page < totalPageCount; page ++) {
List<Document> list = mongoDbServiceImpl.findTempRelationByPage(PageRequest.of(page, pageSize, Sort.by("etlJobId")), catalogName);
for (Document relation : list) {
String sqlId = relation.getString("etlSqlId");
......
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