[發明專利]數據同步方法、系統、電子設備及存儲介質

在審

• 申請號: 202210109449.6
• 申請日: 2022-01-28
• 公開（公告）號: CN114490878A
• 公開（公告）日: 2022-05-13
• 發明（設計）人: 劉釗;李仰招;陳喆
• 申請（專利權）人: 中國農業銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/242;G06F9/54
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 李興福;劉芳

1.一種數據同步系統，其特征在于，包括：

第一數據庫、所述第一數據庫的第一控制設備、消息隊列服務器、至少一個第二數據庫，以及每個所述第二數據庫的第二控制設備；所述第一控制設備通過所述消息隊列服務器連接所述第二控制設備；

所述第一控制設備被配置為，獲取執行第一功能時所需的至少一條SQL語句；確定所述至少一條SQL語句的屬性信息；將每一條SQL語句存入與該條SQL語句的屬性信息對應的存儲空間中，其中，所述第一控制設備包括多個存儲空間，每個存儲空間用于存儲一種屬性信息的SQL語句；當確定所述第一控制設備成功執行所述第一功能，向所述消息隊列服務器發送所述多個存儲空間中的SQL語句；

所述消息隊列服務器被配置為，接收所述第一控制設備發送的所述多個存儲空間中的SQL語句，將所述SQL語句存入與所述多個存儲空間一一對應的消息隊列中；根據所述第二控制設備的訂閱信息，向所述第二控制設備發送與所述訂閱信息對應的至少一個消息隊列中的SQL語句；

所述第二控制設備被配置為，當接收到所述消息隊列服務器發送的至少一個消息隊列，執行所述至少一個消息隊列中的SQL語句。

2.根據權利要求1所述的數據同步系統，其特征在于，

所述屬性信息包括：所述第一數據庫執行所述SQL語句時所進行的數據操作信息和所在的數據表信息；

所述第一控制設備具體被配置為，當所述SQL語句的數據操作信息為對數據進行的增加、刪除和修改操作，將所述SQL語句存入與所述數據表信息對應的存儲空間中；其中，每個存儲空間用于存儲一個數據表信息的SQL語句。

3.根據權利要求1或2所述的數據同步系統，其特征在于，所述第一控制設備具體被配置為，

通過面向切面編程實現的環繞切面是否發送異常指示，確定所述第一控制設備是否成功執行所述第一功能；其中，所述環繞切面用于所述第一控制設備未能成功執行多個功能后分別發送異常指示。

4.根據權利要求1所述的數據同步系統，其特征在于，所述第一控制設備還被配置為，

當確定未能成功向所述消息隊列服務器發送所述多個存儲空間中的SQL語句，間隔預設時間后，再次向所述消息隊列服務器發送所述多個存儲空間中的SQL語句。

5.根據權利要求4所述的數據同步系統，其特征在于，所述第一控制設備具體被配置為，

當確定未能成功向所述消息隊列服務器發送所述多個存儲空間中的SQL語句，將SQL語句存入其他存儲空間，并將所述其他存儲空間中的SQL語句標記為第一狀態，同時刪除前述多個存儲空間中的SQL語句，間隔預設時間后，向所述消息隊列服務器發送所述其他存儲空間中標記為所述第一狀態的所述帶有屬性信息的SQL語句；當確定成功向所述消息隊列服務器發送所述SQL語句后，將所述SQL語句標記為第二狀態；

當確定成功向所述消息隊列服務器發送所述多個存儲空間中的SQL語句，將所述多個存儲空間中的SQL語句刪除。

6.根據權利要求2所述的數據同步系統，其特征在于，所述第一控制設備具體被配置為，

當確定所述第一控制設備成功執行所述第一功能，判斷所述多個存儲空間中是否存在SQL語句；

當所述多個存儲空間中存在SQL語句，向所述消息隊列服務器發送所述多個存儲空間中的SQL語句。

7.根據權利要求1所述的數據同步系統，其特征在于，所述第一控制設備還被配置為，

獲取配置信息，并根據所述配置信息確定所述SQL語句的屬性信息，以及確定當所述SQL語句滿足的預設條件后，將所述SQL語句存入所述屬性信息對應的存儲空間中。