一、读写分离

1、application.properties 配置文件

在 application.properties 配置文件中进行

# 配置真实数据源
spring.shardingsphere.datasource.names=db1,db2
# 配置第1个数据源
spring.shardingsphere.datasource.db1.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.db1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.db1.url=jdbc:mysql://localhost:3306/sharding_db1?useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=GMT
spring.shardingsphere.datasource.db1.username=root
spring.shardingsphere.datasource.db1.password=123456
# 配置第2个数据源
spring.shardingsphere.datasource.db2.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.db2.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.db2.url=jdbc:mysql://localhost:3306/sharding_db2?useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=GMT
spring.shardingsphere.datasource.db2.username=root
spring.shardingsphere.datasource.db2.password=123456##配置主从逻辑数据源，读写分离规则， db1主库，db2从库
spring.shardingsphere.sharding.master-slave-rules.ds0.master-data-source-name=db1
spring.shardingsphere.sharding.master-slave-rules.ds0.slave-data-source-names[0]=db2
#基于读写分离的表分片
spring.shardingsphere.sharding.tables.course.actual-data-nodes=ds0.course_$->{1..2}# 指定表的主键生成策略
spring.shardingsphere.sharding.tables.course.key-generator.column=id
spring.shardingsphere.sharding.tables.course.key-generator.type=SNOWFLAKE
spring.shardingsphere.sharding.tables.course.key-generator.props.worker.id=1
#表策略
spring.shardingsphere.sharding.tables.course.table-strategy.inline.sharding-column=id
spring.shardingsphere.sharding.tables.course.table-strategy.inline.algorithm-expression=course_$->{id%2+1}# 打开shardingsphere的sql日志输出。
spring.shardingsphere.props.sql.show=true# 一个实体类对应两张表，覆盖
spring.main.allow-bean-definition-overriding=true

2、测试

1）保存

   @Testpublic void testSave() throws InterruptedException {for (int i = 0; i < 4; i++) {Course course = new Course();course.setGmtCreate(new Date());course.setName("java");course.setUserId(1001L + i);course.setStatus("1");TimeUnit.MILLISECONDS.sleep(50);int count = courseMapper.insert(course);System.out.println("id ->" + course.getId());}}

从日志中看到，保存操作的数据库都是主库（db1）。

2）查询

    @Testpublic void testIN() {QueryWrapper<Course> wrapper = new QueryWrapper<Course>();wrapper.in("id",1515577381737865217L, 1515492164109004802L, 1515576508269936641L);List<Course> courses = courseMapper.selectList(wrapper);System.out.println(courses.size());courses.forEach(course -> System.out.println(course));}

从日志中看到，查询操作的数据库都是从库（db2）。

因为 id=1515577381737865217记录在主库（db1）中。数据还没有同步到从库（db2），所以查不到。

– 求知若饥，虚心若愚。

ShardingSphere读写分离相关推荐

shardingsphere读写分离+分表【笔记】
shardingsphere读写分离+分表用到的框架:mybatis-plus.druid.shardingsphere-jdbc-spring-boot-starter 依赖(gradle配置,m ...
Springboot2.x +JPA 集成 Apache ShardingSphere 读写分离
分库分表背景: 数据库性能瓶颈:主要分为按照业务来划分或者按照数据量来划分. 拆分方式: 水平拆分(每个表的结构都一样):订单表数据量大,我们可以水平拆分 ,分成order表1.order表2.ord ...
读写分离怎么实现_项目中如何实现读写分离？怎么配置？
上篇文章中,在两个 windows 系统的电脑上安装了最新版 8.0.21 MySQL 数据库,并且配置了主从.MySQL如何配置读写分离? 主从复制的原理思想也很简单,就是从库不断地同步主库的改动, ...
【Spring Boot 实战】数据库千万级分库分表和读写分离实战
一. 前言前几天时间写了如何使用Sharding-JDBC进行分库分表和读写分离的例子,相信能够感受到Sharding-JDBC的强大了,而且使用配置都非常干净.官方支持的功能还很多功能分布式主键. ...
6、ShardingSphere 之读写分离
文章目录 1 读写分离原理 2 Mysql 配置主从复制 2.1 创建2个Mysql 数据库服务,并启动两个Mysql服务 2.2 配置Master库的/etc/my.cnf 2.3 配置Slave库 ...
ShardingSphere(七) 读写分离配置，实现分库读写操作
概述:本章通过介绍使用ShardingSphere实现数据库的读写分离操作.在实现读写分离之前,数据库的主从同步需要提前配置完成,主从同步实现不由Sharding提供.主从同步可参考上一章节<S ...
ShardingSphere JDBC 分库分表读写分离数据加密
简介在上篇文章中,在本地搭建了运行环境,本地来体验下ShardingSphere JDBC的三个功能:分库分表.读写分离.数据加密示例运行首先把概念先捋一捋,参考下面的文档: 数据分片读写分离 ...
shardingsphere之sharding-proxy读写分离学习笔记
shardingsphere之sharding-proxy读写分离学习笔记引言重要提示演示环境版本信息代码示例和参考读写分离简介主从复制主从复制的原理和流程 sharding-prox ...
Shardingsphere的分库分表+读写分离+分页条件查询
Shardingsphere的分库分表与读写分离导入依赖 <dependencies><dependency><groupId>org.springframewo ...

ShardingSphere读写分离

一、读写分离

1、application.properties 配置文件

2、测试

ShardingSphere读写分离相关推荐

最新文章

热门文章