(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211152501.2 (22)申请日 2022.09.21 (71)申请人 深圳市星卡科技股份有限公司 地址 518129 广东省深圳市龙岗区坂田街 道岗头社区天安云谷产业园二期4栋 2606(在深圳市龙岗区坂田街道五和 大道5022 号亚莲好时达工业厂区厂房 三栋五至六楼设有生产经营场所从事 生产经营活动) (72)发明人 蒋永鑫　钟东杰　肖灵聪　 (51)Int.Cl. G06F 16/21(2019.01) G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 一种数据系统的动态分库方法及其装置 (57)摘要 本发明提供一种数据系统的动态分库方法 及其装置， 包括根据事件溯源模式将老集群的数 据同步至新集群， 判断数据是否同步完成， 若是， 则向协调者发送数据同步完成消息， 协调者根据 数据同步完成消息向老集群发送分库命令， 执行 分库命令并更新老集群和新集群的配置， 判断老 集群和新集群是否完成分库， 若是， 则将结果分 别反馈至协调者， 本发明在对数据库进行分库， 分担数据库压力的同时， 能够减少由于数据库分 库导致的系统停机时间较长， 使得整个 分库过程 不会对业务系统造成影响， 降低业 务损失。 权利要求书2页 说明书7页 附图4页 CN 115525626 A 2022.12.27 CN 115525626 A 1.一种数据系统的动态分库方法， 其特 征在于， 包括以下步骤： 根据事件溯源模式将老集群的数据同步至新 集群； 判断所述数据是否同步完成； 若是， 则向所述协调者发送数据同步完成消息， 所述协调者根据所述数据同步完成消 息向所述老集群发送分库命令； 执行所述分库命令并更新所述老集群和所述 新集群的配置； 判断所述老集群和所述 新集群是否 完成分库； 若是， 则将结果分别反馈 至所述协调者。 2.根据权利要求1所述的数据系统 的动态分库 方法， 其特征在于， 所述根据事件溯源模 式将老集群的数据同步至新 集群的步骤中， 包括： 向所述新集群发送同步数据命令； 通过从老集群中获取 快照文件， 以得到时间戳。 3.根据权利要求2所述的数据系统 的动态分库 方法， 其特征在于， 所述判断所述数据 是 否同步完成的步骤中， 包括： 将所述时间戳与本地时间进行对比， 以得到时间差； 当所述时间差在区间1s ‑9s内时， 则判定所述数据同步完成。 4.根据权利要求1所述的数据系统 的动态分库 方法， 其特征在于， 所述执行所述分库命 令并更新所述老集群和所述 新集群的配置的步骤中， 包括： 将所述分库命令插 入所述老集群的命令队列中； 通过共识算法将所述分库命令发送至第一自动机； 通过所述第 一自动机执行所述分库命令， 并得到第 一输出程序和第二输出程序， 其中， 所述第一输出程序为不对非属类消息进行 处理， 所述第二输出程序为将分库完成消息发送 至所述协调者； 将所述分库完成消息存 储至本地数据库。 5.根据权利要求4所述的数据系统 的动态分库 方法， 其特征在于， 所述将所述分库完成 消息存储至本地数据库的步骤之后， 包括： 判断所述老集群是否 接收到所述非属类消息； 若是， 则发送错 误状态信息和重 定向提示至用户端， 以得到老集群位置 。 6.根据权利要求5所述的数据系统 的动态分库 方法， 其特征在于， 所述执行所述分库命 令并更新所述 新集群的配置的步骤中， 包括： 通过第二自动机执行所述分库命令， 并得到第 一处理程序和第二处理程序， 其中， 所述 第一处理程序为将所属类消息进行处理， 并将非属类消息发送至所述用户端， 所述第二处 理程序为将分库完成消息发送至所述协调者； 对所述本地数据库进行 更新。 7.根据权利要求6所述的数据系统 的动态分库 方法， 其特征在于， 所述对所述本地数据 库进行更新的步骤之后， 包括： 判断所述 新集群是否 接收到所述非属类消息； 若是， 则发送错 误状态信息和重 定向提示至所述用户端， 以得到新 集群位置 。 8.根据权利要求1所述的数据系统的动态分库方法， 其特征在于， 所述若是， 则将结果权　利　要　求　书 1/2 页 2 CN 115525626 A 2分别反馈 至所述协调者的步骤之后， 还 包括： 对所述分库命令进行分析以得到分库信息， 其中， 所述分库信息包括 新库数据； 将所述分库信息发送至服 务端， 以得到新库位置 。 9.一种数据系统的动态分库装置， 其特 征在于， 包括： 数据同步模块， 用于根据事 件溯源模式将老集群的数据同步至新 集群； 第一判断模块， 用于判断所述数据是否同步完成； 第一传输模块， 用于则向所述协调者发送数据同步完成消息， 所述协调者根据所述数 据同步完成消息向所述老集群发送分库命令； 执行模块， 用于执 行所述分库命令并更新所述老集群和所述 新集群的配置； 第二判断模块， 用于判断所述老集群和所述 新集群是否 完成分库； 第一反馈模块， 用于若是， 则将结果分别反馈 至所述协调者。权　利　要　求　书 2/2 页 3 CN 115525626 A 3