如何将事务与NestJs存储库一起使用？ [英] How to use transactions with NestJs Repositories?

问题描述

假设我拥有此服务：

@Injectable()
export class MyService {
  constructor(
    @InjectRepository(A)
    private aRepository: Repository<A>,
    @InjectRepository(B)
    private bRepository: Repository<B>,
  ) {}

  doSomething() {
     // TX: begin()
    this.aRepository.save(...);
    this.bRepository.save(...);
    // TX: commit()
  }
}

如何启动并提交事务？

推荐答案

对于事务，不强制使用注入的存储库。您可以这样做：

@Injectable()
export class MyService {
  constructor(
    @InjectRepository(A)
    private aRepository: Repository<A>,
    @InjectRepository(B)
    private bRepository: Repository<B>,
  ) {}

  async doSomething() {
    await getManager().transaction(async (manager) => {
      // TX: begin()
      await manager.getRepository(A).save(...);
      await manager.getRepository(B).save(...);
      // TX: commit()
    });
  }
}

在Typeorm Transactions

中查找更多信息

这篇关于如何将事务与NestJs存储库一起使用？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！