[Spring] 스프링 DB 2편 10

김영한님의 스프링 DB 2편 을 공부하여 정리한 글입니다.

스프링 트랜잭션 전파1 - 커밋, 롤백

Test

@Slf4j
@SpringBootTest
public class BasicTxTest {

    @Autowired
    PlatformTransactionManager txManager;

    @TestConfiguration
    static class Config {
        @Bean
        public PlatformTransactionManager transactionManager(DataSource dataSource) {
            return new DataSourceTransactionManager(dataSource);
        }
    }

    @Test
    void commit() {
        log.info("트랜젝션 시작");
        TransactionStatus status = txManager.getTransaction(new DefaultTransactionAttribute());

        log.info("트랜젝션 커밋 시작");
        txManager.commit(status);
        log.info("트랜젝션 커밋 완료");
    }

    @Test
    void rollback() {
        log.info("트랜젝션 시작");
        TransactionStatus status = txManager.getTransaction(new DefaultTransactionAttribute());

        log.info("트랜젝션 롤백 시작");
        txManager.rollback(status);
        log.info("트랜젝션 롤백 완료");
    }
}

commit()

rollback()

스프링 트랜잭션 전파2 - 트랜잭션 두 번 사용

Test

    @Test
    void double_commit() {
        log.info("트랜젝션1 시작");
        TransactionStatus tx1 = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("트랜젝션1 커밋");
        txManager.commit(tx1);

        log.info("트랜젝션2 시작");
        TransactionStatus tx2 = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("트랜젝션2 커밋");
        txManager.commit(tx2);
    }

    @Test
    void double_commit_rollback() {
        log.info("트랜젝션1 시작");
        TransactionStatus tx1 = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("트랜젝션1 커밋");
        txManager.commit(tx1);

        log.info("트랜젝션2 시작");
        TransactionStatus tx2 = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("트랜젝션2 롤백");
        txManager.rollback(tx2);
    }

double_commit()

• 트랜잭션1을 시작하고, 커넥션 풀에서 conn0 커넥션을 획득했다.
• 트랜잭션1을 커밋하고, 커넥션 풀에 conn0 커넥션을 반납했다.
• 트랜잭션2을 시작하고, 커넥션 풀에서 conn0 커넥션을 획득했다.
• 트랜잭션2을 커밋하고, 커넥션 풀에 conn0 커넥션을 반납했다.

로그를 보면 트랜잭션1과 트랜잭션2가 같은 conn0 커넥션을 사용중이다.
이것은 중간에 커넥션 풀 때문에 그런 것이다.
트랜잭션1은 conn0 커넥션을 모두 사용하고 커넥션 풀에 반납까지 완료했다.
이후에 트랜잭션2가 conn0 를 커넥션 풀에서 획득한 것이다.
따라서 둘은 완전히 다른 커넥션으로 인지하는 것이 맞다.

히카리 커넥션풀이 반환해주는 커넥션을 다루는 프록시 객체의 주소가 트랜잭션1은 HikariProxyConnection@1808774497 이고,
트랜잭션2는 HikariProxyConnection@1242489018 이다.

각각 커넥션 풀에서 HikariProxyConnection@1808774497, HikariProxyConnection@1242489018 커넥션을 조회한 것을 확인할 수 있다.

double_commit_rollback()

스프링 트랜잭션 전파3 - 전파 기본

트랜잭션을 각각 사용하는 것이 아니라, 트랜잭션이 이미 진행중인데, 여기에 추가로 트랜잭션을 수행하면 어떻게 될까?

이런 경우 어떻게 동작할지 결정하는 것을 트랜잭션 전파(propagation)라 한다.

지금부터 설명하는 내용은 트랜잭션 전파의 기본 옵션인 REQUIRED 를 기준으로 설명한다.

외부 트랜잭션이 수행중인데, 내부 트랜잭션이 추가로 수행됨

• 외부 트랜잭션이라고 이름 붙인 것은 처음 시작된 트랜잭션 이다.
• 내부 트랜잭션은 외부에 트랜잭션이 수행되고 있는 도중에 호출되기 때문에 내부 트랜잭션이라 한다.

