利用shardingSphereJdbc实现根据主键id动态分库分表。后期就算再增加库和表。也不影响之前的业务逻辑

本文主要是介绍利用shardingSphereJdbc实现根据主键id动态分库分表。后期就算再增加库和表。也不影响之前的业务逻辑,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

如果你还不知道shardingSphereJdbc是什么。这段话有可能让你更清晰点

如果你想了解更多。请到官网 

概览 :: ShardingSphereicon-default.png?t=L9C2https://shardingsphere.apache.org/document/current/cn/overview/#shardingsphere-jdbc根据主键id动态分库分表实现思路:准备两个库:ds0,ds1。两个表:sys_log0,sys_log1

自定义分库分表算法。利用雪花算法+自己生成的库索引+特殊字符+自己生成的表索引。例如:4031342968806410001 ===》红色部分就是库索引+000+表索引。所以就是ds1库中sys_log1表.

所以不管你怎么增加库和表。这种算法是不影响之前的业务逻辑。都可以找到你的库和表。也可能有更好的实现方式。只是我还没有遇到。

1、接下来让我们一起实现这样的算法。先把maven依赖引进来。这是第一步要做的:

<sharding-jdbc.version>4.1.1</sharding-jdbc.version>
<dependency><groupId>org.apache.shardingsphere</groupId><artifactId>sharding-jdbc-spring-boot-starter</artifactId><version>${sharding-jdbc.version}</version>
</dependency>

2、然后配置分库分表规则:

分库配置:        

 这项的类是自己自定义分库的算法。

precise-algorithm-class-name: com.sharingsperejdbc.demo.sharding.CustomDBShardingAlgorithm

 

分表配置:

  这项的类是自己自定义分表的算法。

precise-algorithm-class-name: com.sharingsperejdbc.demo.sharding.CustomTableShardingAlgorithm

 

由于是根据主键id进行分库分表。所以我们也要自定义主键id.自动进行生成

红色框框中的type的定义要和你利用spi机制配置的名字相同 

1、首先需要在resources资源文件下。建立META-INF/services目录。然后创建文件名为:

org.apache.shardingsphere.spi.keygen.ShardingKeyGenerator的。

文件的内容:com.sharingsperejdbc.demo.sharding.KeyGenerator就是你自己定义生成主键的类

 

 

如果增加表和库了。需要对以下内容size和dbsize更改。具体是表的多少

 

 

 这个type一定要和刚刚说的在yml中一样。不然找不到会报错

 大致做完后,然后进行测试

 找到ds0库sys_log0表

 源码已开放。如果有需要的请自取https://gitee.com/eduction/shardingspherejdbc.git

 我结合了mybatisplus持久层。如果你自定义的生成主键的类。一直不 进generateKey方法。那就需要把实体类中主键id去掉。让shardingspherejdbc去处理主键

分布式主键生成类:

实体类: 

 以上内容只是代表个人观点。如果有更好的方式。可以私聊或者文章内评论。进行探讨哦!

 

这篇关于利用shardingSphereJdbc实现根据主键id动态分库分表。后期就算再增加库和表。也不影响之前的业务逻辑的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/320259

相关文章

golang1.23版本之前 Timer Reset方法无法正确使用

《golang1.23版本之前TimerReset方法无法正确使用》在Go1.23之前,使用`time.Reset`函数时需要先调用`Stop`并明确从timer的channel中抽取出东西,以避... 目录golang1.23 之前 Reset ​到底有什么问题golang1.23 之前到底应该如何正确的

C#实现系统信息监控与获取功能

《C#实现系统信息监控与获取功能》在C#开发的众多应用场景中,获取系统信息以及监控用户操作有着广泛的用途,比如在系统性能优化工具中,需要实时读取CPU、GPU资源信息,本文将详细介绍如何使用C#来实现... 目录前言一、C# 监控键盘1. 原理与实现思路2. 代码实现二、读取 CPU、GPU 资源信息1.

SpringBoot实现动态插拔的AOP的完整案例

《SpringBoot实现动态插拔的AOP的完整案例》在现代软件开发中,面向切面编程(AOP)是一种非常重要的技术,能够有效实现日志记录、安全控制、性能监控等横切关注点的分离,在传统的AOP实现中,切... 目录引言一、AOP 概述1.1 什么是 AOP1.2 AOP 的典型应用场景1.3 为什么需要动态插

Oracle查询优化之高效实现仅查询前10条记录的方法与实践

《Oracle查询优化之高效实现仅查询前10条记录的方法与实践》:本文主要介绍Oracle查询优化之高效实现仅查询前10条记录的相关资料,包括使用ROWNUM、ROW_NUMBER()函数、FET... 目录1. 使用 ROWNUM 查询2. 使用 ROW_NUMBER() 函数3. 使用 FETCH FI

Python脚本实现自动删除C盘临时文件夹

《Python脚本实现自动删除C盘临时文件夹》在日常使用电脑的过程中,临时文件夹往往会积累大量的无用数据,占用宝贵的磁盘空间,下面我们就来看看Python如何通过脚本实现自动删除C盘临时文件夹吧... 目录一、准备工作二、python脚本编写三、脚本解析四、运行脚本五、案例演示六、注意事项七、总结在日常使用

Java实现Excel与HTML互转

《Java实现Excel与HTML互转》Excel是一种电子表格格式,而HTM则是一种用于创建网页的标记语言,虽然两者在用途上存在差异,但有时我们需要将数据从一种格式转换为另一种格式,下面我们就来看看... Excel是一种电子表格格式,广泛用于数据处理和分析,而HTM则是一种用于创建网页的标记语言。虽然两

Java中Springboot集成Kafka实现消息发送和接收功能

《Java中Springboot集成Kafka实现消息发送和接收功能》Kafka是一个高吞吐量的分布式发布-订阅消息系统,主要用于处理大规模数据流,它由生产者、消费者、主题、分区和代理等组件构成,Ka... 目录一、Kafka 简介二、Kafka 功能三、POM依赖四、配置文件五、生产者六、消费者一、Kaf

使用Python实现在Word中添加或删除超链接

《使用Python实现在Word中添加或删除超链接》在Word文档中,超链接是一种将文本或图像连接到其他文档、网页或同一文档中不同部分的功能,本文将为大家介绍一下Python如何实现在Word中添加或... 在Word文档中,超链接是一种将文本或图像连接到其他文档、网页或同一文档中不同部分的功能。通过添加超

windos server2022里的DFS配置的实现

《windosserver2022里的DFS配置的实现》DFS是WindowsServer操作系统提供的一种功能,用于在多台服务器上集中管理共享文件夹和文件的分布式存储解决方案,本文就来介绍一下wi... 目录什么是DFS?优势:应用场景:DFS配置步骤什么是DFS?DFS指的是分布式文件系统(Distr

NFS实现多服务器文件的共享的方法步骤

《NFS实现多服务器文件的共享的方法步骤》NFS允许网络中的计算机之间共享资源,客户端可以透明地读写远端NFS服务器上的文件,本文就来介绍一下NFS实现多服务器文件的共享的方法步骤,感兴趣的可以了解一... 目录一、简介二、部署1、准备1、服务端和客户端:安装nfs-utils2、服务端:创建共享目录3、服