MongoDB 5与Node.js中insertMany唯一约束冲突的处理咨询

方案1：提前过滤重复的Parcel值 #

在构建插入数组时先去重，从根源避免重复键错误，减少数据库无效操作。

const existingParcels = new Set();
const docsToInsert = [];

// 遍历原始数据构建插入数组
for (const item of yourSourceData) {
  if (!existingParcels.has(item.Parcel)) {
    existingParcels.add(item.Parcel);
    docsToInsert.push({ Parcel: item.Parcel, recordNum: item.recordNum });
  } else {
    console.log(`跳过重复Parcel值: ${item.Parcel}`);
    // 这里也可以直接对重复项执行更新逻辑，提前处理
  }
}

// 执行插入，此时不会有重复键问题
await yourCollection.insertMany(docsToInsert);
// 后续正常执行updateOne
await yourCollection.updateOne(/* 你的过滤和更新参数 */);

方案2：捕获insertMany错误后继续执行updateOne #

利用ordered: false让MongoDB尽可能插入所有不重复数据，捕获错误后跳过重复键异常，继续执行后续更新操作。

const docsToInsert = [];
// 构建插入数组的逻辑...

try {
  const insertResult = await yourCollection.insertMany(docsToInsert, { ordered: false });
  console.log(`成功插入 ${insertResult.insertedCount} 条文档`);
} catch (err) {
  if (err.name === 'MongoBulkWriteError') {
    // 只处理重复键错误，其他严重错误按需抛出
    const duplicateErrors = err.writeErrors.filter(e => e.code === 11000);
    console.log(`成功插入 ${err.result.insertedCount} 条，跳过 ${duplicateErrors.length} 条重复记录`);
  } else {
    console.error('插入出现非重复键异常:', err);
    // 若不想继续执行update，可在此抛出错误终止流程
    // throw err;
  }
}

// 无论插入是否部分失败，继续执行更新操作
try {
  const updateResult = await yourCollection.updateOne(
    { /* 过滤条件 */ },
    { /* 更新内容 */ }
  );
  console.log(`更新完成：匹配 ${updateResult.matchedCount} 条，修改 ${updateResult.modifiedCount} 条`);
} catch (err) {
  console.error('更新操作失败:', err);
}

方案3：用bulkWrite整合所有操作 #

将插入和更新操作合并为批量任务，设置ordered: false后，即使部分插入失败，更新操作仍会执行，统一处理错误。

const bulkOps = [];

// 添加插入操作
for (const item of yourSourceData) {
  bulkOps.push({
    insertOne: {
      document: { Parcel: item.Parcel, recordNum: item.recordNum }
    }
  });
}

// 添加后续的updateOne操作
bulkOps.push({
  updateOne: {
    filter: { /* 你的过滤条件 */ },
    update: { /* 你的更新内容 */ },
    upsert: false
  }
});

try {
  const result = await yourCollection.bulkWrite(bulkOps, { ordered: false });
  console.log(`成功插入 ${result.insertedCount} 条，成功更新 ${result.modifiedCount} 条`);
  
  // 处理失败的操作
  if (result.writeErrors.length > 0) {
    result.writeErrors.forEach(err => {
      if (err.code === 11000) {
        console.log(`忽略重复键错误：${err.errmsg}`);
      } else {
        console.error(`写入错误：${err.errmsg}`);
      }
    });
  }
} catch (err) {
  if (err.name === 'MongoBulkWriteError') {
    console.log(`部分操作完成：插入 ${err.result.insertedCount} 条，更新 ${err.result.modifiedCount} 条`);
    err.writeErrors.forEach(error => {
      error.code === 11000 
        ? console.log(`跳过重复记录：${error.errmsg}`) 
        : console.error(`严重错误：${error.errmsg}`);
    });
  } else {
    console.error('批量操作失败:', err);
  }
}

方案4：业务允许时用upsert替代单纯插入 #

如果需求是「Parcel不存在则插入，存在则更新」，直接用带upsert: true的批量更新，彻底避免重复键问题。

const bulkOps = yourSourceData.map(item => ({
  updateOne: {
    filter: { Parcel: item.Parcel },
    update: { $set: { recordNum: item.recordNum } },
    upsert: true
  }
}));

const result = await yourCollection.bulkWrite(bulkOps, { ordered: false });
console.log(`完成：新插入 ${result.upsertedCount} 条，更新 ${result.modifiedCount} 条`);

// 后续执行其他updateOne操作
await yourCollection.updateOne(/* 你的参数 */);

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