[發明專利]一種基于HBase數據庫的數據查詢方法及裝置

有效

• 申請號: 201610653548.5
• 申請日: 2016-08-10
• 公開（公告）號: CN106326361B
• 公開（公告）日: 2020-01-21
• 發明（設計）人: 陳龍;曹睿;王昭;梁生吉;郝玉琨
• 申請（專利權）人: 中國農業銀行股份有限公司
• 主分類號: G06F16/24
• 分類號: G06F16/24
• 代理公司: 11227 北京集佳知識產權代理有限公司
• 代理人: 劉曉菲;王寶筠

1.一種基于HBase數據庫的數據查詢方法，其特征在于，所述方法包括：

接收來自客戶端的數據查詢請求，所述數據查詢請求中包括行鍵查詢字段、預設返回條數和領域對象名稱；其中，所述領域對象名稱是基于HBase訪問對象HAO抽象出的領域對象模型中包含的用于實現數據訪問邏輯的領域類型的名稱；

根據所述領域對象名稱確定對應的領域對象配置文件，所述領域對象配置文件中包括表名和行鍵 生成規則；

根據所述行鍵查詢字段以及HBase數據庫的行鍵生成規則生成行鍵查詢范圍，所述行鍵查詢范圍包括起始行鍵和結束行鍵；

通過所述HAO調用HBase的數據接口，以從與所述表名對應的表內查找所述行鍵查詢范圍，并從所述行鍵查詢范圍中獲得預設返回條數的行鍵對應的數據；

將所述預設返回條數的行鍵對應的數據映射為預設格式，并將映射后的數據發送至所述客戶端。

2.根據權利要求1所述的方法，其特征在于，所述根據所述行鍵查詢字段以及HBase數據庫的行鍵生成規則生成行鍵查詢范圍包括：

將所述行鍵查詢字段進行處理，以使所述行鍵查詢字段符合所述行鍵生成規則；

根據處理后的行鍵查詢字段以及HBase數據庫的行鍵生成規則生成行鍵查詢范圍。

3.根據權利要求1或2所述的方法，其特征在于，所述數據查詢請求中還包括過濾查詢字段，所述領域對象配置文件中還包括過濾器生成規則，所述方法還包括：

根據所述過濾查詢字段以及所述過濾器生成規則生成對應的過濾器；

所述從所述行鍵查詢范圍中獲得預設返回條數的行鍵對應的數據包括：

利用所述過濾器對所述行鍵查詢范圍內的數據進行過濾，得到過濾數據；

從所述過濾數據中提取預設返回條數的數據。

4.根據權利要求3所述的方法，其特征在于，所述過濾查詢字段包括行鍵過濾字段；

所述利用所述過濾器對所述行鍵查詢范圍內的數據進行過濾包括：

利用所述過濾器從所述行鍵查詢范圍內的行鍵中過濾出與所述行鍵過濾字段匹配的行鍵。

5.根據權利要求3所述的方法，其特征在于，所述過濾查詢字段包括列相關過濾字段；

所述利用所述過濾器對所述行鍵查詢范圍內的數據進行過濾包括：

利用所述過濾器從所述行鍵查詢范圍內過濾出與所述列相關過濾字段匹配的數據。

6.根據權利要求3所述的方法，其特征在于，在根據所述過濾查詢字段以及所述過濾器生成規則生成對應的過濾器之前，所述方法還包括：

對所述過濾查詢字段進行處理，以使所述過濾查詢字段滿足所述過濾器的生成要求。

7.一種基于HBase數據庫的數據查詢裝置，其特征在于，所述裝置包括：請求接收單元、配置文件確定單元、范圍生成單元、數據獲取單元和映射單元；

其中，所述請求接收單元，用于接收來自客戶端的數據查詢請求，所述數據查詢請求中包括行鍵查詢字段、預設返回條數和領域對象名稱；其中，所述領域對象名稱是基于HBase訪問對象HAO抽象出的領域對象模型中包含的用于實現數據訪問邏輯的領域類型的名稱；

所述配置文件確定單元，用于根據所述領域對象名稱確定對應的領域對象配置文件，所述領域對象配置文件中包括表名和行鍵 生成規則；

所述范圍生成單元，用于根據所述行鍵查詢字段以及HBase數據庫的行鍵生成規則生成行鍵查詢范圍，所述行鍵查詢范圍包括起始行鍵和結束行鍵；

所述數據獲取單元，用于通過所述HAO調用HBase的數據接口，以從與所述表名對應的表內查找所述行鍵查詢范圍，并從所述行鍵查詢范圍中獲得預設返回條數的行鍵對應的數據；

所述映射單元，用于將所述預設返回條數的行鍵對應的數據映射為預設格式，并將映射后的數據發送至所述客戶端。