【Java】SpringBoot MybatisPlus 连接多数据源（Mysql、SQL Server）_java 配置mysql 多数据源

1. 前言

连接多数据源的场景非常多哈，比如读写分离，多业务库报表。

2. 环境准备

1. JDK1.8
2. Mysql 8.0 （主库）
3. SQL Server 2008 R2（老业务系统）
4. JetBrains IDEA
5. Springboot 2.0.4 （Maven项目）
6. MyBatis-Plus 3.5.0

3. 配置步骤

1）pom.xml

由于我使用到了MybatisPlus，所以直接使用MybatisPlus官方推荐的dynamic-datasource-spring-boot-starter。
其次，用到了SqlServer数据库，所以要增加连接SQLServer的JDBC驱动。（SQL Server 2008 R2对应可以使用8.2.2.jre8版本，我是这么搭配的，供参考）
pom.xml文件中增加：

	<dependencies>
        <!--mybatis-plus 多数据源配置-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
            <version>3.5.0</version>
        </dependency>

        <!-- SQL Server驱动-->
        <dependency>
            <groupId>com.microsoft.sqlserver</groupId>
            <artifactId>mssql-jdbc</artifactId>
            <version>8.2.2.jre8</version>
        </dependency>
    </dependencies>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

2）修改application.yml文件

这里是重中之重，这里要配置好。但是也没有那么难。

1. 之前的配置：

spring:
    jackson:
        date-format: yyyy-MM-dd HH:mm:ss
        time-zone: Asia/Shanghai
    datasource:
        url: jdbc:mysql://localhost:3306/数据库名?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT
        username: root
        password: root
        driver-class-name: com.mysql.cj.jdbc.Driver
        type: com.alibaba.druid.pool.DruidDataSource
1
2
3
4
5
6
7
8
9
10

2. 修改后（多数据源）的配置：

spring:
    jackson:
        date-format: yyyy-MM-dd HH:mm:ss
        time-zone: Asia/Shanghai
    datasource:
        dynamic:
            primary: master #设置默认的数据源或者数据源组,默认值即为master
            strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
            datasource:
                master:
                    url: jdbc:mysql://localhost:3306/数据库名?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT
                    username: root
                    password: root
                    driver-class-name: com.mysql.cj.jdbc.Driver
                    type: com.alibaba.druid.pool.DruidDataSource
                slave_1:
                    url: jdbc:sqlserver://localhost:1433;DatabaseName=数据库名
                    username: sa
                    password: sa
                    driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

其他更详细的配置可以参考这个官方文档描述。
可以看到，我把之前的mysql数据库做成了master库，也就是主库，也就是上面primary参数中配置的默认库，如果代码中没有明确指定数据库，默认就是master库。
另外添加了一个slave_1库，slave_1是一个sqlserver库。从名字可以看出来，slave可以有N个库。

4. 多数据源的使用

配置好之后当然就是使用了。
当然，使用起来也非常简单，总的来说就是：
在service层（或使用到的方法上）添加注解@DS(“xxxxxxx”)
先简单看一下我的项目结构（只展示关键结构，其他涉密不展示）:

- 项目名称
--src
---main
----java
-----com.doph.codepro
------controller
		DophController.java
------entity
		Doph.java
------mapper
		DophMapper.java
------service
		DophService.java
-------impl
		DophServiceImpl.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

1）entity层

就是简单的实体类，简单写几个字段。@Data注解是lombok的，不知道的可以搜索一下噢~

@Data
@TableName("xxx_doph")
public class Doph {
	private static final long serialVersionUID = 1L;
	
	@TableId
	private int id;

	private String name;
	private int age;
}
1
2
3
4
5
6
7
8
9
10
11

2）Mapper层

由于用了mybatisPlus，而且业务都是简单业务，所以这几部分代码量都比较少，不会的可以看一下mybatisplus的官网。

public interface DophMapper extends BaseMapper<Doph>{}
1

3）Service层

public interface DophService extends IService<Doph>{}
1

4）Impl层（重）

由于业务都是写在Impl层的，所以根据最小化原则，这里使用@DS注解。
因为我这个文件中的业务操作都是在slave_1库中的，所以这里的@DS注解我直接加在了类上。当然，根据自己的业务，加在方法上也是ok的。

@Servcie
@DS("slave_1")
public class DophServiceImpl extends ServiceImpl<DophMapper, Doph> implements DophService{}
1
2
3

---

如果这里的业务是:
从slave_1库中取出slaveList，再从master库中取出masterList，把name相同的条目插入到slave_2库里面去。
那么有可能出现这种情况（以下是伪代码举例）：

@Service
public DophServiceImpl extends ServiceImpl<DophMapper, Doph> implements DophService{
	@Autowired
	private DophMapper dophMapper;

	@Override
	@DS("slave_1")
	private List<Doph> getSlave(){
		List<Doph> slaveList = new ...;
		...
		return slaveList ;
	}

	@Override
	@DS("master")
	private List<Doph> getMaster(){
		List<Doph> masterList= new ...;
		...
		return masterList;
	}

	@Override
	@DS("slave_2")	
	public void getDiff(){
		List<Doph> slaveList = getSlave();
		List<Doph> masterList= getMaster();
		//循环比较差异
		for(...){
			if(slave.name.equals(master.name)){
				dophMapper.insert(..);
			}
		}
	}
}
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

5）Controller层

@Controller
@RequestMapping("/doph/")
public class DophController {

    @Autowired
    private DophService dophService;

    @RequestMapping("id1328")
    @ResponseBody
    public Doph testGetOneDoph(){
        QueryWrapper queryWrapper = new QueryWrapper();
        queryWrapper.eq("id",1328);
        return dophService.getOne(queryWrapper);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

以上就能完整地输出一个id为1328的Doph Json啦~

5. 结果展示

证明我不是在吹牛逼，当然，里面的数据是一点都不能透露。

后记

之前一直比较害怕多数据源这块。也说不上来原因。当业务达到一定体量之后，或者源于设计之初的规划，多多少少都会碰到多数据源的情况。之前数据库多用Oracle，并且自己也有OCP证书，所以Oracle的DBLink总是解决多数据源的第一选择。今天终于突破了这个小点。其实真的一点都不难，难的是突破自己的心魔。

共勉。