如何在Mongoose插入数据时，若数据已存在则中断Promise链？

我使用Mongoose在数据库中创建新会员条目，流程为先校验该会员是否已存在。若会员已存在，需直接返回响应；若不存在，则执行插入操作。当前代码中，当会员已存在返回409响应后，后续的then块仍会执行，用状态码判断是临时方案，想找更好的处理方式。

原代码：

createNewMember = (req, res, next) => {

Member.findOne({email: email}).exec()
    .then((members) => {
         if(members == null || members.length==0) {
              // 创建newMember对象
              return newMember.save()   // 1 --> 返回Promise
         } else {
             res.status(409).json({message: "Member already present"})    // 2 --> 我想在此处返回并中断链
         }
     })
     .then((result) => {
          if(res.statusCode === 409) return res;  // 3 --> 我添加的临时解决方法
          return res.status(201).json({message: "member created"}); // 4 --> newMember.save()的回调
     })
     .catch(err => {
          // 处理错误并返回错误响应
     })

解决方案 #

方法1：抛出错误中断Promise链 #

在会员已存在的分支抛出自定义错误，让Promise直接跳转到catch块，跳过后续then逻辑：

createNewMember = (req, res, next) => {
  Member.findOne({ email: email }).exec()
    .then((member) => {
      // 注意：findOne返回单个文档，不是数组，无需判断length
      if (!member) {
        // 创建newMember对象
        return newMember.save();
      } else {
        // 抛出自定义错误，携带业务信息
        throw new Error('Member already present');
      }
    })
    .then((result) => {
      return res.status(201).json({ message: "member created" });
    })
    .catch(err => {
      // 区分自定义业务错误和其他异常
      if (err.message === 'Member already present') {
        return res.status(409).json({ message: err.message });
      }
      // 处理数据库等其他错误
      res.status(500).json({ message: 'Server error', error: err });
    });
}

方法2：用async/await简化流程 #

async/await的线性逻辑更易控制，直接return就能终止后续代码执行：

createNewMember = async (req, res, next) => {
  try {
    const member = await Member.findOne({ email: email }).exec();
    if (member) {
      return res.status(409).json({ message: "Member already present" });
    }
    // 创建newMember对象
    await newMember.save();
    return res.status(201).json({ message: "member created" });
  } catch (err) {
    res.status(500).json({ message: 'Server error', error: err });
  }
}

方法3：原子操作避免竞态（推荐） #

先查询再插入存在竞态条件（多请求同时触发可能插入重复数据），用Mongoose的findOneAndUpdate做原子性创建更可靠：

createNewMember = (req, res, next) => {
  // 构造会员数据
  const memberData = { /* 你的会员字段，如name、email等 */ };
  
  Member.findOneAndUpdate(
    { email: email }, // 查询条件
    memberData, // 要插入的数据
    { 
      upsert: true, // 不存在则插入
      new: true, // 返回操作后的文档
      runValidators: true // 执行Schema验证规则
    }
  ).exec()
  .then((result) => {
    // 判断是否为已存在的会员
    if (result.lastErrorObject?.updatedExisting) {
      return res.status(409).json({ message: "Member already present" });
    }
    return res.status(201).json({ message: "member created" });
  })
  .catch(err => {
    res.status(500).json({ message: 'Server error', error: err });
  });
}

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