(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210351925.5 (22)申请日 2022.04.02 (71)申请人 浪潮卓数 大数据产业发展 有限公司 地址 214002 江苏省无锡市无锡经济开发 区金融一街15号1101、 1102、 1103、 1104、 1105、 1106、 1107、 1108 (72)发明人 尹金刚　罗森　申传旺　李照川　 孙长杰　 (74)专利代理 机构 北京君慧知识产权代理事务 所(普通合伙) 11716 专利代理师 肖鹏 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 一种基于更新时间及 主键的数据同步方法、 设备及介质 (57)摘要 本申请公开了一种基于更新时间及主键的 数据同步方法、 设备及介质， 方法包括： 确认待执 行的数据同步任务， 数据同步任务为将目标数据 库内目标数据表中的数据与源数据库内源数据 表中的数据进行数据同步； 数据同步任务至少包 括数据删除同步任务以及数据更新同步任务； 获 取源数据表中的主键信息， 并根据主键信息在源 数据库中生成主键从表， 用于存储主键信息； 确 认预设的数据同步时间， 并根据数据同步时间， 对比源数据表中的主键信息以及主键从表中的 主键信息， 完成数据删除同步任务； 获取源数据 表中的数据更新时间字段， 并根据数据更新时间 字段以及数据同步时间， 确定数据同步周 期内， 在源数据表内的更新数据， 并根据更新数据， 完 成数据更新同步任务。 权利要求书2页 说明书7页 附图2页 CN 114741401 A 2022.07.12 CN 114741401 A 1.一种基于更新时间及主键的数据同步方法， 其特 征在于， 包括： 确认待执行的数据同步任务， 所述数据同步任务为将目标数据库内目标数据表中的数 据与源数据库内源数据表中的数据进 行数据同步； 所述数据同步任务至少包括数据删除同 步任务以及数据更新同步任务； 获取所述源数据表中的主键信 息， 并根据 所述主键信 息在所述源数据库中生成主键从 表， 用于存 储所述主键信息； 确认预设的数据同步时间， 并根据所述数据同步时间， 对比所述源数据表中的所述主 键信息以及所述主键从表中的所述主键信息， 完成所述数据删除 同步任务； 获取所述源数据表中的数据 更新时间字段， 并根据 所述数据更新 时间字段以及所述数 据同步时间， 确定数据同步周期内， 在所述源数据表内的更新数据， 并根据所述更新数据， 完成所述数据更新同步任务。 2.根据权利要求1所述的方法， 其特征在于， 所述根据所述数据同步时间， 对比所述源 数据表中的所述主键信息以及所述主键从表中的所述主键信息， 完成所述数据删除同步任 务， 具体包括： 通过对比所述源数据表中的所述主键信 息以及所述主键从表中的所述主键信 息， 确定 所述主键从表中的多余主键； 确定所述多余主键在所述目标 数据表中对应的多余数据； 将所述多余数据从所述目标 数据表中删除。 3.根据权利要求1所述的方法， 其特征在于， 所述根据所述更新数据， 完成所述数据更 新同步任务， 具体包括： 确定所述更新数据对应的所述源数据表内的部分主键信息； 在所述目标 数据表确定是否存在所述部分主键信息； 若存在， 则将所述目标 数据表内所述部分主键信息对应的数据更新 为所述更新数据； 若不存在， 则在所述目标 数据表内新增所述更新数据。 4.根据权利要求1所述的方法， 其特征在于， 所述确认待执行的数据同步任务之后方法 还包括： 获取所述源数据表名、 所述目标数据表名、 所述数据更新时间字段名、 所述主键从表名 以及所述同步周期； 创建同步启动表， 用于存储所述源数据表名、 所述目标数据表名、 所述数据更新时间字 段名、 所述主键从表名以及所述同步周期。 5.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 确认所述数据同步过程中需要进行字段处理 的待处理数据， 以及所述待处理数据对应 的处理方式； 创建同步处理表， 用于存储所述需要进行字段处理的待处理数据， 以及所述待处理数 据对应的处 理方式。 6.根据权利要求5所述的方法， 其特征在于， 所述确定数据同步周期内， 在所述源数据 表内的更新数据之后， 所述方法还 包括： 确定所述更新数据是否为所述同步处理表中的所述待处理数据， 若是， 则根据所述待 处理数据对应的所述处 理方式进行处 理。权　利　要　求　书 1/2 页 2 CN 114741401 A 27.根据权利要求1所述的方法， 其特征在于， 所述完成所述数据删除同步任务之后， 所 述方法还 包括： 获取所述源数据表中的主键信 息， 并根据 所述主键信 息在所述源数据库中更新所述主 键从表。 8.根据权利要求1所述的方法， 其特征在于， 所述数据更新 时间字段用于记录一条数据 新增或更新的时间。 9.一种基于更新时间及主键的数据同步设备， 其特 征在于， 包括： 至少一个处 理器； 以及， 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的指令， 所述指令被所述至少一个处 理器执行， 以使所述至少一个处 理器能够执 行： 确认待执行的数据同步任务， 所述数据同步任务为将目标数据库内目标数据表中的数 据与源数据库内源数据表中的数据进 行数据同步； 所述数据同步任务至少包括数据删除同 步任务以及数据更新同步任务； 获取所述源数据表中的主键信 息， 并根据 所述主键信 息在所述源数据库中生成主键从 表， 用于存 储所述主键信息； 确认预设的数据同步时间， 并根据所述数据同步时间， 对比所述源数据表中的所述主 键信息以及所述主键从表中的所述主键信息， 完成所述数据删除 同步任务； 获取所述源数据表中的数据 更新时间字段， 并根据 所述数据更新 时间字段以及所述数 据同步时间， 确定数据同步周期内， 在所述源数据表内的更新数据， 并根据所述更新数据， 完成所述数据更新同步任务。 10.一种非易失性计算机存储介质， 存储有计算机可执行指令， 其特征在于， 所述计算 机可执行指令设置为： 确认待执行的数据同步任务， 所述数据同步任务为将目标数据库内目标数据表中的数 据与源数据库内源数据表中的数据进 行数据同步； 所述数据同步任务至少包括数据删除同 步任务以及数据更新同步任务； 获取所述源数据表中的主键信 息， 并根据 所述主键信 息在所述源数据库中生成主键从 表， 用于存 储所述主键信息； 确认预设的数据同步时间， 并根据所述数据同步时间， 对比所述源数据表中的所述主 键信息以及所述主键从表中的所述主键信息， 完成所述数据删除 同步任务； 获取所述源数据表中的数据 更新时间字段， 并根据 所述数据更新 时间字段以及所述数 据同步时间， 确定数据同步周期内， 在所述源数据表内的更新数据， 并根据所述更新数据， 完成所述数据更新同步任务。权　利　要　求　书 2/2 页 3 CN 114741401 A 3