• Spring Boot 整合 MyBatis Plus实现多数据源的两种方式

    第一种：使用配置类的方式：

    项目结构

            

     xml依赖：

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <parent>
    6.         <artifactId>multi-datasource-parentartifactId>
    7.         <groupId>com.ganbogroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.  
    11.     <modelVersion>4.0.0modelVersion>
    12.  
    13.     <artifactId>multi-datasource-configartifactId>
    14.  
    15.     <properties>
    16.         <maven.compiler.source>8maven.compiler.source>
    17.         <maven.compiler.target>8maven.compiler.target>
    18.     properties>
    19.  
    20.     <dependencies>
    21.         <dependency>
    22.             <groupId>org.springframework.bootgroupId>
    23.             <artifactId>spring-boot-starter-webartifactId>
    24.         dependency>
    25.         
    26.         <dependency>
    27.             <groupId>com.baomidougroupId>
    28.             <artifactId>mybatis-plus-boot-starterartifactId>
    29.             <version>3.3.1version>
    30.         dependency>
    31.         
    32.         <dependency>
    33.             <groupId>com.baomidougroupId>
    34.             <artifactId>mybatis-plus-generatorartifactId>
    35.             <version>3.3.1.tmpversion>
    36.         dependency>
    37.         
    38.         <dependency>
    39.             <groupId>mysqlgroupId>
    40.             <artifactId>mysql-connector-javaartifactId>
    41.             <scope>runtimescope>
    42.         dependency>
    43.         <dependency>
    44.             <groupId>org.springframework.bootgroupId>
    45.             <artifactId>spring-boot-starter-testartifactId>
    46.             <scope>testscope>
    47.         dependency>
    48.         <dependency>
    49.             <groupId>org.projectlombokgroupId>
    50.             <artifactId>lombokartifactId>
    51.             <optional>trueoptional>
    52.         dependency>
    53.     dependencies>
    54.  
    55.     <build>
    56.         <plugins>
    57.             <plugin>
    58.                 <groupId>org.springframework.bootgroupId>
    59.                 <artifactId>spring-boot-maven-pluginartifactId>
    60.             plugin>
    61.         plugins>
    62.     build>
    63.  
    64. project>

    多数据源配置类(DataSource -> SqlsessionFactory -> SqlSessionTemplate -> DataSourceTransactionManager)

    DataSourceUserConfig 配置类：

    1. package com.multidb.configdemo.config;
    2.  
    3. import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
    4. import org.apache.ibatis.session.SqlSessionFactory;
    5. import org.mybatis.spring.SqlSessionTemplate;
    6. import org.mybatis.spring.annotation.MapperScan;
    7. import org.springframework.beans.factory.annotation.Qualifier;
    8. import org.springframework.boot.context.properties.ConfigurationProperties;
    9. import org.springframework.boot.jdbc.DataSourceBuilder;
    10. import org.springframework.context.annotation.Bean;
    11. import org.springframework.context.annotation.Configuration;
    12. import org.springframework.context.annotation.Primary;
    13. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    14. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    15.  
    16. import javax.sql.DataSource;
    17.  
    18. @Configuration
    19. @MapperScan(basePackages = "com.multidb.configdemo.dao.user", sqlSessionTemplateRef = "userSqlSessionTemplate")
    20. public class DataSourceUserConfig {
    21.  
    22.  
    23.     @Primary //设置主数据源
    24.     @Bean(name = "userDataSource")
    25.     @ConfigurationProperties(prefix = "spring.datasource.user")
    26.     public DataSource userDataSource() {
    27.         return DataSourceBuilder.create().build();
    28.     }
    29.  
    30.     @Bean(name = "userSqlSessionFactory")
    31.     public SqlSessionFactory userSqlSessionFactory(@Qualifier("userDataSource") DataSource dataSource) throws Exception {
    32.  
    33.         //工厂bean  SqlSessionFactory
    34.         MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
    35.  
    36.         //设置数据源
    37.         bean.setDataSource(dataSource);
    38.  
    39.         //加载映射文件
    40.         bean.setMapperLocations(new PathMatchingResourcePatternResolver().
    41.                 getResources("classpath*:mapper/user/*.xml"));
    42.         return bean.getObject();
    43.     }
    44.  
    45.     // 数据源事务管理器
    46.     public DataSourceTransactionManager db1TransactionManager(@Qualifier("userDataSource") DataSource dataSource) {
    47.         return new DataSourceTransactionManager(dataSource);
    48.     }
    49.  
    50.     @Bean(name = "userSqlSessionTemplate")
    51.     public SqlSessionTemplate userSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    52.         return new SqlSessionTemplate(sqlSessionFactory);
    53.     }
    54.  
    55. }

    DataSourceOrderConfig 配置类：

    1. package com.multidb.configdemo.config;
    2.  
    3. import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
    4. import org.apache.ibatis.session.SqlSessionFactory;
    5. import org.mybatis.spring.SqlSessionTemplate;
    6. import org.mybatis.spring.annotation.MapperScan;
    7. import org.springframework.beans.factory.annotation.Qualifier;
    8. import org.springframework.boot.context.properties.ConfigurationProperties;
    9. import org.springframework.boot.jdbc.DataSourceBuilder;
    10. import org.springframework.context.annotation.Bean;
    11. import org.springframework.context.annotation.Configuration;
    12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    13. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    14.  
    15. import javax.sql.DataSource;
    16.  
    17.  
    18. @Configuration
    19. @MapperScan(basePackages = "com.multidb.configdemo.dao.order", sqlSessionTemplateRef = "orderSqlSessionTemplate")
    20. public class DataSourceOrderConfig {
    21.  
    22.  
    23. //    @Primary
    24.     @Bean(name = "orderDataSource")
    25.     @ConfigurationProperties(prefix = "spring.datasource.order")
    26.     public DataSource orderDataSource() {
    27.         return DataSourceBuilder.create().build();
    28.     }
    29.  
    30.     @Bean(name = "orderSqlSessionFactory")
    31.     public SqlSessionFactory orderSqlSessionFactory(@Qualifier("orderDataSource") DataSource dataSource) throws Exception {
    32.  
    33.         //工厂bean  SqlSessionFactory
    34.         MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
    35.  
    36.         //设置数据源
    37.         bean.setDataSource(dataSource);
    38.  
    39.         //加载映射文件
    40.         bean.setMapperLocations(new PathMatchingResourcePatternResolver().
    41.                 getResources("classpath*:mapper/order/*.xml"));
    42.         return bean.getObject();
    43.     }
    44.  
    45.     // 数据源事务管理器
    46.     public DataSourceTransactionManager db1TransactionManager(@Qualifier("orderDataSource") DataSource dataSource) {
    47.         return new DataSourceTransactionManager(dataSource);
    48.     }
    49.  
    50.     @Bean(name = "orderSqlSessionTemplate")
    51.     public SqlSessionTemplate orderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    52.         return new SqlSessionTemplate(sqlSessionFactory);
    53.     }
    54.  
    55. }

    多个mapper接口：

      application.properties 配置文件

    1.  
    2. spring:
    3.   datasource:
    4.     user:
    5.       driver-class-name: com.mysql.cj.jdbc.Driver
    6.       username: root
    7.       password: root
    8.       jdbc-url: jdbc:mysql://127.0.0.1:3306/user?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&useSSL=false
    9.     order:
    10.       driver-class-name: com.mysql.cj.jdbc.Driver
    11.       username: root
    12.       password: root
    13.       jdbc-url: jdbc:mysql://127.0.0.1:3306/order?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&useSSL=false
    14.  
    15. mybatis-plus:
    16. #  mapper-locations: classpath:mapper/*.xml # xml文件路径
    17.   configuration:
    18.     map-underscore-to-camel-case: true  # 驼峰转换
    19.     cache-enabled: false  # 是否开启缓存
    20.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # 打印sql
    21. #  global-config: # 全局配置
    22. #    db-column-underline: true  # 数据库字段驼峰下划线转换
    23. #    id-type: 0 # id自增类型(数据库id自增)

    第二种：使用@DS 注解 切换数据源

    新增pom依赖：

    1.   
    2.   <dependency>
    3.       <groupId>com.baomidougroupId>
    4.       <artifactId>dynamic-datasource-spring-boot-starterartifactId>
    5.       <version>3.3.1version>
    6.    dependency>

    application.yml 配置

    1.  
    2.  
    3. spring:
    4.   datasource:
    5.     dynamic:
    6.       primary: user #设置默认的数据源或者数据源组,默认值即为master
    7.       strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
    8.       datasource:
    9.         user:
    10.           url: jdbc:mysql://127.0.0.1:3306/user?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&useSSL=false
    11.           username: root
    12.           password: root
    13.           driver-class-name: com.mysql.jdbc.Driver #3.2.0开始支持SPI可省略此配置
    14.         order:
    15.           url: jdbc:mysql://127.0.0.1:3306/order?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&useSSL=false
    16.           username: root
    17.           password: root
    18.           driver-class-name: com.mysql.jdbc.Driver
    19.  
    20.  
    21. mybatis-plus:
    22.   mapper-locations: classpath:mapper/**/*.xml #xml文件路径
    23.   configuration:
    24.     map-underscore-to-camel-case: true  #驼峰转换
    25.     cache-enabled: false  #是否开启缓存
    26.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #打印sql
    27.   # global-config: #全局配置
    28.   #   db-column-underline: true  #数据库字段驼峰下划线转换
    29.   #   id-type: 0 #id自增类型(数据库id自增)

    添加 @DS注解 切换数据源

    1.  
    2. import com.baomidou.dynamic.datasource.annotation.DS;
    3. import com.multidb.annotationdemo.dao.order.OrderDao;
    4. import com.multidb.annotationdemo.entity.order.Order;
    5. import org.springframework.beans.factory.annotation.Autowired;
    6. import org.springframework.stereotype.Service;
    7.  
    8. @Service
    9. @DS("order")
    10. public class OrderService {
    11.  
    12.     @Autowired
    13.     OrderDao orderDao;
    14.  
    15.     public Order getOrder() {
    16.         return orderDao.selectByPrimaryKey(1L);
    17.     }
    18.  
    19. }
    1. package com.multidb.annotationdemo.service;
    2.  
    3.  
    4. import com.baomidou.dynamic.datasource.annotation.DS;
    5. import com.multidb.annotationdemo.dao.user.UserDao;
    6. import com.multidb.annotationdemo.entity.user.User;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.stereotype.Service;
    9.  
    10. @Service
    11. @DS("user")
    12. public class UserService {
    13.  
    14.     @Autowired
    15.     UserDao userDao;
    16.  
    17.     public User getUser() {
    18.         return userDao.selectByPrimaryKey(1L);
    19.     }
    20.  
    21. }

    启动类配置扫描mapper接口：

    1. @SpringBootApplication
    2. @MapperScan("com.multidb.annotationdemo.dao.**")
    3. public class Datasource1Application {
    4.  
    5.     public static void main(String[] args) {
    6.         SpringApplication.run(Datasource1Application.class, args);
    7.     }
    8.  
    9. }

    测试

    1. @RestController
    2. public class IndexController {
    3.  
    4.     @Autowired
    5.     UserService userService;
    6.     @Autowired
    7.     OrderService orderService;
    8.  
    9.     @GetMapping("/getUser")
    10.     public User getUser() {
    11.         return userService.getUser();
    12.     }
    13.  
    14.     @GetMapping("/getOrder")
    15.     public Order getOrder() {
    16.         return orderService.getOrder();
    17.     }
    18.  
    19. }

    项目源码以及数据库脚本： multi-datasource-parent: Spring boot 整合 MyBatis 实现多数据源。

  • 相关阅读:
    Linux内存管理（三十二）：直接内存规整详解
    C++ 队列！还是要从 STL 中的说起……
    逻辑运算介绍
    Python------学生管理（文件txt处理）
    ClickHouse 复制粘贴多行sql语句报错
    渗透测试tomcat错误信息泄露解决办法
    哪个版本的JVM最快？
    Python基础入门篇【41】--python中的时间包
    EasyRecovery14数据恢复软件官方功能简介
    Docker
  • 原文地址：https://blog.csdn.net/u010972055/article/details/127930188