(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210395995.0 (22)申请日 2022.04.14 (71)申请人 荃豆数字科技有限公司 地址 610000 四川省成 都市高新区蜀锦路 88号1栋1单 元5层7号 (72)发明人 陈飞　 (74)专利代理 机构 成都顶峰专利事务所(普通 合伙) 51224 专利代理师 冉丽 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/23(2019.01) G06F 16/242(2019.01) G06F 16/27(2019.01) G06F 11/14(2006.01) (54)发明名称 一种基于CDC实现的中医药多源 数据查询方 法和设备 (57)摘要 本发明公开了一种基于CDC实现的中医药多 源数据查询方法和设备， 包括： 基于数据变更捕 获CDC监听中医药业务系统的源业务表中的数据 变更， 调用日志解析组件来解析源业务表的日志 文件以提取变更数据； 在数据库连接异常时将变 更数据以逗号分隔值文件格式进行备份存储， 否 则直接将变更数据同步至中间数据库； 利用调度 器基于时间戳的增量提取方法提取增量数据到 目标报表； 接收用户的数据查询请求， 向用户返 回数据查询结果。 本发明无需修改源业务表的数 据结构即可进行数据提取， 实现数据同步， 实现 过程简单； 可以避免在数据库连接时发生数据抽 取中断， 保证数据同步的连续性和完整性； 无需 对数据进行连表查询， 提高数据查询的响应效 率。 权利要求书2页 说明书7页 附图1页 CN 114691696 A 2022.07.01 CN 114691696 A 1.一种基于 CDC实现的中 医药多源数据查询方法， 其特 征在于， 包括： 基于数据变更捕获CDC监听中医药业务系统的源业务表中是否发生了数据变更， 若是， 则调用日志 解析组件来解析源业务表的日志文件， 并从所述日志文件中提取源业务表的变 更数据； 检测是否存在数据库连接异常， 若是， 则将所述变更数据以逗号分隔值文件格式进行 备份存储， 并在数据库连接正常后 将备份的变更数据同步至中间数据库中； 若否， 则直接将 所述变更 数据同步至所述中间数据库中； 在所述中间数据库中运行调度器， 并利用所述调度器基于时间戳的增量提取方法将所 述中间数据库中的增量数据发送到目标报表； 接收用户的数据查询请求， 根据所述数据查询请求在所述目标报表中进行数据查询， 并向用户返回数据查询结果。 2.根据权利要求1所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 基于 数据变更捕获CDC监听中 医药业务系统中源业 务表是否发生了数据变更， 包括： 基于数据变更捕获CDC监听中医药业务系统中源业务表是否发生了INSERT、 UPDATE和 DELETE事 件， 若是， 则认为发生了数据变更。 3.根据权利要求1所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 在调 用日志解析组件来解析源业务表的日志文件， 并从所述日志文件中提取源业务表的变更数 据之前， 所述方法还 包括： 将源业务表中的基础数据通过中间数据库全量同步至目标报表中， 获取源业务表的初 始时间戳最大值， 并获取中间数据库中事务记录的变更时间戳最大值和变更时间戳最小 值， 其中， 所述中间数据库中每条事务记录对应一个变更时间戳， 用于表示数据变更事务开 始执行的时间， 且所述变更时间戳 最小值大于或等于所述初始时间戳 最大值； 调用日志解析组件来解析源业务表的日志文件， 并从所述日志文件中提取源业务表的 变更数据， 包括： 调用日志解析组件来解析源业务表的日志文件， 并从所述变更时间戳最小值对应的源 业务表中提取变更 数据； 在基于变更时间戳最小值对应的源业务表标识序列号提取变更数据之后， 所述方法还 包括： 若所述变更时间戳最小值处于所述变更时间戳最大值和所述初始化时间戳最大值之 间， 则将所述变更 数据同步至所述中间数据库中。 4.根据权利要求3所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 调用 日志解析组件来解析源业务表的日志文件， 并从所述日志文件中提取源业务表的变更数 据， 还包括： 调用日志解析组件来解析源业务表的日志文件， 并从所述初始化 时间戳最大值对应的 业务表中提取变更 数据。 5.根据权利要求1所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 在数 据库连接正常后将备份的变更 数据同步至中间数据库， 包括： 在数据库连接正常后， 将逗号分隔值格式的变更数据写为表格形式的文件数据， 并将 表格形式的变更 数据插入到中间数据库。权　利　要　求　书 1/2 页 2 CN 114691696 A 26.根据权利要求1所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 在数 据库连接正常后将备份的变更 数据同步至中间数据库之后， 所述方法还 包括： 在所述源业务表中设置所述中间数据库的身份列和对应的状态标识值， 并所述源业务 表和所述中间数据库的数据同步结果进行检查， 当所述身份列对应的状态标识 值存在异常 时， 则认为存在数据同步异常； 将异常身份列状态标识值对应的行 数据插入到中间数据库， 实现数据同步 修正。 7.根据权利要求1所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 根据 所述数据查询请求在所述目标报表进行 数据查询， 包括： 根据所述数据查询请求， 确定数据查询类型、 查询时间、 查询指标和查询条件； 根据所述查询类型和所述查询时间设置查询标识， 根据 所述查询 指标和所述查询条件 设置查询对象， 并根据所述 查询标识和所述 查询对象得到查询语句； 利用所述 查询语句在所述目标报表进行 数据查询。 8.根据权利要求7所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 根据 所述查询标识和所述 查询对象得到查询语句， 包括： 根据所述查询标识生成查询语句的ID信息， 根据所述查询对象生成查询参数， 并根据 所述ID信息和所述 查询参数生成初始查询语句； 确定所述初始查询语句对应的查询 指标和查询条件， 并将查询条件和查询指标一致的 多个初始查询语句进行合并， 得到合并查询语句。 9.根据权利要求8所述的基于CDC实现的中医药多源数据查询方法， 其特征在于， 利用 所述查询语句在所述目标报表进行 数据查询， 包括： 利用所述初始查询语句和/或所述合并查询语句， 采用并发线程的执行方式在所述目 标报表中进行 数据查询。 10.一种计算机设备， 其特征在于， 包括依次通信相连的存储器、 处理器和收发器， 其 中， 所述存储器用于存储计算机程序， 所述收发器用于收发消息， 所述处理器用于读取所述 计算机程序， 执行如权利要求1 ‑9任意一项所述的基于CDC实现的中医药多源数据查询方 法。权　利　要　求　书 2/2 页 3 CN 114691696 A 3