修改临时关系类型

src/main/java/com/keymobile/metadata/metadataRelation/pojo/TempRelation.java

+package com.keymobile.metadata.metadataRelation.pojo;
+
+import org.neo4j.ogm.annotation.RelationshipEntity;
+
+/**
+ * @author mahx
+ * @version 1.0
+ * @date 2021/11/29 17:14
+ */
+@RelationshipEntity(type = "TempRelation")
+public class TempRelation extends BaseRelationship {
+}

src/main/java/com/keymobile/metadata/metadataRelation/respository/TempRelationRepository.java

+package com.keymobile.metadata.metadataRelation.respository;
+
+import com.keymobile.metadata.metadataRelation.pojo.TempRelation;
+import org.springframework.data.neo4j.annotation.Query;
+import org.springframework.data.neo4j.repository.Neo4jRepository;
+import org.springframework.data.repository.query.Param;
+
+/**
+ * @author mahx
+ * @version 1.0
+ * @date 2021/11/12 17:54
+ */
+public interface TempRelationRepository extends Neo4jRepository<TempRelation, Long> {
+
+    @Query("match (source:BaseNode),(target:BaseNode) where id(source)=$sourceId and id(target)=$targetId merge p=(source)-[r:TempRelation]->(target) return p")
+    TempRelation mergeTempRelation(@Param("sourceId") Long sourceId, @Param("targetId") Long targetId);
+}

src/main/java/com/keymobile/metadata/metadataRelation/service/impl/MetadataServiceImpl.java

@@ -52,6 +52,8 @@ public class MetadataServiceImpl implements IMetadataService {
     private ExecuteRelationRepository executeRelationRepository;
     @Autowired
     private TempNodeRepository tempNodeRepository;
+    @Autowired
+    private TempRelationRepository tempRelationRepository;
 
     @Autowired
     private PreRelationRepository preRelationRepository;
@@ -808,13 +810,13 @@ public class MetadataServiceImpl implements IMetadataService {
                 if ("Input".equalsIgnoreCase(type)) {
                     Long nodeId = createNode(nameIdMap, catalogName, etlJobId, etlScriptId, source, false, null);
                     if (nodeId != null) {
-                        inputRelationReRepository.mergeInputRelation(nodeId, id);
+                        tempRelationRepository.mergeTempRelation(nodeId, id);
                     }
                 }
                 if ("Output".equalsIgnoreCase(type)) {
                     Long nodeId = createNode(nameIdMap, catalogName, etlJobId, etlScriptId, target, false, null);
                     if (nodeId != null) {
-                        outputRelationRepository.mergeOutRelation(id, nodeId);
+                        tempRelationRepository.mergeTempRelation(id, nodeId);
                     }
                 }
             }