一、前言

本篇demo实现了springboot项目实现了多数据源切换的功能。对一些有多个数据库的项目来说是一个很好的参考。

关于动态数据源的切换的方案有很多，核心只有两种。一种是构建多套环境，另一种是基于spring原生的 AbstractRoutingDataSource 切换。如果你的数据源较少，场景不复杂，选择以上任意一种都可以。如果你需要更多特性，可以参考本demo。

二、实现过程（使用方法）

1. 引入dynamic-datasource-spring-boot-starter。

<dependency>
  <groupId>com.baomidou</groupId>
  <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
  <version>${version}</version>
</dependency>

2.配置数据源。

spring:
  datasource:
    dynamic:
      datasource:
        master:
          username: root
          password: root
          url: jdbc:mysql://localhost/master?characterEncoding=utf-8&useSSL=true&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&serverTimezone=GMT%2b8
          driver-class-name: com.mysql.jdbc.Driver
        slave:
          username: root
          password: root
          url: jdbc:mysql://localhost/slave?characterEncoding=utf-8&useSSL=true&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&serverTimezone=GMT%2b8
          driver-class-name: com.mysql.jdbc.Driver

3.使用 @DS 切换数据源

@DS 可以注解在方法上和类上，同时存在方法注解优先于类上注解。

注解在service实现或mapper接口方法上，但不建议同时在service和mapper注解。

package com.zxh.service.impl;


import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.zxh.entity.User;
import com.zxh.mapper.UserMapper;
import com.zxh.service.UserService;

import org.springframework.stereotype.Service;

@Service
@DS("slave")
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {

    @Override
    @DS("master")//这里必须包一层，不能调用mp默认的插入，因为会走到从库去
    public void addUser(User user) {
        baseMapper.insert(user);
    }
    
    @Override
    @DS("slave")
    public User selectSlaveUser(Long id) {
    	return baseMapper.selectById(id);
    }
}

4.集成mybatis-plus

只要进入mybatisPlus相关jar包，项目自动集成。 兼容mybatisPlus 2.x和3.x的版本。

只要注解在mybatisPlus的mapper或serviceImpl上即可完成mp内置方法切换。

<dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>2.3.1</version>
        </dependency>

5.在本地的mysql分别建master跟slave两个数据库

6.在两个数据库分别建user表，表结构如下：

7.项目演示：

a).执行testAddUser

   @Test
    public void testAddUser() {
        User user = new User();
        user.setName("测试用户" + random.nextInt());
        user.setAge(random.nextInt(100));
        userService.addUser(user);
    }

    @Override
    @DS("master")//这里必须包一层，不能调用mp默认的插入，因为会走到从库去
    public void addUser(User user) {
        baseMapper.insert(user);
    }

因为我们在addUser里加了@DS("master")注解，所以会走到主库里面，可以看到master数据库插了一条记录：

b).执行testSelectById，slave数据库里面有一条数据如下：

 @Test
    public void testSelectById() {
    	User user = userService.selectSlaveUser(2L);
    	System.out.println(user.getName());
    }

执行后结果，可以看到后台打印了用户名

这样就实现了动态加载多数据源的效果。

三、项目结构图

三、常见问题

多个库的事物如何处理？

不能 不能 不能，一个业务操作涉及多个库不要加事务。