Spring3 + Mybatis연동에 추가로 트랜잭션 설정 하여 실패시 Rollback 처리하기

이번 포스팅은 Mybatis 기본 연동법에 추가로 트랜잭션 설정을 잡아주고자 합니다.

MySQL 기준으로 설명합니다.

테이블은 각 DBMS에 맞추어 CREATE 해보시면 되겠습니다.

테이블을 생성해보도록 하겠습니다.

CREATE TABLE mybatis_table (
  title VARCHAR(100) NOT NULL
) ENGINE=INNODB DEFAULT CHARSET=utf8

※ MySQL은 트랜잭션적용을 해주기 위해서는 engine 을 INNODB로 설정을 잡아주셔야 트랜잭션 처리가 가능합니다.

트랜잭션은 여러개 데이터에대한 CRUD 처리 시 하나라도 실패하면 이전에 등록,수정,삭제된 데이터를 모두 롤백 시켜주는 기능입니다.

"나는 그냥 실패직전에 데이터는 그냥 처리하고 실패된 데이터는 수정해서 다시 DB처리할껀대?"

라고 생각하시는분들은 이번 포스팅을 그냥 넘어가주셔도 되겠습니다.

소규모 프로젝트에서 프레임워크 설정을 보면 트랜잭션 설정을 해주지 않은 프로젝트가 꽤 있었습니다.

이럴경우 데이터가 꼬이거나 직접 db에 접속해서 일일이 수정/삭제 해주는 작업을 하니 

일관성있게 트랜잭션 설정을 필수로 해주어야 한다고 본인은 생각합니다.

이전 코드에 이어서 Mybatis 트랜잭션 설정을 잡아주도록 해보겠습니다.

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 + MyBatis 기본설정 + 연동테스트 후 쿼리로그 확인해보기

service 영역에 "@Transactional" 어노테이션을 적용하여 트랜잭션처리를 해주는 방법이 있던대

 이방법에 대해서는 코드를 작성해줄때마다 필요한 메서드에 설정을 해주어야 합니다.

하지만 저는 어노테이션을 이용한 트랜잭션 설정은 하지 않고 

직접 application-config.xml 파일에 트랜잭션 설정을 잡아주도록 하겠습니다.

pom.xml에 다음 라이브러리를 추가해주도록 하겠습니다.

<dependency>
	<groupId>org.aspectj</groupId>
	<artifactId>aspectjweaver</artifactId>
	<version>1.8.4</version>
</dependency>
<dependency>
	<groupId>cglib</groupId>
	<artifactId>cglib-nodep</artifactId>
	<version>3.1</version>
</dependency>

mvc-config.xml 파일내에 "context:component-scan" 태그를 다음처럼 재작성해주세요

<context:component-scan base-package="com.spring" use-default-filters="false">
    <context:include-filter type="annotation" expression="org.springframework.stereotype.Controller" />
</context:component-scan>

 application-config.xml 파일내에 "beans" 태그에 다음 속성을 추가해줍니다.

xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"

beans 태그 속성중 xsi:schemaLocation 속성값내에 다음 URL을 추가 작성해주도록 합니다.

http://www.springframework.org/schema/aop 
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/tx 
http://www.springframework.org/schema/tx/spring-tx.xsd

beans 태그 내에 다음 태그를 추가해주도록 합니다.

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
       <property name="dataSource" ref="dataSource"/>
</bean>
	
<aop:config proxy-target-class="true">
	<aop:pointcut id="serviceOperation" expression="execution(public * com.spring..service.*Service.*(..))" />
	<aop:advisor id="transactionAdvisor" pointcut-ref="serviceOperation" advice-ref="txAdvice"/>
</aop:config>
		
<tx:advice id="txAdvice" transaction-manager="transactionManager">
	<tx:attributes>
		<tx:method name="save*" rollback-for="Exception"/>
		<tx:method name="update*" rollback-for="Exception"/>
		<tx:method name="delete*" rollback-for="Exception"/>
	</tx:attributes>
