第五章：Sharding-JDBC 自定义分片算法

Sharding-JDBC 自定义分片算法

自定义分片算法
- Sharding提供了以下4种算法接口
  - PreciseShardingAlgorithm
  - RangeShardingAlgorithm
  - HintShardingAlgorithm
  - ComplexKeysShardingAlgorithm

自定义分片算法实例

演示自定义PreciseShardingAlgorithm的使用
自定义算法概述
- 表分片策略：
  - 分片键：order_id
  - 分片算法：以order_id为分片键，分片策略为order_id % 2 + 1
    - order_id为偶数，插入t_order_1
    - order_id为奇数，插入t_order_2
- 编写自定义的实现类：MyPreciseShardingAlgorithm，实现PreciseShardingAlgorithm接口
- 将自定义实现类配置到application.properties
- 测试自定义实现类

步骤流程

编写自定义的实现类

public class MyPreciseShardingAlgorithm implements PreciseShardingAlgorithm<Long> {private static final Logger LOGGER = LoggerFactory.getLogger(MyPreciseShardingAlgorithm.class);@Overridepublic String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Long> shardingValue) {LOGGER.info("collection:" + JacksonUtil.writeValueAsString(availableTargetNames) + ",preciseShardingValue:" + JacksonUtil.writeValueAsString(shardingValue));//availableTargetNames: t_order_1,t_order_2//shardingValue: {"logicTableName":"t_order","columnName":"order_id","value":396416249350848512}//collection:["t_order_1","t_order_2"],preciseShardingValue:{"logicTableName":"t_order","columnName":"order_id","value":396416249350848512}//name为两张订单表 t_order_1 和 t_order_2for (String name : availableTargetNames) {//订单号取模加1 与 订单表t_order_1 和 t_order_2的尾号做比对，如相等，就直接返回t_order_1 或 t_order_2if (name.endsWith(String.valueOf(shardingValue.getValue() % 2 + 1))) {LOGGER.info("return name: " + name);return name;}}return null;}
}

配置自定义算法

# 指定 t_order表的分片策略，分片策略包括分片键和分片算法
spring.shardingsphere.sharding.tables.t_order.table-strategy.standard.sharding-column = order_id
spring.shardingsphere.sharding.tables.t_order.table-strategy.standard.precise-algorithm-class-name = com.shair.sharding.MyPreciseShardingAlgorithm

编写自定义的实现类

@RunWith(SpringRunner.class)
@SpringBootTest
class ApplicationTests {@Autowiredprivate OrderDao orderDao;@Testpublic void testInsertOrder() {for (int i = 0; i < 10; i++) {Order order = new Order();order.setPrice(new BigDecimal((i + 1) * 5));order.setUserId(1L);order.setStatus("SUCCESS");orderDao.insert(order);}}
}

日志

com.shair.sharding.MyPreciseShardingAlgorithm - collection:["t_order_1","t_order_2"],preciseShardingValue:{"logicTableName":"t_order","columnName":"order_id","value":396416249178882048}
com.shair.sharding.MyPreciseShardingAlgorithm - return name: t_order_1
ShardingSphere-SQL - Actual SQL: m2 ::: INSERT INTO t_order_1 (price, user_id, status, order_id) VALUES (?, ?, ?, ?) ::: [10, 1, SUCCESS, 396416249178882048]

通过日志可以发现：
- order_id为奇数的被插入到 t_order_2表
- order_id为偶数的被插入到 t_order_1表

第五章：Sharding-JDBC 自定义分片算法相关推荐

ShardingSphere笔记（三）：自定义分片算法 — 按月分表·真·自动建表
ShardingSphere笔记(二):自定义分片算法 - 按月分表·真·自动建表文章目录 ShardingSphere笔记(二):自定义分片算法 - 按月分表·真·自动建表一. 前言二. Sp ...
Sharding JDBC(四) 分片策略一：标准分片策略StandardShardingStrategy
目录一.标准分片策略StandardShardingStrategy 二.StandardShardingStrategy配置实现分库分表最核心的两点SQL 路由 . SQL 改写 applic ...
sharding jdbc 的雪花算法中的属性worker.id和max.vibration.offset
雪花算法生成的id总共64位8个字节,结构如下: 符号位时间位工作机器标识位序列位 1位(固定位0) 41位 10位 12位 worker.id sharding jdbc 4.1.1使用雪花 ...
《无人驾驶车辆模型预测控制》（第2版）第五章主动转向详细学习——算法部分（非线性系统线性化）
一.状态轨迹的线性化方法 1.理解: 第四章的期望轨迹给出了路径上每个点的状态信息(包括状态量和控制量),这类轨迹比较规则,比如直线.圆等,因此其控制量也容易得到,而对于"期望轨迹无法给出所 ...
【.NET Core项目实战-统一认证平台】第五章网关篇-自定义缓存Redis
上篇文章[.NET Core项目实战-统一认证平台]第四章网关篇-数据库存储配置(2)我们介绍了2种网关配置信息更新的方法和扩展Mysql存储,本篇我们将介绍如何使用Redis来实现网关的所有缓存功 ...
WCF 第五章行为实现自定义行为
自定义行为可以在WCF创建运行时和消息处理管道时让你在重要的地方插入代码.行为可以添加到代码中,通过属性或配置文件手动实现服务描述.在所有的情况中,代码可以做一些辅助动作,比如在一个目录中寻找信息或者 ...
第十五章：垃圾回收相关算法
标记阶段:引用计数算法循环引用举例小结标记阶段:可达性分析算法概念思路 GC Roots可以是哪些? 总结小技巧注意对象的finalization机制注意生存还是死亡? 具体过程 ...
第五章：创建自定义绑定
你可以创建自己的自定义绑定 – 没有必要非要使用内嵌的绑定(像click,value等).你可以你封装复杂的逻辑或行为,自定义很容易使用和重用的绑定.例如,你可以在form表单里自定义像grid,ta ...
Sharding JDBC分片和读写分离详解
目录 Sharding Sphere简介开始使用Sharding JDBC 数据分片简单示例 Spring Boot示例代码分析属性分析绑定表和广播表真实表绑定表广播表 Shardin ...

第五章：Sharding-JDBC 自定义分片算法

Sharding-JDBC 自定义分片算法

第五章：Sharding-JDBC 自定义分片算法相关推荐

最新文章

热门文章