(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210881087.2 (22)申请日 2022.07.26 (65)同一申请的已公布的文献号 申请公布号 CN 114936212 A (43)申请公布日 2022.08.23 (73)专利权人 北京安华金和科技有限公司 地址 100089 北京市海淀区中关村南大街 甲18号院1-4 号楼12层D座12 A01 (72)发明人 刘晓韬　李彦君　 (74)专利代理 机构 北京盛询知识产权代理有限 公司 11901 专利代理师 郭成文 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/23(2019.01)G06F 16/242(2019.01) G06F 16/27(2019.01) (56)对比文件 CN 114490554 A,202 2.05.13 CN 113779056 A,2021.12.10 CN 111061745 A,2020.04.24 CN 108536752 A,2018.09.14 CN 107766431 A,2018.0 3.06 US 11093477 B1,2021.08.17 郎大鹏.联网审计中增量数据处 理技术的研 究与应用. 《中国优秀硕士学位 论文全文数据库 信息科技 辑》 .2009,第I138- 588页. 审查员 陈雅萍 (54)发明名称 一种审计数据同步处 理方法和装置 (57)摘要 本申请公开了一种审计数据 同步处理方法 和装置， 该方法包括： 获取待提取的流水执行信 息； 从流水执行信息表中获取预定批次的流水执 行信息中最大时间戳， 其中， 每条流水执行信息 均对应一个时间戳； 从同步进度表中获取SQL模 板信息的最大时间戳、 会话信息的最大时间戳和 风险信息的最大时间戳； 将流水执行信息的最大 时间戳分别与SQL模板信息的最大时间戳、 会话 信息的最大时间戳和风险信息的最大时间戳进 行比较。 通过本申请解决了 现有技术中在流水执 行信息已经入库而其他三种数据尚未入库时进 行数据关联会导致出现错误的问题， 从而可以保 证流水执行信息与SQL模板信息、 会话信息和风 险信息的正确关联， 降低了出错 概率。 权利要求书2页 说明书7页 附图1页 CN 114936212 B 2022.09.23 CN 114936212 B 1.一种审计数据同步处 理方法， 其特 征在于， 包括： 获取待提取的流水执行信 息， 其中， 所述待提取的流水执行信 息为预定批次， 所述待提 取的流水 执行信息从流水 执行信息表中进行提取； 从所述流水执行信息表中获取所述预定批次的流水执行信息中最大时间戳， 其中， 每 条流水执行信息均对应一个时间戳， 该时间戳用于指示该流水 执行信息的发生时间； 从同步进度表中获取SQL模板信息的最大时间戳、 会话信息的最大时间戳和风险信息 的最大时间戳， 其中， 在一批次的SQL模板信息保存在SQL模板信息表之后在所述同步进度 表中记录该批次的SQL模板信息的最大时间戳， 在一批次的会话信息保存在会话信息表之 后在所述同步进度表中记录该批次的会话信息的最大时间戳， 在一批次的风险信息保存在 风险信息表之后在所述同步进度表中记录该批次的风险信息的最大时间戳； 将所述流水执行信息的最大时间戳分别与SQL模板信息的最大时间戳、 会话信息的最 大时间戳和风险信息的最大时间戳进行比较； 根据比较结果确定是否从所述流水执行信息表、 所述SQL模板信息表、 所述会话信息表 和所述风险信息表中提取信息； 其中， 在所述流水执行信息的最大时间戳均小于所述SQL模 板信息的最大时间戳、 会话信息的最大时间戳和风险信息的最大时间戳的情况下， 确定从 所述流水执行信息表、 所述SQL模板信息表、 所述会话信息表和所述风险信息表中提取信 息； 在所述流水执行信息的最大时间戳大于所述SQL模板信息的最大时间戳、 所述会话信息 的最大时间戳和所述风险信息的最大时间戳中的任意之一的情况下， 确定等待第二预定时 长再从同步进度表中获取SQL模板信息的最大时间戳、 会话信息的最大时间戳和风险信息 的最大时间戳并进行比较， 直到所述流水执行信息的最大时间戳均小于所述SQL模板信息 的最大时间戳、 会话信息的最大时间戳和风险信息的最大时间戳。 2.根据权利要求1所述的方法， 其特 征在于， 还 包括： 将从所述流水执行信息表中提取到的流水执行信息， 从所述SQL模板信息表中提取到 的SQL模板信息， 从所述会话信息表中提取的会话信息以及从所述风险信息表中提取到的 风险信息组合成审计数据。 3.根据权利要求1所述的方法， 其特征在于， 所述流水执行信息用来记录所审计的SQL 语句； 所述SQL模板信息用于对所述流水执行信息中所记录的每一条语句来进 行抽象， 对每 条SQL语句公共部分进行抽取， 将公共部分存储到SQL模板信息中， 将每条语句不同的部分 保存在所述流水执行信息中； 所述会话信息是数据库客户端登录到数据库使用的信息； 所 述风险信息是审计的语句对风险的命中情况以及风险级别 信息。 4.一种审计数据同步处 理装置， 其特 征在于， 包括： 第一获取模块， 用于获取待提取的流水执行信 息， 其中， 所述待提取的流水执行信 息为 预定批次， 所述待提取的流水 执行信息从流水 执行信息表中进行提取； 第二获取模块， 用于从所述流水执行信 息表中获取所述预定批次的流水执行信 息中最 大时间戳， 其中， 每条流水执行信息均对应一个时间戳， 该时间戳用于指示该流水执行信息 的发生时间； 第三获取模块， 用于从同步进度表中获取SQL模板信息的最大时间戳、 会话信息的最大 时间戳和风险信息的最大时间戳， 其中， 在一批次的SQL模板信息保存在SQL模板信息表之 后在所述同步进度表中记录该批次的SQL模板信息的最大时间戳， 在一批次的会话信息保权　利　要　求　书 1/2 页 2 CN 114936212 B 2存在会话信息表之后在所述同步进度 表中记录该批次的会话信息的最大时间戳， 在一批次 的风险信息保存在风险信息表之后在所述同步进度表中记录该批次的风险信息的最大时 间戳； 比较模块， 用于将所述流水执行信息的最大时间戳分别与SQL模板信息的最大时间戳、 会话信息的最大时间戳和风险信息的最大时间戳进行比较； 提取模块， 用于根据比较结果确定是否从所述流水执行信息表、 所述SQL模板信息表、 所述会话信息表和所述风险信息表中提取信息； 其中， 在所述流水执行信息的最大时间戳 均小于所述SQL模板信息的最大时间戳、 会话信息的最大时间戳和风险信息的最大时间戳 的情况下， 确定从所述流水执行信息表、 所述SQL模板信息表、 所述会话信息表和所述风险 信息表中提取信息； 在所述流水执行信息的最大时间戳大于所述SQL模板信息的最大时间 戳、 所述会话信息的最大时间戳和所述风险信息的最大时间戳中的任意之一的情况下， 确 定等待第二预定时长再从同步进度表中获取SQL模板信息的最大时间戳、 会话信息的最大 时间戳和风险信息的最大时间戳并进 行比较， 直到所述流水执行信息的最大时间戳均小于 所述SQL模板信息的最大时间戳、 会话信息的最大时间戳和风险信息的最大时间戳。 5.根据权利要求 4所述的装置， 其特 征在于， 还 包括： 组合模块， 用于将从所述流水执行信息表中提取到的流水执行信息， 从所述SQL模板信 息表中提取到的SQL模板信息， 从所述会话信息表中提取 的会话信息以及从所述风险信息 表中提取到的风险信息组合成审计数据。 6.根据权利要求4所述的装置， 其特征在于， 所述流水执行信息用来记录所审计的SQL 语句； 所述SQL模板信息用于对所述流水执行信息中所记录的每一条语句来进 行抽象， 对每 条SQL语句公共部分进行抽取， 将公共部分存储到SQL模板信息中， 将每条语句不同的部分 保存在所述流水执行信息中； 所述会话信息是数据库客户端登录到数据库使用的信息； 所 述风险信息是审计的语句对风险的命中情况以及风险级别 信息。 7.一种存储器， 用于存储软件， 其特征在于， 所述软件用于执行权利要求1至3 中任一项 所述的方法。 8.一种处理器， 用于运行软件， 其特征在于， 所述软件用于执行权利要求1至3 中任一项 所述的方法。权　利　要　求　书 2/2 页 3 CN 114936212 B 3