MongoDB一对一关系中如何实现双向级联删除？

你的代码存在三个核心问题，导致双向级联删除不生效：

1. User模型的pre('remove')钩子查询条件错误 #

你在User的删除钩子中写的是deleteMany({ employee: this._id })，但Employee模型中关联User的字段是user，不是employee；而且一对一关联场景用deleteOne更合理，不需要deleteMany。

2. 缺少Employee模型的级联删除钩子 #

你只给User加了删除时同步删除Employee的逻辑，但删除Employee时没有对应的钩子去删除关联的User——这就是删除Employee时User没被删除的直接原因。

3. 控制器中删除方法的异步处理漏洞 #

你调用user.deleteOne()但没有加await，会导致删除操作还没完成就返回响应，可能引发异步执行顺序问题。

修改后的代码如下： #

1. 修正User模型的pre('remove')钩子

// 级联删除关联的Employee
UserSchema.pre('remove', async function (next) {
  console.log(`删除用户 ${this._id} 关联的员工`);
  // 修正查询字段为user，改用deleteOne
  await this.model('Employee').deleteOne({ user: this._id });
  next();
});

2. 给Employee模型添加pre('remove')钩子

const mongoose = require('mongoose');

const employeeSchema = new mongoose.Schema({
  name: { 
    type: String, 
    required: true 
  },
  lastName: { 
    type: String, 
    required: true 
  },
  type: { 
    type: String, 
    enum: ['employee', 'manager'], 
    default: 'employee' 
  },
  createdAt: {
    type: Date,
    default: Date.now
  },
  user: {
    type: mongoose.Schema.ObjectId,
    ref: 'User',
    required: true
  }

});

// 新增：删除Employee时级联删除关联的User
employeeSchema.pre('remove', async function(next) {
  console.log(`删除员工 ${this._id} 关联的用户`);
  await this.model('User').deleteOne({ _id: this.user });
  next();
});

const Employee = mongoose.model('Employee', employeeSchema);

module.exports = Employee;

3. 修正控制器中的删除方法（添加await）

exports.deleteUser = asyncHandler(async (req, res, next) => {
  if (!req.user) {
    return next(new ErrorResponse('Not authorized to delete this user', 401));
  }

  const user = await User.findById(req.params.id);
  if (!user) {
    return next(
      new ErrorResponse(`User not found with id of ${req.params.id}`, 404)
    );
  }

  // 添加await，确保删除操作完成后再返回响应
  await user.deleteOne();

  res.status(200).json({
    success: true,
    data: {},
  });
});

4. 补充删除Employee的控制器方法（若未实现）

如果还没有删除Employee的接口，需要用实例方法触发钩子，示例如下：

exports.deleteEmployee = asyncHandler(async (req, res, next) => {
  const employee = await Employee.findById(req.params.id);
  if (!employee) {
    return next(
      new ErrorResponse(`Employee not found with id of ${req.params.id}`, 404)
    );
  }

  await employee.deleteOne();

  res.status(200).json({
    success: true,
    data: {},
  });
});

关键注意事项 #

• 必须使用文档实例的deleteOne()或remove()方法才能触发pre('remove')钩子，静态方法如User.deleteOne({_id: id})不会触发中间件。
• 一对一关联场景下，用deleteOne比deleteMany更精准，避免误删数据。
• 所有异步操作必须加await，确保操作执行完成后再返回响应。

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