[發(fā)明專利]DB2數(shù)據(jù)庫數(shù)據(jù)同步更新方法及設備

有效

• 申請?zhí)枺?/td>: 201811219296.0
• 申請日: 2018-10-19
• 公開（公告）號: CN109271452B
• 公開（公告）日: 2021-04-13
• 發(fā)明（設計）人: 付銓;孫峰;趙家威
• 申請（專利權）人: 武漢達夢數(shù)據(jù)庫有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23;G06F16/242
• 代理公司: 武漢智嘉聯(lián)合知識產權代理事務所(普通合伙) 42231
• 代理人: 黃君軍

1.一種DB2數(shù)據(jù)庫數(shù)據(jù)同步更新方法，其特征在于，包括：

在目標端數(shù)據(jù)庫，根據(jù)待同步更新表創(chuàng)建數(shù)據(jù)詳細地址存儲列，在源端數(shù)據(jù)庫，對所述待同步更新表上S鎖，獲取源端DB2數(shù)據(jù)庫當前的日志序列號LSN作為所述待同步更新表的起始LSN，釋放S鎖；獲取所述待同步更新表的結果集，將所述結果集發(fā)送至目標端數(shù)據(jù)庫入庫，再次獲取源端DB2數(shù)據(jù)庫當前LSN作為所述待同步更新表的結束LSN；

在目標端數(shù)據(jù)庫，接收源端同步更新服務發(fā)送的初始化數(shù)據(jù)，將所述待同步更新表中的數(shù)據(jù)及數(shù)據(jù)詳細地址ROWID組成INSERT語句，并在目標端數(shù)據(jù)庫中將ROWID插入所述數(shù)據(jù)詳細地址存儲列，完成所述待同步更新表的數(shù)據(jù)初始化；在源端數(shù)據(jù)庫，若所述結束LSN大于等于所述起始LSN，啟動數(shù)據(jù)實時同步更新服務，將源端DB2數(shù)據(jù)庫的變化發(fā)送至目標端數(shù)據(jù)庫進行數(shù)據(jù)同步更新；

其中，所述數(shù)據(jù)詳細地址存儲列用于存儲源端數(shù)據(jù)庫中的ROWID，所述結果集中包括所述源端數(shù)據(jù)庫中的ROWID；

所述啟動數(shù)據(jù)實時同步更新服務，將源端DB2數(shù)據(jù)庫的變化發(fā)送至目標端數(shù)據(jù)庫，包括：

捕獲并分析源端數(shù)據(jù)庫日志，將源端DB2數(shù)據(jù)庫的增刪變化進行轉換，將轉換后的結果通過TCP/IP網絡發(fā)送至目標端數(shù)據(jù)庫；

所述捕獲并分析源端數(shù)據(jù)庫日志，將源端DB2數(shù)據(jù)庫的增刪變化進行轉換，包括：

將INSERT語句轉換成DELETE語句及新的INSERT語句；

所述將INSERT語句轉換成DELETE及新的INSERT語句，包括：

在源端數(shù)據(jù)庫構造附帶ROWID的DELETE語句發(fā)送至目標端數(shù)據(jù)庫進行同步更新服務，在目標端數(shù)據(jù)庫的同步更新表中刪除所述ROWID對應的記錄，將所述新的INSERT語句發(fā)送至目標端數(shù)據(jù)庫進行同步更新服務，將所述ROWID插入所述數(shù)據(jù)詳細地址存儲列。

2.根據(jù)權利要求1所述的DB2數(shù)據(jù)庫數(shù)據(jù)同步更新方法，其特征在于，所述數(shù)據(jù)詳細地址存儲列的形式包括：隱藏列或普通列。

3.根據(jù)權利要求1所述的DB2數(shù)據(jù)庫數(shù)據(jù)同步更新方法，其特征在于，所述啟動數(shù)據(jù)實時同步更新服務，將源端DB2數(shù)據(jù)庫的變化發(fā)送至目標端數(shù)據(jù)庫進行數(shù)據(jù)同步更新，包括：

同步更新UPDATE語句，根據(jù)源端數(shù)據(jù)庫的值更新目標端數(shù)據(jù)庫中的相應記錄。

4.根據(jù)權利要求1所述的DB2數(shù)據(jù)庫數(shù)據(jù)同步更新方法，其特征在于，所述啟動數(shù)據(jù)實時同步更新服務，將源端DB2數(shù)據(jù)庫的變化發(fā)送至目標端數(shù)據(jù)庫進行數(shù)據(jù)同步更新，包括：

同步更新DELETE語句，根據(jù)源端數(shù)據(jù)庫的值刪除目標端數(shù)據(jù)庫中的相應記錄。