[發明專利]數據核對方法及裝置

有效

• 申請號: 202010129012.X
• 申請日: 2020-02-28
• 公開（公告）號: CN111339100B
• 公開（公告）日: 2023-05-26
• 發明（設計）人: 梁雄;葉建鋒;林海;吳海彬
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/23;G06F16/27;G06F11/36
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 王濤;孫乳筍

1.一種數據核對方法，其特征在于，包括：

獲取主機的表和表中更新的字段；

對更新的所述字段進行排列，對排列后的字段進行賦值得到更新的記錄值；使用主機的時間戳并按照排列順序對字段進行賦值；

基于所述記錄值的索引字段分別查詢主機的表中該索引字段對應的記錄值和平臺的表中該索引字段對應的記錄值；

根據所述主機的表中該索引字段對應的記錄值和所述平臺的表中該索引字段對應的記錄值進行核對。

2.根據權利要求1所述的數據核對方法，其特征在于，在所述基于所述記錄值的索引字段分別查詢主機的表中該索引字段對應的記錄值和平臺的表中該索引字段對應的記錄值之后，還包括：

查詢所述索引字段在平臺的表的記錄中對應字段的時間戳，若所述時間戳與主機當前時間戳的差值大于預設值，則對KAFKA消息隊列進行檢查。

3.根據權利要求2所述的數據核對方法，其特征在于，在所述基于所述記錄值的索引字段分別查詢主機的表中該索引字段對應的記錄值和平臺的表中該索引字段對應的記錄值之后，還包括：

查詢所述索引字段在平臺的表的記錄中對應字段的時間戳，若查詢不到索引字段在平臺的表的記錄中對應字段的時間戳，則對KAFKA消息隊列進行檢查。

4.根據權利要求1所述的數據核對方法，其特征在于，所述根據所述主機的表中該索引字段對應的記錄值和所述平臺的表中該索引字段對應的記錄值進行核對，包括：

將所述主機表中的記錄值的字段類型和所述平臺表中的記錄值的字段類型進行轉換；

將轉換后的所述主機表中的記錄值的字段與所述平臺表中的記錄值的字段進行比對，并存儲比對結果。

5.根據權利要求1所述的數據核對方法，其特征在于，更新的所述字段的類型為時間戳類型或字符型。

6.根據權利要求1所述的數據核對方法，其特征在于，所述排列為升序排列。

7.根據權利要求1所述的數據核對方法，其特征在于，所述索引字段為單一索引字段或多列索引字段。

8.一種數據核對裝置，其特征在于，包括：

自定義單元，用于獲取主機的表和表中更新的字段；

解析執行單元，用于對更新的所述字段進行排列，對排列后的字段進行賦值得到更新的記錄值；使用主機的時間戳并按照排列順序對字段進行賦值；

解析查詢單元，用于基于所述記錄值的索引字段分別查詢主機的表中該索引字段對應的記錄值和平臺的表中該索引字段對應的記錄值；

對比核對單元，用于根據所述主機的表中該索引字段對應的記錄值和所述平臺的表中該索引字段對應的記錄值進行核對。

9.根據權利要求8所述的數據核對裝置，其特征在于，還包括：

第一環境處理單元，用于查詢所述索引字段在平臺的表的記錄中對應字段的時間戳，若所述時間戳與主機當前時間戳的差值大于預設值，則對KAFKA消息隊列進行檢查。

10.根據權利要求9所述的數據核對裝置，其特征在于，還包括：

第二環境處理單元，用于查詢所述索引字段在平臺的表的記錄中對應字段的時間戳，若查詢不到索引字段在平臺的表的記錄中對應字段的時間戳，則對KAFKA消息隊列進行檢查。

11.根據權利要求8所述的數據核對裝置，其特征在于，所述對比核對單元包括：

轉換子單元，用于將所述主機表中的記錄值的字段類型和所述平臺表中的記錄值的字段類型進行轉換；

比對子單元，用于將轉換后的所述主機表中的記錄值的字段與所述平臺表中的記錄值的字段進行比對，并存儲比對結果。

12.根據權利要求8所述的數據核對裝置，其特征在于，更新的所述字段的類型為時間戳類型或字符型。