Neo4j 3.3.1自定义APOC存储过程运行失败，求解决方法

看起来你在编写Neo4j自定义存储过程时踩了几个典型的新手坑，咱们一步步拆解问题并修复：

核心错误分析 #

先看报错信息里最关键的提示：

Field db on AllNodes must be non-final and public.

这是第一个必须解决的问题，除此之外你的代码还有两处不符合Neo4j存储规范的地方，咱们逐个修复：

问题1：@Context注入字段的访问权限错误 #

Neo4j要求被@Context注解标记的字段必须是public的，因为框架需要直接访问这个字段来注入数据库实例。你当前定义的private GraphDatabaseService db;是private权限，导致启动校验失败。

问题2：手动创建GraphDatabaseService实例完全没必要 #

@Context注解的核心作用就是让Neo4j自动把当前运行的数据库实例注入到字段中，你手动new GraphDatabaseFactory()创建实例，会导致重复打开数据库、资源泄漏，还会和Neo4j自身的数据库管理逻辑冲突，直接删掉这段代码即可。

问题3：Result不能直接强制转换为Stream

#

查询返回的Result对象不是Stream<Output>类型，你需要遍历结果集，把每个节点的ID提取出来，手动包装成你定义的Output对象，再转换成Stream返回。

修复后的完整代码 #

package example;

import java.util.stream.Stream;
import org.neo4j.graphdb.GraphDatabaseService;
import org.neo4j.graphdb.Result;
import org.neo4j.procedure.Context;
import org.neo4j.procedure.Procedure;

public class AllNodes {
    // 输出类，添加构造函数方便快速初始化
    public static class Output{
        public String nodeId;

        public Output(String nodeId) {
            this.nodeId = nodeId;
        }
    }

    // @Context字段改为public，让Neo4j可以正常注入数据库实例
    @Context
    public GraphDatabaseService db;

    @Procedure(value = "example.allnodes")
    public Stream<Output> allnodes() {
        // 使用注入的db实例执行查询，直接返回节点ID更高效
        Result result = db.execute("MATCH (n) RETURN id(n) AS nodeId");
        
        // 遍历结果集，映射为Output对象的Stream
        return result.stream()
                .map(record -> new Output(record.get("nodeId").toString()));
    }
}

后续操作注意事项 #

1. 编译依赖：编译代码时需要引入Neo4j的procedure API依赖（以Maven为例）：

<dependency>
    <groupId>org.neo4j</groupId>
    <artifactId>neo4j-procedure-api</artifactId>
    <version>3.3.1</version>
    <scope>provided</scope>
</dependency>

2. 部署jar包：把编译好的jar文件放到Neo4j实例的plugins目录下（Neo4j Desktop可以在实例设置里找到该路径）。
3. 重启服务：重启Neo4j后，就可以在Cypher中调用CALL example.allnodes()来获取所有节点ID了。

内容的提问来源于stack exchange，提问作者Jack Daniel