Spring Data Neo4j 没有创建关系

Question

我有一个存储库方法：

@Query("MATCH (original:Entity{id:{0}}),(n:Entity{id:{1}}) "+ 
        "CREATE (original)-[r:SIMILAR]->(n) "+  
        "RETURN original ")
public Entity connectSimilar(String original, String new);

我在这个服务方法中用来连接实体：

@Transactional
    public Entity linkSimilarStory(String linkedTo, String linked) {
        System.out.println(linkedTo+" and "+linked);

        Entity original = this.findById(linkedTo);
        Entity newEntity = this.findById(linked);

        if(original != null && newEntity != null){

            if(this.checkIfSimilar(original.getNodeId(), newEntity.getNodeId())){
                System.out.println(original.getNodeId()+" and "+newEntity.getNodeId()+" are already Linked !!");
            }else{
                original = repository.connectSimilar(original.getId(), newEntity.getId());
                System.out.print("Entities linked successfully : "+original.getId()+" with "+newEntity.getId());
            }
            System.out.println(this.checkIfSimilar(original.getNodeId(), newEntity.getNodeId()));

        }
        return original;
    }

当我从控制器运行服务方法以链接 2 个现有节点时（我用 println 检查了它们的存在）：

Transaction tx = neoTemplate.getGraphDatabaseService().beginTx();
Node otherNodeToLink = others.get(new Random().nextInt(others.size()-1));
//System.out.println("Linking "+root.getProperty("id").toString()+" And "+otherNodeToLink.getProperty("id").toString());
storyService.linkSimilarStory(root.getProperty("id").toString(), otherNodeToLink.getProperty("id").toString());
tx.close();

我收到了带有他们 ID 的消息 Entities linked successfully。

当我使用 neo4j 控制台检查时，没有创建任何关系！

直接在控制台中运行相同的查询，它会创建关系。

不明白为什么它不适用于 Spring 数据:(

编辑：

我也试过这样做：

Relationship rel = template.getNode(original.getNodeId()).createRelationshipTo(template.getNode(newEntity.getNodeId()), isSimilar);
System.out.println("Rel: "+rel.getType());

它显示 Rel:RelationshipTypeToken[name:SIMILAR,id:7]，但一直没有在 DB 中创建关系！

Answer 1

你试过了吗：

@Query("START original={0}, n={1} "+ 
    "CREATE (original)-[r:SIMILAR]->(n) "+  
    "RETURN original ")
public Entity connectSimilar(Entity original, Entity new);

...因为您已经加载了实体 POJO。然后传入您从代码中获得的“原始”和“新实体”POJO。您应该不需要再次查找它们。

让我们知道这是否有效（我没有在 SDN 项目中尝试过，但是查询看起来正确；必要时进行调整）。