(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210851096.7 (22)申请日 2022.07.19 (71)申请人 福建科融世纪信息科技有限公司 地址 350100 福建省福州市闽侯县上街 镇 科技东路10号中青科研中心8层802室 (72)发明人 许劼　 (74)专利代理 机构 福州旭辰知识产权代理事务 所(普通合伙) 35233 专利代理师 程勇 (51)Int.Cl. G06F 16/9535(2019.01) G06F 16/9537(2019.01) G06F 16/23(2019.01) G06F 16/242(2019.01) G06F 16/2458(2019.01)H04L 67/02(2022.01) (54)发明名称 一种http请求到数据库的数据变更回溯查 询系统 (57)摘要 本发明提供了一种http请求到数据库的数 据变更回溯查询系统， 包括记录存储模块、 查询 变更模块和查找数据变更信息模块； 所述记录存 储模块， 即用户发出http请求， 进入服务器中发 出sql语句， 数据库接收到sql语句， 执行完毕后 推送给解析服务器， 将接收到的变更记录以及 spl语句的哈希值发送至消息队列服务器， 推送 至文档数据库保存； 所述查询变更模块， 即根据 业务条件， 搜索出数据库中的历史记录， 进行抽 取， 作为条件， 在文档数据库中查询历史变更记 录文档列表， 查询出http请求记录信息； 所述查 找数据变更信息模块， 即在步骤S2中根据 请求时 间范围， 使用spl语句哈希值， 搜索关联的变更记 录； 本发明能够实现根据http请求正向定位出 http请求对数据库记录的变更情况。 权利要求书1页 说明书4页 附图3页 CN 115203562 A 2022.10.18 CN 115203562 A 1.一种http请求到数据库的数据变更回溯查询系统， 其特征在于： 包括记录存储模块、 查询变更模块和查找数据变更信息模块； 所述记录存储模块， 即用户发出http请求， 进入服 务器中发出s ql语句， 数据库接收到 sql语句， 执行完 毕后推送给解析服务器， 将 接收到的变 更记录以及spl语句的哈希值 发送至消息队列服务器， 推送至文档数据库保存； 所述查询变 更模块， 即根据业务条件， 搜索出数据库中的历史记录， 进 行抽取， 作为条件， 在 文档数据库 中查询历史变更记录文档列表， 查询出http请求记录信息； 所述查找数据变更信息模块， 即 在步骤S2中根据请求时间范围， 使用spl语句哈希值， 搜索关联的变更记录， 从而实现根据 http请求正向定位出ht tp请求对数据库记录的变更情况。 2.根据权利要求1所述的一种http请求到数据库的数据变更回溯查询系统， 其特征在 于： 所述记录存 储模块具体包括以下步骤： 步骤S1、 用户在网页上操作,发起ht tp请求； 步骤S2、 ht tp请求进入web应用服 务器,被ht tp请求拦截器记录,追加到上 下文中； 步骤S3、 http请求进入web应用服务器中执行业务逻辑， 使用数据库驱动向数据库 服务 器发出sql语句,执行同时数据库 驱动过滤器将sql语句拦截,同时从上下文中提取出http 请求,一并发送至消息队列服 务器的Topic:T1； 步骤S4、 mysql数据库在接收到sql语句后,开始执行,执行完毕后生成binlog记录,并 且推送给bi nlog解析服 务器； 步骤S5、 binlog解析服务器将接收到的rowdata变更记录以及sql语句的哈希值发送至 消息队列服 务器的Topic:T2； 步骤S6、 消费者将消息队列服务器的数据拉取并推送至文档型数据库中持久化保存, 将Topic:T1映射存 储至文档数据库D1库中,将Topic:T2映射存 储至文档数据库D2库中。 3.根据权利要求2所述的一种http请求到数据库的数据变更回溯查询系统， 其特征在 于： 所述查询变更模块具体包括以下步骤： 步骤S10、 根据业务条件,搜索出mysql数据库中 需要查找历史的记录信息； 步骤S20、 抽取中步骤S10中的主键,结合需要查询历史变更的时 间段作为查询条件； 步骤S30、 将步骤S20中抽取的信息作为条件,在 文档数据库D2中查询历 史变更记录文档列表； 步骤S40、 将步骤S 30中查到的文档列表中的每个文档的s ql语句哈希 值作为关联查询条件,在D1库中查询出ht tp请求记录信息 。 4.根据权利要求2所述的一种http请求到数据库的数据变更回溯查询系统， 其特征在 于： 所述查找数据变更信息模块具体包括以下步骤： 步骤S 50、 在D1库中根据请求时间范围, 请求正文和请求头,将上述的条件进行组合构建出查询语句获取需要查找的http请求记 录； 步骤S60、 所述步骤S50中查询返回的每一条记录中都有一个sql语句哈希字段,使用记 录中所有的sql语句哈希值进行第三部查询操作； 步骤S70、 使用sql语句哈希值,在D2库中 搜索关联的变更记录,搜索到的结果即为 这个http请求接口导 致的。权　利　要　求　书 1/1 页 2 CN 115203562 A 2一种http请求到数据库的数据 变更回溯查询系统 技术领域 [0001]本发明涉及 计算机技术领域， 特别是一种http请求到数据库的数据变更回溯查询 系统。 背景技术 [0002]mysql数据库作为最流行的开源数据库之一,并没有提供针对数据库记录的回溯 功能,当业务层面上想要查询出某一条数据记录的历史变更记录,mysql无法提供支持,本 专利使用mysql的binlog日志,结合上http请求拦截器,数据库驱动过滤器,提供对mysql的 数据变更进行回溯的功能,以及溯源引发mysql记录变更的ht tp请求的功能。 发明内容 [0003]有鉴于此， 本 发明的目的是提供一种能够实现根据http请 求正向定位出http请 求 对数据库记录的变更情况或根据数据库记录变更逆向定位出触发数据记录变更 的http请 求以及sql语句的ht tp请求到数据库的数据变更回溯查询系统。 [0004]本发明采用以下方法来实现： 一种http请求到数据库的数据变更回溯查询系统， 包括记录存储模块、 查询变更模块和查找数据变更信息模块； 所述记录存储模块， 即用户发 出http请求， 进入服务器中发出s ql语句， 数据库接收到 sql语句， 执行完 毕后推送给解析服 务器， 将接收到的变更记录以及spl语句的哈希值 发送至消息队列服务器， 推送至文档数据 库保存； 所述查询变更模块， 即根据业务条件， 搜索出数据库中的历史记录， 进 行抽取， 作为 条件， 在文档数据库中查询历史变更记录文档列表， 查询出http请求记录信息； 所述查找数 据变更信息模块， 即在步骤S2中根据请求时间范围， 使用spl语句哈希值， 搜索关联的变更 记录， 从而实现根据ht tp请求正向定位出ht tp请求对数据库记录的变更情况。 [0005]进一步的， 所述记录存 储模块具体包括以下步骤： [0006]步骤S1、 用户在网页上操作,发起ht tp请求； [0007]步骤S2、 ht tp请求进入web应用服 务器,被ht tp请求拦截器记录,追加到上 下文中； [0008]步骤S3、 http请 求进入web应用服务器中执行业务逻辑， 使用数据库驱动向数据库 服务器发出sql语句,执行同时数据库驱动过滤器将sql语句拦截,同时从上下文中提取出 http请求,一并发送至消息队列服 务器的Topic:T1； [0009]步骤S4、 mysql数据库在接收到sql语句后,开始执行,执行完毕后生成binlog记 录,并且推送给bi nlog解析服 务器； [0010]步骤S5、 binlog解析服务器将接收到的rowdata变更记录以及sql语句的哈希值发 送至消息队列服 务器的Topic:T2； [0011]步骤S6、 消费者将消息队列服务器的数据拉取并推送至文档型数据库中持久化保 存,将Topic:T1映射存 储至文档数据库D1库中,将Topic:T2映射存 储至文档数据库D2库中。 [0012]进一步的， 所述查询变更模块具体包括以下步骤： 步骤S10、 根据业务条件,搜索出 mysql数据库中需要查找历史的记录信息； 步骤S20、 抽取中步骤S10中的主键,结合需要查说　明　书 1/4 页 3 CN 115203562 A 3