动态数据源切换（二）：Mybatis不同Mapper映射不同数据源

背景

面对业务需要，业务数据在不同的数据库里面，数据又要在系统里面整合所以需要根据不同的数据操作切换不同的数据源，因此根据Mapper不同切换不同的数据源，来操作对应的数据库

图解

代码实现

 

1. Mybatis配置信息

// Uplus数据源配置信息，
@Configuration
@MapperScan(basePackages = UqierpDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "uqierpSqlSessionFactory")
public class UqierpDataSourceConfig {

   // 指定当前数据源扫描的Mapper(Dao)包

            static final String PACKAGE = "com.uqiauto.dao";
    static final String MAPPER_LOCATION = "classpath:mybatis/mapper/*.xml";

 //  获取配置文件里面当前数据源的的配置信息

            @Value("${uqierp.datasource.url}")
    private String url;

    @Value("${uqierp.datasource.username}")
    private String user;

    @Value("${uqierp.datasource.password}")
    private String password;

    @Value("${uqierp.datasource.driverClassName}")
    private String driverClass;

    @Bean(name = "uqierpDataSource")
    @Primary
    public DataSource uqierpDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(url);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        return dataSource;
    }

    @Bean(name = "uqierpTransactionManager")
    @Primary
    public DataSourceTransactionManager uqierpTransactionManager() {
        return new DataSourceTransactionManager(uqierpDataSource());
    }


    @Bean(name = "uqierpSqlSessionFactory")
    @Primary
    public SqlSessionFactory uqierpSqlSessionFactory(@Qualifier("uqierpDataSource") DataSource uqierpDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(uqierpDataSource);
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                                .getResources(UqierpDataSourceConfig.MAPPER_LOCATION));
        return sessionFactory.getObject();
    }
}

// Shop数据源配置信息
@Configuration
@MapperScan(basePackages = ShopDataSourceConfig.PACKAGE,sqlSessionFactoryRef = "shopSqlSessionFactory")
public class ShopDataSourceConfig {

    static final String PACKAGE = "com.uqiauto.dao.shop";
    static final String MAPPER_LOCATION = "classpath:mybatis/mapper/shop/*.xml";

    @Value("${shop.datasource.url}")
    private String url;

    @Value("${shop.datasource.username}")
    private String user;

    @Value("${shop.datasource.password}")
    private String password;

    @Value("${shop.datasource.driverClassName}")
    private String driverClass;

    @Bean(name = "shopDataSource")
    public DataSource shopDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(url);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        return dataSource;
    }

    @Bean(name = "shopTransactionManager")
    public DataSourceTransactionManager shopTransactionManager() {
        return new DataSourceTransactionManager(shopDataSource());
    }

    @Bean(name = "shopSqlSessionFactory")
    public SqlSessionFactory shopSqlSessionFactory(@Qualifier("shopDataSource") DataSource shopDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(shopDataSource);
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                                .getResources(ShopDataSourceConfig.MAPPER_LOCATION));
        return sessionFactory.getObject();
    }
}