스프링 이 경우 외부 트랜잭션과 내부 트랜잭션을 묶어서 하나의 트랜잭션을 만들어준다. (기본 옵션 REQUIRED)
내부 트랜잭션이 외부 트랜잭션에 참여하는 것이다.

물리 트랜잭션, 논리 트랜잭션

• 스프링은 이해를 돕기 위해 논리 트랜잭션과 물리 트랜잭션이라는 개념을 나눈다.
• 논리 트랜잭션들은 하나의 물리 트랜잭션으로 묶인다.
• 물리 트랜잭션은 우리가 이해하는 실제 데이터베이스에 적용되는 트랜잭션을 뜻한다.
  실제 커넥션을 통해서 트랜잭션을 시작( setAutoCommit(false)) 하고, 실제 커넥션을 통해서 커밋, 롤백하는 단위이다.
• 논리 트랜잭션은 트랜잭션 매니저를 통해 트랜잭션을 사용하는 단위이다.

왜 논리 트랜잭션과 물리 트랜잭션을 나누어 설명하는 것일까?
또 다른 트랜잭션이 내부에 사용되면 여러가지 복잡한 상황이 발생한다.
논리 트랜잭션 개념을 도입하면 다음과 같은 단순한 원칙을 만들 수 있다.

원칙

• 모든 논리 트랜잭션이 커밋되어야 물리 트랜잭션이 커밋된다.
• 하나의 논리 트랜잭션이라도 롤백되면 물리 트랜잭션은 롤백된다.

스프링 트랜잭션 전파4 - 전파 예제

Test

    @Test
    void inner_commit() {
        log.info("외부 트랜젝션 시작");
        TransactionStatus outer = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("outer.isNewTransaction()={}", outer.isNewTransaction());

        log.info("내부 트랙젝션 시작");
        TransactionStatus inner = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("inner.isNewTransaction()={}", inner.isNewTransaction());
        log.info("내부 트랜젝션 커밋");
        txManager.commit(inner);

        log.info("외부 트랜젝션 커밋");
        txManager.commit(outer);
    }

• 실행 결과를 보면 외부 트랜잭션을 시작하거나 커밋할 때는 DB 커넥션을 통한
  물리 트랜잭션을 시작 ( manual commit )하고, DB 커넥션을 통해 커밋 하는 것을 확인할 수 있다.
  그런데 내부 트랜잭션을 시작하거나 커밋할 때는 DB 커넥션을 통해 커밋하는 로그를 전혀 확인할 수 없다.
• 스프링은 이렇게 여러 트랜잭션이 함께 사용되는 경우,
  처음 트랜잭션을 시작한 외부 트랜잭션이 실제 물리 트랜잭션을 관리하도록 한다.

스프링 트랜잭션 전파5 - 외부 롤백

Test

    @Test
    void outer_rollback() {
        log.info("외부 트랜젝션 시작");
        TransactionStatus outer = txManager.getTransaction(new DefaultTransactionAttribute());

        log.info("내부 트랙젝션 시작");
        TransactionStatus inner = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("내부 트랜젝션 커밋");
        txManager.commit(inner);

        log.info("외부 트랜젝션 롤백");
        txManager.rollback(outer);
    }

• 외부 트랜잭션이 물리 트랜잭션을 시작하고 롤백하는 것을 확인할 수 있다.
• 내부 트랜잭션은 앞서 배운대로 직접 물리 트랜잭션에 관여하지 않는다.

스프링 트랜잭션 전파6 - 내부 롤백

Test

    @Test
    void inner_rollback() {
        log.info("외부 트랜젝션 시작");
        TransactionStatus outer = txManager.getTransaction(new DefaultTransactionAttribute());

        log.info("내부 트랙젝션 시작");
        TransactionStatus inner = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("내부 트랜젝션 롤백");
        txManager.rollback(inner);

        log.info("외부 트랜젝션 커밋");
        txManager.commit(outer);
    }

• 논리 트랜잭션이 하나라도 롤백되면 물리 트랜잭션은 롤백된다.
• 내부 논리 트랜잭션이 롤백되면 롤백 전용 마크를 표시한다.
• 외부 트랜잭션을 커밋할 때 롤백 전용 마크를 확인한다.
  롤백 전용 마크가 표시되어 있으면 물리 트랜잭션을 롤백하고, UnexpectedRollbackException 예외를 던진다.

