이미지에서 보면 최종적으로 3번 ‘TEST2’ 스키마에서 ‘Role’ 테이블에 Insert 후 일부러 Exception 발생 해서
‘TEST’ 스키마에서 ‘Member’ 테이블 Insert 된것이 rollback 되는지 확인 하고자 한다. (Propagation: REQUIRED 경우)

Propagation 종류 :

REQUIRED : 기본 설정, 진행중인 transaction이 있으면 참여, 없으면 새로 생성
SUPPORTS : 진행중인 transaction이 있으면 참여, 없으면 transaction 없이 실행
MANDATORY : 진행중인 transaction이 있으면 참여, 없으면 예외.
REQUIRES_NEW : 새로운 transaction 시작. 진행중인 transaction은 보류.
NOT_SUPPORTED : 진행중인 transaction이 있으면 보류, transaction 없이 실행.
NEVER : transaction없이 실행. 진행중인 transaction이 있으면 예외.
NESTED : 중첩 transaction 실행. 자식 tx은 부모 tx에게 영향을 주지 않지만, 부모는 자식에게 영향을 줌.

application.yaml 설정

각각 DataSource Config 설정

MainHikariSchemaDataSourceConfig 설정 - ‘TEST’ 스키마

@Configuration
@ConfigurationProperties(prefix = "spring.datasource." + "main")
@EnableJpaRepositories(
entityManagerFactoryRef = "mainEntityManagerFactory",
transactionManagerRef = "mainTransactionManager",
basePackages = {DatabaseConfig.BASE_ENTITY_PACKAGE_PREFIX + ".member"}
)
@MapperScan(
basePackages = {DatabaseConfig.BASE_MAPPER_PACKAGE_PREFIX + ".member"}
)
public class MainHikariSchemaDataSourceConfig extends DatabaseConfig {
final String name = "main";

    @Bean(name = name + "DataSource")
    @Primary
    public DataSource dataSource() {
        return new LazyConnectionDataSourceProxy(new HikariDataSource(this));
    }

    @Bean(name = name + "SessionFactory")
    @Primary
    public SqlSessionFactory sqlSessionFactory(@Qualifier(name + "DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
        setConfigureSqlSessionFactory(sessionFactoryBean, dataSource);
        return sessionFactoryBean.getObject();
    }

    @Bean(name = name + "SqlSessionTemplate")
    @Primary
    public SqlSessionTemplate firstSqlSessionTemplate(@Qualifier(name + "SessionFactory") SqlSessionFactory sqlSessionFactory) {
        return new SqlSessionTemplate(sqlSessionFactory);
    }

    @Bean(name = name + "EntityManagerFactory")
    @Primary
    public EntityManagerFactory entityManagerFactory(@Qualifier(name + "DataSource") DataSource dataSource) {
        LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
        factory.setDataSource(dataSource);
        factory.setPackagesToScan("com.transaction.entities");
        factory.setPersistenceUnitName(name);
        setConfigureEntityManagerFactory(factory);


        return factory.getObject();
    }

    @Bean(name = name + "TransactionManager")
    @Primary
    public PlatformTransactionManager transactionManager(@Qualifier(name + "EntityManagerFactory") EntityManagerFactory entityManagerFactory) {
        JpaTransactionManager tm = new JpaTransactionManager();
        tm.setEntityManagerFactory(entityManagerFactory);
        return tm;
    }
}

SubHikariSchemaDataSourceConfig 설정 - ‘TEST2’ 스키마

@Configuration
@ConfigurationProperties(prefix = "spring.datasource." + "sub")
@EnableJpaRepositories(
        entityManagerFactoryRef = "subEntityManagerFactory",
        transactionManagerRef = "subTransactionManager",
        basePackages = {DatabaseConfig.BASE_ENTITY_PACKAGE_PREFIX + ".role"}
)
@MapperScan(
        basePackages = {DatabaseConfig.BASE_MAPPER_PACKAGE_PREFIX + ".role"}
)
public class SubHikariSchemaDataSourceConfig extends DatabaseConfig {
    final String name = "sub";

    @Bean(name = name + "DataSource")
    public DataSource dataSource() {
        return new LazyConnectionDataSourceProxy(new HikariDataSource(this));
    }

