Commit 6acdf9e7 by qiuchaofei

1.修改作业元模型的名称,2neo4j查询不指定类型

parent 2370a168
...@@ -13,10 +13,10 @@ import java.util.List; ...@@ -13,10 +13,10 @@ import java.util.List;
public interface Neo4jTableRepository extends Neo4jRepository<Neo4jTable,Long> { public interface Neo4jTableRepository extends Neo4jRepository<Neo4jTable,Long> {
List<Neo4jTable> findNeo4jTableByMetadataId(String metadataId); List<Neo4jTable> findNeo4jTableByMetadataId(String metadataId);
@Query("match (n:Neo4jTable{metadataId:{tableId}} )<-[r:流向]-(m:Neo4jTable) return m ") @Query("match (n{metadataId:{tableId}} )<-[r:流向]-(m) return m ")
List<BaseNode> getSourceTable(@Param("tableId") String tableId); List<BaseNode> getSourceTable(@Param("tableId") String tableId);
@Query("match (n:Neo4jTable{metadataId:{tableId}} )-[r:流向]->(m:Neo4jTable) return m ") @Query("match (n{metadataId:{tableId}} )-[r:流向]->(m) return m ")
List<BaseNode> getTargetTable(@Param("tableId") String tableId); List<BaseNode> getTargetTable(@Param("tableId") String tableId);
} }
...@@ -52,21 +52,21 @@ public class TableServiceImpl implements ITableService { ...@@ -52,21 +52,21 @@ public class TableServiceImpl implements ITableService {
//获取关联作业, //获取关联作业,
List<BaseNode> sourceBaseNodes = neo4jTableRepository.getSourceTable(tableId); List<BaseNode> sourceBaseNodes = neo4jTableRepository.getSourceTable(tableId);
for(BaseNode sourceBaseNode:sourceBaseNodes){ for(BaseNode sourceBaseNode:sourceBaseNodes){
if(sourceBaseNode.getMetadataId().startsWith("EtlJob")){ if(sourceBaseNode.getMetadataId().startsWith("Procedure=")){
ReturnNode returnNode = new ReturnNode(); ReturnNode returnNode = new ReturnNode();
returnNode.setId(sourceBaseNode.getMetadataId()); returnNode.setId(sourceBaseNode.getMetadataId());
returnNode.setName(sourceBaseNode.getName()); returnNode.setName(sourceBaseNode.getName());
returnNode.setType("EtlJob"); returnNode.setType("Procedure");
etlJobs.add(returnNode); etlJobs.add(returnNode);
} }
} }
List<BaseNode> targetBaseNodes = neo4jTableRepository.getTargetTable(tableId); List<BaseNode> targetBaseNodes = neo4jTableRepository.getTargetTable(tableId);
for(BaseNode targetBaseNode:targetBaseNodes){ for(BaseNode targetBaseNode:targetBaseNodes){
if(targetBaseNode.getMetadataId().startsWith("EtlJob")){ if(targetBaseNode.getMetadataId().startsWith("Procedure=")){
ReturnNode returnNode = new ReturnNode(); ReturnNode returnNode = new ReturnNode();
returnNode.setId(targetBaseNode.getMetadataId()); returnNode.setId(targetBaseNode.getMetadataId());
returnNode.setName(targetBaseNode.getName()); returnNode.setName(targetBaseNode.getName());
returnNode.setType("EtlJob"); returnNode.setType("Procedure");
etlJobs.add(returnNode); etlJobs.add(returnNode);
} }
} }
......
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