[發(fā)明專利]數(shù)據(jù)庫處理方法、裝置和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 201710148886.8
• 申請日: 2017-03-14
• 公開（公告）號: CN108572991A
• 公開（公告）日: 2018-09-25
• 發(fā)明（設(shè)計）人: 李清宇;沈俊杰;任莉強;蔡毅勇;肖京宇
• 申請（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀貿(mào)易有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;G06F9/46
• 代理公司: 北京德琦知識產(chǎn)權(quán)代理有限公司 11018
• 代理人: 張曉峰;宋志強

1.一種數(shù)據(jù)庫處理方法，其特征在于，該方法用于包含二個以上數(shù)據(jù)庫的數(shù)據(jù)庫集群；該方法主要包括：

在業(yè)務(wù)邏輯中通過注解的方式標示當(dāng)前業(yè)務(wù)事務(wù)類型；

在收到數(shù)據(jù)存儲請求后，確定該數(shù)據(jù)存儲請求中的用戶標識，如果是新增用戶，則計算該新增用戶在所述數(shù)據(jù)庫集群中對應(yīng)數(shù)據(jù)源的路由信息，將路由信息存儲在路由服務(wù)中；如果是已有用戶，則從所述路由服務(wù)中獲取該用戶對應(yīng)的數(shù)據(jù)源的路由信息；

根據(jù)當(dāng)前用戶對應(yīng)的路由信息，確定對應(yīng)的數(shù)據(jù)源；

判斷當(dāng)前業(yè)務(wù)的事務(wù)類型，如果是單庫事務(wù)，則獲取本地事務(wù)管理器，利用該本地事務(wù)管理器，將所述數(shù)據(jù)存儲請求中的數(shù)據(jù)存儲到當(dāng)前用戶對應(yīng)的路由信息所確定的數(shù)據(jù)源中；如果是跨庫事務(wù)，則獲取分布式事務(wù)管理器，利用該分布式事務(wù)管理器，將所述數(shù)據(jù)存儲請求中的數(shù)據(jù)存儲到當(dāng)前用戶對應(yīng)的路由信息所確定的數(shù)據(jù)源中。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，該方法進一步包括：

在收到數(shù)據(jù)查詢請求后，確定該數(shù)據(jù)查詢請求中的用戶標識，從所述路由服務(wù)中獲取該用戶對應(yīng)的數(shù)據(jù)源的路由信息；

根據(jù)所述用戶的路由信息，確定對應(yīng)的數(shù)據(jù)源；

根據(jù)所述數(shù)據(jù)查詢請求，從所述數(shù)據(jù)源中查詢數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，該方法進一步包括：統(tǒng)計指定用戶對應(yīng)數(shù)據(jù)源的數(shù)據(jù)量，當(dāng)指定用戶對應(yīng)數(shù)據(jù)源的數(shù)據(jù)量超過閾值，則進一步執(zhí)行以下步驟：

將該指定用戶對應(yīng)數(shù)據(jù)源的數(shù)據(jù)遷移到所述數(shù)據(jù)庫集群中的新選定的數(shù)據(jù)源中，并在所述路由服務(wù)中更新該指定用戶對應(yīng)的新選定的數(shù)據(jù)源的路由信息。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，該方法進一步包括：在所述數(shù)據(jù)庫集群中增加新的數(shù)據(jù)源，在所述路由服務(wù)中增加所述新的數(shù)據(jù)源的路由路徑信息；之后當(dāng)接收到數(shù)據(jù)存儲請求后，確定該數(shù)據(jù)存儲請求中的用戶標識，如果是新增用戶，則計算該新增用戶在所述已增加所述新數(shù)據(jù)源的數(shù)據(jù)庫集群中對應(yīng)數(shù)據(jù)源的路由信息，將路由信息存儲在路由服務(wù)中。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，該方法進一步包括：確定所述數(shù)據(jù)庫集群中需要下架的數(shù)據(jù)源，將該需要下架的數(shù)據(jù)源中的數(shù)據(jù)源遷移到所述數(shù)據(jù)庫集群中的新選定的數(shù)據(jù)源中，并在所述路由服務(wù)中更新所述需要下架的數(shù)據(jù)源對應(yīng)的路由信息；刪除所述需要下架的數(shù)據(jù)源。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述計算該新增用戶在所述數(shù)據(jù)庫集群中對應(yīng)數(shù)據(jù)源的路由信息，具體包括：

采用哈希計算的方法為該新增用戶自動計算出一個在所述數(shù)據(jù)庫集群中對應(yīng)數(shù)據(jù)源的路由信息，所述路由信息包括該數(shù)據(jù)源的地址、端口號和數(shù)據(jù)庫名。

7.一種數(shù)據(jù)庫處理裝置，其特征在于，該裝置用于處理包含二個以上數(shù)據(jù)庫的數(shù)據(jù)庫集群，該裝置主要包括：

注解模塊，用于在業(yè)務(wù)邏輯中通過注解的方式標示當(dāng)前業(yè)務(wù)事務(wù)類型；

第一存儲處理模塊，用于在收到數(shù)據(jù)存儲請求后，確定該數(shù)據(jù)存儲請求中的用戶標識，如果是新增用戶，則計算該新增用戶在所述數(shù)據(jù)庫集群中對應(yīng)數(shù)據(jù)源的路由信息，將路由信息存儲在路由服務(wù)中；如果是已有用戶，則從所述路由服務(wù)中獲取該用戶對應(yīng)的數(shù)據(jù)源的路由信息；

第二存儲處理模塊，用于根據(jù)當(dāng)前用戶對應(yīng)的路由信息，確定對應(yīng)的數(shù)據(jù)源；

第三存儲處理模塊，用于判斷當(dāng)前業(yè)務(wù)的事務(wù)類型，如果是單庫事務(wù)，則獲取本地事務(wù)管理器，利用該本地事務(wù)管理器，將所述數(shù)據(jù)存儲請求中的數(shù)據(jù)存儲到當(dāng)前用戶對應(yīng)的路由信息所確定的數(shù)據(jù)源中；如果是跨庫事務(wù)，則獲取分布式事務(wù)管理器，利用該分布式事務(wù)管理器，將所述數(shù)據(jù)存儲請求中的數(shù)據(jù)存儲到當(dāng)前用戶對應(yīng)的路由信息所確定的數(shù)據(jù)源中。

8.根據(jù)權(quán)利要求7所述的裝置，其特征在于，所述裝置進一步包括：

第一查詢模塊，用于在收到數(shù)據(jù)查詢請求后，確定該數(shù)據(jù)查詢請求中的用戶標識，從所述路由服務(wù)中獲取該用戶對應(yīng)的數(shù)據(jù)源的路由信息；

第二查詢模塊，用于根據(jù)所述用戶的路由信息，確定對應(yīng)的數(shù)據(jù)源；

第三查詢模塊，用于根據(jù)所述數(shù)據(jù)查詢請求，從所述數(shù)據(jù)源中查詢數(shù)據(jù)。