事务
创建和使用事务
事务是使用Connection或EntityManager创建的例如:
import { getConnection } from "typeorm";
await getConnection().transaction(transactionalEntityManager => {});
or
import { getManager } from "typeorm";
await getManager().transaction(transactionalEntityManager => {});
你想要在事务中运行的所有内容都必须在回调中执行：
import { getManager } from "typeorm";
await getManager().transaction(async transactionalEntityManager => {
await transactionalEntityManager.save(users);
await transactionalEntityManager.save(photos);
// ...
});
当在事务中工作时需要总是使用提供的实体管理器实例 - transactionalEntityManager如果你使用全局管理器（来自getManager或来自连接的 manager 可能会遇到一些问题你也不能使用使用全局管理器或连接的类来执行查询。必须使用提供的事务实体管理器执行所有操作。
指定隔离级别
指定事务的隔离级别可以通过将其作为第一个参数提供来完成：
import { getManager } from "typeorm";
await getManager().transaction(
"SERIALIZABLE",
transactionalEntityManager => {}
);
隔离级别实现与所有数据库不相关。
以下数据库驱动程序支持标准隔离级别（READ UNCOMMITTED，READ COMMITTED，REPEATABLE READ，SERIALIZABLE）：
- MySQL
- Postgres
- SQL Server
SQlite将事务默认为SERIALIZABLE，但如果启用了shared cache mode，则事务可以使用READ UNCOMMITTED隔离级别。
Oracle仅支持READ COMMITTED和SERIALIZABLE隔离级别。
事务装饰器
以下装饰器可以帮助你组织事务操作 - @Transaction, @TransactionManager 和 @TransactionRepository。
@Transaction将其所有执行包装到一个数据库事务中，@TransportManager提供了一个事务实体管理器，它必须用于在该事务中执行查询：
@Transaction()
save(@TransactionManager() manager: EntityManager, user: User) {
return manager.save(user);
}
隔离级别：
@Transaction({ isolation: "SERIALIZABLE" })
save(@TransactionManager() manager: EntityManager, user: User) {
return manager.save(user);
}
你必须使用@TransportManager提供的管理器。
但是，你也可以使用@TransactionRepository注入事务存储库（使用事务实体管理器）：
@Transaction()
save(user: User, @TransactionRepository(User) userRepository: Repository<User>) {
return userRepository.save(user);
}
你可以注入内置的 TypeORM 的存储库，如Repository，TreeRepository和MongoRepository（使用@TransactionRepository(Entity)entityRepository：Repository）或自定义存储库（扩展内置 TypeORM 的存储库类并用@ EntityRepository装饰的类）使用@TransactionRepository() customRepository：CustomRepository。
使用 QueryRunner 创建和控制单个数据库连接的状态
QueryRunner提供单个数据库连接使用查询运行程序组织事务单个事务只能在单个查询运行器上建立你可以手动创建查询运行程序实例，并使用它来手动控制事务状态例如：
import { getConnection } from "typeorm";
// 获取连接并创建新的queryRunner
const connection = getConnection();
const queryRunner = connection.createQueryRunner();
// 使用我们的新queryRunner建立真正的数据库连
await queryRunner.connect();
// 现在我们可以在queryRunner上执行任何查询，例如：
await queryRunner.query("SELECT * FROM users");
// 我们还可以访问与queryRunner创建的连接一起使用的实体管理器：
const users = await queryRunner.manager.find(User);
// 开始事务：
await queryRunner.startTransaction();
try {
// 对此事务执行一些操作：
await queryRunner.manager.save(user1);
await queryRunner.manager.save(user2);
await queryRunner.manager.save(photos);
// 提交事务：
await queryRunner.commitTransaction();
} catch (err) {
// 有错误做出回滚更改
await queryRunner.rollbackTransaction();
}
在QueryRunner中有 3 种控制事务的方法：
startTransaction- 启动一个新事务。commitTransaction- 提交所有更改。rollbackTransaction- 回滚所有更改。
了解有关Query Runner的更多信息。