Node.js中Neo4j的MERGE语句为何仍会创建重复节点？

问题原因 #

你遇到的重复节点问题核心源于两点：

1. 缺少唯一约束/索引：MERGE需要快速定位匹配节点，若未对Person(user_id)（或你用来判定唯一性的属性组合）创建索引，Neo4j会执行全表扫描。当多个请求并发执行时，多个事务会同时找不到目标节点，进而各自创建新节点，最终导致重复。
2. 无保护的并发执行：你循环创建10个独立Session并同时执行MERGE，这些事务在无约束的情况下，彼此无法感知对方的操作，进一步加剧了重复创建的概率。

另外你的代码存在一个异步处理小问题：dictResult.then(endFn(session))会立即执行endFn，而非等待查询完成后执行，正确写法应为dictResult.then(() => endFn(session))，不过这不是重复节点的直接诱因。

解决方法 #

1. 创建唯一约束（最关键） #

在Neo4j中对Person节点的user_id创建唯一约束，数据库层面会强制保证user_id的唯一性，即使并发执行MERGE也不会生成重复节点，同时还能大幅提升MERGE的查找效率。

执行以下Cypher语句：

CREATE CONSTRAINT unique_person_user_id FOR (p:Person) REQUIRE p.user_id IS UNIQUE;

2. 优化代码逻辑 #

• 避免循环创建多个Session，尽量复用Session或控制并发数，减少不必要的事务竞争。
• 修正异步操作的处理逻辑，确保资源正确释放：

优化后的代码示例：

const neo4j = require('neo4j-driver')

const url = `neo4j://test-neo4j:7687`;

(async () => {
    console.log(`start connect to neo4j : ${url}`);
    const driver = neo4j.driver(
        url,
        neo4j.auth.basic('neo4j', 'nodejs_to_neo4j')
    )

    const endFn = async (session) => {
        await session.close();
        await driver.close();
        console.log(`end connect to neo4j : ${url}`);
    };

    setTimeout(async () => {
        // 复用单个Session，避免创建多个独立Session
        const session = driver.session();
        const userId = '123';
        const nameParam = 'John Doe';
        const query = 'MERGE (n:Person {user_id: $userId, name: $nameParam}) RETURN n';

        const queryPromises = [];
        for(let i = 0; i < 10 ; i++){
            console.log(
                `query(${i + 1}): ${query}`
                .replace('$userId', userId)
                .replace('$nameParam', nameParam)
            );
            // 收集所有查询的Promise
            queryPromises.push(session.run(query, { userId, nameParam }));
        }

        // 等待所有查询完成后再关闭资源
        await Promise.all(queryPromises);
        await endFn(session);
    }, 1000);

})();

补充说明 #

如果你的唯一性判定需要基于user_id和name的组合，可以创建组合唯一约束，但通常user_id本身应作为唯一标识，单独约束user_id更符合业务逻辑。

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