10、SpringBoot 实战 - 集成多数据源 dynamic-datasource

dynamic-datasource-spring-boot-starter 是一个基于 springboot 的快速集成多数据源的启动器。

其支持 Jdk 1.7+、SpringBoot 1.5.x 和 2.x.x。

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 DDKK.COM 弟弟快看，程序员编程资料站
 * @since 2023-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 DDKK.COM 弟弟快看，程序员编程资料站
 * @since 2023-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-datasourceSpringBoot多数据源快速启动器，https://www.oschina.net/p/dynamic-datasource-spring-boot-starter?hmsr=aladdin1e1；