[發明專利]基于分布式流計算實現跨多關系數據庫排序的方法及系統

有效

• 申請號: 201510340733.4
• 申請日: 2015-06-18
• 公開（公告）號: CN104965891B
• 公開（公告）日: 2018-04-27
• 發明（設計）人: 連城;齊權;林杰東;郭海濤
• 申請（專利權）人: 福建富士通信息軟件有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 福州市鼓樓區京華專利事務所(普通合伙)35212
• 代理人: 王美花

1.一種基于分布式流計算實現跨多關系數據庫排序的方法，其特征在于：包括如下步驟：

步驟1、接受應用系統請求的原SQL語句，判斷該原SQL語句中是否包含Order by語句：

(1)如果該原SQL語句中包含Order by語句，且

(11)若該Order by語句為“Order by字段limit起點n，步長m”，則將該原SQL語句變換為“Order by字段limit 0，n+m”，或者

(12)若該Order by語句為“Order by字段limit p”，則將該原SQL語句變換為“Order by字段limit 0，p”；

根據變換后的SQL語句可獲取需要排序的字段、需要的limit數量、結果截斷數量，將變換后的SQL語句、需要排序的字段、需要的limit數量、結果截斷數量和關系型數據庫實例的連接配置信息進行封裝并發送給接受請求節點，并進入步驟2；

(2)如果該原SQL語句中不包含Order by語句，則結束流程；

步驟2、接受請求節點接收后，生成本次請求的唯一編號，根據變換后的SQL語句和關系型數據庫實例的連接配置信息，調用復數個查詢節點查詢對應的關系型數據庫實例，同時將查詢結果返回給該復數個查詢節點，該復數個查詢節點將查詢結果發射到排序節點；然后排序節點根據需要排序的字段、需要的limit數量創建不重復集合自排序結構體，根據所述唯一編號對所述不重復集合自排序結構體進行標識，同時接收由復數個查詢節點發射過來的查詢結果，并將該查詢結果放入所述不重復集合自排序結構體中進行排序；然后根據結果截斷數量將所述不重復集合自排序結構體中排序后的查詢結果進行截斷后，將截斷后的不重復集合自排序結構體進行封裝并返回給應用系統。

2.一種基于分布式流計算實現跨多關系數據庫排序的系統，其特征在于：包括：

數據路由模塊，用于接受應用系統請求的原SQL語句，判斷該原SQL語句中是否包含Order by語句：

(1)如果該原SQL語句中包含Order by語句，且

(11)若該Order by語句為“Order by字段limit起點n，步長m”，則將該原SQL語句變換為“Order by字段limit 0，n+m”，或者

(12)若該Order by語句為“Order by字段limit p”，則將該原SQL語句變換為“Order by字段limit 0，p”；

根據變換后的SQL語句可獲取需要排序的字段、需要的limit數量、結果截斷數量，將變換后的SQL語句、需要排序的字段、需要的limit數量、結果截斷數量和關系型數據庫實例的連接配置信息進行封裝并發送給接受請求節點，并進入分布式流計算模塊；

(2)如果該原SQL語句中不包含Order by語句，則結束流程；

分布式流計算模塊，用于在接受請求節點接收后，生成本次請求的唯一編號，根據變換后的SQL語句和關系型數據庫實例的連接配置信息，調用復數個查詢節點查詢對應的關系型數據庫實例，同時將查詢結果返回給該復數個查詢節點，該復數個查詢節點將查詢結果發射到排序節點；然后排序節點根據需要排序的字段、需要的limit數量創建不重復集合自排序結構體，根據所述唯一編號對所述不重復集合自排序結構體進行標識，同時接收由復數個查詢節點發射過來的查詢結果，并將該查詢結果放入所述不重復集合自排序結構體中進行排序；然后根據結果截斷數量將所述不重復集合自排序結構體中排序后的查詢結果進行截斷后，將截斷后的不重復集合自排序結構體進行封裝并返回給應用系統。