使用.create()批量添加记录时，如何实现遇重复则终止全部创建？

问题根源 #

你用的Field.create()底层调用MongoDB的insertMany，默认是并行无序插入且无原子性保障——遇到重复错误时，已经成功插入的记录不会回滚，所以会出现部分插入的情况。要实现"有重复就全不插"，得用原子性操作或预检查的方式。

方案一：先预检查重复记录（简单高效，适合低并发场景） #

在执行插入前，先查询集合里是否存在要插入的记录，有重复直接返回错误，不执行插入：

// 替换成你的唯一键字段，比如你的唯一约束是`name`字段
const uniqueFieldValues = fieldArr.map(item => item.name);
const hasDuplicate = await Field.exists({ name: { $in: uniqueFieldValues } });

if (hasDuplicate) {
  return res.status(400).json({ message: 'EXIST' });
}

// 确认无重复后再批量创建
const createdItems = await Field.create(fieldArr);
// 后续逻辑

⚠️ 注意：如果业务并发量高，可能出现"检查时无重复，但插入前被其他请求插入了重复数据"的竞态问题，这种情况建议用方案二。

方案二：用MongoDB事务实现原子性插入（适合高并发/强一致性场景） #

MongoDB 4.0及以上支持事务，把整个插入操作放在事务里，一旦出错就回滚所有已操作：

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

try {
  // 把事务session传入create方法
  const createdItems = await Field.create(fieldArr, { session });
  // 提交事务
  await session.commitTransaction();
  // 无错误时的后续逻辑
} catch (error) {
  // 出错就回滚所有操作
  await session.abortTransaction();
  if (error.message.includes('duplicate key error')) {
    return res.status(400).json({ message: 'EXIST' });
  }
  // 处理其他错误
} finally {
  // 结束会话
  session.endSession();
}

⚠️ 注意：事务要求MongoDB是副本集或分片集群，单节点实例不支持事务。

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