事务管理是数据库操作中至关重要的部分，它能确保一系列操作要么全部成功，要么全部失败。本文将详细介绍在 NestJS 框架中使用 TypeORM 进行事务管理的多种方法。

为什么需要事务管理？

想象一下银行转账场景：从一个账户扣款后，向另一个账户加款。如果在这两个操作之间系统崩溃，没有事务管理就会导致金额凭空消失。事务的 ACID 特性（原子性、一致性、隔离性、持久性）正是为了解决这类问题。

方法一：使用 QueryRunner 管理事务

这是最基础也是最灵活的事务管理方式。

async createUserAndProfile() {const queryRunner = this.dataSource.createQueryRunner();await queryRunner.connect();await queryRunner.startTransaction();try {const user = await queryRunner.manager.save(User, { name: 'John',email: 'john@example.com'});await queryRunner.manager.save(Profile, {userId: user.id,bio: 'Hello world'});await queryRunner.commitTransaction();return user;} catch (err) {await queryRunner.rollbackTransaction();throw err;} finally {await queryRunner.release();}
}

方法二：使用 DataSource 的 transaction 方法

更简洁的事务管理方式，自动处理提交和回滚。

async createUserAndProfile() {return this.dataSource.transaction(async (manager) => {const user = await manager.save(User, {name: 'Alice',email: 'alice@example.com'});await manager.save(Profile, {userId: user.id,bio: 'Hello from Alice'});return user;});
}

方法三：创建自定义事务装饰器（推荐）

结合装饰器模式，实现更优雅的事务管理。

// 定义装饰器
export const Transactional = () => {const injectDataSource = InjectDataSource();return (target: any, propertyKey: string, descriptor: PropertyDescriptor) => {injectDataSource(target, 'dataSource');const originalMethod = descriptor.value;descriptor.value = async function (...args: any[]) {const dataSource: DataSource = this.dataSource;return dataSource.transaction((manager) => {return originalMethod.apply(this, [...args, manager]);});};};
};// 使用装饰器
@Transactional()
async transferMoney(fromId: number, toId: number, amount: number, manager?: EntityManager) {// 业务逻辑
}

方法四：全局事务拦截器

适用于需要统一事务管理的场景。

@Injectable()
export class TransactionInterceptor implements NestInterceptor {constructor(@InjectDataSource() private dataSource: DataSource) {}async intercept(context: ExecutionContext, next: CallHandler) {const queryRunner = this.dataSource.createQueryRunner();await queryRunner.connect();await queryRunner.startTransaction();const request = context.switchToHttp().getRequest();request.queryRunner = queryRunner;return next.handle().pipe(tap(async () => {await queryRunner.commitTransaction();await queryRunner.release();}),catchError(async (err) => {await queryRunner.rollbackTransaction();await queryRunner.release();throw err;}),);}
}

事务管理最佳实践

1. 保持事务短小：长时间运行的事务会锁定资源
2. 正确处理异常：确保异常时回滚事务
3. 选择合适的隔离级别：平衡一致性和性能
4. 避免死锁：按固定顺序访问资源
5. 测试并发场景：模拟高并发下的行为

总结

方法	复杂度	灵活性	适用场景
QueryRunner	高	高	需要精细控制的事务
DataSource.transaction	中	中	大多数业务场景
事务装饰器	中	高	需要优雅封装的业务逻辑
全局拦截器	低	低	统一事务管理的API

根据项目复杂度选择合适的方法，对于大多数应用，DataSource.transaction方法或自定义装饰器的方式是最佳选择。

通过合理使用这些事务管理技术，可以构建出健壮可靠的NestJS应用程序，确保数据的一致性和完整性。