트랜잭션(Transaction) 적용

 

1. 트랜잭션 네임스페이스 등록

트랜잭션을 위해 xmlns:tx를 추가했다.

[ applicationContext.xml ]
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
		http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd
		http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd">

	<context:component-scan base-package="com.springbook.biz" />

	<aop:aspectj-autoproxy></aop:aspectj-autoproxy>

	<!-- DataSource 설정 -->
	<context:property-placeholder location="classpath:config/database.properties" />

	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
		destroy-method="close">
		<property name="driverClassName" value="${jdbc.driver}" />
		<property name="url" value="${jdbc.url}" />
		<property name="username" value="${jdbc.username}" />
		<property name="password" value="${jdbc.password}" />
	</bean>

	<!-- Spring JDBC 설정 -->
	<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
		<property name="dataSource" ref="dataSource" />
	</bean>
	
</beans>

2. 트랜잭션 관리자 등록

모든 Transaction 관리자는 PlatformTransactionManager interface를 구현한 클래스이다.

모든 Transaction 관리자는 Transaction 관리에 필요한 commit(), rollback() 메소드를 가지고 있다.

public interface PlatformTransactionManager{
	TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;
    void commit(TransactionStatus status) throws TransactionException;
    void rollback(TransactionStatus status) throws TransactionException;
}

JDBC를 기반으로 동작하기 때문에 DataSourceTranscationManager 클래스를 이용했다.

JPA를 이용하여 DAO 클래스를 구현했다면 JPATransactionManager를 이용하면 된다.

다음과 같이 DataSourceTranscationManager 클래스를 <bean> 등록한다.

[ applicationContext.xml 중 추가 ]
	<!-- Transaction 설정 -->
	<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource"></property>
	</bean>

비즈니스 메소드가 실행되다가 "예외가 발생하면 해당 메소드에 대한 트랜잭션을 롤백"하고 "문제없이 정상으로 수행 종료되면 트랜잭션을 커밋"하면 된다.

3. 트랜잭션 Advice 설정

트랜잭션 관리 기능의 어드바이스는 <tx:advice> 엘리먼트를 사용하여 설정한다.

트랜잭션 관리 기능의 어드바이스 클래스는 직접 구현하지 않는다.

스프링 컨테이너가 <tx:advice> 설정을 참조하여 자동으로 생성한다.

[ applicationContext.xml 중 추가 ]
	<tx:advice id="txAdvice" transaction-manager="txManager">
		<tx:attributes>
			<tx:method name="get*" read-only="true"/>
			<tx:method name="*"/>
		</tx:attributes>
	</tx:advice>

이 말은 트랜잭션 관리 어드바이스 객체에 클래스 이름이나 메소드를 확인할 수 없다는 의미이기도 하다.

단지 어드바이스의 아이디를 id 속성으로, 어드바이스 객체가 사용할 트랜잭션 관리자를 transaction-manager 속성으로 지정할 뿐이다!

위 설정은 get으로 시작하는 모든 메소드는 읽기 전용으로 처리되어 트랜잭션 관리 대상에서 제외한다.

그 외 나머지 메소드들을 트랜잭션 관리에 포함했다는 뜻이다.

4. <aop:advisor> 트랜잭션 적용

<aop:advisor>와 <aop:aspect>는 같은 기능의 엘리먼트이다. 포인트컷과 어드바이스의 결합을 하는 엘리먼트이다.

그런데 왜 둘로 나뉘었을까?

 <aop:aspect> 엘리먼트를 사용하려면 포인트컷과 결합할 어드바이스 객체의 아이디와 어드바이스 메소드 이름을 알아야 한다. 하지만 트랜잭션 관리 어드바이스는 위와 같이 스프링 컨테이너가 자동으로 생성하므로, 어드바이스 메소드 이름을 몰라서 <aop:aspect> 엘리먼트를 사용할 수 없다. 그래서 <aop:advisor>를 사용한다.

	<tx:advice id="txAdvice" transaction-manager="txManager">
		<tx:attributes>
			<tx:method name="get*" read-only="true"/>
			<tx:method name="*"/>
		</tx:attributes>
	</tx:advice>
	
	<aop:config>
		<aop:pointcut id="txPointcut"  expression="execution(* com.springbook.biz..*(..))"/>
		
		<aop:advisor pointcut-ref="txPointcut" advice-ref="txAdvice"/>
	</aop:config>

소스코드 한번에 보기

트랜잭션 설정이 완료된 전체 소스는 다음과 같다.

[ applicationContext.xml ]
<!-- DataSource 설정 -->
<context:property-placeholder location="classpath:config/database.properties" />

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
	destroy-method="close">
	<property name="driverClassName" value="${jdbc.driver}" />
	<property name="url" value="${jdbc.url}" />
	<property name="username" value="${jdbc.username}" />
	<property name="password" value="${jdbc.password}" />
</bean>

<!-- Spring JDBC 설정 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
	<property name="dataSource" ref="dataSource" />
</bean>

<!-- Transaction 설정 -->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
	<property name="dataSource" ref="dataSource"></property>
</bean>

<tx:advice id="txAdvice" transaction-manager="txManager">
	<tx:attributes>
		<tx:method name="get*" read-only="true"/>
		<tx:method name="*"/>
	</tx:attributes>
</tx:advice>

<aop:config>
	<aop:pointcut id="txPointcut"  expression="execution(* com.springbook.biz..*(..))"/>
	
	<aop:advisor pointcut-ref="txPointcut" advice-ref="txAdvice"/>
</aop:config>

정리: 어떤 순서로 동작하는가?

① 클라이언트가 BoardServiceImpl 객체의 insert() 메소드를 호출하면, ② insertBoard() 메소드의 비즈니스 로직이 수행된다.

만약 insertBoard() 수행 중 문제가 발생하면 ③ txAdvice로 등록한 어드바이스가 동작하여 ④ txManager의 rollback() 메소드를 호출한다.

만약 정상적으로 수행되었다면 commit() 메소드를 호출한다.