[發明專利]數據庫數據遷移方法、裝置以及存儲介質

在審

• 申請號: 202011247564.7
• 申請日: 2020-11-10
• 公開（公告）號: CN112306994A
• 公開（公告）日: 2021-02-02
• 發明（設計）人: 薛高飛;曾平
• 申請（專利權）人: 北京沃東天駿信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F16/21
• 分類號: G06F16/21;G06F16/22;G06F16/245;G06F16/27
• 代理公司: 中國貿促會專利商標事務所有限公司 11038
• 代理人: 方亮

1.一種數據庫數據遷移方法，包括：

配置源數據庫表和目標數據庫表之間的數據映射信息；

在源數據庫和目標數據庫提供服務的狀態下，基于所述數據映射信息將所述源數據庫表中的數據同步在所述目標數據庫表中；

在所述源數據庫表和所述目標數據庫表之間進行數據同步操作后，對所述源數據庫表和所述目標數據庫表中的數據進行校驗處理，基于校驗結果判斷所述數據同步操作是否正確并進行相應的處理；

在判斷所述數據同步操作正確后，基于所述數據映射信息將所述目標數據庫表中的新增數據同步在所述源數據庫表中。

2.如權利要求1所述的方法，還包括：

配置所述源數據庫和所述目標數據庫的數據鏈接配置信息；

基于所述數據鏈接配置信息分別配置源數據庫連接池、目標數據庫鏈接池，用以分別存放源數據庫鏈接、目標數據庫鏈接。

3.如權利要求2所述的方法，其中，所述數據鏈接配置信息包括：數據庫類型、鏈接地址、連接字符串以及數據庫用戶名密碼；所述基于所述數據鏈接配置信息分別配置源數據庫連接池、目標數據庫鏈接池包括：

創建所述源數據庫連接池和所述目標數據庫鏈接池，并確定最大數據庫連接數；

基于所述數據鏈接信息以及所述最大數據庫連接數，分別生成所述源數據庫鏈接和所述目標數據庫鏈接，并分別放入所述源數據庫連接池和所述目標數據庫鏈接池中。

4.如權利要求2所述的方法，其中，所述數據映射信息包括：數據表之間的對應關系和數據表字段之間的映射關系；所述基于所述數據映射信息將所述源數據庫表中的數據同步在所述目標數據庫表中包括：

使用所述源數據庫連接池中的源數據庫鏈接和所述目標數據庫鏈接池中的目標數據庫鏈接，基于所述數據映射信息將所述源數據庫表中的數據同步在所述目標數據庫表中。

5.如權利要求4所述的方法，所述使用所述源數據庫連接池中的源數據庫鏈接和所述目標數據庫鏈接池中的目標數據庫鏈接，基于所述數據映射信息將所述源數據庫表中的數據同步在所述目標數據庫表中包括：

配置與所述源數據庫表相對應的數據同步頻率信息；

生成與所述源數據庫表相對應的第一任務，基于所述數據同步頻率信息設置所述第一任務的執行頻率；其中，使用與所述源數據表相對應的線程執行所述第一任務；

基于所述第一任務從所述目標數據庫鏈接池中獲取目標數據庫鏈接，使用獲取的目標數據庫鏈接獲取需要同步的數據信息；

基于所述第一任務從所述源數據庫連接池中獲取源數據庫鏈接，使用獲取的源數據庫鏈接并基于所述需要同步的數據信息從所述源數據庫表中獲取需要同步的數據；

使用獲取的目標數據庫鏈接并基于所述數據映射信息，將所述需要同步的數據插入所述目標數據庫表中。

6.如權利要求5所述的方法，所述使用獲取的目標數據庫鏈接獲取需要同步的數據信息包括：

使用獲取的目標數據庫鏈接查詢與所述目標數據庫表中數據記錄相對應的最大ID值；

所述使用獲取的源數據庫鏈接并基于所述需要同步的數據信息從所述源數據庫表中獲取需要同步的數據包括：

使用獲取的源數據庫鏈接從所述源數據庫表中獲取數據記錄ID值大于所述最大ID值的數據，作為所述需要同步的數據。

7.如權利要求5所述的方法，還包括：

獲取所述源數據庫和所述目標數據庫之間的字段類型轉換信息；

在將所述需要同步的數據插入所述目標數據庫表中時，基于所述字段類型轉換信息對所述需要同步的數據進行類型轉換處理。