1 .一种实现增量数据比对的系统,其特征在于,包括:
同步T环境、仿真F环境、仿真工具、内存数据库、比对工具和结果数据库;
所述T环境包括同步环境核心应用、传统商业数据库、增量同步工具和同步环境分布式
数据库;
所述F环境包括仿真环境核心应用和仿真环境分布式数据库;
所述仿真工具,用于回放T环境业务和F环境业务;
所述内存数据库,用于存储T环境和F环境的报文值映射关系;
所述比对工具,用于根据所述报文值映射关系比对T环境和F环境中的数据;
所述结果数据库,用于存储所述比对工具产生的比对结果数据。
2.根据权利要求1所述的系统,其特征在于,
所述仿真环境核心应用,用于将所述仿真工具输入的业务数据写入所述仿真环境分布
式数据库,产生对应的二进制日志binlog,并向所述仿真工具返回结果报文;
所述同步环境核心应用,用于将所述仿真工具输入的业务数据写入所述传统商业数据
库,产生对应的重做日志redo log,并向所述仿真工具返回结果报文;
所述增量同步工具,用于采集所述传统商业数据库的redo log,解析为SQL后写入所述
同步环境分布式数据库,产生对应的二进制日志binlog;
所述仿真工具,具体用于解析T环境和F环境返回的结果报文,得到报文值映射关系后
写入所述内存数据库。
3 .根据权利要求1所述的系统,其特征在于,
所述比对工具包括一个比对服务端CS和多个比对客户端CC,
每一个CC,用于主动发起心跳注册到所述CS,
所述CS,用于为每个CC分配一对比对源,同时将T环境和F环境的binlog起始位置信息
下发给所有CC;
所述每一个CC,还用于模拟备机方式接入对应的比对源;
所述一对比对源为T环境和F环境各一个对应的分片。
4 .根据权利要求3所述的系统,其特征在于,
所述CS,还用于向每一个CC请求一个业务上为全局递增的字段值;
所述每一个CC,还用于在F环境从binlog起始位置开始搜索,直至找到第一个不小于所
述字段值的binlog位置,返回该位置对应字段值给CS;
所述CS,还用于集齐每一个CC返回的字段值后,将最大的字段值作为初始字段值,查询
所述内存数据库根据T环境和F环境的报文值映射关系获取所述初始字段值对应的T环境相
应的初始字段值,并下发至所有CC;
所述每一个CC,还用于获取T环境和F环境中所述初始字段值对应的binlog文件和位
置,并返回给CS;
所述CS,收到所述binlog文件和位置后,通知所有CC开始按批次解析binlog;
所述每一个CC,还用于按批次解析binlog,将F环境和T环境有对应关系的值,替换为T
环境的值,返回解析结果;
所述CS,收到一个批次的解析结果后,生成落地文件并执行比对,将比对结果存入所述
结果数据库。
权 利 要 求 书
1/3 页
2
评论