Spring3 + Mybatis 여러개 Datasource 연동법(다중 트랜잭션 포함)

이번에 다루고자 하는 Spring + Mybatis 포스팅은 다중DB 설정에 대하여 작성해보도록 하겠습니다.

SqlSession 객체에 "@Resource" 어노테이션을 이용하여 Datasource  구분을 지어 여러개의 DB 호출이 가능합니다.

이전 Mybatis 연동설정법은 다음 포스팅을 참고해주세요

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 Maven을 이용하여 pom.xml에 oracle,mysql,mssql jdbc 라이브러리 등록하기

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

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 + Mybatis연동에 추가로 트랜잭션 설정 하여 실패시 Rollback 처리하기

@Resource 어노테이션을 위해서는 pom.xml에 하단 dependency를 추가해주도록 합니다.

<dependency>
	<groupId>javax.annotation</groupId>
	<artifactId>javax.annotation-api</artifactId>
	<version>1.2</version>
</dependency>

기존 application-config.xml 내에 Datasource 설정코드가 하나 설정 되어있었습니다.

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="드라이버클래스" />
        <property name="url" value="jdbc:mysql://도메인:포트/db명" />
        <property name="username" value="계정" />
        <property name="password" value="패스워드" />
</bean>
 <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="mapperLocations" value="classpath*:query/**" />
 </bean>
 <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
        <constructor-arg ref="sqlSessionFactory" />
 </bean>

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
       <property name="dataSource" ref="dataSource"/>
</bean>

<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>

기존 설정되어있는 위 4가지 bean 태그와 tx:advice 태그를 복사하여 붙여넣기를 합니다.

각 태그들의 id / ref를 변경해주도록 합니다. 

추가로 tx:advice 의 transaction-manager속성같을 변경합니다.

<bean id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="드라이버클래스" />
        <property name="url" value="jdbc:mysql://도메인:포트/db명" />
        <property name="username" value="계정" />
        <property name="password" value="패스워드" />
</bean>
 <bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource2" />
        <property name="mapperLocations" value="classpath*:query/**" />
 </bean>
 <bean id="sqlSession2" class="org.mybatis.spring.SqlSessionTemplate">
        <constructor-arg ref="sqlSessionFactory2" />
 </bean>

<bean id="transactionManager2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
       <property name="dataSource" ref="dataSource2"/>
</bean>

<tx:advice id="txAdvice2" transaction-manager="transactionManager2">
	<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>

기존 aop:config 태그내에 다음 태그 추가를 해주도록 합니다.

<aop:advisor id="transactionAdvisor2" pointcut-ref="serviceOperation" advice-ref="txAdvice2"/>

본인이 사용하고자 하는 db의 가상호출 테이블은 다음과 같습니다.

위 테이블의 COUNT 쿼리를 실행하여 콘솔창에 카운트 수를 출력해보고자 합니다.

위처럼 각 테이블마다 카운트가 이클립스 콘솔창에 동일하게 출력된다면 mybatis 다중 db 연동이 성공한 것일 겁니다.

Controller/Service/Dao 부분 샘플코드를 작성해보도록 합니다.

Controller 추가코드

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

Service 추가코드

public void multipledb() throws SQLException;

ServiceImpl 추가코드

public void multipledb() throws SQLException {
	dao.multipledb1();
	dao.multipledb2();
}

Dao 추가코드

public void multipledb1() throws SQLException;
public void multipledb2() throws SQLException;

DaoImpl 추가코드

public void multipledb1() throws SQLException {
	int count = query.selectOne("query.multipledb1");
	System.out.println("test.mybatis_table COUNT 결과:"+count);
}
public void multipledb2() throws SQLException {
	int count = query2.selectOne("query.multipledb2");
	System.out.println("sample.grid_sample COUNT 결과:"+count);
}

DaoImpl 기존 Sqlsession 인터페이스부분을 다음처럼 변경을 해줍니다.

@Autowired
@Resource(name="sqlSession")
private SqlSession query;
    
@Autowired
@Resource(name="sqlSession2")
private SqlSession query2;

마지막 query.xml에 다음 코드를 추가로 결과 확인을 해보도록 하겠습니다.

<select id="multipledb1" resultType="Integer">
	SELECT COUNT(*)
	FROM mybatis_table
</select>	
<select id="multipledb2" resultType="Integer">
	SELECT COUNT(*)
	FROM grid_sample
</select>

"/multipledb" URL 실행결과

위처럼 @Resource 어노테이션별로 실행한 결과를 콘솔상에서 확인이 되었습니다.

실행결과, 상단 DB툴에서 조회한 COUNT 갯수와 동일한 결과가 나온것을 확인 할 수 있었습니다.

by 개발로짜