[發明專利]數據遷移的方法和裝置

在審

• 申請號: 201910576913.0
• 申請日: 2019-06-28
• 公開（公告）號: CN112148705A
• 公開（公告）日: 2020-12-29
• 發明（設計）人: 張棟芳;黃寶祥
• 申請（專利權）人: 京東數字科技控股有限公司
• 主分類號: G06F16/21
• 分類號: G06F16/21;G06F16/25
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 馮培培;耿雪利

1.一種數據遷移的裝置，其特征在于，包括：

遷移前置模塊，用于監聽遷移請求信息，根據所述遷移請求信息生成遷移任務，并將遷移前置模塊生成的遷移任務寫入至所述遷移任務表；

任務獲取模塊，用于掃描所述遷移任務表，獲取所述遷移表中待處理的遷移任務，將所述遷移任務發送至遷移模塊；

遷移模塊，用于根據所述遷移任務獲取源賬戶的源數據，將所述源數據以目標賬戶數據存儲的形式存儲在目標賬戶下。

2.根據權利要求1所述的裝置，其特征在于，根據所述遷移請求信息生成遷移任務，包括：

根據所述遷移請求信息，查詢分布式集群統一配置的遷移表；

組裝所述遷移請求信息和在所述遷移表查詢到的數據，生成遷移任務；

其中，遷移請求信息，包括：源賬戶信息、目標賬戶信息、遷移請求號。

3.根據權利要求1所述的裝置，其特征在于，所述任務獲取模塊，還用于：將所述遷移任務發送至遷移工具之后，采用樂觀鎖將已經寫入所述遷移任務表的遷移任務的狀態設置為已發送。

4.根據權利要求1所述的裝置，其特征在于，所述遷移模塊，還用于：將所述源數據以目標賬戶的形式存儲在目標賬戶下之前，

分別定位所述遷移任務對應的源賬戶的源數據庫和源數據表、目標賬戶的目標數據庫和目標數據表；

分別計算源賬戶數據庫和數據表信息、目標賬戶的數據庫和數據表信息；和/或，

將源賬戶、目標賬戶的數據庫連接信息保存到當前線程的變量中。

5.根據權利要求1所述的裝置，其特征在于，根據所述遷移任務獲取源賬戶的源數據，將所述源數據以目標賬戶的形式存儲在目標賬戶下，包括：

根據所述遷移任務對源賬戶的待遷移數據進行分頁數據抽取；

將抽取到的所述分頁數據以目標賬戶的形式進行數據轉換；

將所述數據轉換的結果存儲在目標賬戶下。

6.根據權利要求1所述的裝置，其特征在于，還包括遷移校驗模塊，用于：

判斷遷移前的源賬戶與遷移后的目標賬戶的數據總量是否一致；

若數據總量不一致，則重新將所述源數據以目標賬戶的形式存儲在目標賬戶下；

若數據總量一致，則比較所述源賬戶與所述目標賬戶配置的特殊字段總額是否一致；

若所述特殊字段總額一致，則說明所述源賬戶與所述目標賬戶的數據一致；若所述特殊字段總額不一致，則重新將所述源數據以目標賬戶的形式存儲在目標賬戶下。

7.一種數據遷移的方法，其特征在于，包括：

遷移前置模塊監聽遷移請求信息，根據所述遷移請求信息生成遷移任務，并將生成的遷移任務寫入至所述遷移任務表；

任務獲取模塊掃描所述遷移任務表，獲取所述遷移表中待處理的遷移任務，將所述遷移任務發送至遷移模塊；

遷移模塊根據所述遷移任務獲取源賬戶的源數據，將所述源數據以目標賬戶數據存儲的形式存儲在目標賬戶下。

8.根據權利要求7所述的方法，其特征在于，根據所述遷移請求信息生成遷移任務，包括：

根據所述遷移請求信息，查詢分布式集群統一配置的遷移表；

組裝所述遷移請求信息和在所述遷移表查詢到的數據，生成遷移任務；

其中，遷移請求信息，包括：源賬戶信息、目標賬戶信息、遷移請求號。

9.根據權利要求7所述的方法，其特征在于，將所述遷移任務發送至遷移工具之后，采用樂觀鎖將已經寫入所述遷移任務表的遷移任務的狀態設置為已發送。

10.根據權利要求7所述的方法，其特征在于，將所述源數據以目標賬戶的形式存儲在目標賬戶下之前，

分別定位所述遷移任務對應的源賬戶的源數據庫和源數據表、目標賬戶的目標數據庫和目標數據表；

分別計算源賬戶數據庫和數據表信息、目標賬戶的數據庫和數據表信息；和/或，

將源賬戶、目標賬戶的數據庫連接信息保存到當前線程的變量中。