    @Bean(name = name + "SessionFactory")
    public SqlSessionFactory sqlSessionFactory(@Qualifier(name + "DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
        sessionFactoryBean.setDataSource(dataSource);
        return sessionFactoryBean.getObject();
    }

    @Bean(name = name + "SqlSessionTemplate")
    public SqlSessionTemplate firstSqlSessionTemplate(@Qualifier(name + "SessionFactory") SqlSessionFactory sqlSessionFactory) {
        return new SqlSessionTemplate(sqlSessionFactory);
    }

    @Bean(name = name + "EntityManagerFactory")
    public EntityManagerFactory entityManagerFactory(@Qualifier(name + "DataSource") DataSource dataSource) {
        LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
        factory.setDataSource(dataSource);
        factory.setPackagesToScan("com.transaction.entities");
        factory.setPersistenceUnitName(name);
        setConfigureEntityManagerFactory(factory);

        return factory.getObject();
    }

    @Bean(name = name + "TransactionManager")
    public PlatformTransactionManager transactionManager(@Qualifier(name + "EntityManagerFactory") EntityManagerFactory entityManagerFactory) {
        JpaTransactionManager tm = new JpaTransactionManager();
        tm.setEntityManagerFactory(entityManagerFactory);


        return tm;
    }
}

CASE 분별

CASE (http://localhost:9200/required-required)
- TransactionService (MainTransactionManager - Propagation.REQUIRED) -> MemberService (Mybatis - Insert) -> RoleService (Mybatis - Insert)

member Propagation	role Propagation	member Insert	role Insert
REQUIRED	REQUIRED	rollback	rollback

성공적으로 원하는 의도대로 rollback 이 되었다. 아직 안심하기 이르다.

CASE (http://localhost:9200/jpa-required-required)
- TransactionService (MainTransactionManager - Propagation.REQUIRED) -> MemberService (JPA - Insert) -> RoleService (JPA - Insert)

member Propagation	role Propagation	member Insert	role Insert
REQUIRED	REQUIRED	rollback	commit

JPA 경우 role 테이블은 rollback 이 안되었다.

CASE (http://localhost:9200/required-required)
- TransactionService (SubTransactionManager - Propagation.REQUIRED) -> MemberService (Mybatis - Insert) -> RoleService (Mybatis - Insert)

member Propagation	role Propagation	member Insert	role Insert
REQUIRED	REQUIRED	commit	commit

이 경우 모두 rollback 이 안되었다.

CASE (http://localhost:9200/jpa-required-required)
- TransactionService (SubTransactionManager - Propagation.REQUIRED) -> MemberService (JPA - Insert) -> RoleService (JPA - Insert)

member Propagation	role Propagation	member Insert	role Insert
REQUIRED	REQUIRED	commit	rollback

반대로 member 테이블에 rollback 이 안되었다.

해결 방안

이 경우 각각 설정한 TransactionManager 를 묶을 수 있는 ChainedTransactionManager 사용하기

JtaTransactionManager 사용하는 방법이다.

ChainedTransactionManager 사용하기

@Configuration

public class ChainedTxConfig {

    @Bean
    @Primary
    public PlatformTransactionManager transactionManager(PlatformTransactionManager mainTransactionManager, PlatformTransactionManager subTransactionManager) {
        return new ChainedTransactionManager(mainTransactionManager, subTransactionManager);
    }
}

각각 TransactionManager 를 설정 한것을 모두 가져와 ChainedTransactionManager 로 묶는다.

여기서 주의 할 점은 ChainedTransactionManager Class 확인 해보면 getTransaction 메서드 및 commit rollback 메서드가 확인 할수 있다.

getTransaction 메서드는 TransactionManager List 에 순차적으로 저장된 TransactionManager 부터 시작하는데 commit or rollback 은 거꾸로 실행한다.

즉 트랜잭션 체인으로 묶을때 트랜잭션이 제일많이 발생하는 트랜잭션을 최우선순위 둬야한다.

CASE (http://localhost:9200/required-required)
- TransactionService (ChainedTransactionManager - Propagation.REQUIRED) -> MemberService (Mybatis - Insert) -> RoleService (Mybatis - Insert)

member Propagation	role Propagation	member Insert	role Insert
REQUIRED	REQUIRED	rollback	rollback

CASE (http://localhost:9200/jpa-required-required)
- TransactionService (ChainedTransactionManager - Propagation.REQUIRED) -> MemberService (JPA - Insert) -> RoleService (JPA - Insert)

member Propagation	role Propagation	member Insert	role Insert
REQUIRED	REQUIRED	rollback	rollback

성공적이다.