@Transactional Propagation와 Spring Transaction Proxy Pattern

@Transactional Propagation(전파)

propagation의 옵션

옵션
REQUIRED	Default - 부모 트랜잭션이 존재한다면 부모 트랜잭션 내에서 실행, 없다면 새로운 트랜잭션 생성 중간에 자식 / 부모에서 rollback 발생 시, 부모, 자식 모두 rollback
REQUIRES_NEW	무조건 새로운 트랜잭션 생성(시작) 만약 호출한 곳에 이미 트랜잭션이 있다면 기존의 트랜잭션은 메서드가 종료할 때까지 잠시 대기, 본인의 트랜잭션 실행 rollback은 각각 이루어짐
MANDATORY	무조건 부모 트랜잭션에 합류, 이 때 부모 트랜잭션이 없다면 예외 발생
SUPPORTS	메소드가 트랜잭션을 필요로 하지는 않지만,진행 중인 트랜잭션이 존재하면 트랜잭션을 사용한다는 것을 의미진행 중인 트랜잭션이 존재하지 않더라도, 메소드는 정상적(non-transactional)으로 동작한다.
NESTED	부모 트랜잭션이 존재하면 부모 트랜잭션에 중첩, 부모 트랜잭션이 존재하지 않는다면 새로운 트랜잭션을 생성. 부모 트랜잭션에 예외가 발생하면 자식 트랜잭션도 rollback한다. 자식 트랜잭션에 예외가 발생하더라도 부모 트랜잭션은 rollback하지 않는다. 이때 롤백은 부모 트랜잭션에서 자식 트랜잭션을 호출하는 지점까지만 롤백된다. (즉, DB에서 savepoint 기능을 지원해야함 - oracle) 이후 부모 트랜잭션에서 문제가 없으면 부모 트랜잭션은 끝까지 commit 된다. 현재 트랜잭션이 있으면 중첩 트랜잭션 내에서 실행하고, 그렇지 않으면 REQUIRED 처럼 동작합니다.
NEVER	non-transactional 로 실행되며 부모 트랜잭션이 존재하면 Exception이 발생한다.

REQUIRED

@Transaction 에 자세히 들어가보면 Propagation 옵션에 대한 설명이 나와있다. 

앞서 살펴본대로 default는 REQUIRED 다.

 

ref. https://devlog-wjdrbs96.tistory.com/424

Spring에서의 @Transactional 에 대한 Default isolation Level

 

• default 설명

→ DEFAULT설명을 보면 JDBC isolation Level 동일하게 설정.

즉, MySQL InnoDB를 사용 → REPEATABLE READ가 DEFAULT로 사용

---

Spring Transactional Proxy Pattern

 

Proxy Pattern

• 대상 객체의 기능을 대신 수행하는 대리 객체를 사용
• 실제 객체가 아닌 임의의 객체를 생성하여 주입
• JDK Proxy / CGLib Proxy

 

JDK Proxy  /  CGLib Proxy

• JDK Proxy (Dynamic Proxy)
  • Interface가 필요함 (없으면 프록시 생성 불가)
  • Spring AOP default
• CGLib Proxy
  • Class의 byte code를 조작 → 프록시 객체 생성
  • Extends 방식으로 프록시 객체 구현
  • JDK 보다 성능 우월 , 최근 Spring Boot 기본 AOP 전략

JDK Proxy의 경우 : AOP를 적용하여 구현된 클래스의 인터페이스를 프록시 객체로 구현해서 코드를 끼워넣는 방식이다.

Spring은 @Transactional이 적용된 모든 클래스/메서드에 대한 Proxy 생성

• 프록시는 프레임워크가 트랜잭션을 시작/커밋하기 위해 실행 중인 메서드의 전후로 트랜잭션 로직을 주입
  

 

왼쪽은 @Transactional을 적용하기전 상태,

오른쪽은 @Trnasactional이 적용되고 JDK Dynamic Proxy 방식 AOP로 동작했을 때의 모습

