[發(fā)明專利]分布式異構(gòu)數(shù)據(jù)庫系統(tǒng)的數(shù)據(jù)同步方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201910084472.2
• 申請(qǐng)日: 2019-01-29
• 公開（公告）號(hào): CN109885617A
• 公開（公告）日: 2019-06-14
• 發(fā)明（設(shè)計(jì)）人: 沈贇;翁曉俊;劉雪晶;王能
• 申請(qǐng)（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27
• 代理公司: 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127
• 代理人: 王天堯;任默聞

1.一種分布式異構(gòu)數(shù)據(jù)庫系統(tǒng)的數(shù)據(jù)同步方法，其特征在于，包括：

獲取一組或多組操作指令和操作信息，將所述操作指令和操作信息發(fā)送至第一數(shù)據(jù)庫集群，所述操作指令包括：插入數(shù)據(jù)、更新數(shù)據(jù)或刪除數(shù)據(jù)，所述操作信息包括：操作位置與數(shù)據(jù)值；

接收第一數(shù)據(jù)庫集群根據(jù)每組操作指令和操作信息修改對(duì)應(yīng)操作位置處的數(shù)據(jù)后返回的操作結(jié)果；

根據(jù)各操作結(jié)果，將對(duì)應(yīng)的操作指令和操作信息打包為消息發(fā)出，所述消息用于對(duì)第二數(shù)據(jù)庫集群中對(duì)應(yīng)的操作位置進(jìn)行數(shù)據(jù)同步。

2.如權(quán)利要求1所述的方法，其特征在于，所述操作位置包括：應(yīng)用名，數(shù)據(jù)表名和字段名。

3.如權(quán)利要求1所述的方法，其特征在于，根據(jù)各操作結(jié)果，將對(duì)應(yīng)的操作指令和操作信息打包為消息發(fā)出，包括：

接收第一類型數(shù)據(jù)庫系統(tǒng)返回的操作結(jié)果；

若操作位置處的數(shù)據(jù)已成功修改，將對(duì)應(yīng)的操作指令和操作信息打包為消息；

若操作位置處的數(shù)據(jù)未成功修改，則向第一類型數(shù)據(jù)庫系統(tǒng)發(fā)送操作失敗指令，用于第一數(shù)據(jù)庫集群在接收到操作失敗指令后重新根據(jù)操作指令和操作信息修改對(duì)應(yīng)操作位置處的數(shù)據(jù)；

繼續(xù)按上述方法進(jìn)行判斷，并統(tǒng)計(jì)操作失敗指令的發(fā)送次數(shù)，若次數(shù)達(dá)到預(yù)設(shè)閾值，停止判斷，將操作指令和操作信息寫入錯(cuò)誤日志。

4.如權(quán)利要求1所述的方法，其特征在于，還包括：

獲取一組或多組操作指令和操作信息之后，生成每組操作指令和操作信息對(duì)應(yīng)的操作時(shí)間戳；

將已成功修改的操作位置處的數(shù)據(jù)對(duì)應(yīng)的操作指令和操作信息以及操作時(shí)間戳打包為消息。

5.一種分布式異構(gòu)數(shù)據(jù)庫系統(tǒng)的數(shù)據(jù)同步方法，其特征在于，包括：

獲取設(shè)定數(shù)量的消息，所述消息包括操作指令和操作信息，所述操作指令和操作信息與第一數(shù)據(jù)庫集群的操作結(jié)果相對(duì)應(yīng)，所述操作結(jié)果為第一數(shù)據(jù)庫集群根據(jù)每組操作指令和操作信息修改對(duì)應(yīng)操作位置處的數(shù)據(jù)后返回的；

對(duì)同一操作位置的消息進(jìn)行合并，根據(jù)合并后的消息對(duì)第二類型數(shù)據(jù)庫系統(tǒng)中對(duì)應(yīng)的操作位置進(jìn)行數(shù)據(jù)同步。

6.如權(quán)利要求5所述的方法，其特征在于，所述消息還包括操作時(shí)間戳；

按如下步驟對(duì)同一操作位置的消息進(jìn)行合并：

獲取各消息操作信息中的操作位置；

將操作位置相同的消息合并，并按操作時(shí)間戳的先后順序進(jìn)行排列。

7.一種分布式異構(gòu)數(shù)據(jù)庫系統(tǒng)的數(shù)據(jù)同步裝置，其特征在于，包括：

操作獲取模塊，用于獲取一組或多組操作指令和操作信息，將所述操作指令和操作信息發(fā)送至第一數(shù)據(jù)庫集群，所述操作指令包括：插入數(shù)據(jù)、更新數(shù)據(jù)或刪除數(shù)據(jù)，所述操作信息包括：操作位置與數(shù)據(jù)值；

結(jié)果接收模塊，用于接收第一數(shù)據(jù)庫集群根據(jù)每組操作指令和操作信息修改對(duì)應(yīng)操作位置處的數(shù)據(jù)后返回的操作結(jié)果；

消息發(fā)送模塊，用于根據(jù)各操作結(jié)果，將對(duì)應(yīng)的操作指令和操作信息打包為消息發(fā)出，所述消息用于對(duì)第二數(shù)據(jù)庫集群中對(duì)應(yīng)的操作位置進(jìn)行數(shù)據(jù)同步。

8.一種分布式異構(gòu)數(shù)據(jù)庫系統(tǒng)的數(shù)據(jù)同步裝置，其特征在于，包括：

消息接收模塊，用于獲取設(shè)定數(shù)量的消息，所述消息包括操作指令和操作信息，所述操作指令和操作信息與第一數(shù)據(jù)庫集群的操作結(jié)果相對(duì)應(yīng)，所述操作結(jié)果為第一數(shù)據(jù)庫集群根據(jù)每組操作指令和操作信息修改對(duì)應(yīng)操作位置處的數(shù)據(jù)后返回的；

數(shù)據(jù)同步模塊，用于對(duì)同一操作位置的消息進(jìn)行合并，根據(jù)合并后的消息對(duì)第二類型數(shù)據(jù)庫系統(tǒng)中對(duì)應(yīng)的操作位置進(jìn)行數(shù)據(jù)同步。

9.一種計(jì)算機(jī)設(shè)備，包括存儲(chǔ)器、處理器及存儲(chǔ)在存儲(chǔ)器上并可在處理器上運(yùn)行的計(jì)算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)權(quán)利要求1至6任一所述方法。

10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)存儲(chǔ)有執(zhí)行權(quán)利要求1至6任一所述方法的計(jì)算機(jī)程序。