@transactional 사용법

선언적
타겟 오브젝트 위에 @transactional를 붙히기만 하면 끝
@transactional 애노테이션에 다양한 항목들을 지정해서 사용 가능하며, 매서드 클래스 인터페이스에 적용가능하다.

우선순위

구체 클래스 메소드
구체 클래스
인터페이스 메소드
인터페이스

활용방법

우선순위를 이용하여, 구체 클래스에 디폴트 값을 적용하고, 메서드에 구체적인 세부사항을 명시할 수 있다!

테스트 코드에서의 @transactional 사용법

main 코드에서와는 다르게 롤백된다.
항상 롤백이 되어 값이 보이지 않아, 실제로 확인하고 싶다면 @Rollback(false)를 사용하자
메소드 레벨에서는 @Rollback, 클래스 레벨에서는 @TransactionConfiguration 을 사용한다.

@transactional 을 활용하면 얼마나 편리해지는 것일까?

예시 -> 고객 a가 고객 b에게 5000원을 송금하는 상황

a 잔고에서 5000원 감소
b 잔고에서 5000원 감소

두 가지 작업을 하나의 transaction으로 묶고싶은 상황이다.
서버(클라이언트)는 db 서버에 접근하기 위해 커넥션이 필요하다. 커넥션을 획득하고, db 서버에 세션이라는 것을 만드는데, 이 세션이 실제로 SQL을 실행한다고 생각하면 된다.

a 잔고에서 5000원을 감소시킬 동안 에러가 발생한다면 commit을 하지 않고(데이터 실제 반영을 하지 않고), 롤백을 하며, b 잔고에 5000원을 증가시키는 작업 또한 수행하면 안된다.

이 작업은 Service 단에서 수행 될 것이며, 원래라면 서비스 코드에 DataSource가 필요할 것이다.
Service는 순수한 비지니스 로직만 있는 것이 좋은 코드이다. 책임분리원칙에 따라야 한다.

예시코드

@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 void validation(Member toMember) {
        if (toMember.getMemberId().equals("ex")) {
            throw new IllegalStateException("이체중 예외 발생");
        }
    }

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

public class MemberRepositoryV2 {
    private final DataSource dataSource;

    public MemberRepositoryV2(DataSource dataSource) {
        this.dataSource = dataSource;
    }


    public Member findById(Connection con, String memberId) throws SQLException {
        String sql = "select * from member where member_id = ?";
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            pstmt = con.prepareStatement(sql);
            pstmt.setString(1, memberId);
            rs = pstmt.executeQuery();
            if (rs.next()) {
                Member member = new Member();
                member.setMemberId(rs.getString("member_id"));
                member.setMoney(rs.getInt("money"));
                return member;
            } else {
                throw new NoSuchElementException("member not found memberId=" + memberId);
            }
        } catch (SQLException e) {
            log.error("db error", e);
            throw e;
        } finally {
            JdbcUtils.closeResultSet(rs);
            JdbcUtils.closeStatement(pstmt);
        }
    }


    public void update(Connection con, String memberId, int money) throws SQLException {
        String sql = "update member set money=? where member_id=?";
        PreparedStatement pstmt = null;
        try {
            pstmt = con.prepareStatement(sql);
            pstmt.setInt(1, money);
            pstmt.setString(2, memberId);
            pstmt.executeUpdate();
        } catch (SQLException e) {
            log.error("db error", e);
            throw e;
        } finally {
//connection은 여기서 닫지 않는다.
            JdbcUtils.closeStatement(pstmt);
        }
    }


    private void close(Connection con, Statement stmt, ResultSet rs) {
        JdbcUtils.closeResultSet(rs);
        JdbcUtils.closeStatement(stmt);
        JdbcUtils.closeConnection(con);
    }

    private Connection getConnection() throws SQLException {
        Connection con = dataSource.getConnection();
        log.info("get connection={} class={}", con, con.getClass());
        return con;
    }
}

문제점 3가지

JDBC 구현 기술이 서비스 계층에 누수되는 문제 -> 트랜잭션을 적용하기 위해 JDBC 구현 기술이 서비스 계층에 누수되었다.
트랜잭션 동기화 문제 -> 같은 트랜잭션을 유지하기 위해 커넥션을 파라미터로 넘겨야 한다.

예외 누수 -> 스프링이 제공하는 추상화된 런타임 예외로 전환하면 된다.

해결법 1 -> TransactionManager

DataSourceUtils 로 커넥션을 가져온다!

서비스 계층에서 transactionManager.getTransaction() 을 호출해서 트랜잭션을 시작한다.
트랜잭션을 시작하려면 먼저 데이터베이스 커넥션이 필요하다. 트랜잭션 매니저는 내부에서 데이터소스를
사용해서 커넥션을 생성한다.
커넥션을 수동 커밋 모드로 변경해서 실제 데이터베이스 트랜잭션을 시작한다.
커넥션을 트랜잭션 동기화 매니저에 보관한다.
트랜잭션 동기화 매니저는 쓰레드 로컬에 커넥션을 보관한다. 따라서 멀티 쓰레드 환경에 안전하게 커넥션
을 보관할 수 있다.
서비스는 비즈니스 로직을 실행하면서 리포지토리의 메서드들을 호출한다. 이때 커넥션을 파라미터로 전달 하지 않는다.
리포지토리 메서드들은 트랜잭션이 시작된 커넥션이 필요하다. 리포지토리는 DataSourceUtils.getConnection() 을 사용해서 트랜잭션 동기화 매니저에 보관된 커넥션을 꺼내서 사 용한다. 이 과정을 통해서 자연스럽게 같은 커넥션을 사용하고, 트랜잭션도 유지된다.
획득한 커넥션을 사용해서 SQL을 데이터베이스에 전달해서 실행한다.
비즈니스 로직이 끝나고 트랜잭션을 종료한다. 트랜잭션은 커밋하거나 롤백하면 종료된다.
트랜잭션을 종료하려면 동기화된 커넥션이 필요하다. 트랜잭션 동기화 매니저를 통해 동기화된 커넥션을 획득한다.
획득한 커넥션을 통해 데이터베이스에 트랜잭션을 커밋하거나 롤백한다.
전체 리소스를 정리한다.

해결법 2 -> TransactionTemplate.

반복적인 트랜잭션을 위해서 사용되는 반복되는 커밋, 롤백 코드를 제거하자.

    public void accountTransfer(String fromId, String toId, int money) throws SQLException {
        txTemplate.executeWithoutResult((status) -> {
            try {
                bizLogic(fromId, toId, money); // 비지니스 로직
            } catch (SQLException e) {
                throw new IllegalStateException(e);
            }
        });

    }

transactionTemplate이 하는 역할

비즈니스 로직이 정상 수행되면 커밋한다.
언체크 예외가 발생하면 롤백한다. 그 외의 경우 커밋한다.

** 그러나 결국에는 서비스에 트랜잭션을 처리하는 기술로직이 포함된 것이다**

스프링 AOP를 통해 프록시를 도입하면 문제를 깔끔하게 해결할 수 있다.
@transaction을 이용하자!

    @Transactional
    public void accountTransfer(String fromId, String toId, int money) throws SQLException {
        bizLogic(fromId, toId, money);
    }

** 그 길었던 코드가 @transaction 어노테이션 코드 하나로 정리된다. **

[7주차](임주민, 오형석, 이승철) #7

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions