Mongoose v5中如何高效同步产品-用户关联数据的增删？

针对你需要同步productId/personId组合的需求，可以通过两步数据库操作实现更简洁的逻辑，无需提前查询并在JS层面处理数组对比：

核心思路 #

1. 先删除指定personId下，不在请求productId列表中的所有文档
2. 批量对请求中的每个productId执行upsert（存在则不修改，不存在则插入）

代码实现 #

假设你的请求数据结构如下：

const reqData = {
  personId: '09876',
  productIds: ['12345', '67890', '11223'] // 请求携带的目标productId列表
};

对应的Mongoose操作代码：

const ProductPerson = require('./models/productPerson'); // 你的集合模型

async function syncProductPerson(reqData) {
  const { personId, productIds } = reqData;

  // 步骤1：删除该personId下不在请求列表中的文档
  await ProductPerson.deleteMany({
    personId,
    productId: { $nin: productIds }
  });

  // 步骤2：批量upsert请求中的所有组合
  const bulkOps = productIds.map(productId => ({
    updateOne: {
      filter: { personId, productId },
      update: { $set: { personId, productId } }, // 与筛选条件一致，存在时无实际修改
      upsert: true
    }
  }));

  await ProductPerson.bulkWrite(bulkOps);
}

方案优势 #

• 减少一次数据库查询操作，直接通过MongoDB的$nin运算符完成删除逻辑
• 用bulkWrite批量处理插入/更新，相比循环调用updateOne更高效
• 逻辑更紧凑，无需在JS层面手动对比已存在和待操作的数组

可选：原子性保障（事务） #

如果担心并发场景下的数据不一致，可以将两个操作放在MongoDB事务中（需MongoDB 4.0+及以上版本支持）：

const session = await ProductPerson.startSession();
session.startTransaction();

try {
  await ProductPerson.deleteMany(
    { personId, productId: { $nin: productIds } },
    { session }
  );

  await ProductPerson.bulkWrite(bulkOps, { session });

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

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