스프링 Transaction(1)

5 minute read

트랜잭션 기본

❗트랜잭션의 기본 형태
💡 1.connection 의 auto commit 를 false 로 주고
💡 2.try catch 를 이용해서 commit 또는 rollback 하는 것이 기본이다.

스프링 트랜잭션

❗스프링 트랜잭션 개념
💡 스프링 같은 프레임워크 설정에서 특정 이름이나 특정 패키지 클래스에 무조건 걸리게 설정.
💡 특정위치에 어노테이션 형태로 사용할수도 있게 간편화 시킨 것 일뿐이다.

트랜잭션 비권장 상황

❗비권장 상황
💡 많은 경우중 트랜잭션을 사용하지 않는것이 유리한 경우는 대량의 데이터를 처리하는 batch 처리하는게 좋다.
💡 예를들어 99만건까지 들어가고 에러가나면 롤백에도 한참이 걸리고 심지어 어느 로우에서 발생한 문제인지 찾기도 매우 어렵다.
💡 작게 쪼개보면.. select 문에 트랜잭션을 거는것은 낭비다.

스프링의 @Trasaction 개념

Service1

@Service
public class TBBCKW001ServiceImpl implements TBBCKW001Service {

	@Inject
	private TBBCKW001 dao;
	
	@Transactional
	/* 회원일련번호를 생성해서 가져온다. */
	public String getSqMmsn() throws Exception {
		return dao.getSqMmsn();
	}

	/* TBBCKW001 정보를 생성한다. */
	@Transactional
	@Override
	public int setInsert(TBBCKW001DTO TBBCKW001) throws Exception {
		return dao.setInsert(TBBCKW001);
	}
}

Service2

@Service
public class TBBCKW002ServiceImpl implements TBBCKW002Service {

	@Inject
	private TBBCKW002 dao;

	/* 회원일련번호를 생성해서 가져온다. */
	@Transactional
	@Override
	public String getSqSlfMmsn() throws Exception {
		return dao.getSqSlfMmsn();
	}

	/* TBBCKW002 정보를 생성한다. */
	@Transactional
	@Override
	public int setInsert(TBBCKW002DTO TBBCKW002) throws Exception {
		return dao.setInsert(TBBCKW002);
	}
}

❗@Transactional 어노테이션 추가

Controller

@Inject
TBBCKW001Service tBBCKW001Service;
@Inject
TBBCKW002Service tBBCKW002Service;

@Transactional
public void executeTransactionalOperation() throws Exception {
    // 두 서비스 메소드를 순차적으로 호출
    String sqMmsn = tBBCKW001Service.getSqMmsn();
    TBBCKW001DTO tbbckw001DTO = new TBBCKW001DTO();
    // 필요한 작업 수행
    tBBCKW001Service.setInsert(tbbckw001DTO);
    String sqSlfMmsn = tBBCKW002Service.getSqSlfMmsn();
    TBBCKW002DTO tbbckw002DTO = new TBBCKW002DTO();
    // 필요한 작업 수행
    tBBCKW002Service.setInsert(tbbckw002DTO);
}

설명

❗컨트롤러의 @Transaction 제거하면?
💡 만약 executeTransactionalOperation 메소드에서 @Transactional 어노테이션을 제거한다면, 해당 메소드 내에서의 트랜잭션은 발생하지 않습니다.

💡 @Transactional 어노테이션이 메소드에 존재해야 스프링이 해당 메소드를 트랜잭션 경계로 감싸서 트랜잭션을 시작하고 관리합니다.

💡 현재 코드에서 executeTransactionalOperation 메소드에 @Transactional 어노테이션이 있기 때문에, 이 메소드 내에서 실행되는 모든 작업은 하나의 트랜잭션으로 묶입니다. 따라서 tBBCKW001Service와 tBBCKW002Service의 메소드 호출은 하나의 트랜잭션 내에서 수행되고, 메소드 실행 도중에 예외가 발생하면 롤백됩니다.

💡 만약 @Transactional 어노테이션을 executeTransactionalOperation 메소드에서 제거한다면, 각각의 tBBCKW001Service.setInsert와 tBBCKW002Service.setInsert 메소드는 자체적으로 트랜잭션을 시작하게 됩니다. 이 경우, 메소드 별로 트랜잭션이 독립적으로 동작하며, 하나의 메소드에서 예외가 발생해도 다른 메소드의 트랜잭션에는 영향을 주지 않습니다.

