springboot之集成mybatis-plus、druid整合多數(shù)據(jù)源實踐

更新時間：2026年06月04日 09:11:21 作者：我叫晨曦啊

本篇文章詳細(xì)介紹了如何在SpringBoot 2.3.12.RELEASE項目中配置MySQL 8.0數(shù)據(jù)庫,包括pom文件依賴引入、application.yml配置、實體類與mapper層的創(chuàng)建及測試類的編寫,助力開發(fā)者高效構(gòu)建數(shù)據(jù)庫連接

數(shù)據(jù)表準(zhǔn)備

-- 數(shù)據(jù)庫 test1
CREATE TABLE `t_product` (
  `id` int NOT NULL AUTO_INCREMENT,
  `produce_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
  `produce_price` int DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;

-- 數(shù)據(jù)庫 test2
CREATE TABLE `student` (
  `id` int NOT NULL AUTO_INCREMENT,
  `name` varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=101 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

引入pom文件依賴

<!--spring-boot-starter-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>
<!--spring-boot-starter-web-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--spring-boot-starter-test-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>
<!-- lombok -->
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>1.18.26</version>
</dependency>
<!--Mybatis-Plus 注意版本-->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.5.1</version>
</dependency>
<!--dynamic-datasource-spring-boot-starter-->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>3.5.2</version>
</dependency>
<!--druid-spring-boot-starter-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.2.16</version>
</dependency>
<!-- mysql-connector-j -->
<dependency>
    <groupId>com.mysql</groupId>
    <artifactId>mysql-connector-j</artifactId>
    <version>8.0.33</version>
</dependency>

application.yml配置文件

spring:
  autoconfigure:
    exclude:  com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
  datasource:
    dynamic:
      primary: master
      datasource:
        master:
          type: com.alibaba.druid.pool.DruidDataSource
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://1.1.1.1:3306/test1?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useSSL=false
          username: root
          password: 123456
        slave:
          type: com.alibaba.druid.pool.DruidDataSource
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://2.2.2.2:3306/test2?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useSSL=false
          username: root
          password: 654321
    druid:
      # 如果initialSize數(shù)量較多時，打開會加快應(yīng)用啟動時間
      async-init: true
      # 連接池初始化時創(chuàng)建的連接數(shù)
      initial-size: 5
      # 連接池中最大連接數(shù)
      max-active: 50
      # 連接池中最小空閑連接數(shù)
      min-idle: 5
      # 連接池中最大空閑連接數(shù)
      max-idle: 20
      # 配置獲取連接等待超時的時間 毫秒
      max-wait: 6000
      # 配置間隔多久才進行一次檢測，檢測需要關(guān)閉的空閑連接，單位是毫秒
      time-between-eviction-runs-millis: 60000
      # 增強timeBetweenEvictionRunsMillis的周期性連接檢查，minIdle內(nèi)的空閑連接，每次檢查強制驗證連接有效性
      keep-alive: true
      # 配置一個連接在池中最小生存的時間，單位是毫秒
      min-evictable-idle-time-millis: 300000
      max-evictable-idle-time-millis: 172800000
      # 用于檢測連接是否有效的SQL語句
      validation-query: select 1
      validation-query-timeout: 1
      # 是否開啟空閑連接的檢測
      test-while-idle: true
      # 是否開啟連接的檢測功能，在獲取連接時檢測連接是否有效
      test-on-borrow: false
      # 是否開啟連接的檢測功能，在歸還連接時檢測連接是否有效
      test-on-return: false
      # 是否緩存preparedStatement，也就是PSCache。PSCache對支持游標(biāo)的數(shù)據(jù)庫性能提升巨大，比如說oracle。在mysql下建議關(guān)閉。
      pool-prepared-statements: false
      filter:
        stat:
          enabled: true
          db-type: mysql
          log-slow-sql: true
          slow-sql-millis: 3000
          connection-stack-trace-enable: true
        wall:
          enabled: true
          db-type: mysql
          config:
            insert-allow: true
            delete-allow: false
            update-allow: true
            drop-table-allow: false
      stat-view-servlet:
        # http://localhost:8989/mp/druid/index.html
        # 啟用StatViewServlet
        enabled: true
        # 訪問內(nèi)置監(jiān)控頁面的路徑，內(nèi)置監(jiān)控頁面的首頁是/druid/index.html
        url-pattern: /druid/*
        # 不允許清空統(tǒng)計數(shù)據(jù),重新計算
        reset-enable: false
        # 配置監(jiān)控頁面訪問密碼
        login-username: root
        login-password: 123456
        # 允許訪問的地址，如果allow沒有配置或者為空，則允許所有訪問
        allow: 127.0.0.1
        # 拒絕訪問的地址，deny優(yōu)先于allow，如果在deny列表中，就算在allow列表中，也會被拒絕
mybatis-plus:
  # 實體類Mapper.xml文件所在包
  mapper-locations: classpath:mapper/*Mapper.xml
  # 指定 MyBatis 別名包掃描路徑，用于給包中的類注冊別名。注冊后，在 Mapper 對應(yīng)的 XML 文件中可以直接使用類名，無需使用全限定類名。
  type-aliases-package: com.sun.pojo
  configuration:
    # 開啟駝峰映射，A_COLUMN > aColumn
    map-underscore-to-camel-case: true
    # 是否允許單條sql 返回多個數(shù)據(jù)集
    multiple-result-sets-enabled: true
    # mybatis-plus的日志輸出到控制臺
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

新建實體類

@Data
@TableName("t_product")
public class Product {

    @TableId(value = "id", type = IdType.AUTO)
    private Integer id;

    @TableField("produce_name")
    private String produceName;

    @TableField("produce_price")
    private String producePrice;

}

@Data
@TableName("student")
public class Student {

    @TableId(value = "id", type = IdType.AUTO)
    private Integer id;

    @TableField("remark")
    private String remark;
}

新建mapper

在mapper層類上使用@DS()注解區(qū)分使用的數(shù)據(jù)源

@DS("master")
@Mapper
public interface ProductMapper extends BaseMapper<Product> {
}

@DS("slave")
@Mapper
public interface StudentMapper extends BaseMapper<Student> {
}

新建測試類

@SpringBootTest
@RunWith(SpringRunner.class)
public class DataTest {

    @Autowired
    private StudentMapper studentMapper;

    @Autowired
    private ProductMapper productMapper;

    @Test
    public void dataTest() {
        LambdaQueryWrapper<Student> studentWrapper = new LambdaQueryWrapper<>();
        List<Student> studentList = studentMapper.selectList(studentWrapper);
        studentList.forEach(System.out::println);

        LambdaQueryWrapper<Product> productWrapper = new LambdaQueryWrapper<>();
        List<Product> productList = productMapper.selectList(productWrapper);
        productList.forEach(System.out::println);
    }
    
}