Mongoose删除嵌套groups分组并关联删除GroupMember成员文档

错误原因 #

触发报错的核心原因有两个：

1. $pull 语法使用错误：删除数组中符合条件的完整元素，不需要使用位置运算符$，直接指定数组字段+匹配规则即可。
2. 位置运算符$要求查询条件中必须包含对应数组的匹配规则，你仅传入了userId作为查询条件，没有匹配groups数组的元素，自然无法找到对应位置触发报错。

完整实现代码 #

需要先查询获取目标分组关联的成员ID列表，再同步删除GroupMember集合文档，最后更新用户的groups数组，完整代码如下：

router.delete(  
  "/:userId/:groupId",
  catchAsync(async (req, res) => {
    const { userId, groupId } = req.params;

    // 1. 先查询对应用户，获取要删除的分组的成员ID列表
    const user = await User.findById(userId);
    if (!user) {
      return res.status(404).send({ message: "用户不存在" });
    }

    // 查找目标分组
    const targetGroup = user.groups.find(group => group._id.toString() === groupId);
    if (!targetGroup) {
      return res.status(404).send({ message: "分组不存在" });
    }

    const memberIdsToDelete = targetGroup.groupMembers;

    // 2. 批量删除关联的GroupMember文档
    await GroupMember.deleteMany({ _id: { $in: memberIdsToDelete } });

    // 3. 从用户的groups数组中删除目标分组
    const updatedUser = await User.findByIdAndUpdate(
      userId,
      { $pull: { groups: { _id: groupId } } },
      { new: true }
    );

    res.send({ updatedUser });
  })
);

可选优化：加入事务保证数据一致性 #

如果需要避免「删除了成员但分组没删掉」的不一致问题，可以加入mongoose事务处理：

router.delete(  
  "/:userId/:groupId",
  catchAsync(async (req, res) => {
    const session = await mongoose.startSession();
    session.startTransaction();
    try {
      const { userId, groupId } = req.params;

      const user = await User.findById(userId).session(session);
      if (!user) {
        return res.status(404).send({ message: "用户不存在" });
      }

      const targetGroup = user.groups.find(group => group._id.toString() === groupId);
      if (!targetGroup) {
        return res.status(404).send({ message: "分组不存在" });
      }

      const memberIdsToDelete = targetGroup.groupMembers;

      await GroupMember.deleteMany({ _id: { $in: memberIdsToDelete } }, { session });
      const updatedUser = await User.findByIdAndUpdate(
        userId,
        { $pull: { groups: { _id: groupId } } },
        { new: true, session }
      );

      await session.commitTransaction();
      res.send({ updatedUser });
    } catch (err) {
      await session.abortTransaction();
      throw err;
    } finally {
      session.endSession();
    }
  })
);

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