💡 따라서, @Transactional 어노테이션을 executeTransactionalOperation 메소드에서 제거하면 각 서비스 메소드의 트랜잭션이 독립적으로 동작하게 되므로 주의가 필요합니다. 이는 서비스 메소드 간의 일관성을 유지하기 위해 트랜잭션을 한 덩어리로 묶는 것이 필요한 경우에 고려되어야 합니다.

실제 테스트 환경

TABLE1 (기업테이블)

TABLE2 (사용자테이블)

❗@Transactional 테스트 준비
💡 테스트 테이블은 총 2개
💡 테스트 테이블은 총 2개

실제 테스트 시작

❗순서
💡 STEP1. 기업테이블을 먼저 UPDATE
💡 STEP2. 사용자테이블을 UPDATE (익셉션발생)
💡 STEP3. 기업테이블 트랜잭션이 되었는지 결과확인

STEP1. 프론트엔드 요청

{
    "mmsn": "C0000002",
    "bzno": "1234567890",
    "entNm": "이치란기업_수정",
    "buTlno": "0511111111",
    "buBadr": "일본 후쿠오카시_수정",
    "entEmad": "ichiran@jp.com",
    "userCnt": "",
    "mbrNewJnYmd": "2024.02.13",
    "exptYmd": "2024.02.13",
    "mode": "U",
    "isUser": false,
    "slfMmsn": "M0000002",
    "itrSvcCsnm": "직원1_수정",
    "slfCtfTlno": "23423423423",
    "connIp": "234.234.234.234",
    "connIp1": "234",
    "connIp2": "234",
    "connIp3": "234",
    "connIp4": "234",
    "cstEmad": "member1@jp.com",
    "lgnId": "ichi1_수정",
    "hdnIsIdDupCheck": "true",
    "itrUsrPwd": "@@@@@adminaBCKZZ",
    "hdnIsPwdCreate": false,
    "type": "ADM_MBR_UDP"
}

STEP2. 백엔드 요청

@Inject
TBBCKW001Service tBBCKW001Service;
@Inject
TBBCKW002Service tBBCKW002Service;

@Transactional
public void executeTransactionalOperation() throws Exception {
    // 두 서비스 메소드를 순차적으로 호출
    
    /*************
    기업
    *************/
    TBBCKW001DTO tbbckw001DTO = new TBBCKW001DTO();
    
    // 기업테이블 필요한 값 SET 수행
    // 생략..

    tBBCKW001Service.setUpdate(tbbckw001DTO); //UPDATE 수행

    /*************
    사용자
    *************/
    TBBCKW002DTO tbbckw002DTO = new TBBCKW002DTO();
    
    // 기업테이블 필요한 값 SET 수행
    //테스트 강제 익셉션 발생시키기1 (DB 길이 에러 방식)
    TBBCKW002.setMmsn("C9999999"); 
	TBBCKW002.setSlfMmsn("M9999999"); 

	//테스트 강제 익셉션 발생시키기2 (JAVA에러 방식)
	//throw new SysException(SysErrorCode.INTERNAL_SERVER_ERROR);
    
    tBBCKW002Service.setUpdate(tbbckw002DTO); //UPDATE 수행


    //결과는...?
}

STEP3. 결과

❗트랜잭션 처리 실패
💡 기업테이블만 수정이 되어있다…

재시도 1차

서비스(서비스2개를 묶어서)

@Service
public class BlangInsertService {
	@Inject
	TBBCKW001Service TBBCKW001Service;
	@Inject
	TBBCKW002Service TBBCKW002Service;
	@Inject
	private TBBCKW002 dao;	
	
	
	/* [트랜잭션적용] TBBCKW001, TBBCKW002 정보를 갱신한다. */
	@Transactional
	public int allUpdate(TBBCKW001DTO TBBCKW001, TBBCKW002DTO TBBCKW002, @RequestBody Map<String, Object> params) throws Exception {
		
		TBBCKW001Service.setUpdate(TBBCKW001, params);
		TBBCKW002Service.setUpdate(TBBCKW002, params);
		
		return 1;
	}
}

컨트롤러

