如何在删除Mongoose User时仅删除无其他引用的Property

你现在的问题是删除用户时会直接删掉所有关联的Property，但其实只需要删除那些没有被其他任何用户引用的孤立Property。下面提供几种可行的实现方案：

方案一：基础遍历检查（适合中小数据量） #

修改User模型中的post('findOneAndDelete')中间件，遍历用户关联的每个Property，检查是否还有其他用户引用它，没有则删除：

const User = require('./User'); // 确保引入User模型
const Property = require('./Property');

userSchema.post('findOneAndDelete', async function(doc) {
  // 获取被删除用户的所有关联Property ID
  const propertyIds = doc.properties;
  if (!propertyIds.length) return; // 没有关联Property直接返回

  // 逐个检查每个Property是否还有其他用户引用
  for (const propId of propertyIds) {
    // 统计除当前被删用户外，还有多少用户关联这个Property
    const refCount = await User.countDocuments({
      _id: { $ne: doc._id },
      properties: propId
    });

    // 没有其他引用则删除该Property
    if (refCount === 0) {
      await Property.findByIdAndDelete(propId);
    }
  }
});

方案二：聚合查询批量处理（适合大数据量） #

如果用户和Property数据量较大，逐个遍历效率偏低，可以用MongoDB的聚合查询批量找出所有孤立的Property，再一次性删除：

userSchema.post('findOneAndDelete', async function(doc) {
  const propertyIds = doc.properties;
  if (!propertyIds.length) return;

  // 通过聚合查询找出所有未被其他用户引用的Property ID
  const aggregationResult = await User.aggregate([
    { $match: { _id: { $ne: doc._id } } }, // 排除当前被删除的用户
    { $unwind: '$properties' }, // 展开所有用户的Property数组
    { $group: { _id: '$properties' } }, // 去重得到所有被引用的Property ID
    { $group: { _id: null, usedProps: { $push: '$_id' } } },
    { $project: {
        orphanedProps: {
          $setDifference: [propertyIds, '$usedProps'] // 计算出孤立的Property ID
        }
      }
    }
  ]);

  const orphanedProps = aggregationResult[0]?.orphanedProps || [];
  if (orphanedProps.length) {
    await Property.deleteMany({ _id: { $in: orphanedProps } });
  }
});

方案三：双向关联优化（推荐长期方案） #

上面两种方案都需要查询User集合来统计引用次数，如果你能修改数据结构，可以给Property模型添加反向引用的users数组，这样操作会更高效：

1. 修改Property模型 #

const propertySchema = new mongoose.Schema({
  name: { type: String, unique: true },
  type: { type: String, enum: ['house', 'apartment', 'room', 'parking', 'pool'] },
  numberOfBedrooms: { type: Number },
  numberOfBathrooms: { type: Number },
  maxNumberOfGuests: { type: Number },
  users: [{ type: Schema.Types.ObjectId, ref: 'user' }] // 新增：存储关联的用户ID
});

module.exports = mongoose.model("property", propertySchema);

2. 修改用户添加Property的逻辑 #

每次用户关联Property时，记得同时把用户ID加到Property的users数组里（比如在用户更新或创建的中间件里处理）：

// 示例：用户添加Property时的操作
async function addPropertyToUser(userId, propId) {
  await User.findByIdAndUpdate(userId, { $push: { properties: propId } });
  await Property.findByIdAndUpdate(propId, { $push: { users: userId } });
}

3. 修改删除用户的中间件 #

删除用户时，先移除每个关联Property中的用户引用，再检查users数组是否为空，为空则删除Property：

userSchema.post('findOneAndDelete', async function(doc) {
  const propertyIds = doc.properties;
  if (!propertyIds.length) return;

  for (const propId of propertyIds) {
    // 从Property的users数组中移除当前用户ID
    const updatedProperty = await Property.findByIdAndUpdate(
      propId,
      { $pull: { users: doc._id } },
      { new: true } // 返回更新后的文档
    );

    // 如果没有其他用户引用，删除该Property
    if (updatedProperty.users.length === 0) {
      await Property.findByIdAndDelete(propId);
    }
  }
});

注意事项 #

• 所有中间件都要加上async关键字，因为用到了await，原代码里的中间件缺少async会报错
• 如果用双向关联，要确保用户和Property的关联操作是原子性的（可以用Mongoose事务，避免出现数据不一致）

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