利索能及
我要发布
收藏
专利号: 2023103886653
申请人: 山东捷瑞数字科技股份有限公司
专利类型:发明专利
专利状态:已下证
更新日期:2026-09-16
缴费截止日期: 暂无
联系人

摘要:

权利要求书:

1.一种MYSQL数据库回档云平台,其特征在于,包括:MySQL数据库、二进制读取应用Maxwell、消息队列Kafka、流计算搜索引擎ElaticSearch以及SQL回档模块;

所述MySQL数据库生成并存储二进制日志文件binlog;

所述二进制读取应用Maxwell将二进制日志文件binlog解析为json格式的数据,并将json格式的数据发送到所述消息队列Kafka;

所述消息队列Kafka将json格式的数据同步到流计算搜索引擎ElaticSearch中,并存储为原始数据;

所述SQL回档模块将流计算搜索引擎ElaticSearch中json格式的数据进行解析,得到SQL指令集,并根据SQL指令集进行SQL回档;所述SQL指令集包括:DataBase、Table、type、timestamp、pos、执行时间、还原时间、偏移量、执行数据以及旧数据;所述SQL回档模块包括:数据解析单元、数据查找单元、数据回档单元以及数据计算单元;

所述数据解析单元用于对json格式的数据进行解析,确定执行SQL对应的SQL指令集,并将SQL指令集中的数据按type进行反向推导,得到执行SQL,并再次对执行SQL逆向推导得到回档SQL;所述反向推导和逆向推导为将已知的database、table、以及data对象和存在的old对象进行组合拼装;

所述数据查找单元用于查找执行SQL的执行时间或pos,并根据执行SQL的执行时间或pos定位数据还原的位置;所述数据查找单元包括:SQL语句列表查找子单元和数据还原的位置定位子单元;

所述SQL语句列表查找子单元用于根据执行SQL,采用数据指纹比对方式确定相似匹配度最高的SQL语句列表;

所述数据还原的位置定位子单元用于根据SQL语句列表对应的执行时间或pos对误操作SQL进行定位,进而根据误操作SQL的位置确定数据还原的位置。

2.根据权利要求1所述的一种MYSQL数据库回档云平台,其特征在于,所述数据解析单元还用于将回档SQL按DataBase、Table、Timestamp进行有序存储;

所述数据回档单元用于根据执行SQL的可填信息以及必填信息,完成数据逆向回档;所述可填信息包括:DataBase和Table;所述必填信息包括:执行时间或偏移量;

所述数据计算单元与所述数据回档单元相配合;所述数据计算单元用于通过倒序提取回档SQL,计算回档SQL是否符合逆向还原规则;若符合,则执行,反之,则跳过执行。

3.根据权利要求1所述的一种MYSQL数据库回档云平台,其特征在于,所述数据回档单元执行时会自动执行所述数据计算单元,进行回档SQL的清洗与过滤。

4.根据权利要求1所述的一种MYSQL数据库回档云平台,其特征在于,所述type包括:create、alter、drop、insert、update、delete、drop或truncate。