基于自定义存储过程统计Neo4j中节点的最大度数

嘿，我太懂你这种情况了——Neo4j 3.2.3版本的APOC确实可能因为版本兼容问题，没有包含apoc.stats.degrees这个过程，自己动手实现一个完全可行！下面是一步步的实现方案，适配你的版本：

1. 前置准备 #

首先得确保Neo4j允许加载自定义存储过程：

• 打开neo4j.conf配置文件，添加/修改以下两行：

  dbms.security.procedures.unrestricted=my.extension.*
  dbms.security.procedures.whitelist=my.extension.*
  

  这里的my.extension是你自定义过程的包名，也可以换成你喜欢的命名。
• 用Java开发的话，需要引入Neo4j 3.2.3的依赖（以Maven为例）：

  <dependency>
      <groupId>org.neo4j</groupId>
      <artifactId>neo4j</artifactId>
      <version>3.2.3</version>
      <scope>provided</scope>
  </dependency>
  

2. 核心代码实现 #

写一个Java类，实现遍历所有节点、计算最大度数的逻辑：

package my.extension.procedures;

import org.neo4j.graphdb.*;
import org.neo4j.procedure.*;
import java.util.stream.Stream;

public class MaxDegreeProcedure {

    // 注入数据库服务实例
    @Context
    public GraphDatabaseService db;

    // 定义存储过程的名称和运行模式（只读，避免修改数据）
    @Procedure(name = "my.extension.stats.maxDegree", mode = Mode.READ)
    @Description("返回数据库中所有节点的最大度数（入度+出度）")
    public Stream<MaxDegreeResult> calculateMaxDegree() {
        long maxDegree = 0;

        // 开启只读事务遍历节点
        try (Transaction tx = db.beginTx()) {
            ResourceIterator<Node> allNodes = tx.getAllNodes().iterator();
            while (allNodes.hasNext()) {
                Node currentNode = allNodes.next();
                long currentDegree = currentNode.getDegree(); // 默认计算所有关系类型的总度数
                if (currentDegree > maxDegree) {
                    maxDegree = currentDegree;
                }
            }
            tx.success();
        }

        return Stream.of(new MaxDegreeResult(maxDegree));
    }

    // 定义返回结果的实体类
    public static class MaxDegreeResult {
        public long maxDegree;

        public MaxDegreeResult(long maxDegree) {
            this.maxDegree = maxDegree;
        }
    }
}

3. 打包部署 #

• 把代码编译成jar包，放到Neo4j安装目录下的plugins文件夹里
• 重启Neo4j服务，确保日志里没有加载错误

4. 调用自定义过程 #

重启完成后，在Neo4j浏览器里执行：

CALL my.extension.stats.maxDegree()

就能得到类似这样的结果：

可选优化（按需添加） #

如果需要更灵活的功能，可以给过程加参数：

• 过滤特定标签的节点：添加@Name("targetLabel") String label参数，用db.findNodes(Label.label(label))替代tx.getAllNodes()
• 区分入度/出度：添加@Name("direction") String direction参数，用currentNode.getDegree(Direction.valueOf(direction.toUpperCase()))计算指定方向的度数

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