0

对于一组多数据库，我成功配置了 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();
    }

我的问题是，我怎样才能使上面的 MyBatis 配置@Db1使用@Db1 transactionManagerDb1？

并且，以同样的方式，制作另一个 MyBatis 配置以@Db2使用@Db2 transactionManagerDb2？

4

1 回答 1

2

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")
于 2021-06-03T16:31:59.923 回答