SpringBoot使用mybatis-plus配置多个数据源，实现项目中从两个不同的数据库读取数据

admin

SpringBoot使用mybatis-plus配置多个数据源，实现项目中从两个不同的数据库读取数据
1、添加依赖包

1. <properties>
   
2.     <java.version>1.8</java.version>
   
3.     <mybatis.version>2.1.2</mybatis.version>
   
4.     <mybatis.plugin.version>3.4.3</mybatis.plugin.version>
   
5.     <pagehelper.version>1.2.13</pagehelper.version>
   
6. </properties>

复制代码

1. <dependency>
   
2.     <groupId>mysql</groupId>
   
3.     <artifactId>mysql-connector-java</artifactId>
   
4.     <scope>runtime</scope>
   
5. </dependency>
   
6. <dependency>
   
7.     <groupId>org.springframework.boot</groupId>
   
8.     <artifactId>spring-boot-starter-jdbc</artifactId>
   
9. </dependency>
   
10. <dependency>
    
11.     <groupId>org.mybatis.spring.boot</groupId>
    
12.     <artifactId>mybatis-spring-boot-starter</artifactId>
    
13.     <version>${mybatis.version}</version>
    
14. </dependency>
    
15. <dependency>
    
16.     <groupId>com.baomidou</groupId>
    
17.     <artifactId>mybatis-plus-boot-starter</artifactId>
    
18.     <version>${mybatis.plugin.version}</version>
    
19. </dependency>
    
20. <dependency>
    
21.     <groupId>com.github.pagehelper</groupId>
    
22.     <artifactId>pagehelper-spring-boot-starter</artifactId>
    
23.     <version>${pagehelper.version}</version>
    
24. </dependency>

复制代码

2、禁止SpringBoot自动配置数据源

在启动类注解上添加exclude参数

1. @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
   
2. public class DemoApplication {
   
3. 
   
4.     public static void main(String[] args) {
   
5.         SpringApplication.run(DemoApplication.class, args);
   
6.     }
   
7. 
   
8. }

复制代码

3、配置文件application.yml添加数据库信息

1. spring:
   
2.   datasource:
   
3.     db1:
   
4.       type: com.zaxxer.hikari.HikariDataSource
   
5.       driverClassName: com.mysql.cj.jdbc.Driver
   
6.       jdbcUrl: jdbc:mysql://172.16.253.52:3306/aaa?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&serverTimezone=GMT%2B8
   
7.       username: root
   
8.       password: root
   
9.     db2:
   
10.       type: com.zaxxer.hikari.HikariDataSource
    
11.       driverClassName: com.mysql.cj.jdbc.Driver
    
12.       jdbcUrl: jdbc:mysql://172.16.253.55:3306/bbb?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&serverTimezone=GMT%2B8
    
13.       username: root
    
14.       password: root
    

复制代码

4、代码中配置db1和db2的数据源

新建类DataSourceConfig1

配置MapperLocation路径和MapperScan扫描路径

1. @Slf4j
   
2. @Configuration
   
3. @MapperScan(basePackages = "com.demo.mapper.db1.**", sqlSessionFactoryRef = "sqlSessionFactoryDB1")
   
4. public class DataSourceConfig1 {
   
5.    
   
6.     @Primary
   
7.     @Bean(name = "dataSourceDB1")
   
8.     @ConfigurationProperties(prefix = "spring.datasource.db1")
   
9.     public DataSource dataSource() {
   
10.         return DataSourceBuilder.create().type(HikariDataSource.class)
    
11.                 .build();
    
12.     }
    
13. 
    
14.     @Bean(name = "sqlSessionFactoryDB1")
    
15.     public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSourceDB1") DataSource dataSource) throws Exception {
    
16.         MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();
    
17.         sessionFactoryBean.setDataSource(dataSource);
    
18.         sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
    
19.                 .getResources("classpath*:mapper/db1/*.xml"));
    
20.         log.info("------dataSource db12 配置成功");
    
21.         return sessionFactoryBean.getObject();
    
22.     }
    
23. 
    
24.     @Bean(name = "sqlSessionTemplateDB1")
    
25.     public SqlSessionTemplate sqlSessionFactoryTemplate(@Qualifier("sqlSessionFactoryDB1") SqlSessionFactory sqlSessionFactory) {
    
26.         return new SqlSessionTemplate(sqlSessionFactory);
    
27.     }
    
28. 
    
29.     @Bean(name = "txManagerDB1")
    
30.     public PlatformTransactionManager txManager(@Qualifier("dataSourceDB1") DataSource dataSource) {
    
31.         return new DataSourceTransactionManager(dataSource);
    
32.     }
    
33. }
    

复制代码

新建类DataSourceConfig2

1. @Slf4j
   
2. @Configuration
   
3. @MapperScan(basePackages = "com.demo.mapper.db2.**", sqlSessionFactoryRef = "sqlSessionFactoryDB2")
   
4. public class DataSourceConfig2 {
   
5.    
   
6.     @Primary
   
7.     @Bean(name = "dataSourceDB2")
   
8.     @ConfigurationProperties(prefix = "spring.datasource.db2")
   
9.     public DataSource dataSource() {
   
10.         return DataSourceBuilder.create().type(HikariDataSource.class)
    
11.                 .build();
    
12.     }
    
13. 
    
14.     @Bean(name = "sqlSessionFactoryDB2")
    
15.     public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSourceDB2") DataSource dataSource) throws Exception {
    
16.         MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();
    
17.         sessionFactoryBean.setDataSource(dataSource);
    
18.         sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
    
19.                 .getResources("classpath*:mapper/db2/*.xml"));
    
20.         log.info("------dataSource db2 配置成功");
    
21.         return sessionFactoryBean.getObject();
    
22.     }
    
23. 
    
24.     @Bean(name = "sqlSessionTemplateDB2")
    
25.     public SqlSessionTemplate sqlSessionFactoryTemplate(@Qualifier("sqlSessionFactoryDB2") SqlSessionFactory sqlSessionFactory) {
    
26.         return new SqlSessionTemplate(sqlSessionFactory);
    
27.     }
    
28. 
    
29.     @Bean(name = "txManagerDB2")
    
30.     public PlatformTransactionManager txManager(@Qualifier("dataSourceDB2") DataSource dataSource) {
    
31.         return new DataSourceTransactionManager(dataSource);
    
32.     }
    
33. }

复制代码

至此配置完成