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

有效

• 申請號: 201610875651.4
• 申請日: 2016-09-30
• 公開（公告）號: CN107016014B
• 公開（公告）日: 2020-08-04
• 發明（設計）人: 張銳;劉銀
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 李輝;劉飛

1.一種異構數據庫的數據同步方法，其特征在于，包括以下步驟：

在基于預設的第一數據同步機制，將源數據庫中預定范圍的數據同步至目標數據庫的過程中，檢測所述第一數據同步機制的狀態；

當所述第一數據同步機制的狀態異常時，啟用第二數據同步機制，以將所述源數據庫中預定范圍的數據同步至所述目標數據庫；

其中，所述第一數據同步機制，包括：

通過數據同步中心DRC監聽所述源數據庫的日志文件，以從所述日志文件中獲取所述源數據庫中預定范圍的數據，然后將其同步至所述目標數據庫；

所述啟用第二數據同步機制，包括：

接收分布式資源管理DRM平臺推送的數據同步任務；所述數據同步任務包括數據恢復時間點及所述源數據庫中的待同步數據庫表的標識；

根據所述待同步數據庫表的標識，從該待同步數據庫表中定時撈取，其創建時間點晚于所述數據恢復時間點的所有數據放入臨時列表，并將所述臨時列表中的數據插入所述目標數據庫中對應的數據庫表。

2.根據權利要求1所述的異構數據庫的數據同步方法，其特征在于，還包括：

所述的定時撈取中，除首次撈取的撈取范圍為待同步數據庫表中，其創建時間晚于所述數據恢復時間點的所有數據外，其后每次撈取的撈取范圍為創建時間晚于上一次撈取的截止時間的所有數據。

3.根據權利要求1所述的異構數據庫的數據同步方法，其特征在于，所述的定時撈取是在每次接收到，由調度中心定時發送的驅動消息時觸發的。

4.根據權利要求1所述的異構數據庫的數據同步方法，其特征在于，在所述第二數據同步機制下，當所述源數據庫中的待同步數據庫表有多個時，并行處理每個待同步數據庫表的同步，或者根據預設的數據同步優先級處理每個待同步數據庫表的同步。

5.根據權利要求1所述的異構數據庫的數據同步方法，其特征在于，在所述的插入之前，還包括：

判斷所述目標數據庫中對應的數據庫表中，是否已存所述臨時列表中的數據；

如果不存在，則將所述臨時列表中的數據插入所述目標數據庫中對應的數據庫表。

6.根據權利要求5所述的異構數據庫的數據同步方法，其特征在于，還包括：

如果所述目標數據庫中對應的數據庫表內已存在所述臨時列表中的數據，則忽略該數據。

7.根據權利要求1所述的異構數據庫的數據同步方法，其特征在于，在將所述臨時列表中的數據插入所述目標數據庫中對應的數據庫表之后，還包括：

清空所述臨時列表。

8.根據權利要求7所述的異構數據庫的數據同步方法，其特征在于，所述的數據恢復時間點包括以下中的任意一種：

所述DRC最近一次成功同步數據時的時間點；

所述DRC發生異常時的時間點；

在所述DRC發生異常時的時間點的基礎上，向前偏移指定時間后的時間點。

9.一種異構數據庫的數據同步裝置，其特征在于，包括：

同步狀態檢測模塊，用于在基于預設的第一數據同步機制，將源數據庫中預定范圍的數據同步至目標數據庫的過程中，檢測所述第一數據同步機制的狀態；

同步機制替換模塊，用于當所述第一數據同步機制的狀態異常時，啟用第二數據同步機制，以將所述源數據庫中預定范圍的數據同步至所述目標數據庫；

其中，所述同步狀態檢測模塊，包括：

監聽子模塊，用于通過數據同步中心DRC監聽所述源數據庫的日志文件，以從所述日志文件中獲取所述源數據庫中預定范圍的數據，然后將其同步至所述目標數據庫；

所述同步機制替換模塊，包括：

任務接收子模塊，用于接收分布式資源管理DRM平臺推送的數據同步任務；所述數據同步任務包括數據恢復時間點及所述源數據庫中的待同步數據庫表的標識；

數據同步子模塊，用于根據所述待同步數據庫表的標識，從該待同步數據庫表中定時撈取，其創建時間點晚于所述數據恢復時間點的所有數據放入臨時列表，并將所述臨時列表中的數據插入所述目標數據庫中對應的數據庫表。