事务

非官方测试版翻译

本页面由 PageTurner AI 翻译（测试版）。未经项目官方认可。 发现错误？ 报告问题 →

创建和使用事务

事务通过 DataSource 或 EntityManager 创建。 示例：

await myDataSource.transaction(async (transactionalEntityManager) => {
    // execute queries using transactionalEntityManager
})

或

await myDataSource.manager.transaction(async (transactionalEntityManager) => {
    // execute queries using transactionalEntityManager
})

所有需要在事务中执行的操作都必须在回调函数内完成：

await myDataSource.manager.transaction(async (transactionalEntityManager) => {
    await transactionalEntityManager.save(users)
    await transactionalEntityManager.save(photos)
    // ...
})

事务操作最重要的限制是必须始终使用提供的事务实体管理器实例—— 本例中的 transactionalEntityManager。禁止使用全局实体管理器。 所有操作必须使用提供的事务实体管理器执行。

指定隔离级别

可通过在第一个参数位置指定隔离级别：

await myDataSource.manager.transaction(
    "SERIALIZABLE",
    (transactionalEntityManager) => {},
)

隔离级别的具体实现并非在所有数据库中都保持一致。

以下数据库驱动支持标准隔离级别（READ UNCOMMITTED、READ COMMITTED、REPEATABLE READ、SERIALIZABLE）：

• MySQL

• Postgres

• SQL Server

SQLite 默认使用 SERIALIZABLE 隔离级别，但启用_共享缓存模式_时，事务可使用 READ UNCOMMITTED 隔离级别。

Oracle 仅支持 READ COMMITTED 和 SERIALIZABLE 隔离级别。

使用 QueryRunner 创建并控制单数据库连接状态

QueryRunner 提供单个数据库连接。 事务通过查询运行器进行管理。 单个事务只能在单个查询运行器上建立。 您可以手动创建查询运行器实例并控制事务状态。 示例：

// create a new query runner
const queryRunner = dataSource.createQueryRunner()

// establish real database connection using our new query runner
await queryRunner.connect()

// now we can execute any queries on a query runner, for example:
await queryRunner.query("SELECT * FROM users")

// we can also access entity manager that works with connection created by a query runner:
const users = await queryRunner.manager.find(User)

// lets now open a new transaction:
await queryRunner.startTransaction()

try {
    // execute some operations on this transaction:
    await queryRunner.manager.save(user1)
    await queryRunner.manager.save(user2)
    await queryRunner.manager.save(photos)

    // commit transaction now:
    await queryRunner.commitTransaction()
} catch (err) {
    // since we have errors let's rollback changes we made
    await queryRunner.rollbackTransaction()
} finally {
    // you need to release query runner which is manually created:
    await queryRunner.release()
}

QueryRunner 提供三种事务控制方法：

• startTransaction - 在查询运行器实例内启动新事务

• commitTransaction - 提交使用该查询运行器实例所做的所有更改

• rollbackTransaction - 回滚使用该查询运行器实例所做的所有更改

了解更多关于查询运行器。