(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210106077.1 (22)申请日 2022.01.28 (71)申请人 中国工商银行股份有限公司 地址 100140 北京市西城区复兴门内大街 55号 (72)发明人 刘雪晶　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 张娜　臧建明 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/23(2019.01) G06F 16/2455(2019.01) G06F 16/25(2019.01) G06F 16/182(2019.01) (54)发明名称 一种查询数据的方法和装置 (57)摘要 提供一种查询数据的方法和装置， 涉及大数 据领域。 该方法包括： 获取查询条件， 该查询条件 用于查询第一数据库中的第一数据； 基于该查询 条件从预先构建的目标索引表中查询第一数据 在第一数据库中的存储位置， 目标索引表中包括 至少一个查询条件与第一数据库中的至少一条 数据的存储位置的对应关系， 至少一个查询条件 中的每个查询条件对应于第一数据库中的一条 或多条数据； 基于第一数据的存储位置读取第一 数据。 通过预先构建的包括查询条件和数据的存 储位置的对应关系的索引表， 在触发查询数据 后， 可以根据获取到的查询条件在索引表中找到 与该查询条件对应的数据的存储位置， 从而可以 根据该存储位置快速地读取到用户所查询的数 据， 降低查询数据的时延。 权利要求书2页 说明书13页 附图2页 CN 114510480 A 2022.05.17 CN 114510480 A 1.一种查询数据的方法， 其特 征在于， 所述方法包括： 获取查询条件， 所述 查询条件用于查询第一数据库中的第一数据； 基于所述查询条件从预先构建的目标索引表中查询所述第一数据在所述第一数据库 中的存储位置， 所述目标索引表中包括至少一个查询条件与所述第一数据库中的至少一条 数据的存储位置的对应关系， 所述至少一个查询条件中的每个查询条件对应于所述第一数 据库中的一条或多条 数据； 基于所述第一数据的存 储位置读取 所述第一数据。 2.如权利要求1所述的方法， 其特征在于， 所述基于所述查询条件从预先构建的目标索 引表中查询所述第一数据在所述第一数据库中的存 储位置， 包括： 从预先构建的至少一个索引表中确定所述目标索引表， 所述目标索引表是包括所述查 询条件的索引表， 所述至少一个索引表中的每个索引表包括至少一个查询条件与所述第一 数据库中的至少一条 数据的存 储位置的对应关系； 基于所述 查询条件从所述目标索引表中查询所述第一数据的存 储位置。 3.如权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 构建所述至少一个索引表。 4.如权利要求3所述的方法， 其特 征在于， 所述构建所述至少一个索引表， 包括： 获取所述第一数据库的原 始信息； 基于所述原始信息确定所述至少一个索引表中每个索引表的表名和每个索引表包括 的至少一个查询条件； 基于每个索引表的表名、 每个索引表包括的至少一个查询条件以及每个查询条件对应 的数据在所述第一数据库中的存 储位置， 构建所述至少一个索引表。 5.如权利要求4所述的方法， 其特征在于， 所述至少一个索引表构建在第二数据库中， 所述第二数据库是 具有联机分析处 理能力的数据库。 6.如权利要求 4或5所述的方法， 其特 征在于， 所述方法还 包括： 在确定所述第 一数据库中的数据发生变化的情况下， 对发生变化的数据 所关联的一个 或多个索引表进行 更新。 7.如权利要求6所述的方法， 其特征在于， 所述第一数据为批式数据， 所述批式数据是 在大数据平台上进行批量处理的数据， 所述第一数据库为hive， 所述原始信息包括所述第 一数据库包括的至少一个数据 表中每个数据 表的表名和每个数据 表包括的至少一个字段， 每个数据 表的表名用于确定一个索引表的表名， 每个数据 表中的至少一个字段用于确定一 个查询条件。 8.如权利要求7所述的方法， 其特征在于， 所述在确定所述第 一数据库中的数据发生变 化的情况 下， 对发生变化的数据所关联的一个或多个索引表进行 更新， 包括： 在监听到所述第 一数据库中的数据发生变化的情况下， 对发生变化的数据所关联的一 个或多个索引表进行 更新。 9.如权利要求6所述的方法， 其特征在于， 所述第一数据为流式数据， 所述流式数据是 在大数据 平台上进 行流式处理的数据， 所述第一数据库为Kafka， 所述原始信息包括所述第 一数据库包括的至少一个话题中每个话题的名称和每个话题包括的至少一个消息中每个 消息包括的至少一个字段， 每个话题的名称用于确定一个索引表的表名， 每个消息包括的权　利　要　求　书 1/2 页 2 CN 114510480 A 2至少一个字段用于确定一个查询条件。 10.如权利要求9所述的方法， 其特征在于， 所述在确定所述第一数据库中的数据发生 变化的情况 下， 对发生变化的数据所关联的一个或多个索引表进行 更新， 包括： 实时读取每 个话题中的新增 消息； 在确定一个话题中的至少一个新增消息指示对所述第 一数据库中的数据进行增加、 删 除或修改的情况 下， 对发生变化的数据所关联的一个或多个索引表进行 更新。 11.一种查询数据的装置， 其特 征在于， 所述装置包括： 获取模块， 用于获取查询条件， 所述 查询条件用于查询第一数据库中的第一数据； 查询模块， 用于基于所述查询条件从预先构建的目标索引表中查询所述第 一数据在所 述第一数据库中的存储位置， 所述目标索引表中包括至少一个查询条件与所述第一数据库 中的至少一条数据的存储位置的对应关系， 所述至少一个查询条件中的每个查询条件对应 于所述第一数据库中的一条或多条 数据； 读取模块， 用于基于所述第一数据的存 储位置读取 所述第一数据。 12.一种查询数据的装置， 其特征在于， 包括处理器， 所述处理器用于执行权利要求1至 10中任一项所述的方法。 13.一种计算机可读存储介质， 其特征在于， 包括计算机程序， 当所述计算机程序在计 算机上运行时， 使得 所述计算机执 行如权利要求1至10中任一项所述的方法。 14.一种计算机程序产品， 其特征在于， 包括计算机程序， 当所述计算机程序被运行时， 使得计算机执 行如权利要求1至10中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114510480 A 3