1、多数据源连接的两种方式：分包||注解；

分包：通过包名指定连接那个数据源；

application.properties配置

###datasource1spring.datasource.test1.driver-class-name = com.mysql.jdbc.Driverspring.datasource.test1.jdbc-url = jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf-8spring.datasource.test1.username = rootspring.datasource.test1.password = root###datasource2spring.datasource.test2.driver-class-name = com.mysql.jdbc.Driverspring.datasource.test2.jdbc-url = jdbc:mysql://localhost:3306/test02?useUnicode=true&characterEncoding=utf-8spring.datasource.test2.username = rootspring.datasource.test2.password = root

配置文件中新增两个数据源

 

//DataSource01@Configuration // 注册到springboot容器中@MapperScan(basePackages = "com.itmayiedu.test01", sqlSessionFactoryRef = "test1SqlSessionFactory")public class DataSource1Config {    /**     * @methodDesc: 功能描述:(配置test1数据库)*/    @Bean(name = "test1DataSource")    @ConfigurationProperties(prefix = "spring.datasource.test1")    @Primary    public DataSource testDataSource() {        return DataSourceBuilder.create().build();    }    /**     * @methodDesc: 功能描述:(test1 sql会话工厂)*/    @Bean(name = "test1SqlSessionFactory")    @Primary    public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource)            throws Exception {        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();        bean.setDataSource(dataSource);        // bean.setMapperLocations(        // new        // PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml"));        return bean.getObject();    }    /**     * @methodDesc: 功能描述:(test1 事物管理)*/    @Bean(name = "test1TransactionManager")    @Primary    public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {        return new DataSourceTransactionManager(dataSource);    }    @Bean(name = "test1SqlSessionTemplate")    @Primary    public SqlSessionTemplate testSqlSessionTemplate(            @Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {        return new SqlSessionTemplate(sqlSessionFactory);    }}//DataSource2@Configuration // 注册到springboot容器中@MapperScan(basePackages = "com.itmayiedu.test02", sqlSessionFactoryRef = "test2SqlSessionFactory")public class DataSource2Config {    /**     * @methodDesc: 功能描述:(配置test2数据库)*/    @Bean(name = "test2DataSource")    @ConfigurationProperties(prefix = "spring.datasource.test2")    public DataSource testDataSource() {        return DataSourceBuilder.create().build();    }    /**     *      * @methodDesc: 功能描述:(test2 sql会话工厂)*/    @Bean(name = "test2SqlSessionFactory")    public SqlSessionFactory testSqlSessionFactory(@Qualifier("test2DataSource") DataSource dataSource)            throws Exception {        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();        bean.setDataSource(dataSource);        // bean.setMapperLocations(        // new        // PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test2/*.xml"));        return bean.getObject();    }    /**     * @methodDesc: 功能描述:(test2 事物管理)*/    @Bean(name = "test2TransactionManager")    public DataSourceTransactionManager testTransactionManager(@Qualifier("test2DataSource") DataSource dataSource) {        return new DataSourceTransactionManager(dataSource);    }    @Bean(name = "test2SqlSessionTemplate")    public SqlSessionTemplate testSqlSessionTemplate(            @Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {        return new SqlSessionTemplate(sqlSessionFactory);    }}

多数源事务注意：

在多数据源的情况下，使用@Transactional注解时，应该指定事务管理者

Springboot1.5的时候 没有默认指向数据源 会报错

Springboot2.0的时候 不报错

@Transactional(transactionManager = "test2TransactionManager")

 

 

注解原理：通过AOP技术拦截，手写注解，当传递的参数是DataSource1则获取DataSource1的连接；同理其他数据源；【比较麻烦，当工程较大时，方法较多使用的注解也多，容易忘掉；推荐分包方式】