如何在Neo4j GraphQL中连接节点前检查节点是否存在

你当前的OGM代码会在用户不存在时仍创建Comment节点，只是无法关联到User。要实现「仅当指定ID的User存在时才创建Comment」的逻辑，且用单次数据库调用完成，推荐以下两种方案：

方案1：自定义Cypher Mutation（最优，纯单次数据库调用） #

直接在GraphQL Schema中定义带Cypher语句的Mutation，用Cypher的MATCH先确认User存在，再执行创建和关联操作，整个逻辑在单次请求内完成：

修改后的Schema：

type Comment  {
    id: ID @id
    timeAdded: DateTime! @timestamp(operations: [CREATE])
    writer: User! @relationship(type: "WRITTEN_BY", direction: IN)
    content: String
}

type User {
   id: ID @id
   name: String
   commentsWritten: [Comment!]! @relationship(type: "WRITTEN_BY", direction: OUT)
}

type Mutation {
    addComment(authorID: String!, content: String!): Comment
        @cypher(
            statement: """
                MATCH (u:User {id: $authorID})
                CREATE (c:Comment {content: $content})
                CREATE (u)-[:WRITTEN_BY]->(c)
                SET c.timeAdded = datetime()
                RETURN c
            """
        )
}

逻辑说明：

• MATCH语句会先查找指定ID的User，只有找到时才会执行后续的CREATE操作
• 如果User不存在，整个Cypher不会创建任何节点，直接返回null
• 由于自定义Cypher不会触发@timestamp的自动赋值，需要手动用datetime()设置timeAdded字段

方案2：OGM事务包裹查询与创建（原子性保障，单事务内完成） #

如果更倾向于用OGM原有写法，可以用Neo4j事务包裹「查询用户存在性」和「创建评论」两步，确保要么全部成功要么全部回滚：

修改后的Resolver：

addComment: async (src, args, ctx) => {
    const { authorID, content } = args;
    const session = ctx.ogm.driver.session();
    let result = null;

    try {
        await session.executeWrite(async tx => {
            // 先查询用户是否存在
            const userCheck = await tx.run(
                'MATCH (u:User {id: $authorID}) RETURN count(u) > 0 AS exists',
                { authorID }
            );

            if (!userCheck.records[0].get('exists')) {
                throw new Error('目标用户不存在');
            }

            // 用户存在时创建评论并关联
            result = await ctx.ogm.models.Comment.create({
                input: [{
                    content,
                    writer: { connect: { where: { node: { id: authorID } } } }
                }]
            }, { session: tx });
        });
        return result;
    } catch (err) {
        console.error(err);
        return null;
    } finally {
        await session.close();
    }
}

逻辑说明：

• 整个流程在同一个写事务中执行，避免出现「创建了Comment但关联失败」的中间状态
• 相比方案1会多一次数据库查询，但逻辑更贴近你原本的OGM代码习惯

内容的提问来源于stack exchange，提问作者B''H Bi'ezras -- Boruch Hashem