(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211051430.7 (22)申请日 2022.08.31 (71)申请人 武汉达梦数据库股份有限公司 地址 430000 湖北省武汉市东湖新 技术开 发区高新大道999号未来科技大厦C3 栋16-19层 (72)发明人 曾丽　赵家威　孙峰　彭青松　 (74)专利代理 机构 深圳市六加知识产权代理有 限公司 4 4372 专利代理师 向彬 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/21(2019.01) (54)发明名称 一种初始化全量数据和增量数据并行同步 方法与装置 (57)摘要 本发明提供一种初始化全量数据和增量数 据并行同步方法与装置， 在源端对目标端进行数 据迁移的过程中， 将同步表的初始化全量数据和 操作日志的增量数据进行并行发送， 并且在目标 端创建三个不同的分组， 一个分组用于缓存初始 化全量数据并进行同步， 另外两个 分组分别缓存 初始化全量数据完成同步以前迁移的增量数据， 和缓存初始化全量数据完成同步 以后迁移的增 量数据， 并在初始化全量数据完成同步以后再对 增量数据全部进行同步， 实现了增量数据与初始 化全量数据的并行同步。 权利要求书2页 说明书15页 附图3页 CN 115470295 A 2022.12.13 CN 115470295 A 1.一种初始化全量数据和 增量数据并行同步方法， 其特 征在于， 包括： 目标端创建第一分组、 第二分组和第三分组； 接收来自于源端的待同步表的初始化全量数据以及增量数据； 将所述初始化全量数据缓存至所述第 三分组， 以进行待同步表的初始化全量数据的同 步； 将第一增量数据缓存至所述第 一分组， 将第二增量数据缓存至所述第 二分组， 其中， 所 述第一增量数据包括在所述初始 化全量数据完成同步之后产生的增量数据， 所述第二增量 数据包括在所述待同步表的初始化全量数据完成同步以前产生的增量数据； 在完成待同步表的初始化全量数据的同步后， 对所述第 一分组和所述第 二分组中的增 量数据进行同步， 实现增量数据与初始化全量数据的并行同步。 2.根据权利要求1所述的初始化全量数据和增量数据并行同步方法， 其特征在于， 所述 对所述第一分组和所述第二分组中的增量数据进行同步包括： 对于所述第一分组中的增量数据， 在完成待 同步表的初始化全量数据的同步后， 并且 在接收到增量数据所对应的事务的提交操作后， 对相应的增量数据进行同步操作。 3.根据权利要求1所述的初始化全量数据和增量数据并行同步方法， 其特征在于， 所述 对所述第一分组和所述第二分组中的增量数据进行同步包括： 对于所述第二分组中的增量数据， 在所述待 同步表的初始化全量数据完成同步后， 判 断所述第二分组中是否存在从属于所述待同步表的第三增量数据； 如果在所述第 二分组中存在从属于所述待同步表的第 三增量数据， 则判断所述第 二分 组中是否存在所述第三增量数据所对应的事务的提交操作； 若所述第二分组中存在所述第 三增量数据 所对应的事务的提交操作， 则对所述第 三增 量数据进行同步操作。 4.根据权利要求3所述的初始化全量数据和增量数据并行同步方法， 其特征在于， 所述 判断所述第二分组中是否存在所述第三增量数据所对应的事务的提交操作之后还 包括： 若所述第二分组中不存在所述第 三增量数据 所对应的事务的提交操作， 则将所述第 三 增量数据迁移至所述第一分组中。 5.根据权利要求1所述的初始化全量数据和增量数据并行同步方法， 其特征在于， 所述 方法还包括： 在接收到事务的提交操作后， 判断所述第二分组中是否存在该事务所对应的增量数 据； 如果存在， 则将该事务的提交操作添加至所述第二分组中。 6.根据权利要求1～5任一所述的初始化全量数据和增量数据并行同步方法， 其特征在 于， 将接收来自于源端的待同步表的初始化全量数据以及增量数据包括： 对所述源端 进行查询， 将查询到的所述初始化全量数据迁移至所述目标端； 捕获所述源端的操作日志， 将 捕获到的所述增量数据同步迁移至所述目标端。 7.根据权利要求1～5任一所述的初始化全量数据和增量数据并行同步方法， 其特征在 于， 所述方法还 包括： 所述目标端接收到所述待同步表的初始化全量数据同步结束的操作消息后， 将所述待 同步表的状态标记为初始化全量数据同步完成。权　利　要　求　书 1/2 页 2 CN 115470295 A 28.根据权利要求7所述的初始化全量数据和增量数据并行同步方法， 其特征在于， 在所 述目标端接收来自源端的迁移数据的过程中， 所述目标端提取接收到的消息中的控制信 息， 根据所述控制信息得到事务的提交操作消息以及待同步表的初始化全量数据同步结束 的操作消息 。 9.一种初始化全量数据和增量数据并行同步装置， 其特征在于， 包括至少一个处理器， 以及， 与所述至少一个处理器通信连接的存储器； 其中， 所述存储器存储有可被所述至少一 个处理器执行的指 令， 所述指 令被所述处理器执行， 用于执行权利要求 1‑8任一所述的初始 化全量数据和 增量数据并行同步方法。 10.一种非易失性计算机存储介质， 其特征在于， 所述计算机存储介质存储有计算机可 执行指令， 该计算机可执行指 令被一个或多个处理器执行， 用于完成本发明权利要求 1‑8任 一项所述的初始化全量数据和 增量数据并行同步方法。权　利　要　求　书 2/2 页 3 CN 115470295 A 3