目录

• 一、简介
• 二、准备
• 2.1 数据库
• 2.2 代码
• 三、案例
• 3.1 查询用户库主库用户表记录
• 3.2 查询用户库从库用户表记录
• 3.3 新增用户库主库用户记录
• 3.4 商品库查询商品记录
• 3.5 商品库新增商品记录
• 3.6 用户库商品库多数据源嵌套
• 四、总结

一、简介

• 俩年前用AOP自己封装过一个多数据源，连接地址：springboot + mybatis + druid + 多数据源 ， 有兴趣的可以看下；
• 当时没有处理多数据源嵌套的情况，现在发现mybatis plus比较好用，所以该篇文章写下demo;
• mybatis-plus的官网：MyBatis-Plus,请参考多数据源的篇幅； 另外mybatis-plus已经可以整合阿里的分布式事务组件seata了，demo待写；
• 因为mybatis-plus相对来说还是要手动处理的地方比较多，后面会考虑换成sharding-jdbc做多数据源和读写分离，后者完全接管，不需要自己去手动处理；不过，有好有坏，后者用的时候需要将前面的没有处理的因为延时可能导致查不到的地方全部强制走主库，而前者就不需要，什么时候接入都可以，但是后者可能会多写两行代码，要多方面去权衡；
• 代码github路径： https://github.com/1956025812/ds-many

二、准备
2.1 数据库

• 准备三个数据库，用户库一主一从[模拟读写分离]，商品库[模拟多数据源]。user_master[默认主库],user_slave, goods
• 用户主库user_master的用户表sys_user

