使用Mongoose更新MongoDB数据时如何避免重复邮箱写入？

问题原因 #

• 首先要确认MongoDB的User集合已经成功创建了email字段的唯一索引：Schema中定义unique: true仅会在首次创建集合时自动生成索引，若你的集合是预先存在的，需要手动执行索引创建才能让唯一性约束生效。
• 你当前的错误处理逻辑没有对唯一键冲突的专属错误（错误码11000）做单独处理，即使索引生效触发冲突，也只会统一返回通用500错误，不会返回明确的邮箱重复提示。
• 直接遍历req.body生成更新字段的逻辑存在安全风险，可能被恶意用户传入未定义的字段篡改数据，建议先做字段白名单过滤。

修复方案1（推荐：依赖数据库唯一索引，原子性更高，避免并发竞态问题） #

首先先确认索引创建成功，在Schema定义后添加索引生成逻辑：

const UserSchema = new Schema({
  fullName: { type: String, required: true },
  email: { type: String, unique: true, required: true  }
});
// 主动触发索引创建，避免旧集合没有生成唯一索引
UserSchema.createIndexes();
const User = mongoose.model('User', UserSchema);

然后修改控制器代码，新增错误码判断逻辑，同时做字段过滤：

exports.update = async (req, res) => {
  // 做字段白名单过滤，仅允许更新指定字段，避免安全风险
  const allowedUpdates = ['fullName', 'email'];
  const updates = {};
  for (const key of Object.keys(req.body)) {
    if (allowedUpdates.includes(key)) {
      updates[key] = req.body[key];
    }
  }

  const userId = req.body._id ? req.body._id : req.userId;
  try {
    const data = await User.updateOne({ _id: userId }, { $set: updates });
    if (data.n === 0) {
      return res.status(404).send({ message: "Not Found!" });
    }
    res.status(200).send({ message: "Success!" });
  } catch (err) {
    // 判断是否是唯一键冲突错误
    if (err.code === 11000 && err.keyPattern?.email) {
      return res.status(400).send({ message: "该邮箱已被其他账号占用" });
    }
    res.status(500).send({ message: "Failed!" });
  }
};

修复方案2（前置校验，提前给用户反馈） #

如果需要在操作数据库前就判断邮箱是否重复，可以新增前置查询逻辑，建议搭配方案1的错误捕获一起使用，避免并发请求下的竞态问题：

exports.update = async (req, res) => {
  const allowedUpdates = ['fullName', 'email'];
  const updates = {};
  for (const key of Object.keys(req.body)) {
    if (allowedUpdates.includes(key)) {
      updates[key] = req.body[key];
    }
  }

  const userId = req.body._id ? req.body._id : req.userId;

  // 前置校验邮箱是否被其他用户占用
  if (updates.email) {
    const existUser = await User.findOne({ email: updates.email, _id: { $ne: userId } });
    if (existUser) {
      return res.status(400).send({ message: "该邮箱已被其他账号占用" });
    }
  }

  try {
    const data = await User.updateOne({ _id: userId }, { $set: updates });
    if (data.n === 0) {
      return res.status(404).send({ message: "Not Found!" });
    }
    res.status(200).send({ message: "Success!" });
  } catch (err) {
    // 保留错误兜底判断，避免并发场景下的冲突
    if (err.code === 11000 && err.keyPattern?.email) {
      return res.status(400).send({ message: "该邮箱已被其他账号占用" });
    }
    res.status(500).send({ message: "Failed!" });
  }
};

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