(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210911970.1 (22)申请日 2022.07.29 (71)申请人 天翼云科技有限公司 地址 100007 北京市东城区青龙胡同甲1 号、 3号2幢2层20 5-32室 (72)发明人 林佩航　任正国　关雨晗　 (74)专利代理 机构 北京三聚阳光知识产权代理 有限公司 1 1250 专利代理师 熊飞雪 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/2455(2019.01) G06F 16/242(2019.01) G06F 11/34(2006.01) (54)发明名称 数据库的数据同步方法及装置、 存储介质、 处理器 (57)摘要 本申请公开了一种数据库的数据 同步方法 及装置、 存储介质、 处理器。 该方法包括： 获取需 要进行数据同步的源数据库的待同步数据， 待同 步数据包括目标事件产生的数据； 对待同步数据 的目标事件进行拆 分， 得到第一事件产生的第一 数据， 第二事件产生的第二数据； 根据第一事件 和第二事件， 进行数据同步， 将待同步数据同步 到对应的目标数据库， 目标数据库与源数据库的 种类不同， 目标事件在不同种类的数据库中执行 的数据结构不同， 第一事件和第二事件在不同种 类的数据库中执行的数据结构相同。 解决了相关 技术中涉及到分布式数据库的数据同步， 需要将 日志进行归并排序聚合来实现， 导致操作性差， 部分情况 下无法同步的问题。 权利要求书2页 说明书10页 附图4页 CN 115357661 A 2022.11.18 CN 115357661 A 1.一种数据库的数据同步方法， 其特 征在于， 包括： 获取需要进行数据同步的源数据库的待 同步数据， 其中， 待 同步数据包括目标事件产 生的数据； 对所述待同步数据的目标事件进行拆分， 得到第 一数据和第 二数据， 其中， 所述第一数 据为第一事件产生的数据， 所述第二数据为第二事件产生的数据， 所述第一事件和所述第 二事件的叠加与所述目标事 件相同； 根据所述第一事件和所述第二事件， 进行数据同步， 将所述待 同步数据同步到对应的 目标数据库， 其中， 所述目标数据库与所述源数据库的种类不同， 所述目标事件在不同种类 的数据库中执行的数据结构不同， 所述第一事件和所述第二事件在不同种类的数据库中执 行的数据结构相同。 2.根据权利要求1所述的方法， 其特征在于， 根据所述第一事件和所述第二事件， 进行 数据同步， 将所述待同步数据同步到对应的目标 数据库包括： 根据所述源数据库和所述目标数据库的种类， 确定对所述第 一数据或所述第 二数据是 否进行修改； 在对所述第 一数据或所述第 二数据进行修改的情况下， 根据修改后的第 一数据或第 二 数据， 以及未修改的第二数据或第一数据， 将第一事件和所述第二事件输入到所述 目标数 据库， 以将所述待同步数据同步到所述目标 数据库； 和/或， 在对所述第 一数据或所述第 二数据未进行修改的情况下， 根据 所述第一数据或第 二数 据的执行属 性， 将第一事件和所述第二事件输入到所述 目标数据库， 以将所述待同步数据 同步到所述目标 数据库。 3.根据权利要求2所述的方法， 其特征在于， 在所述源数据库为分布式数据库， 所述目 标数据库为非分布式数据库的情况 下， 确定所述第一数据需要修改； 根据预设方式对所述第一数据进行修改； 根据修改后的第一数据， 以及未修改的第二数据， 将第一事件和所述第二事件输入到 所述目标 数据库， 以将所述待同步数据同步到所述目标 数据库。 4.根据权利要求2所述的方法， 其特征在于， 在所述源数据库为非分布式数据库， 所述 目标数据库为分布式数据库的情况 下， 确定所述第一数据或所述第二数据不需要修改； 根据所述第 一事件的和所述第 二事件的第 一执行属性， 将所述第 一事件和所述第 二事 件输入到所述目标 数据库， 以将所述待同步数据同步到所述目标 数据库。 5.根据权利要求3或4所述的方法， 其特 征在于， 所述方法还 包括： 对所述第二数据的属性 参数进行设置， 确定所述第二事 件的第二执 行属性； 根据所述第 二执行属性将所述第 一事件和所述第 二事件输入到所述目标数据库， 以将 所述待同步数据同步到所述目标 数据库。 6.根据权利要求5述的方法， 其特征在于， 所述目标事件为修改up date事件， 所述第一 事件为删除delete事 件， 所述第二事 件为插入insert事件。 7.根据权利要求6方法， 其特 征在于， 根据预设方式对所述第一数据进行修改包括： 对删除事件的语句数据中的查找条件中增加了分片键， 其中， 所述分片健用于标识数 据的存储位置和修改版本， 所述第一事件为删除delete事件的情况下， 所述第一数据为所权　利　要　求　书 1/2 页 2 CN 115357661 A 2述删除事 件的语句数据； 和/或， 第一执行属性为所述删除delete事件和所述插入insert事件执行入库至目标数据库 的属性； 和/或， 第二执行属性为所述插入insert事件在入库至目标数据库时采用不存在则 插入， 存在 则更新的执 行策略的属性。 8.一种数据库的数据同步装置， 其特 征在于， 包括： 获取模块， 用于获取需要进行数据同步的源数据库的待同步数据， 其中， 待同步数据包 括目标事 件产生的数据； 拆分模块， 用于对所述待同步数据的目标事件进行拆分， 得到第一数据和第 二数据， 其 中， 所述第一数据为第一事件产生的数据， 所述第二数据为第二事件产生的数据， 所述第一 事件和所述第二事 件的叠加与所述目标事 件相同； 同步模块， 用于根据 所述第一事件和所述第二事件， 进行数据同步， 将所述待同步数据 同步到对应的目标数据库， 其中， 所述目标数据库与所述源数据库的种类不同， 所述目标事 件在不同种类的数据库中执行的数据结构不同， 所述第一事件和所述第二事件在不同种类 的数据库中执 行的数据结构相同。 9.一种计算机可读存储介质， 其特征在于， 所述存储介质用于存储程序， 其中， 所述程 序执行权利要求1至7中任意 一项所述的数据库的数据同步方法。 10.一种电子设备， 其特征在于， 包括一个或多个处理器和存储器， 所述存储器用于存 储一个或多个程序， 其中， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所 述一个或多个处 理器实现权利要求1至7中任意 一项所述的数据库的数据同步方法。权　利　要　求　书 2/2 页 3 CN 115357661 A 3