发布时间:2018-12-11
技术:springboot1.5.1 + maven3.0.1+ mybatis-plus-boot-starter2.3.1 + dynamic-datasource-spring-boot-starter2.4.2 + jdk1.8
概述
详细
代码下载:http://www.demodashi.com/demo/14622.html
一、前言
本篇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()); }
执行后结果,可以看到后台打印了用户名
这样就实现了动态加载多数据源的效果。
三、项目结构图
三、常见问题
多个库的事物如何处理?
不能 不能 不能,一个业务操作涉及多个库不要加事务。
代码下载:http://www.demodashi.com/demo/14622.html
注:本文著作权归作者,由demo大师发表,拒绝转载,转载需要作者授权
原文地址:https://www.cnblogs.com/demodashi/p/10503263.html