mybatis-plus官方提供了多数据源的jar包（dynamic-datasource-spring-boot-starter），官网也简单说了一下，有一些点不太明确，因此记录下来。
项目使用了Postgresql和MySQL2种数据源。
1. 导包
pom.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.10.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>dynamic-datasource-mybatisplus</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>dynamic-datasource-mybatisplus</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.5.8</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.1</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.4.1</version>
</dependency>
<dependency>
<groupId>org.apache.velocity</groupId>
<artifactId>velocity-engine-core</artifactId>
<version>2.3</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.4.1</version>
</dependency>
<!-- druid -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.5</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
2. 配置文件
application.yml文件
# server
server:
port: 1100
servlet:
context-path: /dynamicdatasource
# spring
spring:
datasource:
dynamic:
primary: master #设置默认的数据源或者数据源组,默认值即为master
strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
datasource:
master:
url: jdbc:postgresql://192.168.1.1:5432/postgres?stringtype=unspecified
username: postgres
password: 123456
driver-class-name: org.postgresql.Driver
slave:
url: jdbc:mysql://192.168.1.2:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8&allowMultiQueries=true&autoReconnect=true
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
druid:
# 连接池配置
# 配置初始化大小、最小、最大
initial-size: 5
max-active: 200
min-idle: 5
# 连接超时时间
max-wait: 6000
# 间隔多久进行一次检测，检测需要关闭的空闲连接，单位是毫秒
time-between-eviction-runs-millis: 60000
# 一个连接在连接池中最小的生存时间，单位是毫秒
min-evictable-idle-time-millis: 120000
# 用来检测连接是否有效的sql，要求是一个查询语句。 如果validationQuery为null，testOnBorrow、testOnReturn、 testWhileIdle都不会其作用。
validation-query: SELECT 1
# 当从连接池借用连接时，是否测试该连接
test-on-borrow: false
# 在连接归还到连接池时是否测试该连接
test-on-return: false
# 当连接空闲时，是否执行连接测试
test-while-idle: true
# 是否缓存preparedStatement，也就是PSCache。 PSCache对支持游标的数据库性能提升巨大，比如说oracle。 在mysql5.5以下的版本中没有PSCache功能，建议关闭掉
pool-prepared-statements: true
# 要启用PSCache，必须配置大于0，当大于0时， poolPreparedStatements自动触发修改为true。 在Druid中，不会存在Oracle下PSCache占用内存过多的问题， 可以把这个数值配置大一些，比如说100
max-pool-prepared-statement-per-connection-size: 100
# 合并多个DruidDataSource的监控数据
use-global-data-source-stat: true
# 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
filter:
# 慢SQL记录(sql语句执行时间超过某个界限就记录下来)
stat:
log-slow-sql: true
slow-sql-millis: 2000
# wall:
# config:
# none-base-statement-allow: true
# multi-statement-allow: true
# 本来有防火墙的过滤器的，但批量更新总是过不去，就去掉了，加防火墙怎么实现批量更新？还没解决
filters: stat
# 监控配置
# WebStatFilter配置
web-stat-filter:
# 是否开启web-jdbc监控 默认是false
enabled: true
# 是否开启单个监控url调用的sql列表 默认开启
profile-enable: true
url-pattern: /*
exclusions: /druid/*,*.gif,*.png,*.jpg,*.html,*.js,*.css,*.ico
# 是否开启session统计 默认false
session-stat-enable: true
# 设置session统计的最大值 默认是1000
session-stat-max-count: 1000
# StatViewServlet配置
stat-view-servlet:
# 是否开启druid的数据统计界面 默认false
enabled: true
url-pattern: /druid/*
# 登录监控界面的用户名以及密码，登录url为 IP:port/druid
login-username: druid
login-password: 123
allow:
deny:
# HTML页面上的“Reset All”功能
reset-enable: true
# mybatis
mybatis-plus:
type-aliases-package: com.example.demo.entity
# 指定mybatis映射文件的位置
mapper-locations: classpath:mapper/*.xml
configuration:
# 开启驼峰命名转换（开启后需要注意字段写法，不然返回值为null）
map-underscore-to-camel-case: true
# 配置mybatis日志输出
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
global-config:
db-config:
id-type: AUTO
配置中需要注意2点：
- 使用了druid连接池，druid连接池部分配置还是像以前一样写，但是数据源部分不写到druid下面
- 数据源部分写到spring.datasource.dynamic下面，这样mybatis-plus会自动装配，并配置了
@DS注解可以使用
- 数据源部分写到spring.datasource.dynamic下面，这样mybatis-plus会自动装配，并配置了
3. 使用
像原来一样，用注解来区分使用哪个数据源就行。
package com.example.demo.dao;
import com.example.demo.entity.Dept;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
public interface DeptDao extends BaseMapper<Dept> {
}
package com.example.demo.dao;
import com.example.demo.entity.User;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
@DS("slave") // 名字就是配置文件中写的那个
public interface UserDao extends BaseMapper<User> {
}
package com.example.demo.service;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.example.demo.dao.DeptDao;
import com.example.demo.dao.UserDao;
import com.example.demo.entity.Dept;
import com.example.demo.entity.User;
@Service
public class DynamicDataSourceService {
@Resource
private DeptDao deptDao;
@Resource
private UserDao userDao;
public void testMaster() {
List<Dept> selectList = deptDao.selectList(new QueryWrapper<Dept>());
System.out.println(selectList.size());
for (Dept d : selectList) {
System.out.println(d);
}
}
public void testSlave() {
Page<User> p = new Page<User>(2, 2);
p = userDao.selectPage(p, new QueryWrapper<User>());
System.out.println(p.getRecords().size());
for (User u : p.getRecords()) {
System.out.println(u);
}
}
}
比较简单，可以拿起来就用，不用自己再装配数据源、定义注解了，还可以使用分页。
若启动报错，是由于自动装配druid的数据源的话，可以屏蔽掉druid的自动装配（@SpringBootApplication(exclude = DruidDataSourceAutoConfigure.class)）
