springboot整合mybatis跨库操作、配置多个数据源DataSource

﹏ヽ暗。殇╰゛Y 2022-04-13 09:17 713阅读 0赞

声明，使用JDK8、idea、lombok、springboot2.0进行测试：  
》  
》

> ###### 1、mybatis多数据源的使用场景： ######
> 
>  *  操作同一台服务器上不同的数据库，或者多地机器上的相同或不相同数据库。  
>     进行跨库操作、多数据源进行分离数据；
>  *  使得程序得以扩展，当一台或者部分服务器宕机，不影响整个应用的服务；
> 
> ###### 2、多数据源配置的思路： ######
> 
>  *  数据隔离，把数据分别存放在test、test02这两个数据库中；
>  *  创建数据源Datasource指定使用的哪个数据源配置，并将其注入到SqlSessionFactory 会话工厂；
>  *  创建事务TransactionManager，需把数据源注入；
>  *  把SqlSessionFactory 注入，创建sqlSessionTemplate模板，使用模板操作mapper接口；
>  *  把模板放到mapper 路径下，并 @MapperScan注解 声明mapper接口位置；
> 
> 代码实现如下：  
> 源码下载如下：  
> [https://github.com/medoo-Ai/mybatis-demo][https_github.com_medoo-Ai_mybatis-demo]

》  
application.properties配置文件;  
配置两个数据源one 和two ;

mybatis.config-location=classpath:mybatis/mybatis-config.xml
    
    spring.datasource.one.jdbc-url=jdbc:mysql://localhost:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    spring.datasource.one.username=root
    spring.datasource.one.password=root
    spring.datasource.one.driver-class-name=com.mysql.cj.jdbc.Driver
    
    spring.datasource.two.jdbc-url=jdbc:mysql://localhost:3306/test02?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    spring.datasource.two.username=root
    spring.datasource.two.password=root
    spring.datasource.two.driver-class-name=com.mysql.cj.jdbc.Driver

> ###### 2.1、创建并配置第一个数据源 DataSource1Config ： ######

###### 2.11 、创建数据源 DataSource ######

@Bean(name = "oneDataSource")   作用在方法上，注入；一般和@Qulifiler配合使用；
    @ConfigurationProperties(prefix = "spring.datasource.one")  指定加载哪个数据库配置；
    @Primary  是指默认值，多个数据源只能存在一个默认值，及仅能一个数据源使用该注解；

@Configuration
    @MapperScan(basePackages = "com.mybatis.neo.mybatisdemo.mapper.one", sqlSessionTemplateRef = "oneSqlSessionTemplate")
    public class DataSource1Config { 
        /** * 加载配置数据源 * @return * @Primary 是指具有默认值 */
        @Bean(name = "oneDataSource")
        @ConfigurationProperties(prefix = "spring.datasource.one")
        @Primary
        public DataSource testDataSource() { 
            return DataSourceBuilder.create().build();
        }

###### 2.12 、创建会话工厂 sqlsessionFactory ######

> 把数据源注入，创建 sqlsessionFactory ；  
> @Qualifier 注解是细粒度选择注入，通俗一点就是指定哪一个name 的参数注入；在这里，就是指定名字为oneDataSource 的数据源，进行注入；  
> 它不能够作用在类上面，作用在method 上和@Bean 组合使用，等价于@ReSource

@Bean(name = "oneSqlSessionFactory")
        @Primary
        public SqlSessionFactory testSqlSessionFactory(@Qualifier("oneDataSource") DataSource dataSource) throws Exception { 
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/one/*.xml"));
            //Resource[] mapperLocations
            return bean.getObject();
        }

###### 2.13 、创建事务 transactionManager ######

mytatis 要操作事务啊，transactionManager需要datasource ，所以把数据源注入，创建事务；

@Bean(name = "oneTransactionManager")
        @Primary
        public DataSourceTransactionManager testTransactionManager(@Qualifier("oneDataSource") DataSource dataSource) { 
            return new DataSourceTransactionManager(dataSource);
        }

###### 2.14 、创建 sqlSessionTemplate 模板 ######

创建 sqlSessionTemplate 模板,使用模板对mapper 接口进行操作，省去接口实现类；  
需要SqlSessionFactory 注入，创建模板；

@Bean(name = "oneSqlSessionTemplate")
        @Primary
        public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("oneSqlSessionFactory") SqlSessionFactory sqlSessionFactory) { 
            return new SqlSessionTemplate(sqlSessionFactory);
        }

###### 2.15 、 sqlSessionTemplate 模板的作用； ######

> sqlSessionTemplate 用来操作mapper接口中的crud  
> \* 所以，把sqlSessionTemplate 传入mapper的包路径下  
> \* 在 @MapperScan中添加进去；

> ###### 2.2、创建并配置第二个数据源 DataSource2Config ： ######
> 
> 由于默认连接的是第1个数据库test ,数据源2的配置去掉@Primary 注解，  
> 并更换mapper的地址路径即可；

》

@Configuration
    @MapperScan(basePackages = "com.mybatis.neo.mybatisdemo.mapper.two", sqlSessionTemplateRef  = "twoSqlSessionTemplate")
    public class DataSource2Config { 
        @Bean(name = "twoDataSource")
        @ConfigurationProperties(prefix = "spring.datasource.two")
        public DataSource testDataSource() { 
            return DataSourceBuilder.create().build();
        }
        @Bean(name = "twoSqlSessionFactory")
        public SqlSessionFactory testSqlSessionFactory(@Qualifier("twoDataSource") DataSource dataSource) throws Exception { 
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/two/*.xml"));
            return bean.getObject();
        }
        @Bean(name = "twoTransactionManager")
        public DataSourceTransactionManager testTransactionManager(@Qualifier("twoDataSource") DataSource dataSource) { 
            return new DataSourceTransactionManager(dataSource);
        }
        @Bean(name = "twoSqlSessionTemplate")
        public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("twoSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { 
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    
    }

> ###### 3、创建 MultiDataSourceTest 测试类; ######
> 
>  *  对数据库1插入2条数据，使用 test 的数据源
>  *  对数据库2插入1条数据，使用 test02 的数据源

/** * @auther SyntacticSugar * @data 2018/11/28 0028下午 5:45 */
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class MultiDataSourceTest { 
    
        @Autowired
        private User1Mapper user1Mapper;
        @Autowired
        private User2Mapper user2Mapper;
    
        @Test
        public void test() { 
            user1Mapper.insert(new User("aa111", "a123456", UserSexEnum.MAN));
            user1Mapper.insert(new User("bb111", "b123456", UserSexEnum.WOMAN));
            user2Mapper.insert(new User("cc222", "b123456", UserSexEnum.MAN));
        }
    }

运行，ok,分别向test /test02这两个数据库的users表中插入了数据；  
![1][]  
test02数据库中users表  
![s][]  
test数据库中users表  
![在这里插入图片描s述][s 1]

[https_github.com_medoo-Ai_mybatis-demo]: https://github.com/medoo-Ai/mybatis-demo
[1]: /images/20220413/f76e667762c641fabd1c4ae71d43d773.png
[s]: /images/20220413/b9426efd6c6546488da568a4b0e72449.png
[s 1]: /images/20220413/e7379a18be6b4ad5809b944690eec68f.png