//@Inject
//TBBCKW001Service tBBCKW001Service;
//@Inject
//TBBCKW002Service tBBCKW002Service;
@Inject
BlangInsertService blangInsertService;


@Transactional
public void executeTransactionalOperation() throws Exception {
    // 두 서비스 메소드를 순차적으로 호출
    
    /*************
    기업
    *************/
    TBBCKW001DTO tbbckw001DTO = new TBBCKW001DTO();
    
    // 기업테이블 필요한 값 SET 수행
    // 생략..

    //tBBCKW001Service.setUpdate(tbbckw001DTO); //UPDATE 수행

    /*************
    사용자
    *************/
    TBBCKW002DTO tbbckw002DTO = new TBBCKW002DTO();
    
    // 기업테이블 필요한 값 SET 수행
    //테스트 강제 익셉션 발생시키기1 (DB 길이 에러 방식)
    //TBBCKW002.setMmsn("C9999999"); 
	  //TBBCKW002.setSlfMmsn("M9999999"); 

	  //테스트 강제 익셉션 발생시키기2 (JAVA에러 방식)
  	//throw new SysException(SysErrorCode.INTERNAL_SERVER_ERROR);
    
    //tBBCKW002Service.setUpdate(tbbckw002DTO); //UPDATE 수행

    blangInsertService.allUpdate(TBBCKW001DTO, TBBCKW002DTO, params);
    logger.debug("blangInsertService.allUpdate COUNT: " + count);

}

STEP1. 프론트엔드 요청

{
    "mmsn": "C0000002",
    "bzno": "1234567890",
    "entNm": "이치란기업_수정",
    "buTlno": "0511111111",
    "buBadr": "일본 후쿠오카시_수정",
    "entEmad": "ichiran@jp.com",
    "userCnt": "",
    "mbrNewJnYmd": "2024.02.13",
    "exptYmd": "2024.02.13",
    "mode": "U",
    "isUser": false,
    "slfMmsn": "M0000002",
    "itrSvcCsnm": "직원1_수정",
    "slfCtfTlno": "23423423423",
    "connIp": "234.234.234.234",
    "connIp1": "234",
    "connIp2": "234",
    "connIp3": "234",
    "connIp4": "234",
    "cstEmad": "member1@jp.com",
    "lgnId": "ichi1_수정",
    "hdnIsIdDupCheck": "true",
    "itrUsrPwd": "@@@@@adminaBCKZZ",
    "hdnIsPwdCreate": false,
    "type": "ADM_MBR_UDP"
}

STEP2. 결과

❗트랜잭션 처리 실패
💡 이번에도… 기업테이블만 수정이 되어있다…

중간점검

트랜잭선 미적용 시 로그

[2024-03-02 00:24:56] DEBUG: org.mybatis.spring.SqlSessionUtils - Creating a new SqlSession
[2024-03-02 00:24:56] DEBUG: org.mybatis.spring.SqlSessionUtils - SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5fbc5b0e] was not registered for synchronization because synchronization is not active

(중략)
[2024-03-02 00:24:57] DEBUG: com.blang.bck.TBBCKW001Mapper.TBBCKW001Update - ==>  Preparing: UPDATE TBBCKW001 A SET A.업체명 = ?, A.사업자등록번호 = ?, A.사업장기본주소 = ?, A.사업장전화번호 = ?, A.업체이메일주소 = ?, A.유효기간년월일 = ?, A.회원신규가입년월일 = ?, A.시스템최종갱신일시 = CURRENT_TIMESTAMP(), A.시스템최종거래일시 = DATE_FORMAT(NOW(), '%Y%m%d%H%i%s%f') WHERE A.회원일련번호 = ? 
[2024-03-02 00:24:57] DEBUG: com.blang.bck.TBBCKW001Mapper.TBBCKW001Update - ==> Parameters: 이치란기업_수정(String), 1234567890(String), 일본 후쿠오카시_수정(String), 0511111111(String), ichiran@jp.com(String), 20240213(String), 20240213(String), C0000002(String)
[2024-03-02 00:24:57] DEBUG: com.blang.bck.TBBCKW001Mapper.TBBCKW001Update - <==    Updates: 1


[2024-03-02 00:24:57] DEBUG: org.mybatis.spring.SqlSessionUtils - Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5fbc5b0e]

