[發明專利]一種數據存儲方法、裝置、系統及介質

有效

• 申請號: 201910554958.8
• 申請日: 2019-06-25
• 公開（公告）號: CN110245148B
• 公開（公告）日: 2021-03-23
• 發明（設計）人: 李楊;閆旭;楊得力;牛魏書;霍浩
• 申請（專利權）人: 河南中原消費金融股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06F16/28
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 丁曼曼

1.一種數據存儲方法，其特征在于，應用于同步數據庫，包括：

預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致；

判斷是否滿足預設的存儲觸發條件；

如果是，則停止所述數據同步操作，并將本地的當前數據作為時點數據以供數據倉庫獲取并存儲；

其中，在所述預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致之前，所述方法還包括：

判斷是否所述同步數據庫與所述源系統數據庫之間的SQL語法兼容且所述源系統數據庫中執行的SQL語句未包含有函數；

如果是，則所述預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致，包括：

預先通過獲取并執行所述源系統數據庫中執行的SQL語句，保持與所述源系統數據庫中的數據一致；

否則，所述預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致，包括：

預先通過解析所述源系統數據庫的日志獲取并執行相應的數據庫操作邏輯，保持與所述源系統數據庫中的數據一致。

2.根據權利要求1所述的數據存儲方法，其特征在于，所述判斷是否滿足預設的存儲觸發條件包括：

判斷當前時刻是否處于目標時刻點，或判斷是否傳入有觸發指令。

3.根據權利要求1所述的數據存儲方法，其特征在于，當所述同步數據庫以及所述源系統數據庫均為Oracle類型的數據庫時，所述預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致，包括：

預先基于OGG工具執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致。

4.根據權利要求1至3任意一項所述的數據存儲方法，其特征在于，在所述停止所述數據同步操作，并將本地的當前數據作為時點數據以供數據倉庫獲取并存儲之后，所述方法還包括：

當接收到由所述數據倉庫傳入的存儲結束指令時，執行與所述源系統數據庫的所述數據同步操作，并保持與所述源系統數據庫中的數據一致。

5.一種同步數據庫裝置，其特征在于，包括：

存儲器，用于存儲計算機程序；

處理器，用于執行所述計算機程序時實現如權利要求1至4任一項所述的數據存儲方法的步驟。

6.一種數據存儲系統，其特征在于，包括：

源系統數據庫裝置；

同步數據庫裝置，用于預先執行與所述源系統數據庫裝置的數據同步操作，保持與所述源系統數據庫裝置中的數據一致；判斷是否滿足預設的存儲觸發條件；如果是，則停止所述數據同步操作，并將本地的當前數據作為時點數據以供數據倉庫裝置獲取并存儲；其中，在所述預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致之前，還包括：

判斷是否所述同步數據庫與所述源系統數據庫之間的SQL語法兼容且所述源系統數據庫中執行的SQL語句未包含有函數；

如果是，則所述預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致，包括：

預先通過獲取并執行所述源系統數據庫中執行的SQL語句，保持與所述源系統數據庫中的數據一致；

否則，所述預先執行與源系統數據庫的數據同步操作，保持與所述源系統數據庫中的數據一致，包括：

預先通過解析所述源系統數據庫的日志獲取并執行相應的數據庫操作邏輯，保持與所述源系統數據庫中的數據一致；

所述數據倉庫裝置，用于判斷是否滿足預設的所述存儲觸發條件；如果是，則獲取并存儲所述同步數據庫裝置本地的當前數據。

7.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序被處理器執行時實現如權利要求1至4任一項所述的應用于同步數據庫的數據存儲方法的步驟。