如何在FeathersJS的Hook中实现回滚？求Mongoose回滚操作示例

要在FeathersJS Hook中实现关联操作的回滚，核心是利用Mongoose的**事务会话（Session）**来包裹所有需要原子性执行的数据库操作——这样所有绑定到同一个会话的变更，要么全部成功提交，要么在任意一步出错时一起回滚，比手动反向操作更可靠。下面是针对你需求的完整实现示例：

完整Hook代码示例 #

module.exports = async (hook) => {
  // 从Feathers的Mongoose客户端获取会话
  const mongooseClient = hook.app.get('mongooseClient');
  const session = await mongooseClient.startSession();
  
  // 开启事务
  session.startTransaction();

  try {
    // 将会话存入hook上下文，方便后续环节复用（可选）
    hook.context.mongooseSession = session;

    // 执行service1的update操作，传入会话参数绑定事务
    const data1Save = await hook.app.service('service1').update(
      hook.id, // 替换为service1要更新的记录ID
      hook.data, // 你的service1更新数据
      { session } // 关联事务会话
    );

    // 执行service2的update操作，同样绑定到同一个会话
    await hook.app.service('service2').update(
      'target-service2-id', // 替换为service2要更新的记录ID
      hook.data.service2Data, // 你的service2更新数据
      { session }
    );

    // 所有操作成功，提交事务
    await session.commitTransaction();
    session.endSession();

    return hook;
  } catch (err) {
    // 捕获到错误，立即回滚所有事务内的变更
    await session.abortTransaction();
    session.endSession();

    // 抛出错误，让Feathers自动处理错误响应
    throw new Error(`操作失败，已回滚所有变更: ${err.message}`);
  }
};

关键细节说明 #

• 事务会话的作用：Mongoose的会话会把所有关联它的数据库操作纳入同一个事务，确保原子性——要么全部成功，要么全部回滚。
• 传递会话到Service：Feathers的Mongoose Service会自动识别第三个参数中的session选项，无需修改Service本身的代码（只要你的Service是基于Feathers Mongoose生成的）。
• 错误处理逻辑：一旦任何一步操作抛出错误，代码会进入catch块，执行abortTransaction()回滚所有变更，然后结束会话并抛出错误通知客户端。
• 避免手动回滚的坑：相比手动去反向更新service1的记录，事务回滚是数据库层面的原生支持，不会因为业务逻辑变化（比如后续新增字段）导致回滚不彻底的问题。

内容的提问来源于stack exchange，提问作者wu-sama