트랜잭션

 

트랜잭션 적용

트랜잭션은 비즈니스 로직이 있는 서비스 계층에서 시작해야한다. 이유는 비즈니스 로직이 잘못되면 해당 비즈니스 로직으로 인해 문제가 되는 부분을 함께 롤백해야하기 때문이다.

트랜잭션은 세션 단위로 진행된다. 세션은 커넥션 당 하나의 세션이 부여된다.

 

트랜잭션을 시작하기 위해서는 커넥션이 필요하므로 결국 서비스 계층에서 커넥션 만들고, 트랜잭션 커밋 이후에 커넥션을 종료해야 한다.

 

애플리케이션에서 DB 커넥션을 사용하려면 트랜잭션을 사용하는 동안 같은 커넥션을 유지해야 한다. 그래야 같은 세션을 사용할 수 있다.

그럼 애플리케이션 로직에서 어떻게 같은 커넥션을 유지할 수 있을까? 커넥션을 파라미터로 전달해서 같은 커넥션이 사용되도록 하자

 

 

커넥션은 유지하기 위해 변경된 부분

1. 커넥션 유지가 필요한 두 메서드(findById, update)는 파라미터로 넘어온 커넥션을 사용해야한다. 따라서 con = getConnection()코드가 있으면 안된다.

이전 코드에서는 con = getConnection(); 해서 메서드 호출할 때마다 새로운 커넥션을 생성했다.

2. 커넥션 유지가 필요한 두 메서드는 리포지토리에서 커넥션을 닫으면 안된다.

커넥션을 전달 받은 리포지토리 뿐만 아니라 이휴에도 커넥션을 계속 이어서 사용하기 때문에 닫으면 안된다.

그럼 커넥션을 언제 닫냐? 서비스 로직이 끝날 때 트랜잭션을 종료하고 닫아야 한다.

 

애플리케이션 로직에서 트랜잭션 연동 로직 작성

@Slf4j
@RequiredArgsConstructor
public class MemberServiceV2 {

    private final DataSource dataSource;

    private final MemberRepositoryV2 memberRepository;

    public void accountTransfer(String fromId, String toId, int money) throws SQLException {
        Connection con = dataSource.getConnection();
        try {
            con.setAutoCommit(false); //트랜잭션 시작
            //비즈니스 로직 시작
            bizLogic(con, fromId, toId, money);

            con.commit(); //성공시 커밋

        } catch (Exception e) {
            con.rollback();//실패시 롤백
            throw new IllegalStateException(e);
        } finally {
            release(con);
        }
    }

    private void bizLogic(Connection con, String fromId, String toId, int money) throws SQLException {
        Member fromMember = memberRepository.findById(con, fromId);
        Member toMember = memberRepository.findById(con, toId);

        memberRepository.update(con, fromId, fromMember.getMoney() - money);
        validation(toMember); //예외 발생하면 아래 코드로 못 넘어감
        memberRepository.update(con, toId, toMember.getMoney() + money);
    }

    private static void release(Connection con) {
        if (con != null) {
            try {
                con.setAutoCommit(true); //커넥션 풀 고려
                con.close();
            } catch (Exception e) {
                log.info("error", e);
            }
        }
    }

    private static void validation(Member toMember) {
        if (toMember.getMemberId().equals("ex")) {
            throw new IllegalStateException("이체중 예외 발생");
        }
    }
}

비즈니스 로직 실행 전에 Connection con = dataSource.getConnection(); 커넥션 얻고, 미리 얻은 커넥션을 비즈니스 로직에 전달해 준다( bizLogic(con, fromId, toId, money);)

 

con.commit()

• 비즈니스 로직이 정상 수행 되면 트랜잭션을 커밋

 

con.rollback()

• catch(Ex){...}를 사용해서 비즈니스 로직 수행 도중에 예외가 발생하면 트랜잭션을 롤백한다.

 

release(con)

• finally{...}를 사용해서 커넥셔을 모두 사용하고 나면 안전하게 종료. con.close()를 호출했을 때 커넥션이 종료되는 것이 아니라 커넥션 풀에 반환되는데 반환되기 전에 트랜잭션을 자동 커밋 모드로 변경하는 것이 안전하다.

---

트랜잭션을 적용해도 남아 있는 문제

애플리케이션에서 DB트랜잭션을 적용하려면 서비스 계층이 매우 지저분해지고, 생각보다 복잡한 코드를 요구

서비스 계층을 순수하게 유지할 수 있는 방법이 있을까? 

 

→ 스프링을 사용해서 해결