TypeORM多个Repository如何实现统一事务？各启独立事务问题怎么解决

问题根源 #

你虽然在Service层手动创建了事务对应的QueryRunner，并将事务管理器queryRunner.manager传入了各Repository方法，但自定义Repository的逻辑中并没有使用传入的事务管理器执行数据库操作，仍然调用了this.findOne这类Repository原生方法，这类方法默认绑定全局非事务的EntityManager，所以每步操作都会生成独立事务，无法加入外层统一事务。另外你在Repository参数上添加的@TransactionManager()装饰器是配合@Transaction()装饰器式事务使用的，手动传管理器的场景下不需要使用。

解决方法 #

所有需要加入统一事务的Repository自定义方法，都优先使用传入的事务管理器执行数据库操作，没有传入时再降级使用Repository原生方法。

1. 修改自定义Repository逻辑

以UserRepository为例，修改后代码如下：

// userRepository
@EntityRepository(User)
export class UserRepository extends Repository<User> {
    async findUser(
        id: string,
        // 去掉@TransactionManager()装饰器
        transactionManager?: EntityManager
    ) {
        // 优先使用传入的事务管理器执行查询
        const findUser = transactionManager 
            ? await transactionManager.findOne(User, { id: id })
            : await this.findOne({ id: id });

        if (!findUser) {
            throw new NotFoundUserException();
        }
        return findUser;
    }
}

2. 同步修改其余两个Repository

按照同样的规则修改TrimRepository的saveUserTrim方法、TireRepository的saveTrimTire方法，所有增删改查操作都优先使用传入的transactionManager执行，比如保存操作用transactionManager.save(Trim, 实体)，不要直接调用this.save。

注意事项 #

• 不要同时混用手动QueryRunner事务和@Transaction()装饰器式事务，避免事务冲突
• 如果你升级到TypeORM 0.3.x版本，getConnection()已被弃用，改为注入DataSource实例调用createQueryRunner()创建事务即可，上层事务逻辑不需要大改

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