如何使用 TypeORM 在事务中执行多个 QueryBuilder

在使用TypeORM进行数据库操作时，理解如何在事务中执行多个QueryBuilder是非常重要的。事务确保了数据库的完整性，通过在一个操作失败时回滚所有操作来阻止数据部分更新。

下面是如何在TypeORM中使用事务来执行多个QueryBuilder操作的步骤：

1. 使用getConnection或entityManager开启事务

首先，你需要从TypeORM获取数据库连接，然后开启一个事务。这可以通过entityManager或直接从连接中获取。

typescript
import { getConnection } from "typeorm";

// 获取连接并开启事务
const connection = getConnection();
const queryRunner = connection.createQueryRunner();

await queryRunner.connect();
await queryRunner.startTransaction();

2. 在事务中执行多个查询操作

在事务中，你可以使用queryRunner.manager来执行多个QueryBuilder操作。每个QueryBuilder操作将使用相同的数据库连接和事务上下文。

typescript
try {
    // 使用QueryBuilder创建第一个查询
    const userInsertResult = await queryRunner.manager
        .createQueryBuilder()
        .insert()
        .into(User)
        .values({ name: "John Doe", email: "john@example.com" })
        .execute();

    // 假设你需要使用上一步插入的用户ID
    const newUserId = userInsertResult.identifiers[0].id;

    // 使用新的用户ID作为外键，创建另一个查询
    const profileInsertResult = await queryRunner.manager
        .createQueryBuilder()
        .insert()
        .into(Profile)
        .values({ userId: newUserId, bio: "Hello World" })
        .execute();

    // 提交事务
    await queryRunner.commitTransaction();
} catch (error) {
    // 如果有错误发生，回滚事务
    await queryRunner.rollbackTransaction();
} finally {
    // 最后释放queryRunner
    await queryRunner.release();
}

3. 错误处理和事务回滚

在事务中执行多个操作时，如果任何操作失败，你必须回滚事务来保持数据的一致性。这是通过捕获异常，并在异常块中调用rollbackTransaction方法来完成的。完成事务后，不要忘记释放queryRunner。

以上就是在TypeORM中使用事务执行多个QueryBuilder的一个基本例子。使用事务可以确保数据操作的原子性，避免因部分操作成功而导致的数据不一致问题。