Commit 64cc534c by qiuchaofei

1注释1104的关系

parent 7d20204d
...@@ -72,7 +72,7 @@ public class AsyncDataFromMongoToNeo4j { ...@@ -72,7 +72,7 @@ public class AsyncDataFromMongoToNeo4j {
metadataService.syschroTable2EtlJobRelations(catalogName); metadataService.syschroTable2EtlJobRelations(catalogName);
//同步1104报表 //同步1104报表
metadataService.syschro1104Relations(catalogName); // metadataService.syschro1104Relations(catalogName);
// metadataService.syschroRelationFromMongo(catalogName); // metadataService.syschroRelationFromMongo(catalogName);
// // 同步其他数据(模型,标准,质量等) // // 同步其他数据(模型,标准,质量等)
// //
......
...@@ -1863,17 +1863,17 @@ public class MetadataServiceImpl implements IMetadataService { ...@@ -1863,17 +1863,17 @@ public class MetadataServiceImpl implements IMetadataService {
long time0 = System.currentTimeMillis(); long time0 = System.currentTimeMillis();
long totalElement = mongoDbServiceImpl.countRelation(PageRequest.of(page,pageSize),catalogName); long totalElement = mongoDbServiceImpl.countRelation(PageRequest.of(page,pageSize),catalogName);
long time1 = System.currentTimeMillis(); long time1 = System.currentTimeMillis();
logger.info("从 mmongo获取的关系的总数量是:"+ totalElement +" ,耗时:" +(time1-time0) ); logger.info("从mongo获取的关系的总数量是:"+ totalElement +" ,耗时:" +(time1-time0) );
int totalPageCount = ((int)totalElement/pageSize)+1; int totalPageCount = ((int)totalElement/pageSize)+1;
logger.info("从 mmongo分页获取关系,每页:"+ pageSize); logger.info("准备分页从mongo获取关系,每页:"+ pageSize);
for(; page< totalPageCount;page++){ for(; page< totalPageCount;page++){
logger.info("开始从 mmongo 第"+page +" 次获取关系。"); logger.info("开始从 mongo 第"+page+1 +" 次获取关系。");
String description = ""; String description = "";
long time3 = System.currentTimeMillis(); long time3 = System.currentTimeMillis();
List<Document> relationList = mongoDbServiceImpl.findRelationByPage(PageRequest.of(page,pageSize,Sort.by("_id")),catalogName); List<Document> relationList = mongoDbServiceImpl.findRelationByPage(PageRequest.of(page,pageSize,Sort.by("_id")),catalogName);
long time4 = System.currentTimeMillis(); long time4 = System.currentTimeMillis();
logger.info("从 mmongo 第"+page +" 次获取关系。 ,耗时:" +(time4-time3) ); logger.info("从 mongo 第"+page+1 +" 次获取关系结束,耗时:" +(time4-time3) );
for(Document relation :relationList){ for(Document relation :relationList){
description = relation.getString("description"); description = relation.getString("description");
String type = relation.getString("type"); String type = relation.getString("type");
......
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