CREATE TABLE `sys_user` (`id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '主键',`username` varchar(32) NOT NULL COMMENT '账号',`password` varchar(128) NOT NULL COMMENT 'MD5加密的密码',`nickname` varchar(128) DEFAULT NULL COMMENT '昵称',`email` varchar(64) NOT NULL COMMENT '邮箱',`head_img_url` varchar(256) DEFAULT NULL COMMENT '头像路径',`state` tinyint(4) NOT NULL COMMENT '状态：0-删除，1-启用，2-禁用',`register_source` tinyint(4) NOT NULL COMMENT '注册来源：1-系统注册，2-用户注册，3-QQ，4-WX',`create_info` varchar(64) DEFAULT NULL COMMENT '创建信息',`create_time` datetime NOT NULL COMMENT '创建时间',`update_info` varchar(64) DEFAULT NULL COMMENT '修改信息',`update_time` datetime DEFAULT NULL COMMENT '修改时间',PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=47 DEFAULT CHARSET=utf8 COMMENT='用户表'

用户从库user_slave的用户表sys_user

CREATE TABLE `sys_user` (`id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '主键',`username` varchar(32) NOT NULL COMMENT '账号',`password` varchar(128) NOT NULL COMMENT 'MD5加密的密码',`nickname` varchar(128) DEFAULT NULL COMMENT '昵称',`email` varchar(64) NOT NULL COMMENT '邮箱',`head_img_url` varchar(256) DEFAULT NULL COMMENT '头像路径',`state` tinyint(4) NOT NULL COMMENT '状态：0-删除，1-启用，2-禁用',`register_source` tinyint(4) NOT NULL COMMENT '注册来源：1-系统注册，2-用户注册，3-QQ，4-WX',`create_info` varchar(64) DEFAULT NULL COMMENT '创建信息',`create_time` datetime NOT NULL COMMENT '创建时间',`update_info` varchar(64) DEFAULT NULL COMMENT '修改信息',`update_time` datetime DEFAULT NULL COMMENT '修改时间',PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=47 DEFAULT CHARSET=utf8 COMMENT='用户表'

商品库goods的商品表goods

CREATE TABLE `goods` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`goods_name` varchar(256) NOT NULL COMMENT '商品名称',`goods_remark` varchar(256) DEFAULT NULL COMMENT '商品描述',`status` tinyint(4) NOT NULL COMMENT '状态：0-删除，1-上架，2-下架',`create_user` varchar(64) DEFAULT NULL COMMENT '创建人信息',`create_time` datetime NOT NULL COMMENT '创建时间',`update_user` varchar(64) DEFAULT NULL COMMENT '修改人信息',`update_time` datetime DEFAULT NULL COMMENT '修改时间',PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 COMMENT='商品表'

【使用Mybatis|使用Mybatis Plus整合多数据源和读写分离的详细过程】
2.2 代码
pom依赖

com.baomidoudynamic-datasource-spring-boot-starter3.2.0

application.yml

server:port: 8000servlet:context-path: / spring:datasource:dynamic:primary: user_masterstrict: falsedatasource:user_master:url: jdbc:mysql://localhost:3306/user_masterusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Driveruser_slave:url: jdbc:mysql://localhost:3306/user_slaveusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Drivergoods:url: jdbc:mysql://localhost:3306/goodsusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Driver

代码目录结构

文章图片


三、案例
3.1 查询用户库主库用户表记录
SysUserController

package com.yss.ds.demo.controller; import com.baomidou.dynamic.datasource.annotation.DS; import com.yss.ds.demo.entity.SysUser; import com.yss.ds.demo.service.ISysUserService; import com.yss.ds.demo.vo.ResultVO; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; /** * * 用户表 前端控制器 *
* * @author qjwyss * @since 2020-09-02 */@RestController@RequestMapping("/sysUser")public class SysUserController { @Resourceprivate ISysUserService iSysUserService; // http://localhost:8000/sysUser/selectUser?uid=5@GetMapping("/selectUser")public ResultVO selectUser(Integer uid) {SysUser sysUser = this.iSysUserService.selectUser(uid); return ResultVO.getSuccess("", sysUser); } }

ISysUserService

package com.yss.ds.demo.service; import com.baomidou.mybatisplus.extension.service.IService; import com.yss.ds.demo.entity.SysUser; /** * * 用户表 服务类 *
* * @author qjwyss * @since 2020-09-02 */public interface ISysUserService extends IService { SysUser selectUser(Integer uid); }

SysUserServiceImpl： 只需要在service方法上用@DS("user_master")注解标明该方法的数据源即可

package com.yss.ds.demo.service.impl; import com.alibaba.fastjson.JSONObject; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yss.ds.demo.entity.Goods; import com.yss.ds.demo.entity.SysUser; import com.yss.ds.demo.mapper.SysUserMapper; import com.yss.ds.demo.service.IGoodsService; import com.yss.ds.demo.service.ISysUserService; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Date; /** * * 用户表 服务实现类 *
* * @author qjwyss * @since 2020-09-02 */@Service@Slf4jpublic class SysUserServiceImpl extends ServiceImpl implements ISysUserService { @Resourceprivate SysUserMapper sysUserMapper; @DS("user_master")@Overridepublic SysUser selectUser(Integer uid) {return this.getById(uid); } }

输出： 可以看到的查询到的是主库的记录

{"code":1,"msg":"","data":{"id":5,"username":"yss003","password":"E10ADC3949BA59ABBE56E057F20F883E","nickname":"猿叔叔003-主库","email":"yss@5566.com","headImgUrl":"qwerwqe","state":1,"registerSource":1,"createInfo":null,"createTime":"2020-01-16T14:46:50.000+0000","updateInfo":null,"updateTime":"2020-04-29T13:48:00.000+0000"}}

3.2 查询用户库从库用户表记录
SysUserController

@RestController@RequestMapping("/sysUser")public class SysUserController { @Resourceprivate ISysUserService iSysUserService; // http://localhost:8000/sysUser/selectUserSlave?uid=5@GetMapping("/selectUserSlave")public ResultVO selectUserSlave(Integer uid) {SysUser sysUser = this.iSysUserService.selectUserSlave(uid); return ResultVO.getSuccess("", sysUser); } }

ISysUserService

public interface ISysUserService extends IService { SysUser selectUserSlave(Integer uid); }

SysUserServiceImpl： 只需要在service方法上用@DS("user_slave")注解标明该方法的数据源即可

@Service@Slf4jpublic class SysUserServiceImpl extends ServiceImpl implements ISysUserService { @Resourceprivate SysUserMapper sysUserMapper; @DS("user_slave")@Overridepublic SysUser selectUserSlave(Integer uid) {return this.getById(uid); } }

结果： 可以看到的查询到的是从库的记录

{"code":1,"msg":"","data":{"id":5,"username":"yss003","password":"E10ADC3949BA59ABBE56E057F20F883E","nickname":"猿叔叔003-从库","email":"yss@5566.com","headImgUrl":"qwerwqe","state":1,"registerSource":1,"createInfo":null,"createTime":"2020-01-16T14:46:50.000+0000","updateInfo":null,"updateTime":"2020-04-29T13:48:00.000+0000"}}

3.3 新增用户库主库用户记录
SysUserController

@RestController@RequestMapping("/sysUser")public class SysUserController { @Resourceprivate ISysUserService iSysUserService; // http://localhost:8000/sysUser/save@GetMapping("/save")public ResultVO saveSysUser() {this.iSysUserService.saveSysUser(); return ResultVO.getSuccess(""); } }

ISysUserService

public interface ISysUserService extends IService { void saveSysUser(); }

SysUserServiceImpl

@Service@Slf4jpublic class SysUserServiceImpl extends ServiceImpl implements ISysUserService { @Resourceprivate SysUserMapper sysUserMapper; /*** 支持主数据源的事务*/@DS("user_master")@Transactional(rollbackFor = Exception.class)@Overridepublic void saveSysUser() {SysUser sysUser = new SysUser().setUsername("yss013").setPassword("123456").setEmail("yss@013.com").setState(1).setRegisterSource(1).setCreateTime(new Date()); save(sysUser); System.out.println(1 / 0); save(sysUser); } }

结果： 支持主数据源的事务，如果把1/0去掉可以看到保存了俩条记录，不去掉则回滚都不保存；

3.4 商品库查询商品记录
GoodsController

@RestController@RequestMapping("/goods")public class GoodsController { @Resourceprivate IGoodsService iGoodsService; // http://localhost:8000/goods/selectGoods?gid=1@GetMapping("/selectGoods")public ResultVO selectGoods(Integer gid) {Goods goods = this.iGoodsService.selectGoods(gid); return ResultVO.getSuccess(null, goods); } }

IGoodsService

package com.yss.ds.demo.service; import com.baomidou.mybatisplus.extension.service.IService; import com.yss.ds.demo.entity.Goods; /** * * 商品表 服务类 *
* * @author qjwyss * @since 2020-09-02 */public interface IGoodsService extends IService { Goods selectGoods(int id); }

GoodsServiceImpl

package com.yss.ds.demo.service.impl; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yss.ds.demo.entity.Goods; import com.yss.ds.demo.mapper.GoodsMapper; import com.yss.ds.demo.service.IGoodsService; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.Date; /** * * 商品表 服务实现类 *
* * @author qjwyss * @since 2020-09-02 */@Servicepublic class GoodsServiceImpl extends ServiceImpl implements IGoodsService { @DS("goods")@Overridepublic Goods selectGoods(int id) {return this.getById(id); } }

结果

{"code":1,"data":{"id":1,"goodsName":"手机","goodsRemark":"小米手机","status":1,"createUser":"system","createTime":"2019-12-16T20:31:02.000+0000","updateUser":"system","updateTime":"2019-12-16T20:31:07.000+0000"}}

3.5 商品库新增商品记录
GoodsController

@RestController@RequestMapping("/goods")public class GoodsController { @Resourceprivate IGoodsService iGoodsService; // http://localhost:8000/goods/save@GetMapping("/save")public ResultVO saveGoods() {this.iGoodsService.saveGoods(); return ResultVO.getSuccess(""); } }

IGoodsService

public interface IGoodsService extends IService { void saveGoods(); }

GoodsServiceImpl： 只需要在service方法上用@DS("goods")注解标明该方法的数据源即可; 单裤数据源均支持事务；

@Servicepublic class GoodsServiceImpl extends ServiceImpl implements IGoodsService { /*** 商品库数据源也支持事务*/@DS("goods")@Transactional(rollbackFor = Exception.class)@Overridepublic void saveGoods() {Goods goods = new Goods().setGoodsName("商品名称A").setStatus(1).setCreateTime(new Date()); this.save(goods); System.out.println(1/0); this.save(goods); } }

结果： 可以看到：如果去掉1/0，则保存俩条记录，如果加上，则俩条都不保存；

3.6 用户库商品库多数据源嵌套
SysUserController

@RestController@RequestMapping("/sysUser")public class SysUserController { @Resourceprivate ISysUserService iSysUserService; // http://localhost:8000/sysUser/saveUserAndQueryGoods@GetMapping("/saveUserAndQueryGoods")public ResultVO saveUserAndQueryGoods() {this.iSysUserService.saveUserAndQueryGoods(); return ResultVO.getSuccess(""); } }

ISysUserService

public interface ISysUserService extends IService { void saveUserAndQueryGoods(); void saveSingleUser(); }

SysUserServiceImpl： 嵌套数据源必须有额外的外层方法，外层方法不要标明数据源，内层全部在service上标明各自的数据源；

@Service@Slf4jpublic class SysUserServiceImpl extends ServiceImpl implements ISysUserService { @Resourceprivate SysUserMapper sysUserMapper; @Resourceprivate IGoodsService iGoodsService; /*** 嵌套数据源的话最外层不要加数据源* 内层方法加各自的数据源 保证一个service只有一个数据源*/@Overridepublic void saveUserAndQueryGoods() {this.saveSingleUser(); Goods goods = this.iGoodsService.selectGoods(1); log.info("商品信息为：{}", JSONObject.toJSONString(goods)); } @DS("user_master")@Overridepublic void saveSingleUser() {SysUser sysUser = new SysUser().setUsername("yss013").setPassword("123456").setEmail("yss@013.com").setState(1).setRegisterSource(1).setCreateTime(new Date()); this.save(sysUser); }}

结果： 可以发现用户库先是添加了用户记录，并且查询到了商品库的商品信息；

四、总结 到此这篇关于Mybatis Plus整合多数据源和读写分离的文章就介绍到这了,更多相关Mybatis Plus多数据源读写分离内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

推荐阅读

• 

  基友是什么 基友是什么意思
• 

  老板煤气灶怎么调火力常见故障,以及处理方式？
• 

  戴尔Latitude7380笔记本电池续航短的原因是什么
• 

  班布尔善和康熙的关系
• 

  茶宠怎么选 选购茶宠的妙招
• 

  我要吃掉的你的胰脏是什么意思
• 

  显卡怎么降电压，显卡怎么降电压和频率
• 

  兼职对大学生来说弊端大还是益处大？
• 

  洗衣机的除霉味小妙招有哪些
• 

  华为mate30无线充电怎么用 华为mate30无线充电怎样用
• 

  农村的地还没征收能强拆房屋吗
• 

  新手怎么入门视频剪辑,视频剪辑会运用到什么功能
• 

  节瓜怎么吃好 推荐几款食疗方法
• 

  无尽之路
• 

  为什么有人说“强者不是能征服什么,而是看能承受什么”？
• 

  红色芍药花语是什么 芍药花的花语是什么啊
• 

  我国刑法中非法出售增值税专用发票罪规定量刑标准是什么
• 

  如何在手机上连接黑魂2服务器？ 黑魂2服务器怎么用手机
• 

  番茄煮熟皮就皱了是为什么
• 

  河海大学gis复试线，河海大学gis考研

• 由浅入深理解AOP
• 【译】20个更有效地使用谷歌搜索的技巧
• 关于QueryWrapper|关于QueryWrapper,实现MybatisPlus多表关联查询方式
• mybatisplus如何在xml的连表查询中使用queryWrapper
• mybatisplus|mybatisplus where QueryWrapper加括号嵌套查询方式
• MybatisPlus|MybatisPlus LambdaQueryWrapper使用int默认值的坑及解决
• MybatisPlus使用queryWrapper如何实现复杂查询
• iOS中的Block
• Linux下面如何查看tomcat已经使用多少线程
• 使用composer自动加载类文件