❗Spring - myBatis 환경에서 트랜잭션이 적용되지 않으면 위 로그를 볼 수 있다.
💡 처음부터 나는 적용이 되지 않은 상태였던 것이다.

이유는 애초에 안되는 설정..?

#답변
이렇게 도는게 저는 맞다고 보이는데요..지금 셋팅하신 상황에서는 말이죠.. 왜냐면 DAO 메소드를 한번씩 호출할때 마다 SQLSession이 한번씩 생성됩니다. Service에서 Loop를 5번 돌렸다면 5개의 SQLSession이 생성되는거죠.. SQLSession쪽은 FactoryBean 개념이어서 호출될때마다 그때그때 만들어지는겁니다.. 이 부분을 Service 쪽에서 Loop를 돌리지 마시구요.. Service에서는 DAO 쪽 한번만 호출하게 하시고.. DAO에서 Loop를 돌리면서 배치를 시켜보세요.. 어차피 insert..select..union all.. 스타일의 구문이기때문에.. 다른 곳에서의 재사용성은 없다고 봐야 할것 같고.. 그렇다면 SQLSession은 한번만 생성시킨 상태에서 Batch 잡으로 돌리는게.. 그나마 SQLSession 생성 타임이라도 없앨수가 있겠죠..

재시도 2차

설정

  <!-- Enables the Spring MVC @Controller programming model -->
  <annotation-driven />
  <tx:annotation-driven transaction-manager="transactionManager"/> <!-- tx 설정을 추가 -->

❗<tx:annotation-driven />
💡 은 트랜잭션과 관련된 어노테이션(@Transactional)을 활성화시키는 역할을 합니다.
💡 transaction-manager 속성을 사용하여 어떤 트랜잭션 매니저를 사용할 것인지 지정할 수 있습니다.
💡 이 설정은 주로 서비스 계층에서 @Transactional 어노테이션을 사용할 때 필요하며, 트랜잭션 관리를 활성화시킵니다.

❗따라서, 웹 애플리케이션에서 트랜잭션을 사용하는 경우에는 두 설정을 함께 사용하는 것이 일반적입니다. 아래는 두 설정을 함께 사용하는 예시입니다:

STEP1. 프론트엔드 요청

{
    "mmsn": "C0000002",
    "bzno": "1234567890",
    "entNm": "이치란기업_수정",
    "buTlno": "0511111111",
    "buBadr": "일본 후쿠오카시_수정",
    "entEmad": "ichiran@jp.com",
    "userCnt": "",
    "mbrNewJnYmd": "2024.02.13",
    "exptYmd": "2024.02.13",
    "mode": "U",
    "isUser": false,
    "slfMmsn": "M0000002",
    "itrSvcCsnm": "직원1_수정",
    "slfCtfTlno": "23423423423",
    "connIp": "234.234.234.234",
    "connIp1": "234",
    "connIp2": "234",
    "connIp3": "234",
    "connIp4": "234",
    "cstEmad": "member1@jp.com",
    "lgnId": "ichi1_수정",
    "hdnIsIdDupCheck": "true",
    "itrUsrPwd": "@@@@@adminaBCKZZ",
    "hdnIsPwdCreate": false,
    "type": "ADM_MBR_UDP"
}

결과

❗트랜잭션 처리 성공
💡 정상적으로 롤백되었다 !!!!!!!!!!!

❗콘솔로그(맨 마지막사진)
💡 동일 세션범위에서 처리하는것을 볼 수 있다.

Share on

Twitter Facebook LinkedIn

스프링 Transaction(1)

트랜잭션 기본

스프링 트랜잭션

트랜잭션 비권장 상황

스프링의 @Trasaction 개념

Service1

Service2

Controller

설명

실제 테스트 환경

TABLE1 (기업테이블)

TABLE2 (사용자테이블)

실제 테스트 시작

STEP1. 프론트엔드 요청

STEP2. 백엔드 요청

STEP3. 결과

재시도 1차

서비스(서비스2개를 묶어서)

컨트롤러

STEP1. 프론트엔드 요청

STEP2. 결과

중간점검

트랜잭선 미적용 시 로그

이유는 애초에 안되는 설정..?

재시도 2차

설정

STEP1. 프론트엔드 요청

결과

Share on

Leave a comment

You may also enjoy

메타관리

스프링 Mybatis와 JPA

스프링 에러처리(2) 디테일 커스텀처리