[發(fā)明專利]數(shù)據(jù)查詢方法、裝置、計(jì)算機(jī)設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011528271.6
• 申請日: 2020-12-22
• 公開（公告）號: CN112632102A
• 公開（公告）日: 2021-04-09
• 發(fā)明（設(shè)計(jì)）人: 丁勇
• 申請（專利權(quán)）人: 平安普惠企業(yè)管理有限公司
• 主分類號: G06F16/242
• 分類號: G06F16/242;G06F16/2453;G06F16/25
• 代理公司: 深圳市世聯(lián)合知識產(chǎn)權(quán)代理有限公司 44385
• 代理人: 汪琳琳

1.一種數(shù)據(jù)查詢方法，其特征在于，包括下述步驟：

在接收到數(shù)據(jù)查詢指令時(shí)，獲取所述數(shù)據(jù)查詢指令對應(yīng)的查詢數(shù)據(jù)對；

根據(jù)所述查詢數(shù)據(jù)對連接目標(biāo)數(shù)據(jù)庫集群，并生成所述目標(biāo)數(shù)據(jù)庫集群的消費(fèi)主題；

根據(jù)所述消費(fèi)主題查詢所述目標(biāo)數(shù)據(jù)庫集群中的所有有效數(shù)據(jù)，對所述有效數(shù)據(jù)進(jìn)行反序列化，得到目標(biāo)對象；

從所述目標(biāo)數(shù)據(jù)庫集群中獲取所述目標(biāo)對象對應(yīng)的目標(biāo)數(shù)據(jù)對，匹配所述查詢數(shù)據(jù)對和所述目標(biāo)數(shù)據(jù)對，在所述查詢數(shù)據(jù)對與所述目標(biāo)數(shù)據(jù)對匹配成功時(shí)，返回與所述查詢數(shù)據(jù)對匹配成功的目標(biāo)數(shù)據(jù)對，以及所述匹配成功的目標(biāo)數(shù)據(jù)對的查詢值。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)查詢方法，其特征在于，所述根據(jù)所述消費(fèi)主題查詢所述目標(biāo)數(shù)據(jù)庫集群中的所有有效數(shù)據(jù)的步驟具體包括：

獲取所述目標(biāo)數(shù)據(jù)庫集群的分區(qū)數(shù)，啟動與所述分區(qū)數(shù)相同個(gè)數(shù)的所述消費(fèi)主題；

在所述目標(biāo)數(shù)據(jù)庫集群中根據(jù)所述消費(fèi)主題對所述有效數(shù)據(jù)進(jìn)行分區(qū)查詢。

3.根據(jù)權(quán)利要求1所述的數(shù)據(jù)查詢方法，其特征在于，所述返回與所述查詢數(shù)據(jù)對匹配成功的目標(biāo)數(shù)據(jù)對，以及所述匹配成功的目標(biāo)數(shù)據(jù)對的查詢值的步驟具體包括：

所述查詢值包括分區(qū)值和偏移量，在所述查詢數(shù)據(jù)對與所述目標(biāo)數(shù)據(jù)對匹配完成時(shí)，通過接口返回所有與所述查詢數(shù)據(jù)對匹配成功的目標(biāo)數(shù)據(jù)對的分區(qū)值和偏移量。

4.根據(jù)權(quán)利要求1所述的數(shù)據(jù)查詢方法，其特征在于，在所述返回與所述查詢數(shù)據(jù)對匹配成功的目標(biāo)數(shù)據(jù)對，以及所述匹配成功的目標(biāo)數(shù)據(jù)對的查詢值的步驟之后包括：

統(tǒng)計(jì)所述查詢數(shù)據(jù)對與所述目標(biāo)數(shù)據(jù)對匹配成功的數(shù)據(jù)條數(shù)，并獲取所述目標(biāo)數(shù)據(jù)對的數(shù)據(jù)類型；

根據(jù)所述數(shù)據(jù)條數(shù)和所述數(shù)據(jù)類型，確定所述查詢數(shù)據(jù)對是否為臟數(shù)據(jù)，其中，在所述數(shù)據(jù)類型為標(biāo)識類型，且所述數(shù)據(jù)條數(shù)大于等于預(yù)設(shè)閾值時(shí)，確定所述目標(biāo)數(shù)據(jù)對為所述臟數(shù)據(jù)。

