TypeORM queryRunner를 이용한 트랜잭션 제어

queryRunner를 이용한 트랜잭션 제어

queryRunner는 single database connection을 제공하기 때문에 트랜잭션 제어가 가능하다.
좀더 세부적으로 직접 트랜잭션을 제어하고 싶을 때에는 QueryRunner를 사용하면 된다.

 

// queryRunner 생성!!
const queryRunner = dataSource.createQueryRunner()

// 새로운 queryRunner를 연결한다.
await queryRunner.connect()

// 생성한 쿼리러너를 통해 쿼리문을 날리는 것도 가능하다.
await queryRunner.query("SELECT * FROM users")


// 새로운 트랜잭션을 시작한다는 의미의 코드이다.
await queryRunner.startTransaction()

try {
    // 원하는 트랜잭션 동작을 정의하면 된다!
    await queryRunner.manager.save(user1)
    await queryRunner.manager.save(user2)

    // 모든 동작이 정상적으로 수행되었을 경우 커밋을 수행한다.
    await queryRunner.commitTransaction()
} catch (err) {
    // 동작 중간에 에러가 발생할 경우엔 롤백을 수행한다.
    await queryRunner.rollbackTransaction()
} finally {
    // queryRunner는 생성한 뒤 반드시 release 해줘야한다.
    await queryRunner.release()
}