使用原生SpringBoot方式让Mybatis-Plus轻松实现多数据源详解_springboot mybatis-plus 多数据源 ds

一般都是使用第三方 mybatis 扩展库dynamic-datasource-spring-boot-starter来切换多数据源.但是使用@DS切换数据源在有@Transactional事务注解的时候会有一个坑!

原因： 开启事务的同时，会从数据库连接池获取数据库连接；

如果内层的service使用@DS切换数据源，只是又做了一层拦截，但是并没有改变整个事务的连接；

在这个事务内的所有数据库操作，都是在事务连接建立之后，所以会产生数据源没有切换的问题；

为了使@DS起作用，必须替换数据库连接，也就是改变事务的传播机智，产生新的事务，获取新的数据库连接；

所以service方法上除了加@Transactional外，还需要设置propagation = Propagation.REQUIRES_NEW参数.

我这里主要介绍使用原生SpringBoot方式让Mybatis-Plus轻松实现多数据源，需要的朋友可以参考下.

依赖项:

使用Gradle构建时的配置: build.gradle文件:

dependencies {
  implementation 'org.springframework.boot:spring-boot-starter'
  implementation 'org.springframework.boot:spring-boot-starter-jdbc'
    
  runtimeOnly 'mysql:mysql-connector-java:5.1.49'
    
  //Mybatis-Plus
  implementation "com.baomidou:mybatis-plus-boot-starter:3.5.2"
  
  //单元测试  
  testImplementation 'org.springframework.boot:spring-boot-starter-test'
}
1
2
3
4
5
6
7
8
9
10
11
12

使用Maven构建时的配置: pom.xml文件:

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

<!-- 单元测试 -->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
</dependency>

<!-- Mybatis-Plus -->
<dependency>
  <groupId>com.baomidou</groupId>
  <artifactId>mybatis-plus-boot-starter</artifactId>
  <version>3.5.2</version>
</dependency>
<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>5.1.49</version>
  <scope>runtime</scope>
</dependency>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

编辑属性文件,例如: application.yaml

spring:
  datasource:
    #主数据库
    master:
      driver-class-name: com.mysql.jdbc.Driver
      jdbc-url: "jdbc:mysql://127.0.0.1:3306/mybatis?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai"
      username: "root"
      password: "111111"
      minimum-idle: 5
      maximum-pool-size: 10
    #副数据库
    slave:
      driver-class-name: com.mysql.jdbc.Driver
      jdbc-url: "jdbc:mysql://127.0.0.1:3306/mt?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai"
      username: "root"
      password: "111111"
      minimum-idle: 5
      maximum-pool-size: 10

---
#mybatis plus 设置
mybatis-plus:
  configuration:
    # 这个配置会将执行的sql打印出来，在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    # 返回类型为Map,显示null对应的字段
    call-setters-on-nulls: true
  global-config:
    # 关闭MP3.0自带的banner
    banner: false
    db-config:
      #主键类型  0:"数据库ID自增",1:"该类型为未设置主键类型", 2:"用户输入ID",3:"全局唯一ID (数字类型唯一ID)", 4:"全局唯一ID UUID",5:"字符串全局唯一ID (idWorker 的字符串表示)";
      id-type: 4
      # 默认数据库表下划线命名
      table-underline: true
      # 逻辑删除
      logic-delete-field: flag # 全局逻辑删除的实体字段名(since 3.3.0,配置后可以忽略不配置步骤2)
      logic-delete-value: 1 # 逻辑已删除值(默认为 1)
      logic-not-delete-value: 0 # 逻辑未删除值(默认为 0)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小惠珠哦/article/detail/902926