[Java知识库] SpringBoot实战（十）集成多数据源dynamic-datasource

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> SpringBoot实战（十）集成多数据源dynamic-datasource -> 正文阅读

[Java知识库]SpringBoot实战（十）集成多数据源dynamic-datasource

1.Maven依赖

<!-- Dynamic datasource -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>2.4.2</version>
</dependency>

2. @DS注解

@DS 可以注解在方法上和类上，同时存在方法注解优先于类上注解。建议注解在serviceImpl类或mapper接口方法上。

注意：从2.0.0 不再支持@DS空注解，您必须指明你所需要的数据库组名或者具体某个数据库名称。

注解	结果
没有@DS注解	默认数据源
@DS(“dsName”)	数据源名称

3.普通Hihari连接池

SpringBoot 2.x默认是使用HikariCP的, 所以觉得HikariCP可以的不需要换Druid。

3.1 yml配置

server:
  port: 8081

spring:
  datasource:
    dynamic:
      primary: auth
      datasource:
        auth:
          url: jdbc:mysql://localhost:3306/auth?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
          username: root
          password: root
          driver-class-name: com.mysql.cj.jdbc.Driver
        mydb1:
          url: jdbc:mysql://localhost:3306/mydb1?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
          username: root
          password: root
          driver-class-name: com.mysql.cj.jdbc.Driver

mybatis:
  mapper-locations: "classpath:mapper/*.xml"

#showSql
logging:
  level:
    com:
      demo:
        auth:
          mapper : debug

4.Druid连接池

4.1 Druid依赖

<!-- Druid -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.1.22</version>
</dependency>

4.2 yml配置

server:
  port: 8081

spring:
  datasource:
    dynamic:
      primary: auth
      datasource:
        auth:
          # JDBC 配置(驱动类自动从url的mysql识别,数据源类型自动识别)
          type: com.alibaba.druid.pool.DruidDataSource
          url: jdbc:mysql://localhost:3306/auth?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
          username: root
          password: root
          driver-class-name: com.mysql.cj.jdbc.Driver
          druid:
            #连接池配置(通常来说，只需要修改initialSize、minIdle、maxActive
            initial-size: 1
            max-active: 20
            min-idle: 1
            # 配置获取连接等待超时的时间
            max-wait: 60000
            #打开PSCache，并且指定每个连接上PSCache的大小
            pool-prepared-statements: true
            max-pool-prepared-statement-per-connection-size: 20
            validation-query: SELECT 'x'
            test-on-borrow: false
            test-on-return: false
            test-while-idle: true
            #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
            time-between-eviction-runs-millis: 60000
            #配置一个连接在池中最小生存的时间，单位是毫秒
            min-evictable-idle-time-millis: 300000
            filters: stat,wall
            # WebStatFilter配置，说明请参考Druid Wiki，配置_配置WebStatFilter
            #是否启用StatFilter默认值true
            web-stat-filter.enabled: true
            web-stat-filter.url-pattern: /*
            web-stat-filter.exclusions: "*.js , *.gif ,*.jpg ,*.png ,*.css ,*.ico , /druid/*"
            web-stat-filter.session-stat-max-count: 1000
            web-stat-filter.profile-enable: true
            # StatViewServlet配置
            #展示Druid的统计信息,StatViewServlet的用途包括：1.提供监控信息展示的html页面2.提供监控信息的JSON API
            #是否启用StatViewServlet默认值true
            stat-view-servlet.enabled: true
            #根据配置中的url-pattern来访问内置监控页面，如果是上面的配置，内置监控页面的首页是/druid/index.html例如：
            #http://127.0.0.1:9000/druid/index.html
            #http://127.0.0.1:8080/mini-web/druid/index.html
            stat-view-servlet.url-pattern: /druid/*
            #允许清空统计数据
            stat-view-servlet.reset-enable: true
        mydb1:
          # JDBC 配置(驱动类自动从url的mysql识别,数据源类型自动识别)
          type: com.alibaba.druid.pool.DruidDataSource
          url: jdbc:mysql://localhost:3306/mydb1?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
          username: root
          password: root
          driver-class-name: com.mysql.cj.jdbc.Driver
          druid:
            #连接池配置(通常来说，只需要修改initialSize、minIdle、maxActive
            initial-size: 1
            max-active: 20
            min-idle: 1
            # 配置获取连接等待超时的时间
            max-wait: 60000
            #打开PSCache，并且指定每个连接上PSCache的大小
            pool-prepared-statements: true
            max-pool-prepared-statement-per-connection-size: 20
            validation-query: SELECT 'x'
            test-on-borrow: false
            test-on-return: false
            test-while-idle: true
            #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
            time-between-eviction-runs-millis: 60000
            #配置一个连接在池中最小生存的时间，单位是毫秒
            min-evictable-idle-time-millis: 300000
            filters: stat,wall
            # WebStatFilter配置，说明请参考Druid Wiki，配置_配置WebStatFilter
            #是否启用StatFilter默认值true
            web-stat-filter.enabled: true
            web-stat-filter.url-pattern: /*
            web-stat-filter.exclusions: "*.js , *.gif ,*.jpg ,*.png ,*.css ,*.ico , /druid/*"
            web-stat-filter.session-stat-max-count: 1000
            web-stat-filter.profile-enable: true
            # StatViewServlet配置
            #展示Druid的统计信息,StatViewServlet的用途包括：1.提供监控信息展示的html页面2.提供监控信息的JSON API
            #是否启用StatViewServlet默认值true
            stat-view-servlet.enabled: true
            #根据配置中的url-pattern来访问内置监控页面，如果是上面的配置，内置监控页面的首页是/druid/index.html例如：
            #http://127.0.0.1:9000/druid/index.html
            #http://127.0.0.1:8080/mini-web/druid/index.html
            stat-view-servlet.url-pattern: /druid/*
            #允许清空统计数据
            stat-view-servlet.reset-enable: true

mybatis:
  mapper-locations: "classpath:mapper/*.xml"

#showSql
logging:
  level:
    com:
      demo:
        auth:
          mapper : debug

4.3 排除原生的Druid配置

import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication(exclude = DruidDataSourceAutoConfigure.class)
public class SpringbootDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootDemoApplication.class, args);
    }

}

5. UserController

import com.demo.auth.entity.User;
import com.demo.auth.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * 用户表(User)表控制层
 *
 * @author ACGkaka
 * @since 2021-06-18 16:49:55
 */
