發布時間：2018-12-11
技術：springboot1.5.1 + maven3.0.1+ mybatis-plus-boot-starter2.3.1 + dynamic-datasource-spring-boot-starter2.4.2 + jdk1.8
概述
基於springboot的多數據源配置
詳細
一、前言
本篇demo實現了springboot項目實現了多數據源切換的功能。對一些有多個數據庫的項目來說是一個很好的參考。
關於動態數據源的切換的方案有很多，核心只有兩種。一種是構建多套環境，另一種是基於spring原生的 AbstractRoutingDataSource 切換。如果你的數據源較少，場景不復雜，選擇以上任意一種都可以。如果你需要更多特性，可以參考本demo。
二、實現過程（使用方法）
-
引入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());
}
執行后結果，可以看到后台打印了用戶名
這樣就實現了動態加載多數據源的效果。
三、項目結構圖
三、常見問題
多個庫的事物如何處理？
不能 不能 不能，一個業務操作涉及多個庫不要加事務。