5.根據(jù)權(quán)利要求4所述的數(shù)據(jù)查詢方法，其特征在于，所述統(tǒng)計(jì)所述查詢數(shù)據(jù)對與所述目標(biāo)數(shù)據(jù)對匹配成功的數(shù)據(jù)條數(shù)的步驟具體包括：

在所述查詢數(shù)據(jù)對與所述目標(biāo)數(shù)據(jù)對匹配成功時(shí)，基于預(yù)設(shè)的內(nèi)置計(jì)數(shù)器記錄匹配成功的次數(shù)；

根據(jù)所述匹配成功的次數(shù)確定所述查詢數(shù)據(jù)對與所述目標(biāo)數(shù)據(jù)對匹配成功的數(shù)據(jù)條數(shù)。

6.根據(jù)權(quán)利要求1所述的數(shù)據(jù)查詢方法，其特征在于，在所述返回與所述查詢數(shù)據(jù)對匹配成功的目標(biāo)數(shù)據(jù)對，以及所述匹配成功的目標(biāo)數(shù)據(jù)對的查詢值的步驟之后還包括：

獲取所述查詢數(shù)據(jù)對的目標(biāo)格式模版；

根據(jù)所述目標(biāo)格式模版對所述目標(biāo)數(shù)據(jù)對進(jìn)行格式篩選，確定所述目標(biāo)數(shù)據(jù)對中不符合格式規(guī)范的目標(biāo)數(shù)據(jù)對為臟數(shù)據(jù)。

7.根據(jù)權(quán)利要求1所述的數(shù)據(jù)查詢方法，其特征在于，所述根據(jù)所述查詢數(shù)據(jù)對連接目標(biāo)數(shù)據(jù)庫集群的步驟具體包括：

獲取所述查詢數(shù)據(jù)對的查詢參數(shù)，解析所述查詢參數(shù)得到查詢密鑰；

根據(jù)所述查詢密鑰連接至所述目標(biāo)數(shù)據(jù)庫集群。

8.一種數(shù)據(jù)查詢裝置，其特征在于，包括：

獲取模塊，用于在接收到數(shù)據(jù)查詢指令時(shí)，獲取所述數(shù)據(jù)查詢指令對應(yīng)的查詢數(shù)據(jù)對；

生成模塊，用于根據(jù)所述查詢數(shù)據(jù)對連接目標(biāo)數(shù)據(jù)庫集群，并生成所述目標(biāo)數(shù)據(jù)庫集群的消費(fèi)主題；

查詢模塊，用于根據(jù)所述消費(fèi)主題查詢所述目標(biāo)數(shù)據(jù)庫集群中的所有有效數(shù)據(jù)，對所述有效數(shù)據(jù)進(jìn)行反序列化，得到目標(biāo)對象；

匹配模塊，用于從所述目標(biāo)數(shù)據(jù)庫集群中獲取所述目標(biāo)對象對應(yīng)的目標(biāo)數(shù)據(jù)對，匹配所述查詢數(shù)據(jù)對和所述目標(biāo)數(shù)據(jù)對，在所述查詢數(shù)據(jù)對與所述目標(biāo)數(shù)據(jù)對匹配成功時(shí)，返回與所述查詢數(shù)據(jù)對匹配成功的目標(biāo)數(shù)據(jù)對，以及所述匹配成功的目標(biāo)數(shù)據(jù)對的查詢值。

9.一種計(jì)算機(jī)設(shè)備，包括存儲器和處理器，所述存儲器中存儲有計(jì)算機(jī)可讀指令，所述處理器執(zhí)行所述計(jì)算機(jī)可讀指令時(shí)實(shí)現(xiàn)如權(quán)利要求1至7中任一項(xiàng)所述的數(shù)據(jù)查詢方法的步驟。

10.一種計(jì)算機(jī)可讀存儲介質(zhì)，其特征在于，所述計(jì)算機(jī)可讀存儲介質(zhì)上存儲有計(jì)算機(jī)可讀指令，所述計(jì)算機(jī)可讀指令被處理器執(zhí)行時(shí)實(shí)現(xiàn)如權(quán)利要求1至7中任一項(xiàng)所述的數(shù)據(jù)查詢方法的步驟。