如何让Mongoose事务忽略11000重复键错误继续执行？

MongoDB事务的底层机制决定了：只要事务内出现任何写错误（包括11000重复键错误），事务会被立即标记为终止状态，后续所有操作都会抛出251 NoSuchTransaction错误，这个行为无法修改。你之前尝试的循环创建和事务内bulkWrite都因为这个机制失败。

根据你的场景（文档数量少，需要一次性返回所有错误），有两种可行方案：

方案一：预检查重复键 + 事务（保证原子性） #

先提前排查出所有重复的文档，只把非重复文档放入事务中创建，既保证非重复文档的原子性，又能收集所有重复错误。

代码示例 #

const duplicateErrors = [];
const uniqueKeyField = 'email'; // 替换为你的唯一键字段，比如username

// 1. 提取所有待创建文档的唯一键值
const uniqueValues = documents.map(doc => doc[uniqueKeyField]);

// 2. 查询数据库中已存在的唯一键
const existingDocs = await Document.find(
  { [uniqueKeyField]: { $in: uniqueValues } },
  { [uniqueKeyField]: 1 }
);
const existingValues = new Set(existingDocs.map(doc => doc[uniqueKeyField]));

// 3. 分离重复文档和可创建文档
const creatableDocs = documents.filter(doc => {
  if (existingValues.has(doc[uniqueKeyField])) {
    duplicateErrors.push(createDuplicateError({ [uniqueKeyField]: doc[uniqueKeyField] }));
    return false;
  }
  return true;
});

// 4. 事务中创建非重复文档
let session;
try {
  session = await mongoose.startSession();
  session.startTransaction();
  
  if (creatableDocs.length > 0) {
    await Document.create(creatableDocs, { session });
  }
  
  await session.commitTransaction();
} catch (error) {
  if (session) await session.abortTransaction();
  // 处理预检查后突发的重复键错误（竞态场景）
  if (error.code === 11000) {
    duplicateErrors.push(createDuplicateError(error.keyValue));
  } else {
    throw error; // 非重复键错误直接抛出
  }
} finally {
  if (session) await session.endSession();
}

// 返回所有重复错误
if (duplicateErrors.length > 0) {
  throw new Error(`存在重复项：${JSON.stringify(duplicateErrors)}`);
}

说明 #

• 优点：保证非重复文档要么全部创建成功，要么全部回滚，符合事务原子性要求
• 缺点：存在极小概率的竞态条件（预检查后到事务创建前，其他请求插入了相同键），但可以通过捕获最终的11000错误兜底

方案二：放弃事务，使用非事务无序bulkWrite（允许部分成功） #

如果你的业务不需要原子性（允许部分文档创建成功，同时收集所有错误），可以直接用非事务的无序bulkWrite，它会继续执行所有操作并返回所有错误。

代码示例 #

// 构造bulkWrite插入操作
const operations = documents.map(doc => ({
  insertOne: { document: doc }
}));

// 执行无序批量插入
const result = await Document.bulkWrite(operations, { ordered: false });

// 收集所有重复键错误
const duplicateErrors = [];
if (result.writeErrors) {
  result.writeErrors.forEach(err => {
    if (err.code === 11000) {
      duplicateErrors.push(createDuplicateError(err.err.keyValue));
    } else {
      // 非重复键错误可选择抛出或收集
      throw err;
    }
  });
}

// 返回所有重复错误
if (duplicateErrors.length > 0) {
  throw new Error(`存在重复项：${JSON.stringify(duplicateErrors)}`);
}

说明 #

• 优点：无需预检查，直接执行即可收集所有重复错误，实现简单
• 缺点：没有事务原子性，部分文档会成功创建，不适合需要强一致性的场景

为什么你的尝试失败？ #

1. 循环create：第一次触发11000错误时，MongoDB自动终止了事务，后续所有操作都因事务已终止而抛出251错误
2. 事务内bulkWrite：根据MongoDB规则，事务中的bulkWrite无论是否设置ordered: false，第一个错误都会终止事务，无法继续执行后续操作

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