(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211045457.5 (22)申请日 2022.08.30 (71)申请人 昆仑数智科技有限责任公司 地址 100007 北京市东城区青龙胡同1号歌 华大厦15 01室 申请人 中国石油天然气集团有限公司 (72)发明人 崔雪征　靳贞珍　元红萍　朱明新　 张金龙　李娟　贾小龙　王成刚　 (74)专利代理 机构 北京三高永信知识产权代理 有限责任公司 1 1138 专利代理师 董亚军 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/18(2019.01) G06F 16/242(2019.01)G06F 16/2455(2019.01) G06F 16/23(2019.01) (54)发明名称 数据库同步方法、 装置、 电子设备及存储介 质 (57)摘要 本公开提供了一种数据库同步方法、 装置、 电子设备及存储介质， 属于互联网技术领域。 所 述方法包括： 基于源数据库中第一数据表的日志 和目标数据库中第二数据表， 确定第一数据表对 应的有效SQL语句， 第一数据表和第二数据的表 名称相同； 基于有效SQL语句对应的操作类型， 采 用不同方式， 缓存有效SQL语句的主键； 当达到 预 设时间， 基于有效SQL语句的主键， 按照有效SQL 语句对应的操作类型， 对第二数据表中数据进行 同步。 本公开基于有效SQL语句的主键， 对第二数 据表中数据进行同步， 即便有效SQL语句中的字 段存在缺失， 也能够实现不同数据库的数据同 步。 权利要求书2页 说明书10页 附图3页 CN 115470294 A 2022.12.13 CN 115470294 A 1.一种数据库同步方法， 其特 征在于， 所述方法包括： 基于源数据库中第 一数据表的日志和目标数据库中第 二数据表， 确定所述第 一数据表 对应的有效结构化 查询语言SQ L语句， 所述第一数据表和所述第二数据的表名称相同； 基于所述有效SQ L语句对应的操作类型， 采用不同方式， 缓存所述有效SQ L语句的主键； 当达到预设时间， 基于所述有效SQL语句的主键， 按照所述有效SQL语句对应的操作类 型， 对所述第二数据表中数据进行同步。 2.根据权利要求1所述的方法， 其特征在于， 所述根据源数据库中第 一数据表的日志和 目标数据库中第二数据表， 确定所述第一数据表对应的有效SQ L语句， 包括： 从所述源数据库中第一数据表的日志中， 获取 所述第一数据表对应的SQ L语句； 对所述SQ L语句进行解析， 得到所述SQ L语句对应的主键； 将所述SQ L语句对应的主键与所述第二数据表中各个表字段名称进行比较； 当所述SQL语句对应的主键与所述第二数据表中任一表字段名称相同， 则将所述SQL语 句作为所述有效SQ L语句。 3.根据权利要求1所述的方法， 其特征在于， 所述基于所述有效SQL语句对应的操作类 型， 采用不同方式， 缓存所述有效SQ L语句的主键， 包括： 当所述有效SQL语句的操作类型为更新操作， 获取所述有效SQL语句的set语句部分和 where语句部分； 从所述where语句部分， 获取 所述有效SQ L语句的主键； 从所述set语句部分， 获取 所述有效SQ L语句的主键对应的最 新数据； 将所述有效SQL语句的主键对应的最新数据缓存在第一数据字典中， 并将所述有效SQL 语句的主键缓存在第二数据字典中。 4.根据权利要求3所述的方法， 其特征在于， 所述当达到预设时间， 基于所述有效SQL语 句的主键， 按照所述有效SQL语句对应的操作类型， 对所述第二数据表中数据进行同步， 包 括： 当达到预设时间， 将所述第二数据字典中缓存的所述有效SQL语句的主键拼接成SQL查 询语句； 基于所述SQL查询语句， 从所述第二数据表中， 查询所述有效SQL语句的主键对应的数 据； 将所述有效SQ L语句的主键对应的数据缓存到所述第二数据字典中； 采用所述第一数据字典中所述有效SQL语句的主键对应的最新数据， 对所述第二数据 字典中有效SQ L语句的主键对应的数据进行 更新； 按照所述有效SQL语句对应的操作类型， 将所述第二数据字典中有效SQL语句的主键对 应的更新数据写入到所述第二数据表中。 5.根据权利要求1所述的方法， 其特征在于， 所述基于所述有效SQL语句对应的操作类 型， 采用不同方式， 缓存所述有效SQ L语句的主键， 包括： 当所述有效SQ L语句的操作类型为删除操作， 获取 所述有效SQ L语句的where语句部分； 从所述where语句部分， 获取 所述有效SQ L语句的主键； 将所述有效SQ L语句的主键缓存在第二数据字典中。 6.根据权利要求5所述的方法， 其特征在于， 所述当达到预设时间， 基于所述有效SQL语权　利　要　求　书 1/2 页 2 CN 115470294 A 2句的主键， 按照所述有效SQL语句对应的操作类型， 对所述第二数据表中数据进行同步， 包 括： 当达到预设时间， 将所述第二数据字典中缓存的所述有效SQL语句的主键拼接成SQL查 询语句； 基于所述SQL查询语句， 从所述第二数据表中， 查询所述有效SQL语句的主键对应的数 据； 按照所述有效SQL语句对应的操作类型， 将所述有效SQL语句的主键对应的数据从所述 第二数据表中删除。 7.根据权利要求1所述的方法， 其特征在于， 所述基于所述有效SQL语句对应的操作类 型， 采用不同方式， 缓存所述有效SQ L语句的主键， 包括： 当所述有效SQL语句的操作类型为插入操作， 获取所述有效SQL语句的主键及其对应的 最新数据； 将所述有效SQ L语句的主键对应的最 新数据缓存在所述第二数据表的数组中； 所述当达到预设时间， 基于所述有效SQL语句的主键， 按照所述有效SQL语句对应的操 作类型， 对所述第二数据表中数据进行同步， 包括： 当达到预设时间， 按照所述有效SQL语句对应的操作类型， 将所述数组中的数据写入到 所述第二数据表中。 8.一种数据库同步装置， 其特 征在于， 所述装置包括： 确定模块， 用于基于源数据库中第一数据表的日志和目标数据库中第二数据表， 确定 所述第一数据表对应的有效结构化查询语言SQL语句， 所述第一数据表和所述第二数据的 表名称相同； 缓存模块， 用于基于所述有效SQL语句对应的操作类型， 采用不同方式， 缓存所述有效 SQL语句的主键； 同步模块， 用于当达到预设时间， 基于所述有效SQL语句的主键， 按照所述有效SQL语句 对应的操作类型， 对所述第二数据表中数据进行同步。 9.一种电子设备， 其特征在于， 所述电子设备包括处理器和存储器， 所述存储器中存储 有至少一条程序代码， 所述至少一条程序代码由所述处理器加载并执行， 以实现如权利要 求1至7中任一项所述的数据库同步方法。 10.一种计算机可读存储介质， 其特征在于， 所述存储介质中存储有至少一条程序代 码， 所述至少一条程序代码由处理器加载并执行， 以实现如权利要求1至7中任一项所述的 数据库同步方法。权　利　要　求　书 2/2 页 3 CN 115470294 A 3