[發明專利]一種用于多源數據的查詢方法及系統

在審

• 申請號: 201710808772.1
• 申請日: 2017-09-09
• 公開（公告）號: CN107818127A
• 公開（公告）日: 2018-03-20
• 發明（設計）人: 王鋒華;錢仲文;張旭東;黃建平;夏洪濤;成敬周;祝春捷;陳俊;方凌斌;潘堅躍;陳浩;呂旭芬;紀德良;王仲鋒;王政
• 申請（專利權）人: 國網浙江省電力公司;國網浙江省電力公司杭州供電公司;國家電網公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;G06F21/54
• 代理公司: 杭州華鼎知識產權代理事務所(普通合伙)33217
• 代理人: 項軍

技術領域

本發明屬于數據庫領域，特別涉及一種用于多源數據的查詢方法及系統。

背景技術

隨著云計算、大數據技術的不斷發展，作為國民支柱產業的電力行業的信息化水平也在不斷提高，各業務核心系統和數據中心積累了海量的數據，因此如何有效的查詢并應用數據成為電力行業信息化研究的一個重要課題。

當前的數據查詢主要基于結構化查詢語言(Structured Query Language，SQL)進行，但是該查詢過程往往只能針對一個或單項數據庫進行，對于種類繁雜、數量眾多的跨庫數據查詢，往往無法做到準確查詢，從而降低了數據查詢的有效性。

發明內容

為了解決現有技術中存在的缺點和不足，本發明提供了建立邏輯數據庫從而對查詢請求進行分類處理，最終提高數據查詢有效性的用于多源數據的查詢方法及系統。

為了達到上述技術目的，本發明提供了一種用于多源數據的查詢方法，所述查詢方法用于在業務應用層與數據庫之間提供數據訪問應答，所述查詢方法，包括：

接收來自業務應用的數據訪問請求，將訪問請求轉發至數據訪問組件，數據訪問組件提取訪問請求中的傳遞參數，對傳遞參數進行判斷；

當判斷結果表明數據訪問為跨庫數據請求時，令數據訪問組件將數據訪問請求轉發至分布式數據查詢引擎；

令分布式數據查詢引擎連接至與數據訪問請求對應的多數據源，從多數據源處獲取與數據訪問請求對應的查詢結果，將查詢結果轉發至數據訪問組件，使得數據轉發組件將查詢結果發送至業務應用。

可選的，所述數據訪問請求的表現形式為結構化查詢語言。

可選的，所述數據訪問組件為提供標準java數據庫連接驅動、與業務應用對接的接口。

可選的，所述數據訪問組件，用于：

創建連接、以及發送SQL請求；

其中，創建連接，包括正確配置JDBC參數，將JDBC參數傳給連接管理模塊，連接管理模板根據JDBC版本提供參數至狀態服務器進行驗證，獲取元數據信息；

SQL請求，包括判斷生成的SQL連接是否為穿透連接，如果為穿透連接，則基于給定的物理數據庫按需創建或選擇連接。

另一方面，本申請實施例還提供了一種用于多源數據的查詢系統，所述查詢方法用于在業務應用層與數據庫之間提供數據訪問應答，其特征在于，所述查詢系統，包括：

服務訪問應用程序接口，用于接收來自業務應用的數據訪問請求，將訪問請求轉發至數據訪問組件，數據訪問組件提取訪問請求中的傳遞參數，對傳遞參數進行判斷；

JDBC HUB引擎容器模塊，用于當判斷結果表明數據訪問為跨庫數據請求時，令數據訪問組件將數據訪問請求轉發至分布式數據查詢引擎；

應用數據庫驅動層，用于令分布式數據查詢引擎連接至與數據訪問請求對應的多數據源，從多數據源處獲取與數據訪問請求對應的查詢結果；

服務訪問應用程序接口，還用于將查詢結果轉發至數據訪問組件，使得數據轉發組件將查詢結果發送至業務應用。

可選的，所述服務訪問應用程序接口，具體用于：

提供JDBC協議接入接口，捕獲到應用數據庫驅動發送的命令請求，對業務系統及業務數據庫透明無感知，支持多數據庫混合協議；

通過SQL連接傳遞的參數判斷需要訪問何種類型數據庫，并加以解析、分析處理。

可選的，所述JDBC HUB引擎容器模塊，包括：

SQL解析、數據路由、驅動管理、數據源管理、性能分析、操作審計、數據解析和處理、SQL性能數據收集、權限管理以及庫表管理；

其中，權限管理包括進行庫、表級別的權限管理和控制，細粒度的權限依賴底層數據源來控制；

驅動管理包括用戶注冊各種驅動信息，支持多版本驅動的管理。

實例管理包括提供給平臺運維人員配置管理JDBC HUB實例的各種系統參數。

可選的，所述SQL解析，包括：

應用的請求解析到庫、表等相關信息，為SQL分發到具體的數據源做準備。最終請求將通過關系型數據庫的適配器連接到各個關系型數據庫。

可選的，所述數據路由，包括：

數據路由：根據SQL解析的結果和庫表名字空間管理的信息，確定使用哪個數據源適配器和最終的數據源，并建立連接把請求轉發出去，為了性能的提高，支持連接池等和優化技術，同時是各種處理插件的接入點，例如性能收集模塊。

可選的，所述數據訪問組件，用于：

創建連接、以及發送SQL請求；