如何让 SqlSessionFactory 使用特定的 TransactionManager？

Question

对于一组多数据库，我成功配置了JDBC/JPA个配置。

@Db1 @Bean Datasource dataSourceDb1();
@Db1 @Bean AbstractEntityManagerFactoryBean entityManagerFactoryDb1(@Db1 DataSource);
@Db1 @Bean TransactionManager transactionManagerDb1(@Db1 DataSource);

@Db2 @Bean Datasource dataSourceDb2();
@Db2 @Bean AbstractEntityManagerFactoryBean entityManagerFactoryDb2(@Db2 DataSource);
@Db2 @Bean TransactionManager transactionManagerDb2(@Db2 DataSource);

如您所见，每个数据库的所有配置都是分开的。

现在我想为每个数据库配置MyBatis。

我知道我可以制作出这样的 SqlSessionFactory。

    @Db1
    @Bean
    @ConfigurationProperties("application.db1.mybatis.configuration")
    org.apache.ibatis.session.Configuration mybatisConfigurationDb1() {
        return new org.apache.ibatis.session.Configuration();
    }

    @Db1
    @Bean
    public SqlSessionFactory sqlSessionFactoryDb1(
            @Db1 final DataSource dataSource,
            @Db1 final org.apache.ibatis.session.Configuration configuration) throws Exception {
        final SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(dataSource);
        factoryBean.setConfiguration(configuration);
        factoryBean.setVfs(SpringBootVFS.class); // // TODO: Check, works as expected? Required, actually?
        return factoryBean.getObject();
    }

我的问题是，如何为 @Db1 使用 @Db1 transactionManagerDb1 进行上述 MyBatis 配置？

并且，以同样的方式，为 @Db2 进行另一个 MyBatis 配置，使用 @Db2 transactionManagerDb2?

Answer 1

SqlSessionFactory 将使用与数据源关联的事务管理器。 MyBatis 使用 Spring 的本机事务管理，因此您可以像在 Spring 中一样配置数据源和事务管理器。诀窍是创建多个 SqlSessionFactories 并将映射器关联到它们。

基本思路是做两个SqlSessionFactories，给它们起不同的名字：

// configure Datasources and transaction managers as normal, then...

@Bean(name = "SessionFactory1")
public SqlSessionFactory sqlSessionFactory1(Datasource...) {
  ...
}

@Bean(name = "SessionFactory2")
public SqlSessionFactory sqlSessionFactory2(Datasource...) {
  ...
}

然后使用 MapperScan 注释为每个工厂附加不同的映射器：

@MapperScan(basePackages = "foo.bar.mapper1", sqlSessionFactoryRef = "SessionFactory1")
@MapperScan(basePackages = "foo.bar.mapper2", sqlSessionFactoryRef = "SessionFactory2")

如何让 SqlSessionFactory 使用特定的 TransactionManager？

How can I make an SqlSessionFactory uses specific TransactionManager?

mybatis

spring-mybatis

transactionmanager

mybatis-configuration