[發明專利]基于Oracle的數據同步方法、裝置及計算機設備

在審

• 申請號: 202011191712.8
• 申請日: 2020-10-30
• 公開（公告）號: CN112307121A
• 公開（公告）日: 2021-02-02
• 發明（設計）人: 周毅
• 申請（專利權）人: 中國平安人壽保險股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/22;G06F16/23;G06F16/242
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 李翔宇

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

實時檢測消息隊列集群中是否從Oracle數據庫中讀取到增量日志數據；

若消息隊列集群中從Oracle數據庫中讀取到增量日志數據，消費所述消息隊列集群中的增量日志數據；

解析獲取所述增量日志數據中的增量數據，將所述增量數據依次進行特殊字符處理和類型轉換，以得到處理后增量數據，將所述處理后增量數據發送至Ignite集群進行存儲；

若當前系統時間與上一數據異步傳輸時間之間的時間間隔等于預設的數據異步傳輸周期，調用本地預先存儲的SQL語句，通過所述SQL語句從Oracle數據庫中讀取對應的待同步數據；以及

獲取Ignite集群的目標Ignite節點中的備用表區域，將所述待同步數據發送至備用表區域。

2.根據權利要求1所述的基于Oracle的數據同步方法，其特征在于，所述解析獲取所述增量日志數據中的增量數據，包括：

獲取所述增量日志數據中的目標表名稱、數據操作類型及目標數據，根據所述目標表名稱、數據操作類型及目標數據獲取增量數據。

3.根據權利要求1所述的基于Oracle的數據同步方法，其特征在于，所述將所述增量數據依次進行特殊字符處理和類型轉換，以得到處理后增量數據，包括：

調用預先存儲的特殊字符集合，獲取所述特殊字符集合中包括的特殊字符；

判斷所述增量數據中是否包括所述特殊字符集合中的特殊字符；

若所述增量數據中包括所述特殊字符集合中的特殊字符，獲取對應的目標特殊字符集，將目標特殊字符集中每一目標特殊字符之前自動增加\以進行轉義，得到轉義處理后增量數據；

獲取所述轉義處理后增量數據中數字數據類型和日期數據類型，將所述轉義處理后增量數據中數字數據類型和日期數據類型軍轉換成java數字數據類型和java日期數據類型，以得到處理后增量數據。

4.根據權利要求1所述的基于Oracle的數據同步方法，其特征在于，所述獲取Ignite集群的目標Ignite節點中的備用表區域，將所述待同步數據發送至備用表區域，包括：

將所述待同步數據進行數據清洗，以更新待同步數據；

獲取本地存儲的字段映射表，根據所述字段映射表獲取所述待同步數據中各字段在備用表區域中對應的待寫入表字段，以生成當前SQL語句；

根據所述當前SQL語句將所述待同步數據寫入至備用表區域。

5.根據權利要求4所述的基于Oracle的數據同步方法，其特征在于，所述根據所述當前SQL語句將所述待同步數據寫入至備用表區域之后，還包括：

若接收到備用表區域對應的Ignite節點發送的同步失敗通知信息，將待同步數據進行回滾后發送至備用表區域。

6.根據權利要求4所述的基于Oracle的數據同步方法，其特征在于，所述根據所述當前SQL語句將所述待同步數據寫入至備用表區域之后，還包括：

若接收到備用表區域對應的Ignite節點發送的同步成功通知信息，判斷是否接收到Ignite節點發送的備用表區域狀態切換為生效表區域的切換通知信息；

若接收到Ignite節點發送的備用表區域狀態切換為生效表區域的切換通知信息，將所述待同步數據發送至待刪除區域進行存儲。

7.根據權利要求4所述的基于Oracle的數據同步方法，其特征在于，所述將所述待同步數據進行數據清洗，以更新待同步數據，包括：

獲取所述待同步數據中的殘缺數據及缺失數據，以存儲至非有效數據表；

將所述待同步數據中的殘缺數據及缺失數據進行刪除，以更新待同步數據。