买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉重庆海创云链数字科技有限公司申请的专利基于FlinkCDC的实时整库同步方法、系统、设备及存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN116628090B 。

龙图腾网通过国家知识产权局官网在2025-08-19发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202310605029.1，技术领域涉及：G06F16/27；该发明授权基于FlinkCDC的实时整库同步方法、系统、设备及存储介质是由王沐;张晨设计研发完成，并于2023-05-25向国家知识产权局提交的专利申请。

本基于FlinkCDC的实时整库同步方法、系统、设备及存储介质在说明书摘要公布了：本发明属于数据库同步技术领域，具体公开了基于FlinkCDC的实时整库同步方法、系统、设备及存储介质，通过FlinkCDC组件拉取业务数据库整库实时的日志变动数据，来提取当前日志变动数据对应的表名和字段名，判定下游数据库及特殊无需同步表名集合中是否存对应的表名和字段名，若不存在则从业务数据库中查询获取对应的字段信息来映射转换得到下游数据库的适配字段信息，再通过构建语句指令使下游数据库建表建字段来满足当前日志变动数据的录入条件，最后将业务数据库当前日志变动数据同步到下游数据库中，可以高效实现业务数据库到下游数据库实时数据流批一体同步，极大的提升数据库整库同步的便捷程度与时效性。

本发明授权基于FlinkCDC的实时整库同步方法、系统、设备及存储介质在权利要求书中公布了：1.基于FlinkCDC的实时整库同步方法，其特征在于，包括： 通过FlinkCDC组件拉取业务数据库整库实时的日志变动数据； 提取出当前的日志变动数据中对应的表名和字段名，并将提取的表名和字段名与缓存的下游数据库中的表名和字段名进行比对，判断下游数据库中是否存在当前日志变动数据对应的表名和字段名； 在判定下游数据库中不存在当前日志变动数据对应的表名和字段名时，将提取的表名与预存的特殊无需同步表名集合中的各表名进行比对，判断特殊无需同步表名集合中是否存在当前日志变动数据对应的表名； 在判定特殊无需同步表名集合中不存在当前日志变动数据对应的表名时，根据当前日志变动数据对应的表名从业务数据库中查询获取该表名对应表的字段信息，所述字段信息包括字段类型和字段长度； 根据设定的映射转换关系对所述字段信息进行映射转换处理，得到下游数据库对应的字段类型和字段长度； 根据下游数据库对应的字段类型和字段长度组装构建语句，并将构建语句传输至下游数据库，以使下游数据库执行构建语句建表以及建字段； 将当前日志变动数据传输至建表及建字段后的下游数据库，使下游数据库根据构建的表和字段写入当前日志变动数据。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人重庆海创云链数字科技有限公司，其通讯地址为：400000 重庆市江北区观音桥东环路9号1幢7-11（自主承诺）；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。