스프링 트랜잭션 전파7 - REQUIRES_NEW

Test

    @Test
    void inner_rollback_requires_new() {
        log.info("외부 트랜젝션 시작");
        TransactionStatus outer = txManager.getTransaction(new DefaultTransactionAttribute());
        log.info("outer.isNewTransaction()={}", outer.isNewTransaction());

        log.info("내부 트랙젝션 시작");
        DefaultTransactionAttribute definition = new DefaultTransactionAttribute();
        definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        TransactionStatus inner = txManager.getTransaction(definition);
        log.info("inner.isNewTransaction()={}", inner.isNewTransaction());

        log.info("내부 트랜젝션 롤백");
        txManager.rollback(inner);

        log.info("외부 트랜젝션 커밋");
        txManager.commit(outer);
    }

• REQUIRES_NEW 옵션을 사용하면 물리 트랜잭션이 명확하게 분리된다.
• REQUIRES_NEW 를 사용하면 데이터베이스 커넥션이 동시에 2개 사용된다는 점을 주의해야 한다.

스프링 트랜잭션 전파8 - 다양한 전파 옵션

실무에서는 대부분 REQUIRED 옵션을 사용한다.
그리고 아주 가끔 REQUIRES_NEW 을 사용하고, 나머지는 거의 사용하지 않는다.

• REQUIRED
  가장 많이 사용하는 기본 설정이다. 기존 트랜잭션이 없으면 생성하고, 있으면 참여한다.
  트랜잭션이 필수라는 의미로 이해하면 된다. (필수이기 때문에 없으면 만들고, 있으면 참여한다.)
  기존 트랜잭션 없음: 새로운 트랜잭션을 생성한다.
  기존 트랜잭션 있음: 기존 트랜잭션에 참여한다.

• REQUIRES_NEW
  항상 새로운 트랜잭션을 생성한다.
  기존 트랜잭션 없음: 새로운 트랜잭션을 생성한다.
  기존 트랜잭션 있음: 새로운 트랜잭션을 생성한다.

• SUPPORT
  트랜잭션을 지원한다는 뜻이다. 기존 트랜잭션이 없으면, 없는대로 진행하고, 있으면 참여한다.
  기존 트랜잭션 없음: 트랜잭션 없이 진행한다.
  기존 트랜잭션 있음: 기존 트랜잭션에 참여한다.

• NOT_SUPPORT
  트랜잭션을 지원하지 않는다는 의미이다.
  기존 트랜잭션 없음: 트랜잭션 없이 진행한다.
  기존 트랜잭션 있음: 트랜잭션 없이 진행한다. (기존 트랜잭션은 보류한다)

• MANDATORY
  의무사항이다. 트랜잭션이 반드시 있어야 한다. 기존 트랜잭션이 없으면 예외가 발생한다.
  기존 트랜잭션 없음: IllegalTransactionStateException 예외 발생
  기존 트랜잭션 있음: 기존 트랜잭션에 참여한다.

• NEVER
  트랜잭션을 사용하지 않는다는 의미이다. 기존 트랜잭션이 있으면 예외가 발생한다. 기존 트랜잭션도
  허용하지 않는 강한 부정의 의미로 이해하면 된다.
  기존 트랜잭션 없음: 트랜잭션 없이 진행한다.
  기존 트랜잭션 있음: IllegalTransactionStateException 예외 발생

• NESTED
  기존 트랜잭션 없음: 새로운 트랜잭션을 생성한다.
  기존 트랜잭션 있음: 중첩 트랜잭션을 만든다.
  중첩 트랜잭션은 외부 트랜잭션의 영향을 받지만, 중첩 트랜잭션은 외부에 영향을 주지 않는다.
  중첩 트랜잭션이 롤백 되어도 외부 트랜잭션은 커밋할 수 있다.
  외부 트랜잭션이 롤백 되면 중첩 트랜잭션도 함께 롤백된다.

  • 참고
    JDBC savepoint 기능을 사용한다. DB 드라이버에서 해당 기능을 지원하는지 확인이 필요하다.
    중첩 트랜잭션은 JPA에서는 사용할 수 없다.