(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210663786.X (22)申请日 2022.06.13 (71)申请人 中国科学院空天信息创新研究院 地址 100190 北京市海淀区北四环西路19 号 (72)发明人 刘璐娇　吴业炜　孙晓瑶　吴梦超　 (74)专利代理 机构 中科专利商标代理有限责任 公司 11021 专利代理师 任岩 (51)Int.Cl. G06F 16/27(2019.01) G06F 9/445(2018.01) (54)发明名称 异地数据库同步方法、 装置、 设备及 介质 (57)摘要 一种异地数据库同步方法， 应用于异地部署 系统， 异地部署系统包括至少一个数据管理总系 统和多个异地分系统， 包括： 通过部署于各个异 地分系统上的收集服务 以预设的频率并按照预 设同步条件执行同步任务， 生成数据信息文件， 同步任务包括采集并封装数据， 数据信息文件为 SQL文件； 将同步条件和数据信息文件打包为第 一数据文件包， 发送给数据管理总系统， 数据信 息文件包的文件名 称中包括本次数据采集的时 间标志和任务单号； 当数据管 理总系统接收到第 一数据文件包时， 调用部署于数据管理总系统的 同步服务解析第一数据文件包， 在判定时间标志 和任务单号符合预设条件后， 根据同步条件和数 据信息文件 更新数据库。 同步频率和内容可由数 据管理总 系统异地配 置。 权利要求书2页 说明书11页 附图5页 CN 115098587 A 2022.09.23 CN 115098587 A 1.一种异地数据库同步方法， 应用于异地部署系统， 所述异地部署系统包括至少一个 数据管理总 系统和多个异地分系统， 其特 征在于， 包括： 通过部署于各个所述异地分系统上的收集服务以预设的频率并按照预设同步条件执 行同步任务， 生 成数据信息文件， 所述同步任务包括根据同步条件采集并封装数据， 所述数 据信息文件为SQ L文件； 将所述同步条件和所述数据信 息文件打包为第 一数据文件包， 发送给所述数据 管理总 系统， 所述第一数据文件 包的文件名称中包括本次数据采集的时间标志和任务单号； 当所述数据管理总系统接收到所述第 一数据文件包时， 调用部署于所述数据 管理总系 统的同步服务解析所述第一数据文件包， 在判定所述时间标志和所述任务单号符合预设条 件后， 根据所述同步条件和所述数据信息文件更新数据库。 2.根据权利要求1所述的方法， 其特征在于， 当所述数据 管理总系统接收到所述第 一数 据文件包时， 调用部署于所述数据管理总系统的同步服务解析所述第一数据文件包， 在判 定所述时间标志和所述任务单号符合预设条件后， 根据所述同步条件和所述数据信息文件 更新数据库包括： 当所述数据管理总系统接收到所述第 一数据文件包后， 调用所述同步服务从所述第 一 数据文件 包的文件名中解析 出所述时间标志和所述任务单号； 根据任务单号， 查询所述同步服务的最新时间标志， 判断是否已接收过与所述任务单 号相同且时间标志早于当前 所述时间标志的数据文件 包； 若存在与所述任务单号相同且时间标志早于当前所述 时间标志的数据文件包， 则解析 所述第一数据文件 包以获取 所述同步条件和数据信息文件， 以更新所述数据库； 若存在与所述任务单号相同且时间标志晚于当前所述 时间标志的数据文件包， 则放弃 所述第一数据文件 包。 3.根据权利要求1所述的方法， 其特征在于， 所述同步条件包括数据库标志、 数据库表 名和数据采集条件， 所述数据采集条件包括删除条件， 所述根据所述同步条件和所述数据 信息文件更新数据库包括： 根据所述数据库标志查找数据库连接信息， 以连接对应的数据库； 将所述数据库表名和所述数据采集条件传递给预设的删除脚本， 以删除所述数据库中 对应的数据库表中与所述删除条件相关的数据； 完成数据删除后， 将所述数据信息文件中包括的数据插入所述数据库表， 完成数据同 步。 4.根据权利要求1所述的方法， 其特征在于， 所述通过部署于各个所述异地分系统上的 收集服务以预设的频率并按照预设同步条件执 行同步任务， 生成数据信息文件 包括： 按照预设的频率调用所述收集服务的条件生成插件， 根据 预设的同步条件生成信 息描 述文件， 所述信息描述文件包括的数据库标志、 数据库表名 和数据采集条件， 其中， 所述条 件生成插 件根据所服 务的数据库类型封装； 调用所述收集服务的数据采集插件， 根据所述数据标志查找数据库连接信息， 以根据 所述数据库连接信息连接对应的数据库， 并根据所述数据采集条件采集所述数据库 表名对 应的数据库表中的数据， 生成所述数据信息文件。 5.根据权利要求1所述的方法， 其特征在于， 所述收集服务和所述同步服务采用插件式权　利　要　求　书 1/2 页 2 CN 115098587 A 2设计， 所述收集 服务和所述同步 服务的启动方法包括： 定时扫描所述收集服务和/或所述同步服务的XML配置文件， 启动 需要加载的插件， 并 计算所述插 件的MD5值； 比较所述插 件的当前MD5值和上一次MD5值， 若两者 不一样， 则重新启动所述插 件； 在重启所述插 件前， 确认所述异步分系统中没有正在执 行的同步任务； 若存在正在执 行的同步任务， 则在所述同步任务完成后重启所述插 件。 6.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 通过所述数据 管理总系统向各所述异地分系统下发同步任务， 所述同步任务包括所述 同步条件和数据同步频率； 通过所述数据管理总 系统向各 所述异地分系统下发所述收集 服务的更新插 件。 7.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 建立所述数据管理总 系统与各 所述异地分系统之间和各 所述异地分系统之间的通信； 当其中一个所述异地分系统与所述数据管理总系统之间通信故障时， 控制所述异地分 系统通过其它所述异地分系统转发所述数据文件 包。 8.一种异地数据库同步装置， 其特 征在于， 包括： 数据收集模块， 用于通过部署于各个所述异地分系统上的收集服务以的预设频率并按 照预设同步条件执行同步任务， 生成数据信息文件， 所述同步任务包括采集并封装数据， 所 述数据信息文件为SQ L文件； 数据转发模块， 用于将所述同步条件和所述数据信息文件打包为第一数据文件包， 发 送给所述数据管理总系统， 所述第一数据文件包的文件名称中包括本次数据采集的时间标 志和任务单号； 数据同步模块， 用于当所述数据管理总系统接收到所述第一数据文件包时， 启动部署 于所述数据管理总系统的同步服务解析所述第一数据文件包， 在判定所述时间标志和所述 任务单号符合预设条件后， 根据所述同步条件和所述数据信息文件更新数据库。 9.一种电子设备， 包括： 存储器， 处理器及存储在存储器上并可在处理器上运行的计算 机程序， 其特征在于， 所述处理器执行所述计算机程序时， 实现权利要求 1至7中的任一项 所 述异地数据库同步方法中的各个步骤。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时， 实现权利要求1至7中的任一项异地数据库同步方法中的各个步骤。权　利　要　求　书 2/2 页 3 CN 115098587 A 3