GraphQL Mutation返回空值：事务性操作执行与结果获取异常

首先，你的Mutation返回空值的核心原因是异步操作没有正确返回Promise——你用了bcrypt的回调函数，而GraphQL的Resolver会在回调执行前就结束，直接返回undefined，导致前端拿到空结果。另外，要实现“邮件失败则数据库不更新”的原子性需求，我们需要借助数据库事务来保证两个操作的一致性。

下面一步步给你解决：

1. 把回调式代码改成Promise/Async-Await风格 #

GraphQL的Resolver如果涉及异步操作，必须返回一个Promise，这样GraphQL才会等待异步任务完成后再返回结果。bcrypt本身支持Promise调用，我们可以用async/await来简化代码，避免回调嵌套。

2. 用数据库事务保证原子性 #

我们需要开启一个数据库事务：先在事务中创建数据库记录，然后尝试发送邮件。如果邮件发送成功，就提交事务；如果失败，就回滚事务，这样数据库里不会留下新增的记录。

下面是完整的示例代码（假设你用Sequelize作为ORM，其他ORM/原生SQL的事务逻辑类似）：

Mutation: {
  async createDealer(_, params) {
    console.log("params: " + JSON.stringify(params));
    try {
      // 第一步：加密密码，用async/await替代回调
      const salt = await bcrypt.genSalt(10);
      const hashedPassword = await bcrypt.hash(params.password, salt);

      // 第二步：开启数据库事务
      const transaction = await sequelize.transaction();

      try {
        // 在事务中创建经销商记录
        const newDealer = await Dealer.create(
          {
            ...params,
            password: hashedPassword // 存加密后的密码
          },
          { transaction } // 指定使用当前事务
        );

        // 第三步：发送注册邮件，这里要确保sendRegistrationEmail返回Promise
        await sendRegistrationEmail(newDealer.email);

        // 邮件发送成功，提交事务
        await transaction.commit();

        // 返回创建好的经销商数据给前端
        return newDealer;
      } catch (emailError) {
        // 邮件发送失败，回滚事务，数据库不会保存记录
        await transaction.rollback();
        // 抛出错误，让GraphQL返回给前端错误信息
        throw new Error(`注册失败：邮件发送错误 - ${emailError.message}`);
      }
    } catch (error) {
      // 处理密码加密或事务开启时的错误
      throw new Error(`注册失败：${error.message}`);
    }
  }
}

关键注意事项 #

• 邮件函数要返回Promise：如果你的邮件发送库是回调式的（比如nodemailer的旧写法），可以用Node.js的util.promisify把它转成Promise风格：

  const { promisify } = require('util');
  const sendRegistrationEmail = promisify(yourCallbackBasedEmailFunction);
  

• 数据库要支持事务：比如MySQL要使用InnoDB引擎（MyISAM不支持事务），PostgreSQL默认支持事务。如果用原生SQL，要手动执行BEGIN、COMMIT、ROLLBACK语句，并且确保所有操作在同一个数据库连接中执行。
• 错误处理要到位：每个异步环节的错误都要捕获，确保事务能正确回滚，同时给前端返回清晰的错误信息。

这样修改后，你的Mutation就不会返回空值了，而且能保证“邮件失败则数据库不更新”的需求。

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