[發明專利]數據同步的方法及裝置

有效

• 申請號: 201710861912.1
• 申請日: 2017-09-21
• 公開（公告）號: CN110019507B
• 公開（公告）日: 2021-06-08
• 發明（設計）人: 陳熹榮
• 申請（專利權）人: 北京國雙科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 北京鼎佳達知識產權代理事務所(普通合伙) 11348
• 代理人: 王偉鋒;劉鐵生

1.一種數據同步的方法，其特征在于，所述方法包括：

獲取待同步的第一表格和第二表格的邏輯結構，所述第一表格為可寫集群中的表格，所述第二表格為可讀集群中與所述第一表格的表格名稱相同的表格；

逐行對比所述第一表格和所述第二表格中的字段；

根據當前對比的行所屬的行類型以及對比結果，確定所述第一表格中當前對比的行相對于所述第二表格中當前對比的行的行特征，所述行類型包括常規字段行和分區字段行，所述行特征包括修改后的行、增加的行以及未修改的行；

若所述行特征是所述修改后的行，則將所述第一表格中當前對比的行和所述第二表格中當前對比的行對應記錄到修改表中；

若所述行特征是所述增加的行，則將所述第一表格中當前對比的行記錄到增加表中；

基于所述修改表和所述增加表對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步；

基于所述修改表和所述增加表對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步包括：

基于所述修改表創建修改語句，基于所述增加表創建增加語句；

通過執行所述修改語句和所述增加語句對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步；

在通過執行所述修改語句和所述增加語句對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步之前，所述方法還包括：

輸出所述修改語句、所述增加語句、所述第一表格和所述第二表格，以供用戶確認；

通過執行所述修改語句和所述增加語句對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步包括：

當接收到確認指令后，通過執行所述修改語句和所述增加語句對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步。

2.根據權利要求1所述的方法，其特征在于，根據當前對比的行所屬的行類型以及對比結果，確定所述第一表格中當前對比的行相對于所述第二表格中當前對比的行的行特征包括：

若當前對比的兩行相同，則確定所述行特征是所述未修改的行；

若當前對比的兩行存在不同，且當前對比的兩行均屬于常規字段行，則確定所述行特征是所述修改后的行；

若所述第二表格中當前對比的行屬于分區字段行，且所述第一表格中當前對比的行屬于常規字段行，則確定所述行特征是所述增加的行。

3.根據權利要求1至2中任一項所述的方法，其特征在于，獲取待同步的第一表格和第二表格的邏輯結構包括：

通過desc命令獲取所述第一表格和所述第二表格的schema結構。

4.一種數據同步的裝置，其特征在于，所述裝置包括：

獲取單元，用于獲取待同步的第一表格和第二表格的邏輯結構，所述第一表格為可寫集群中的表格，所述第二表格為可讀集群中與所述第一表格的表格名稱相同的表格；

對比單元，用于逐行對比所述第一表格和所述第二表格中的字段；

確定單元，用于根據當前對比的行所屬的行類型以及對比結果，確定所述第一表格中當前對比的行相對于所述第二表格中當前對比的行的行特征，所述行類型包括常規字段行和分區字段行，所述行特征包括修改后的行、增加的行以及未修改的行；

記錄單元，用于當所述行特征是所述修改后的行時，將所述第一表格中當前對比的行和所述第二表格中當前對比的行對應記錄到修改表中；

所述記錄單元還用于當所述行特征是所述增加的行時，將所述第一表格中當前對比的行記錄到增加表中；

處理單元，用于基于所述修改表和所述增加表對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步；

所述處理單元包括：

創建模塊，用于基于所述修改表創建修改語句，基于所述增加表創建增加語句；

處理模塊，用于通過執行所述修改語句和所述增加語句對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步；

所述處理單元還包括：

輸出模塊，用于在通過執行所述修改語句和所述增加語句對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步之前，輸出所述修改語句、所述增加語句、所述第一表格和所述第二表格，以供用戶確認；

所述處理模塊，用于當接收到確認指令后，通過執行所述修改語句和所述增加語句對所述第二表格進行處理，以使得所述第二表格與所述第一表格同步。