Neo4j触发器失效致Next.js应用冻结问题求助

一、触发器未为应用创建的节点添加creation_date #

核心原因 #

你在Neo4j浏览器安装触发器时，默认使用的是neo4j数据库，但Next.js应用连接的是qalam数据库。APOC触发器是数据库级别的资源，在neo4j库安装的触发器不会作用于qalam库，这就是为什么浏览器手动创建节点时触发器生效，应用创建的节点却没有creation_date的原因。

修复步骤 #

1. 切换到qalam数据库重新安装触发器：

:use qalam
CALL apoc.trigger.install(
  'add_creation_date',
  'UNWIND $createdNodes AS n SET n.creation_date = $commitTime',
  {phase:'after'}
);

2. 验证触发器是否已正确安装在qalam库：

:use qalam
CALL apoc.trigger.list() YIELD name, query, config
RETURN name, query, config

可选优化：如果需要可读的日期格式，可以将触发器逻辑修改为：

UNWIND $createdNodes AS n SET n.creation_date = datetime($commitTime)

二、Next.js应用提交表单后冻结 #

核心原因 #

代码中创建了数据库会话，但未在使用后关闭，导致连接池资源耗尽，后续请求无法获取连接，最终引发应用冻结。

修复步骤 #

修改注册逻辑，添加会话关闭逻辑（使用try/finally确保无论请求成功或失败都关闭会话）：

"use server";
import * as z from "zod";
import { RegisterSchema } from "@/schemas";
import driver from "@/app/utils/noe4j";
import { DBLabels, UserPrivileges } from "@/globals/types";

export const register = async (values: z.infer<typeof RegisterSchema>) => {
  // ... 省略其他逻辑 ...
  const session = driver.session({ database: "qalam" });
  try {
    const query = `
      MERGE (counter: ${DBLabels.ID_COUNTER} {label: '${DBLabels.USER}'})
      ON CREATE SET counter.last_id = 0
      WITH counter
      CREATE (user: ${DBLabels.USER} {
          user_name: $user_name,
          first_name: $first_name,
          last_name: $last_name,
          email: $email,
          password: $password,
          privileges: $privileges
      })
      WITH user, counter
      CALL apoc.atomic.add(counter, 'last_id', 1) YIELD newValue
      SET user.user_id = newValue
      RETURN user
    `;

    const results = await session.executeWrite(async (tx) => {
      return tx.run(query, { ...new_user });
    });
    // ... 省略结果处理逻辑 ...
  } finally {
    // 强制关闭会话，释放连接池资源
    await session.close();
  }
  // ... 省略其他逻辑 ...
};

如果你的Node.js环境支持ES模块的using声明，也可以用更简洁的写法：

export const register = async (values: z.infer<typeof RegisterSchema>) => {
  // ... 省略其他逻辑 ...
  await using session = driver.session({ database: "qalam" });
  
  const query = `
    MERGE (counter: ${DBLabels.ID_COUNTER} {label: '${DBLabels.USER}'})
    ON CREATE SET counter.last_id = 0
    WITH counter
    CREATE (user: ${DBLabels.USER} {
        user_name: $user_name,
        first_name: $first_name,
        last_name: $last_name,
        email: $email,
        password: $password,
        privileges: $privileges
    })
    WITH user, counter
    CALL apoc.atomic.add(counter, 'last_id', 1) YIELD newValue
    SET user.user_id = newValue
    RETURN user
  `;

  const results = await session.executeWrite(async (tx) => {
    return tx.run(query, { ...new_user });
  });
  // ... 省略结果处理逻辑 ...
};

额外验证步骤 #

1. 检查Neo4j日志（neo4j.log）：如果触发器执行出错，日志中会包含权限、语法等相关报错信息。
2. 修复后重新提交表单：确认新创建的用户节点已包含creation_date属性，且应用不再冻结。

内容的提问来源于stack exchange，提问作者Djebarra Rabah Abderrazak