当前位置: 首页 > news >正文

Spring基于dynamic-datasource实现MySQL多数据源

目录

多数据源实现

引入依赖

yml配置文件

业务代码

案例演示


多数据源实现

引入依赖
<dependency><groupId>com.baomidou</groupId><artifactId>dynamic­datasource­spring­boot­starter</artifactId><version>3.5.0</version>
</dependency>
yml配置文件
spring:datasource:dynamic:#设置默认的数据源或者数据源组,默认值即为masterprimary: master#严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源strict: falsedatasource:master:url: jdbc:mysql://127.0.0.1:3306/datasource1?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&useSSL=falseusername: rootpassword: 123456initial-size: 1min-idle: 1max-active: 20test-on-borrow: truedriver-class-name: com.mysql.cj.jdbc.Driverslave_1:url: jdbc:mysql://127.0.0.1:3306/datasource2?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&useSSL=falseusername: rootpassword: 123456initial-size: 1min-idle: 1max-active: 20test-on-borrow: truedriver-class-name: com.mysql.cj.jdbc.Driver

配置主库和从库,指定默认主库为master数据源。

业务代码

控制层代码如下

@RestController
@RequestMapping("friend")
@Slf4j
public class FriendController {@Autowiredprivate FriendService friendService;@GetMapping(value = "select")public List<Friend> select(){return friendService.list();}@GetMapping(value = "insert")public void in(){Friend friend = new Friend();friend.setName("张三");friendService.save(friend);}@Autowiredprivate DataSource dataSource;@DeleteMapping("ds/del")public String remove(String name) {DynamicRoutingDataSource ds = (DynamicRoutingDataSource) dataSource;ds.removeDataSource(name);return "删除成功";}
}

 服务层代码如下

@Service
public class FriendImplService implements FriendService {@AutowiredFriendMapper friendMapper;@Override@DS("slave_1")  // 从库public List<Friend> list() {return friendMapper.list();}@Override@DS("master")@DSTransactionalpublic void save(Friend friend) {friendMapper.save(friend);}@DS("master")@DSTransactionalpublic void saveAll(){// 执行多数据源的操作}
}

dao层代码如下

public interface FriendMapper   {@Select("SELECT * FROM friend")List<Friend> list();@Insert("INSERT INTO  friend(`name`) VALUES (#{name})")void save(Friend friend);
}

 实体代码如下

@Data
public class Friend  {private Long id;private String name;}

       使用dynamic这种方式,可以比较简单的实现多数据库,只需要在配置数据源时指定数据源名称,在使用的时候通过@DS注解指定即可,也支持多数据源下的事务,通过@DSTransactional实现。

案例演示

当前数据库

执行insert请求,从数据源的数据写入了,主数据源没有数据。

执行select请求

http://www.lryc.cn/news/287245.html

相关文章:

  • JS高频面试题(下)
  • 单点登陆(SSO)基于CAS实现前后端分离的SSO系统开发「IDP发起」
  • 二叉树
  • 边缘计算:挑战与机遇的平衡艺术
  • Windows11 Copilot助手开启教程(免费GPT-4)
  • 【Golang入门教程】如何使用Goland创建并运行项目
  • 鸿蒙开发实战-手写文心一言AI对话APP
  • 鸿蒙常用UI效果及一些处理方式总结
  • dataGrip连接数据库mysql和intersystems的iris
  • 【51单片机】点亮第一个LED灯
  • ubuntu20.04 格式化 硬盘 扩展硬盘
  • openssl3.2/test/certs - 031 - purpose variants: clientAuth
  • ubuntu下docker卸载和重新安装
  • 搭建k8s集群实战(一)系统设置
  • go-carbon v2.3.6 发布,轻量级、语义化、对开发者友好的 golang 时间处理库
  • 力扣2859-计算k置位下标对应元素的和
  • [计算机提升] 切换(域)用户
  • 蓝桥杯练习题dfs与bfs
  • 软件游戏提示msvcp140.dll丢失的解决方法,全面分析msvcp140.dll文件
  • LandrayOA内存调优 / JAVA内存调优 / Tomcat web.xml 超时时间调优实战
  • 免费SSL数字证书申请,免费数字证书使用教程
  • 深入理解Flutter中的GlobalKey与LocalKey(ValueKey、ObjectKey、UniqueKey)及其使用方法
  • linux命令学习
  • 核桃的数量---蓝桥杯
  • 进程通信与socket编程实践之猜数字小游戏
  • AcWing 1241. 外卖店优先级(复杂模拟思路 + 代码详解)
  • 查询文件hash值
  • [docker] Docker资源管理
  • 不就业,纯兴趣,应该自学C#还是JAVA?
  • 【Go面试向】defer与time.sleep初探