깔끔하게 정리된 코드로 트랜잭션 경계를 관리하기 위해 스프링이 제공하는 방법

Connection 파라미터 제거

Connection을 파라미터로 직접 전달하는 문제를 해결해보자.

upgradeLevels() 메서드가 트랜잭션 경계 설정을 해야 한다는 사실은 피할 수 없다.

• upgradeLevels() 메서드에서 Connection 생성과 트랜잭션 경계를 관리하게 한다.

• (스프링 사용 전) DAO 를 호출할 때 Connection 을 파라미터로 넘겨준다.

• (스프링 사용 후) 트랜잭션 동기화transaction symchronization

  • UserService 에서 트랜잭션을 시작하기 위해 만든 Connection 오브젝트를 특별한 저장소에 보관
  • 이후 호출되는 메서드에서 저장된 Connection 을 가져다 사용하게 한다.
  • DAO 가 사용하는 JdbcTemplate 이 트랜잭션 동기화 방식을 이용하도록 하는 것
  • 트랜잭션이 모두 종료되면 동기화를 마친다.

  

  트랜잭션 동기화를 사용한 경우의 작업 흐름

  1. UserService 는 Connection 을 생성한다.
  2. 생성한 Connection 을 트랜잭션 동기화 저장소에 저장한다.
     • Connection**.setAutoCommit(false)** 를 호출해 트랜잭션을 시작한다.
     • 본격적으로 DAO 기능을 이용하기 시작한다.
  3. update() 메서드가 호출된다
  4. 내부에서 이용하는 JdbcTemplate 메서드에서 트랜잭션 동기화 저장소에 현재 시작된 트랜잭션을 가진 Connection 오브젝트가 존재하는지 확인한다.
     • upgradeLevels() 메서드 시작 부분에서 저장한 Connection 을 가져온다.
  5. 가져온 Connection 을 이용해 PreparedStatement 를 만들어 수정 SQL 을 실행한다.
     • 트랜잭션 동기화 저장소에서 DB Connection 을 가져왔을 때는 JdbcTemplate 은 Connection 을 닫지 않은 상태로 작업을 마친다.
     • 이렇게 트랜잭션 내에서 첫 DB 작업을 마친다.
       • 여전히 Connection 은 개방
       • 트랜잭션은 진행중
       • 트랜잭션 동기화 저장소에 저장
  6. 두번째 update() 호출된다.
  7. 트랜잭션 동기화 저장소에서 Connection 을 가져온다.
  8. 사용한다.
  9. 마지막 update() 도 같은 트랜잭션을 가져와(10) 사용한다.(11)

1. Connection 의 commit() 을 호출해서 트랜잭션을 완료한다.
2. 트랜잭션 저장소가 더이상 Connection 오브젝트를 저장하지 않도록 제거한다.

어느 작업중에라도 예외 상황 발생 시 UserService 는 Connection**.rollback()** 을 호출하고 Connection 오브젝트는 제거한다.

<aside> 📌

트랜잭션 동기화 저장소는 작업 스레드마다 독립적으로 Connectino 오브젝트를 저장하고 관리한다. 고로 다중 사용자를 처리하는 서버의 멀티스레드 환경에서 충돌날 일은 없다.

</aside>

결과

1. 파라미터를 통해 일일이 Connection 오브젝트를 전달할 필요가 없어진다.
2. 트랜잭션 경계 설정이 필요한 메서드에서만 Connection 을 다룬다.
   • 여기서 생성된 Connection 과 트랜잭션을 DAO 의 JdbcTemplate 이 사용할 수 있도록 별도의 저장소에 동기화 하는 방법을 저장하면 된다.
3. UserDao 인터페이스에서 일일이 JDBC 인터페이스인 Connection 을 사용한다고 노출할 필요가 없다.

트랜잭션 동기화 적용

멀티스레드 환경에서도 안전한 트랜잭션 동기화 방법 구현은 기술적으로 어려운 일이다.

→ 스프링은 JdbcTemplate 과 더불어 트랜잭션 동기화 기능을 지원하는 유틸리티 메서드를 제공한다.

public class UserService {

  private DataSource dataSource;
  public void setDataSource(DataSource dataSource){
    this.dataSource = dataSource;
  }

// UserService.class
public void upgradeLevels(){
    **TransactionSynchronizationManager.initSynchronization();;**
    Connection c = **DataSourceUtils.getConnection(dataSource);**
    c.setAutoCommit(false);