</tx:advice>

상단 "tx:advice" 태그내 "tx:method"태그의 name은 

service영역내에 트랜잭션을 처리하고자 하는 메서드명을 정의해주는 겁니다.

인터셉터 URL 지정해주는 것과 비슷한 개념입니다.

2014/11/12 - [개발에필요한연동법/스프링연동] - Spring3 인터셉터와 세션을이용하여 로그인 처리해보기

Service 패키지를 생성 후 다음 템플릿 코드를 작성해주도록 합니다.

StudyService.java 샘플코드

public interface StudyService {	
	public void saveTest() throws SQLException;
}

StudyServiceImpl.java 샘플코드

@Service
public class StudyServiceImpl implements StudyService {
	@Autowired
	private StudyDao dao;

	@Override
	public void saveTest() throws SQLException {
		dao.saveTest("글등록테스트1");
		dao.saveTest(null);
	}
}

※ DAO 클래스에 "@Repository" 어노테이션이 필수선언이라면 

Service 클래스에는 "@Service" 어노테이션을 필수로 설정해주셔야 합니다.

이어서 컨트롤러에 다음 코드를 추가 작성합니다.

@Autowired
private StudyService studyService;

@RequestMapping("/saveTest")
public void saveTest(){
	try {
		studyService.saveTest();	
	} catch (Exception e) {
		e.printStackTrace();
	}
}

전에 생성했던 Dao/DaoImpl 에 다음코드를 추가합니다.

StudyDao.java 추가 코드

public void saveTest(String value) throws SQLException;

StudyDaoImpl.java 추가 코드

@Override
public void saveTest(String value) throws SQLException {
	query.insert("query.saveTest",value);
}

이어서 query.xml에 insert 쿼리문을 작성합니다.

query.xml 추가코드

<insert id="saveTest" parameterType = "String">
	INSERT INTO mybatis_table(title)
	VALUES(#{value})
</insert>

이전 DB연동 포스팅과 다른점이 있다면 이전에는 Controller -> Dao를 바로 호출 하는 형식이었는데 

트랜잭션을 Service단에 묶어서 재작성하였습니다.

Conroller -> Service -> Dao 이러한 구조로 진행이 되는데 

트랜잭션 처리를 위해 Service부분에 같은 Dao메소드를 2번 호출해주었습니다.

하나는 제대로된 값을 set, 나머지는 NULL값을 INSERT하도록 진행하였습니다.

샘플테이블 제작한 TITLE 컬럼을 확인하면 NOT NULL이므로 

마지막 NULL값이 INSERT될시 에러를 출력시키면서 롤백이 되어야합니다.

정상적으로 롤백이 될지 컨트롤러 호출을 브라우저로 해보도록 하겠습니다.

다음과같이 "Column 'title' cannot be null" Exception을 발생 시켰습니다.

한번 DB에 데이터가 등록되어있나 확인해보도록 하겠습니다.

우선 트랜잭션이 처리되었는지 데이터가 들어가지 않았습니다.

그럼 Service의 메서드명을 변경하여 트랜잭션 설정을 적용시켜보지 않도록 하겠습니다.

기존 StudyService / StudyServiceImpl 에 정의한 saveTest() 메소드를 insertTest() 로 변경해주고 

컨트롤러의 saveTest() 메소드 내에 정의한 

"studyService.saveTest();" -> "studyService.insertTest();"

로 변경을 해주고 서버재시작 후 , 

컨트롤러를 재실행 해보도록 합니다.

같은 Exception이 발생이 되고 DB의 데이터는 다음처럼 Exception 발생전 insert된 데이터가 추가된 것을 확인 할 수 있습니다.

※  insertTest 메서드에 트랜잭션을 적용하고 싶다면 tx:method에 name명을 등록해주면 되겠습니다.

by 개발로짜