@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserService userService;

    /**
     * 插入单条数据
     *
     * @return 单条数据
     */
    @GetMapping("/insertOne")
    public User insertOne() {
        User user = new User();
        user.setUsername("ACGkaka1");
        user.setPassword("123456");
        user.setEmail("123@123.com");
        user.setPhone("15588888888");
        user.setDelFlag("0");
        return userService.insert(user);
    }

    /**
     * 插入单条数据
     *
     * @return 单条数据
     */
    @GetMapping("/insertOne2")
    public User insertOne2() {
        User user = new User();
        user.setUsername("ACGkaka2");
        user.setPassword("123456");
        user.setEmail("123@123.com");
        user.setPhone("15588888888");
        user.setDelFlag("0");
        return userService.insert2(user);
    }

    /**
     * 查询全部数据
     *
     * @return 全部数据
     */
    @GetMapping("/findAll")
    public List<User> findAll() {
        return userService.findAll();
    }

    /**
     * 查询全部数据
     *
     * @return 全部数据
     */
    @GetMapping("/findAll2")
    public List<User> findAll2() {
        return userService.findAll2();
    }

}

6. UserServiceImpl

import com.baomidou.dynamic.datasource.annotation.DS;
import com.demo.auth.entity.User;
import com.demo.auth.mapper.UserMapper;
import com.demo.auth.service.UserService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

/**
 * 用户表(User)表服务实现类
 *
 * @author ACGkaka
 * @since 2021-06-18 16:49:55
 */
@Service
public class UserServiceImpl implements UserService {

    @Resource
    private UserMapper userMapper;

    @Override
    public List<User> findAll() {
        // 查询多条数据
        return this.userMapper.queryAllByLimit(1, -1);
    }

    @DS("mydb1")
    @Override
    public List<User> findAll2() {
        // 查询多条数据
        return this.userMapper.queryAllByLimit(1, -1);
    }

    @Override
    public User insert(User user) {
        // 新增数据
        this.userMapper.insert(user);
        return user;
    }

    @DS("mydb1")
    @Override
    public User insert2(User user) {
        // 新增数据
        this.userMapper.insert(user);
        return user;
    }
}

7.测试

7.1 新增数据

在auth数据库新增一条数据：http://localhost:8081/user/insertOne

在mydb1数据库新增一条数据：http://localhost:8081/user/insertOne2

7.2 查询数据

在auth数据库查询数据：http://localhost:8081/user/findAll

在mydb1数据库查询数据：http://localhost:8081/user/findAll2

7.3 测试结果

/user/findAll 接口查询的是auth数据库中存储的“ACGkaka1”；
/user/findAll2 接口查询的是mydb数据库中存储的“ACGkaka2”；
多数据源配置成功。

8.源码地址：

https://gitee.com/acgkaka/SpringBootExamples/tree/master/springboot-dynamic-datasource

整理完毕，完结撒花~

参考地址：

1.springBoot(六) 调用多数据源 dynamic-datasource，https://blog.csdn.net/Tang_5253/article/details/101095855
2.dynamic-datasource SpringBoot 多数据源快速启动器，https://www.oschina.net/p/dynamic-datasource-spring-boot-starter?hmsr=aladdin1e1