jdbc : transaction manager
This commit is contained in:
haerong22
@@ -0,0 +1,130 @@
|
||||
package com.example.jdbc.repository;
|
||||
|
||||
import com.example.jdbc.domain.Member;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.jdbc.datasource.DataSourceUtils;
|
||||
import org.springframework.jdbc.support.JdbcUtils;
|
||||
|
||||
import javax.sql.DataSource;
|
||||
import java.sql.*;
|
||||
import java.util.NoSuchElementException;
|
||||
|
||||
/**
|
||||
* 트랜잭션 - 트랜잭션 매니저
|
||||
* DataSourceUtils.getConnection()
|
||||
* DataSourceUtils.releaseConnection()
|
||||
*/
|
||||
@Slf4j
|
||||
public class MemberRepositoryV3 {
|
||||
|
||||
private final DataSource dataSource;
|
||||
|
||||
public MemberRepositoryV3(DataSource dataSource) {
|
||||
this.dataSource = dataSource;
|
||||
}
|
||||
|
||||
public Member save(Member member) throws SQLException {
|
||||
String sql = "insert into member(member_id, money) values(?, ?)";
|
||||
|
||||
Connection con = null;
|
||||
PreparedStatement pstmt = null;
|
||||
|
||||
try {
|
||||
con = getConnection();
|
||||
pstmt = con.prepareStatement(sql);
|
||||
pstmt.setString(1, member.getMemberId());
|
||||
pstmt.setInt(2, member.getMoney());
|
||||
pstmt.executeUpdate();
|
||||
return member;
|
||||
} catch (SQLException e) {
|
||||
log.error("db error", e);
|
||||
throw e;
|
||||
} finally {
|
||||
close(con, pstmt, null);
|
||||
}
|
||||
}
|
||||
|
||||
public Member findById(String memberId) throws SQLException {
|
||||
String sql = "select * from member where member_id = ?";
|
||||
|
||||
Connection con = null;
|
||||
PreparedStatement pstmt = null;
|
||||
ResultSet rs = null;
|
||||
|
||||
try {
|
||||
con = getConnection();
|
||||
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 {
|
||||
close(con, pstmt, rs);
|
||||
}
|
||||
}
|
||||
|
||||
public void update(String memberId, int money) throws SQLException {
|
||||
String sql = "update member set money=? where member_id=?";
|
||||
|
||||
Connection con = null;
|
||||
PreparedStatement pstmt = null;
|
||||
|
||||
try {
|
||||
con = getConnection();
|
||||
pstmt = con.prepareStatement(sql);
|
||||
pstmt.setInt(1, money);
|
||||
pstmt.setString(2, memberId);
|
||||
|
||||
int result = pstmt.executeUpdate();
|
||||
log.info("resultSize={}", result);
|
||||
} catch (SQLException e) {
|
||||
log.error("db error", e);
|
||||
throw e;
|
||||
} finally {
|
||||
close(con, pstmt, null);
|
||||
}
|
||||
}
|
||||
|
||||
public void delete(String memberId) throws SQLException {
|
||||
String sql = "delete from member where member_id=?";
|
||||
|
||||
Connection con = null;
|
||||
PreparedStatement pstmt = null;
|
||||
|
||||
try {
|
||||
con = getConnection();
|
||||
pstmt = con.prepareStatement(sql);
|
||||
pstmt.setString(1, memberId);
|
||||
pstmt.executeUpdate();
|
||||
} catch (SQLException e) {
|
||||
log.error("db error", e);
|
||||
throw e;
|
||||
} finally {
|
||||
close(con, pstmt, null);
|
||||
}
|
||||
}
|
||||
|
||||
private void close(Connection con, Statement stmt, ResultSet rs) {
|
||||
JdbcUtils.closeResultSet(rs);
|
||||
JdbcUtils.closeStatement(stmt);
|
||||
// 트랜잭션 동기화를 사용하려면 DataSourceUtils 를 사용해야 한다.
|
||||
DataSourceUtils.releaseConnection(con, dataSource);
|
||||
}
|
||||
|
||||
private Connection getConnection() throws SQLException {
|
||||
// 트랜잭션 동기화를 사용하려면 DataSourceUtils 를 사용해야 한다.
|
||||
Connection con = DataSourceUtils.getConnection(dataSource);
|
||||
log.info("get connection={}, class={}", con, con.getClass());
|
||||
return con;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,52 @@
|
||||
package com.example.jdbc.service;
|
||||
|
||||
import com.example.jdbc.domain.Member;
|
||||
import com.example.jdbc.repository.MemberRepositoryV3;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.transaction.PlatformTransactionManager;
|
||||
import org.springframework.transaction.TransactionStatus;
|
||||
import org.springframework.transaction.support.DefaultTransactionDefinition;
|
||||
|
||||
import java.sql.SQLException;
|
||||
|
||||
/**
|
||||
* 트랜잭션 - 트랜잭션 매니저
|
||||
*/
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor
|
||||
public class MemberServiceV3_1 {
|
||||
private final PlatformTransactionManager transactionManager;
|
||||
private final MemberRepositoryV3 memberRepository;
|
||||
|
||||
public void accountTransfer(String fromId, String toId, int money) throws SQLException {
|
||||
// 트랜잭션 시작
|
||||
TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());
|
||||
try {
|
||||
// 비지니스 로직
|
||||
bizLogic(fromId, toId, money);
|
||||
|
||||
transactionManager.commit(status); // 성공시 커밋
|
||||
} catch (Exception e) {
|
||||
transactionManager.rollback(status); // 실패시 롤백
|
||||
throw new IllegalStateException(e);
|
||||
}
|
||||
}
|
||||
|
||||
private void bizLogic(String fromId, String toId, int money) throws SQLException {
|
||||
Member fromMember = memberRepository.findById(fromId);
|
||||
Member toMember = memberRepository.findById(toId);
|
||||
|
||||
memberRepository.update(fromId, fromMember.getMoney() - money);
|
||||
|
||||
validation(toMember);
|
||||
|
||||
memberRepository.update(toId, toMember.getMoney() + money);
|
||||
}
|
||||
|
||||
private void validation(Member toMember) {
|
||||
if (toMember.getMemberId().equals("ex")) {
|
||||
throw new IllegalStateException("이체중 예외 발생");
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,88 @@
|
||||
package com.example.jdbc.service;
|
||||
|
||||
import com.example.jdbc.domain.Member;
|
||||
import com.example.jdbc.repository.MemberRepositoryV3;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.DisplayName;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
|
||||
import org.springframework.jdbc.datasource.DriverManagerDataSource;
|
||||
import org.springframework.transaction.PlatformTransactionManager;
|
||||
|
||||
import java.sql.SQLException;
|
||||
|
||||
import static com.example.jdbc.connection.ConnectionConst.*;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.assertj.core.api.Assertions.assertThatThrownBy;
|
||||
|
||||
/**
|
||||
* 트랜잭션 - 트랜잭션 매니저
|
||||
*/
|
||||
class MemberServiceV3_1Test {
|
||||
|
||||
public static final String MEMBER_A = "memberA";
|
||||
public static final String MEMBER_B = "memberB";
|
||||
public static final String MEMBER_EX = "ex";
|
||||
|
||||
private MemberRepositoryV3 memberRepository;
|
||||
private MemberServiceV3_1 memberService;
|
||||
|
||||
@BeforeEach
|
||||
void before() {
|
||||
DriverManagerDataSource dataSource = new DriverManagerDataSource(URL, USERNAME, PASSWORD);
|
||||
memberRepository = new MemberRepositoryV3(dataSource);
|
||||
|
||||
PlatformTransactionManager transactionManager = new DataSourceTransactionManager(dataSource);
|
||||
|
||||
memberService = new MemberServiceV3_1(transactionManager, memberRepository);
|
||||
}
|
||||
|
||||
@AfterEach
|
||||
void after() throws SQLException {
|
||||
memberRepository.delete(MEMBER_A);
|
||||
memberRepository.delete(MEMBER_B);
|
||||
memberRepository.delete(MEMBER_EX);
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("정상 이체")
|
||||
void accountTransfer() throws SQLException {
|
||||
// given
|
||||
Member memberA = new Member(MEMBER_A, 10000);
|
||||
Member memberB = new Member(MEMBER_B, 10000);
|
||||
memberRepository.save(memberA);
|
||||
memberRepository.save(memberB);
|
||||
|
||||
// when
|
||||
memberService.accountTransfer(memberA.getMemberId(), memberB.getMemberId(), 2000);
|
||||
|
||||
// then
|
||||
Member findMemberA = memberRepository.findById(memberA.getMemberId());
|
||||
Member findMemberB = memberRepository.findById(memberB.getMemberId());
|
||||
|
||||
assertThat(findMemberA.getMoney()).isEqualTo(8000);
|
||||
assertThat(findMemberB.getMoney()).isEqualTo(12000);
|
||||
}
|
||||
|
||||
@Test
|
||||
@DisplayName("이체중 예외 발생")
|
||||
void accountTransferEx() throws SQLException {
|
||||
// given
|
||||
Member memberA = new Member(MEMBER_A, 10000);
|
||||
Member memberEx = new Member(MEMBER_EX, 10000);
|
||||
memberRepository.save(memberA);
|
||||
memberRepository.save(memberEx);
|
||||
|
||||
// when
|
||||
assertThatThrownBy(() -> memberService.accountTransfer(memberA.getMemberId(), memberEx.getMemberId(), 2000))
|
||||
.isInstanceOf(IllegalStateException.class);
|
||||
|
||||
// then
|
||||
Member findMemberA = memberRepository.findById(memberA.getMemberId());
|
||||
Member findMemberB = memberRepository.findById(memberEx.getMemberId());
|
||||
|
||||
assertThat(findMemberA.getMoney()).isEqualTo(10000);
|
||||
assertThat(findMemberB.getMoney()).isEqualTo(10000);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user