如何让 SqlSessionFactory 使用特定的 TransactionManager？

问题描述

对于一组多个数据库，我成功配置了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?

解决方法

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