如何使用 Java 插件在 Neo4j 中 return 多个节点？

Question

我尝试在 Java 中编写一个函数，用于在我的 Neo4j 图形数据库中查找具有相同名称和标签的节点。

@UserFunction(value = "boris.example")
@Description("finds nodes with same name")

   public  ResourceIterator<Node> passName(@Name("nodeId") long nodeId)
   {
        Node nodeX = null;

        Node node = db.getNodeById( nodeId ); //Find node with spcific ID
        Object nameVal = node.getProperties("name"); //Get its name
        Label label = Label.label("VersionableObject"); //Decl. of label

        // Find nodes by label and name
        ResourceIterator<Node> nodes = db.findNodes(label, "name", nameVal); 
        nodes.close();

        return nodes;
   }

此函数导致以下异常并拒绝启动 Neo4j：

"参数 ResourceIterator<Node> 在 passName 中位置 0 与类型 Label 无法转换为 Neo4j 类型：不知道如何将 org.neo4j.graphdb.ResourceIterator 映射到 Neo4j 类型系统。"

然后我尝试使用

将 ResourceIterator 转换为 Stream

Stream<Node> nodesStream = nodes.stream();

同样的错误 - Neo4j 无法映射流..

ResourceIterator<Node> nodes = db.findNodes(label, "name", nameVal);    

        while (nodes.hasNext()) {

            nodeX = nodes.next();

        }
        nodes.close();

return nodeX;

Neo4j 中的输出为空，即使它应该找到 3 个节点。

将流转换为数组或列表也不起作用。

找到一个节点并显示自身或其属性有效，例如：

Node node = db.getNodeById( nodeId );
Map<String, Object> propertyMap = node.getProperties("name");

编辑

使用 mode.READ 将 @UserFunction 更改为 @Procedure 后：

package org.neo4j.example.procedure_template;


import org.neo4j.graphdb.ResourceIterator;
import java.util.stream.Stream;
import org.neo4j.graphdb.GraphDatabaseService;
import org.neo4j.graphdb.Label;
import org.neo4j.graphdb.Node;
import org.neo4j.logging.Log;
import org.neo4j.procedure.*;
import org.neo4j.procedure.Description;
import org.neo4j.procedure.Name;


public class FindNode {

    @Context
    public GraphDatabaseService db;

    @Context
    public Log log;


    public FindNode() {
    }

    @Procedure(value = "boris.getAllNodesWithProperty", mode = Mode.READ)
    @Description("boris.getAllNodesWithProperty - finds Node by ID and return defined Property")

       public Stream<Node> passName(@Name("nodeId") long nodeId)

       {
        Node node = db.getNodeById( nodeId );
        Object nameVal = node.getProperties("name");
        Label label = Label.label("VersionableObject");

        ResourceIterator<Node> nodes = db.findNodes(label, "name", nameVal);
        Stream<Node> nodesStream = nodes.stream();

        return nodesStream;
       }

}

在这种情况下，我得到："Procedures with zero output fields must be declared as VOID"。

有什么想法吗？谢谢！

Answer 1

在 Neo4j 中，您可以通过创建一些自定义 user defined function 或 procedure.

来扩展 Cypher

A user defined function 只是一个转换器，它是只读的，return 是一个单一类型，可以是：long, Long, double, Double, boolean, Boolean, String, Node, Relationship, Path, Map<String, Object, or List<T>

A procedure 可以接受参数，对数据库执行操作，并 return 结果（作为流）。

在你的代码中，你定义了一个user function，我想你想要的是一个procedure。这就是为什么你有从 ResourceIterator 到 Neo4j Type System.

的转换错误

您必须进行这些更改：

将 @UserFunction(value = "boris.example") 替换为 @Procedure(value = "boris.example", mode = Mode.READ)
将方法的 return 类型更改为 Stream<Node>

干杯。

编辑

一个过程必须return一个pojo或一个简单的类型。所以你必须把你的 Node 包裹在这样的 pojo 中：

public class FindNode {

    @Context
    public GraphDatabaseService db;

    @Context
    public Log log;


    @Procedure(value = "boris.getAllNodesWithProperty", mode = Mode.READ)
    @Description("boris.getAllNodesWithProperty - finds Node by ID and return defined Property")
    public Stream<NodeResult> passName(@Name("nodeId") long nodeId)

    {
        Node node = db.getNodeById( nodeId );
        Object nameVal = node.getProperty("name");
        Label label = Label.label("VersionableObject");

        ResourceIterator<Node> nodes = db.findNodes(label, "name", nameVal);

        return nodes.stream().map( item -> new NodeResult(item));
    }

    public class NodeResult {

        public final Node node;

        public NodeResult(Node node) {
            this.node = node;
        }
    }


}

如何使用 Java 插件在 Neo4j 中 return 多个节点？

How to return multiple nodes in Neo4j using Java plugin?

java

neo4j

neo4j-plugin

neo4j-apoc

编辑