Node+MongoDB5实现Upsert时遇原子操作符及重复键问题如何解决？

问题分析 #

1. insertMany重复键错误：因为Parcel字段有唯一索引，插入已存在的值会触发E11000重复键错误。虽然设置了{ ordered: false }会继续插入其他不重复记录，但错误仍会抛出。
2. updateMany用法错误：你写的updateMany({}, recordsArr, { upsert: true })完全不符合语法——updateMany的第二个参数必须是带**原子操作符（如$set）**的更新文档，且不能传数组，所以会报Update document requires atomic operators错误。

正确解决方案 #

方案1：批量upsert（存在则更新/跳过，不存在则插入） #

使用bulkWrite实现批量的updateOne操作，每个操作针对单个Parcel值做upsert：

// 构造批量操作数组
const bulkOps = lastNameRecords.map(record => ({
  updateOne: {
    filter: { Parcel: record.name }, // 用Parcel字段匹配已有记录
    update: { $set: { recordNum: 'TBD' } }, // 原子操作符$set设置字段
    upsert: true // 不存在则插入，存在则更新
  }
}));

console.log('待处理记录数:', bulkOps.length);
try {
  const response = await collection.bulkWrite(bulkOps);
  console.log(`成功插入${response.upsertedCount}条新记录，更新${response.modifiedCount}条已有记录`);
  
  // 原代码中的updateOne需修正result变量（原代码中result未定义，需自行补充查询条件）
  // const updated = await collection.updateOne({ /* 你的查询条件 */ }, { $set: { recordNum: 'ERD' } });
} catch (error) {
  console.error('批量操作失败:', error);
}

如果只想插入不存在的记录、不修改已有数据，可将update改为{ $setOnInsert: { recordNum: 'TBD' } }，这样只有插入新记录时才会设置recordNum，已有记录不会被改动。

方案2：跳过重复记录，继续插入其他数据 #

如果不需要更新已有记录，仅需忽略重复值、插入其余数据，可保留insertMany并在catch中处理E11000错误：

const recordsArr = lastNameRecords.map(record => ({
  Parcel: record.name,
  recordNum: 'TBD'
}));

console.log('待插入记录数:', recordsArr.length);
try {
  const response = await collection.insertMany(recordsArr, { ordered: false });
  console.log(`成功插入${response.insertedCount}条记录`);
} catch (error) {
  if (error.code === 11000) {
    // 捕获重复键错误，此时非重复记录已完成插入
    console.log(`跳过重复记录，成功插入${error.result.insertedCount}条记录`);
    console.log('重复的Parcel值:', error.writeErrors.map(err => err.errmsg.match(/Parcel: "(.*?)"/)[1]));
  } else {
    console.error('插入失败:', error);
  }
}

关键说明 #

• bulkWrite是MongoDB官方推荐的批量复杂操作方式，支持多种操作类型（updateOne、insertOne等），适配批量upsert场景。
• 所有更新操作必须使用原子操作符（$set、$inc等），不能直接传入完整文档，这是MongoDB的更新语法硬性要求，和是否定义Schema无关。

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