트랜잭션 처리를 다이나믹 프록시 객체에 대신 위임한다.

다이나믹 프록시 객체는 타깃이 상속하고있는 인터페이스를 상속 후 추상메서드를 구현하며 내부적으로 타깃 메서드 호출 전 후로 트랜잭션 처리를 수행한다.
Controller는 타깃의 메서드를 호출하는것으로 생각하지만 실제로는 프록시의 메서드를 호출하게된다.

(logging 또한 마찬가지)

 

private fun → @Transactional 적용 불가

 

→ proxy 객체에서의 구현 코드 예시

private void createUserListWithTrans(){
    EntityTransaction tx = em.getTransaction();
    tx.begin();

    super.createUserListWithTrans();   // private이기 때문에 에러 발생

    tx.commit();
}

 

같은 클래스 내에서의 여러 @Transactional method 호출시 주의

@Slf4j
@RequiredArgsConstructor
@Service
public class UserService {
    private final UserRepository userRepository;

    @Transactional
    public void createUserListWithTrans(){
        for (int i = 0; i < 10; i++) {
            createUser(i);
        }
    }

    public void createUserListWithoutTrans(){
        for (int i = 0; i < 10; i++) {
            createUser(i);
        }
    }

    @Transactional
    public User createUser(int index){
        User user = User.builder()
                .name("testname::"+index)
                .email("testemail::"+index)
                .build();

        userRepository.save(user);
        return user;
    }

• jpa가 만든 proxy 객체 Injection

• 중간에 부모에 대해 RuntimeException 발생 시키기

//UserService.java

@Transactional
public void createUserListWithTrans(){
    for (int i = 0; i < 10; i++) {
        createUser(i);
    }

    throw new RuntimeException(); // user 생성 완료 후 Exception 발생
}

@Transactional
public User createUser(int index){
    User user = User.builder()
            .name("testname::"+index)
            .email("testemail::"+index)
            .build();

    userRepository.save(user);
    return user;
}

 

10번의 createUser가 실행됐지만 최종적으로는 0개가 생성된 User

 

createUser에 @Transaction이 걸려있어 각각 commit이 될거라 예상했지만 실제 생성된 User는 0개이며
 transaction이 rollback된듯한 결과가 나왔습니다.

 

Proxy로 생성한 객체 예상 코드 

@Slf4j
@RequiredArgsConstructor
@Service
public class UserService359caca0 extends UserService {
    private final EntityManager em;

    // Proxy객체에서 UserService의 createUserListWithTrans를 호출하고
    // createUserListWithTrans는 그 안에서 같은 클래스의 createUser()를 호출하기 때문에
    // createUserListWithTrans의 Transaction만 동작하게됨

    public void createUserListWithTrans(){
        EntityTransaction tx = em.getTransaction();
        tx.begin();

        super.createUserListWithTrans();

        tx.commit();
    }

    public void createUserListWithoutTrans(){
        super.createUserListWithoutTrans();
    }

    public User createUser(int index){
        EntityTransaction tx = em.getTransaction();
        tx.begin();

        User user = super.createUser(index);

        tx.commit();    

        return user;
    }

1. Proxy 객체에서 Transaction을 설정
2. 이후 기존 UserService의 createUserListWithTrans() 실행
3. UserService의 createUserListWithTrans안에서 같은 클래스 안의 createUser 실행
   • 자식 트랜잭션 실행 → default : REQUIRED
4. 모든 과정 완료 후 Transaction 종료

Proxy형태로 동작하게 되면 위 과정대로 동작하기 떄문에 최초 진입점인 createUserListWithTrans의 Transaction만 동작하게 되는것입니다.

@Test + @Transactional = Default (Rollback)

• rollback을 원하지 않을 경우 : @Rollback(false) 로 설정하면 된다.

 

ref: https://cobbybb.tistory.com/17 , https://kangyb.tistory.com/15