(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211186240.6 (22)申请日 2022.09.27 (71)申请人 中国船舶集团有限公司第七一 一研 究所 地址 201108 上海市闵行区华宁路31 11号 (72)发明人 郭巍　任深圳　周英　 (74)专利代理 机构 深圳紫藤知识产权代理有限 公司 44570 专利代理师 黄威 (51)Int.Cl. G06F 16/27(2019.01) (54)发明名称 数据库同步方法及分布式数据库系统 (57)摘要 本发明提供了一种数据库同步方法及分布 式数据库系统。 所述数据库同步方法包括数据获 取、 数据校验、 结果判断以及筛选同步等步骤。 所 述数据库同步方法采用了数据库对 数据库的1对 1对比校验的数据同步方式， 提高分布式数据库 系统中每个数据库的利用率， 同时减低了多数据 库系统中数据库之间的同步难度， 进而减小分布 式数据库系统的开发难度。 权利要求书2页 说明书7页 附图5页 CN 115510160 A 2022.12.23 CN 115510160 A 1.一种数据库同步方法， 其特 征在于， 包括以下步骤： 数据获取： 第一数据库接收并存 储由外部数据源所传输过来的数据； 数据校验： 同步发送模块和同步接收模块分别获取同一 时间段内所述第 一数据库和第 二数据库的历史数据信息， 并进行 校验； 结果判断： 所述同步发送模块依据 校验结果判断是否 需要同步； 其中， 当所述校验结果 一致时， 所述第一数据库和所述第二数据库无需同步； 当所述校验结果不一致时， 进入筛选 同步步骤； 筛选同步： 筛选出同一时间段中所述第一数据库和所述第二数据库中需要同步的数 据， 并将所筛 选出的数据发送至所述第二数据库中。 2.如权利要求1所述的数据库同步方法， 其特 征在于， 所述数据校验步骤中包括： 所述同步发送模块获取所述 时间段内所述第 一数据库中的第 一历史数据信 息， 并发送 至同步接收模块； 所述同步接收模块获取所述 时间段内所述第 二数据库中的第 二历史数据信 息， 并将所 述第二历史数据信息与所述第一历史数据信息进行 校验； 所述同步接收模块将所述校验结果发送至所述同步发送模块。 3.如权利要求1所述的数据库同步方法， 其特 征在于， 所述筛 选同步步骤中包括： 所述同步发送模块和所述同步接收模块分别将所述时间段均分为大小相同的多个第 一时间片， 并将每一个所述第一时间片作为 一第一存 储点； 所述同步发送模块和所述同步接收模块分别获取所述第一数据库和所述第二数据库 在每一所述第一存 储点中的数据量； 所述同步发送模块将所述第一数据库中每一所述第一存储点的数据量发送至所述同 步接收模块， 所述同步接收模块将所述第二数据库中每一所述第一存储点中的数据量大小 与所述第一数据库中对应的所述第一存储点的数据量进行对比， 并将每一个第一存储点的 对比结果发送至所述同步发送模块； 所述同步发送模块接收所述第 一存储点的对比结果， 并根据所述对比结果找出数据量 不一致的第一时间片， 所述第一时间片所对应的第一存 储点中含有需要 进行同步的数据。 4.如权利要求3所述的数据库同步方法， 其特 征在于， 所述筛 选同步步骤中还 包括： 所述同步发送模块和所述同步接收模块分别将所述第一时间片均分为大小相同的多 个第二时间片， 并将每一个所述第二时间片作为 一第二存 储点； 所述同步发送模块和所述同步接收模块分别获取所述第一数据库和所述第二数据库 在每一所述第二存 储点中的数据量； 所述同步发送模块将所述第一数据库中每一所述第二存储点的数据量发送至所述同 步接收模块， 所述同步接收模块将所述第二数据库中每一所述第二存储点中的数据量与所 述第一数据库中对应的所述第二存储点的数据量进行对比， 并将 每一个第二存储点的对比 结果发送至所述同步发送模块； 所述同步发送模块接收所述第 二存储点的对比结果， 并根据所述对比结果找出数据量 不一致的第二时间片， 所述第二时间片中所对应的数据即为需要 进行同步的数据； 所述同步发送模块将所述时间片中所对应的数据发送至所述同步接收模块。 5.如权利要求1所述的数据库同步方法， 其特征在于， 在所述数据校验步骤钱还包括获权　利　要　求　书 1/2 页 2 CN 115510160 A 2取时间段步骤， 所述获取时间段步骤 包括： 所述同步发送模块获取所述第 一数据库中最靠近运行时间的数据插入时间， 记为第 一 时间点； 将所述第一时间点向前偏移1分钟至 5分钟， 记为第二时间点； 将所述第二时间点向前偏移5 至60分钟， 记为第三时间点； 将所述第二时间点与所述第三时间点之前的时间区间作为所述时间段。 6.如权利要求1所述的数据库同步方法， 其特 征在于， 还 包括以下步骤： 改变所述时间段 所处的时间区间， 并再次执 行所述数据校验步骤； 其中， 第N次数据 校验步骤中所述时间段 区间中的最大值等于第 N+1次数据 校验步骤中 所述时间段区间中的最小值， N 为大于或等于1的正整数。 7.如权利要求6所述的数据库同步方法， 其特 征在于， 还 包括以下步骤： 当所述时间段中的最小值与所述第一 时间点间隔24小时及24小时以上时， 扩大单次时 间段的区间范围， 所述区间范围修改为24小时或24小时以上。 8.如权利要求1所述的数据库同步方法， 其特征在于， 所述同步发送模块和所述同步接 收模块之 间通过网络长连接 建立通讯， 且所述同步发送模块和所述同步接收模块之 间所传 输的信息在发出 前预先通过lz4压缩算法进行 数据压缩。 9.一种分布式数据库系统， 其特征在于， 使用如权利要求1 ‑8中任意一项所述的数据库 同步方法进行 数据的同步； 所述分布式数据库系统包括： 至少一第一数据库、 至少一第二数据库、 至少一同步发送模块和至少一同步接收模块； 所述同步发送模块分别与所述第一数据库和所述同步接收模块 通信连接； 所述同步接收模块分别与所述第二数据库和所述同步发送模块 通信连接； 所述第一数据库和所述第二数据库通过所述同步发送模块和所述同步接收模块试实 现数据筛 选以及同步。 10.如权利要求9所述的分布式数据库系统， 其特征在于， 所述第一数据库和所述第二 数据库均设有一数据输入模块和一数据输出模块， 所述数据输入模块用于将数据输入所述 第一数据库或所述第二数据库中， 所述数据输出模块用于将调出所述第一数据库或所述第 二数据库中的数据； 所述分布式数据库系统还 包括： 至少一数据查询模块， 所述数据查询模块与所述第 一数据库的数据输出模块或所述第 二数据库的数据输出模块 通信连接； 日志模块， 通过 添加标志位的方式记录所述分布式数据库系统的运行信息 。权　利　要　求　书 2/2 页 3 CN 115510160 A 3