NESTJS/TypeOrm数据库事务

Question

假设我们有两个服务，A和B。服务A有一个函数执行以下操作：

1. 验证数据

现在，让我们假设以下步骤之一，步骤3或4失败。由于服务B对数据库进行了更改，这些更改仍然存在。

在这种情况下，有没有办法回滚数据库？我曾考虑过数据库事务，但在nest js中找不到任何方法来实现这一点，尽管TypeOrm支持它，但nest看起来并不自然。如果不是的话，我现在被服务B所做的更改“卡住”了，但是如果没有服务B所做的更改，A应该已经做了。

多谢了。

Answer 1

typeorm事务性cls hooked使用cls（延续本地存储）在不同的存储库和服务方法之间处理和传播事务。

@Injectable()
export class PostService {
  constructor(
    private readonly authorRepository: AuthorRepository,
    private readonly postRepository: PostRepository,
  ) {}

  @Transactional() // will open a transaction if one doesn't already exist
  async createPost(authorUsername: string, message: string): Promise<Post> {
    const author = await this.authorRepository.create({ username: authorUsername });
    return this.postRepository.save({ message, author_id: author.id });
  }
}

Answer 2

以下是我如何解决它，因为我需要使用悲观锁。

我觉得这是一种“嵌套”方式，因为你可以简单地要求NestJS注入一个TypeormConnection的实例，你就可以开始了。

@Injectable()
class MyService {
  // 1. Inject the Typeorm Connection
  constructor(@InjectConnection() private connection: Connection) { }

  async findById(id: number): Promise<Thing> {
    return new Promise(resolve => {
      // 2. Do your business logic
      this.connection.transaction(async entityManager => {
        resolve(
          await entityManager.findOne(Thing, id, {
            lock: { mode: 'pessimistic_write' },
          }),
        );
      });
    });
  }
}

只需将所需的任何其他逻辑放入中即可。事务阻塞，您就可以开始了。

注意：您必须使用由提供的entityManager。事务方法，否则它将无法工作。

Answer 3

许多解决方案是可用的，它们都应该基于SQL事务管理。

就我个人而言，我认为实现这一点的最简单方法是在数据库上执行代码时使用相同的EntityManager实例。然后你可以使用这样的东西：

getConnection().transaction(entityManager -> {
    service1.doStuff1(entityManager);
    service2.doStuff2(entityManager);
});

您可以从EntityManager实例生成QueryRunner，如果您在ORM操作之外执行原始SQL，该实例将被包装在同一事务中。您还需要从EntityManager生成Repository实例，否则它们将在主事务之外执行代码。