coldsmog开发笔记
JS 事件笔记
Ckeditor 上传WPS图片失败问题
Springboot
SpringBoot 统一异常处理
Springboot 引入外部jar包
Springboot 打成war包
Springboot 多环境配置
SpringBoot @Scope注解学习
Springboot 快速生成项目API文档
SpringCache 缓存
Spring jetcache 二级缓存
Springboot 按条件装配类
FastJson的JsonPath语法
正则表达式语法
Spring 路径匹配
Feign 基础数据操作
监控Feign调用metrics
Springboot feign的性能优化
Jackson 设置序列化属性
SpringBoot 集成 Spring Data Mongodb 操作 MongoDB
MongoDB 的一些注意事项
MongoDB 指令对比
Jackson 解析XML
Springboot Redis注册
SpringBoot RedisTemplate批量插入
Springboot 指标监控Micrometer
springboot validation 注解校验
springboot 引入配置
Springboot 静态文件处理
Springboot 导出csv文件
Springboot 事件驱动(发布/订阅模式)
Springboot 启动过程和扩展点
Springboot 优化停机上下线
Spring自动装配 - 干饭角度学习
Springboot ShardingJDBC
Springboot的重试
springboot 动态修改端口
Oracle
Oracle 中实现自增ID
Oracle 定时任务
Oracle 解锁临时表
Oracle 检查连接数
Oracle 表空间
Oracle 解释执行SQL
markdown作图(适用typora)
服务器压测
业务对象层和数据层
并发限流处理
中间件
Yarn的使用
Dubbo学习笔记-RPC扩展和本地Mock
Dubbo学习笔记-泛化实现进行mock
Redis缓存穿透,缓存击穿,缓存雪崩
Galera 集群说明
Pip 镜像
pip 使用
MySQL命令行
数据库缓存双写方案
Git相关操作
Redis 操作时间复杂度一览
nacos 杂记
mybatis 散记
shardingjdbc
一次线上事故排查发现的Caffeine缓存死锁问题
设计模式
重新讲讲单例模式和几种实现
更优雅地实现策略模式
Http-headers
Prometheus 杂散笔记
JAVA 散记
CompletableFuture
Gson、FastJson、Jackson、json-lib对比总结
jackson 时间的序列化踩坑
JVM
自定义注解
mysql类型和java类型 转换一览表
枚举维护一个Map<value, Enum>的映射
Java中String +、concat、StringBuilder、StringBuffer 性能对比
TraceId 使用
MySQL 多数据源处理
Mybatis-plus 流式查询
JAVA发送win 桌面通知
idea 启动项目失败非代码问题杂记
Lambda 简述
Arthas 使用笔记
一种链式更新数据的数据模式
Skywalking 新增中间件插件
Redission 使用
数据导出为图片
IDEA 的热重启
Netty 工具类
maven 插件
本文档使用 MrDoc 发布
-
+
首页
Springboot ShardingJDBC
# 快速入门 ## 引入依赖 ``` <dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-core</artifactId> <version>${latest.release.version}</version> </dependency> ``` ## 简单分片 ```yaml spring: shardingsphere: datasource: names: ds0, ds1 # 数据源名称,多个数据源用逗号分隔 ds0: # 第一个数据源配置 type: com.zaxxer.hikari.HikariDataSource # 使用 HikariCP 数据源 driver-class-name: com.mysql.cj.jdbc.Driver # 数据库驱动类名 jdbc-url: jdbc:mysql://localhost:3306/ds0 # 数据库 URL username: root # 数据库用户名 password: pass # 数据库密码 ds1: # 第二个数据源配置 type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://localhost:3306/ds1 username: root password: pass sharding: tables: user: # 表名,这里以 user 表为例 actual-data-nodes: ds$->{0..1}.user$->{0..1} # 实际的数据节点,格式为数据源名称.表名称,支持范围表达式 table-strategy: # 表分片策略 inline: # 内联分片策略 sharding-column: userid # 分片键 algorithm-expression: user$->{userid % 2} # 分片算法Groovy表达式,这里表示根据 userid 的值模 2 决定分配到哪个表 database-strategy: # 数据库分片策略 inline: sharding-column: userid # 分片键 algorithm-expression: ds$->{userid % 2} # 分片算法Groovy表达式,这里表示根据 userid 的值模 2 决定分配到哪个数据库 ``` ## 复杂分片(自定义分片) 1. 实现ShardingAlgorithm接口 ```java public class CustomShardingAlgorithm implements PreciseShardingAlgorithm<Integer> { /** * tableNames 对应分片库中所有分片表的集合 * shardingValue 为分片属性,其中 logicTableName 为逻辑表,columnName 分片健(字段),value 为从 SQL 中解析出的分片健的值 */ @Override public String doSharding(Collection<String> tableNames, PreciseShardingValue<Long> shardingValue) { for (String tableName : tableNames) { // TODO 实现自己的取模算法, String value = shardingValue.getValue() % tableNames.size() + ""; if (tableName.endsWith(value)) { return tableName; } } throw new IllegalArgumentException(); } } ``` 2. 修改配置 ```yaml spring: shardingsphere: sharding: tables: user: # 表名,这里以 user 表为例 actual-data-nodes: ds$->{0..1}.user$->{0..1} # 实际的数据节点,格式为数据源名称.表名称,支持范围表达式 actual-data-nodes: ds$->{0..1}.user$->{0..1} table-strategy: standard: # 标准模式 sharding-column: userid precise-algorithm-class-name: com.example.CustomShardingAlgorithm # 实现接口的全类名 database-strategy: inline: sharding-column: userid algorithm-expression: ds$->{type % 2} ```
寒烟濡雨
2024年4月26日 14:17
转发文档
收藏文档
上一篇
下一篇
手机扫码
复制链接
手机扫一扫转发分享
复制链接
关于 MrDoc
觅思文档MrDoc
是
州的先生
开发并开源的在线文档系统,其适合作为个人和小型团队的云笔记、文档和知识库管理工具。
如果觅思文档给你或你的团队带来了帮助,欢迎对作者进行一些打赏捐助,这将有力支持作者持续投入精力更新和维护觅思文档,感谢你的捐助!
>>>捐助鸣谢列表
微信
支付宝
QQ
PayPal
Markdown文件
分享
链接
类型
密码
更新密码