MongoDB单请求写入两个模型仅首个保存成功的解决方法

当前代码只有第一个模型能写入数据的核心原因是JavaScript函数执行到第一个return语句就会直接终止退出，排在第一个return之后的newCustomer初始化、保存逻辑永远不会被执行，和模型本身无关。
除此之外现有代码还有两个明显问题：

• 混用await和.then()的异步写法，逻辑容易混乱
• Mongoose的save().then()回调只会接收保存成功的文档对象，不会返回error参数，原有代码写的错误判断逻辑完全不生效，保存时抛出的异常无法被捕获。

根据对数据一致性的要求不同，有两种可落地的实现方式：

基础修正版（无事务，适合一致性要求低的场景） #

核心修改点是移除第一个save后的提前return，等两个写操作都执行完成后再统一返回结果，统一用async/await做异步处理，用try/catch捕获所有异常。

// 函数必须加async关键字才能在内部使用await
module.exports.registerAccount = async (reqBody) => {
  try {
    // 初始化用户实例并保存
    const newAccount = new User({
      firstName: reqBody.firstName,
      lastName: reqBody.lastName,
      email: reqBody.email,
      mobileNum: reqBody.mobileNum,
      password: bcrypt.hashSync(reqBody.password, 10)
    })
    const savedAccount = await newAccount.save()

    // 初始化订单实例并保存
    const newCustomer = new Order({
      FirstName: reqBody.firstName,
      LastName: reqBody.lastName,
      MobileNum: reqBody.mobileNum
    })
    const savedCustomer = await newCustomer.save()

    // 两个操作都成功才返回true
    return Boolean(savedAccount && savedCustomer)
  } catch (err) {
    console.error('注册写入数据失败:', err)
    return false
  }
}

这个写法的缺陷是如果User保存成功、Order保存失败，会出现User表有数据、Order表无数据的不一致问题，不适合核心业务场景。

事务版（生产环境推荐，保证数据强一致） #

如果要求两个模型的数据要么同时写入成功，要么全部失败不产生脏数据，需要用MongoDB事务实现跨集合原子写入。
使用前提：MongoDB为副本集/分片集群部署（本地单节点开发可开启单节点副本集模式），Mongoose版本≥5.2.0。

const mongoose = require('mongoose')

module.exports.registerAccount = async (reqBody) => {
  // 开启事务会话
  const session = await mongoose.startSession()
  session.startTransaction()

  try {
    // 所有写操作绑定当前事务会话
    const newAccount = new User({
      firstName: reqBody.firstName,
      lastName: reqBody.lastName,
      email: reqBody.email,
      mobileNum: reqBody.mobileNum,
      password: bcrypt.hashSync(reqBody.password, 10)
    })
    await newAccount.save({ session })

    const newCustomer = new Order({
      FirstName: reqBody.firstName,
      LastName: reqBody.lastName,
      MobileNum: reqBody.mobileNum
    })
    await newCustomer.save({ session })

    // 所有操作无报错则提交事务，数据正式写入
    await session.commitTransaction()
    return true
  } catch (err) {
    // 任意一步报错则回滚所有已执行的写操作，不产生脏数据
    await session.abortTransaction()
    console.error('注册写入失败，事务已回滚:', err)
    return false
  } finally {
    // 释放会话资源
    await session.endSession()
  }
}

• 不要在业务逻辑执行中途随意添加return，会直接终止后续代码执行
• Mongoose异步操作建议统一用async/await + try/catch的写法处理错误，不要在then回调中尝试接收error参数，该位置无法捕获异常
• 注意核对两个模型的Schema字段名：当前代码User模型用小驼峰（firstName、mobileNum）、Order模型用大驼峰开头（FirstName、MobileNum），需确保传入字段名和Schema定义完全一致，否则会出现字段丢失问题
• 核心业务场景的跨集合写入必须用事务保证一致性，网络波动、数据库超时等异常都可能导致独立的两次写入只成功一个，产生难以修复的脏数据

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