TypeORM-Transactional为何为每个save()开启独立事务而非单个事务？

核心问题分析 #

你预期4次save()操作被单个事务包裹形成原子单元，但实际每个操作都在独立事务中提交，说明事务上下文没有在服务调用链中正确传递，导致每个数据库操作都开启了新事务。以下是具体原因和修复步骤：

1. 最外层入口未开启事务（关键前提） #

ServiceA.preloginStep是整个流程的起点，但没有标记@Transactional注解。虽然ServiceB.createFooWithBar配置了@Transactional(REQUIRED)，它会开启一个顶层事务，但ServiceC.createPersonalBar的事务上下文传递失败，导致它又开启了新事务，最终每个save操作因上下文缺失而单独提交。

2. AsyncLocalStorage(ALS)上下文传递异常 #

Nest事务依赖ALS在异步调用链中传递事务上下文，以下情况会导致上下文丢失：

• 服务调用使用了手动实例化的对象（而非Nest依赖注入），但你的代码中用this.serviceB/this.serviceC是DI注入，这点可排除。
• initializeTransactionalContext初始化后被意外重置，或与其他ALS使用场景冲突。
• 装饰器顺序错误，比如@Transactional未正确绑定到方法执行上下文。

3. TypeORM事务数据源配置问题 #

addTransactionalDataSource需要确保所有Repository都使用事务化数据源：

• 未通过TypeOrmModule.forFeature注册Repository，导致Nest注入的是普通Repository而非事务化实例。
• typeorm-transactional与@nestjs/typeorm、typeorm版本不兼容，导致事务上下文无法绑定到Repository操作。

修复步骤 #

步骤1：给最外层入口添加事务注解 #

修改ServiceA.preloginStep，添加事务注解，确保整个流程处于同一事务上下文：

// ServiceA
import { Transactional, Propagation } from 'typeorm-transactional';

@Transactional({ propagation: Propagation.REQUIRED })
async preloginStep(input, ip) {
    let foo = await this.fooRepo.findOne({ where: { mobile: input.mobile } });
    if (!foo) {
        const { user: baseFoo } = await this.serviceB.createFooWithBar(input.mobile);
        foo = baseFoo;
    }
    return { next: 'PASSWORD' };
}

步骤2：调整内部方法的事务传播行为 #

将内部方法的传播模式改为MANDATORY（强制依赖外层事务，无外层事务则报错），快速排查上下文丢失问题：

// ServiceB
@Transactional({ propagation: Propagation.MANDATORY })
async createFooWithBar(mobile: string) {
    // 原有代码不变
}

// ServiceC
@Transactional({ propagation: Propagation.MANDATORY })
async createPersonalBar(foo) {
    // 原有代码不变
}

步骤3：验证Repository注册与数据源配置 #

1. 确保所有实体对应的Repository都通过TypeOrmModule.forFeature在模块中注册：

// 示例：ServiceB所在模块
@Module({
  imports: [TypeOrmModule.forFeature([Foo])],
  providers: [ServiceB, ServiceC],
  exports: [ServiceB],
})
export class BusinessModule {}

2. 确认addTransactionalDataSource配置正确，确保返回事务化数据源：

TypeOrmModule.forRootAsync({
  useFactory: () => (process.env.NODE_ENV === 'production' ? ormConfigProd() : ormConfig()),
  dataSourceFactory: async (options: DataSourceOptions) => {
    const dataSource = new DataSource(options);
    return addTransactionalDataSource({ dataSource });
  },
}),

步骤4：确认装饰器与依赖注入正确性 #

• 确保使用的是typeorm-transactional包的@Transactional注解，而非其他包的同名装饰器。
• 所有服务均通过Nest依赖注入获取，禁止手动new Service()实例化。

验证修复 #

修改后重新运行，查看数据库查询日志，应仅出现一次START TRANSACTION和一次COMMIT，所有INSERT操作都在同一个事务中执行。

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