這篇文章主要為大家展示了“POSTGRESQL  CDC怎么用”，內(nèi)容簡(jiǎn)而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“POSTGRESQL  CDC怎么用”這篇文章吧。

創(chuàng)新互聯(lián)建站堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：網(wǎng)站建設(shè)、網(wǎng)站設(shè)計(jì)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的杞縣網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

首先 POSTGRESQL 本身的復(fù)制方式有流式復(fù)制和邏輯復(fù)制兩種，今天要說(shuō)的就是邏輯復(fù)制中的CDC功能。而實(shí)施CDC POSTGRESQL 要具備兩個(gè)功能，1 獲取數(shù)庫(kù)的變更日志(WAL) 和  獲取變更日志前的數(shù)據(jù)一致性快照，最后要保存消費(fèi)者的偏移量。而提到邏輯復(fù)制，是從PG10開(kāi)始的新功能。

1 先通過(guò)一個(gè)實(shí)踐來(lái)看看什么叫PG的 CDC （以忽略部分?jǐn)?shù)據(jù)庫(kù)基礎(chǔ)設(shè)置）

首先我們先要?jiǎng)?chuàng)建一個(gè)邏輯復(fù)制槽，并且使用系統(tǒng)給定的一個(gè)test_decoding的解碼插件。

創(chuàng)建完復(fù)制槽后，我們開(kāi)始一些相關(guān)的數(shù)據(jù)庫(kù)操作，從下圖可以看出想的DDL 操作并沒(méi)有解析，僅僅是記錄了begin commit  

我們來(lái)在做做 DML操作，明顯相關(guān)的記錄可以被解碼并且可以看出數(shù)據(jù)庫(kù)剛才在操作了什么。

當(dāng)然具體的使用我們還需要使用 pg_recvlogical 來(lái)進(jìn)行數(shù)據(jù)的捕捉和更多的應(yīng)用，如果直接將這些輸出output  到動(dòng)態(tài)的文件中，那一個(gè)數(shù)據(jù)庫(kù)的CDC的記錄就有了。以后在發(fā)現(xiàn)數(shù)據(jù)庫(kù)哪個(gè)表里面的記錄不對(duì)，就可用這樣的方法早做日志進(jìn)行記錄。

同時(shí)我們也可以更換邏輯復(fù)制槽中的解碼工具，我們看一下，在PG中輸入的數(shù)據(jù)，經(jīng)過(guò)邏輯復(fù)制槽后，直接解碼為為 JSON 的數(shù)據(jù)

當(dāng)然如果我們使用了其他的解析插件的情況下，還可以將語(yǔ)句直接翻譯過(guò)來(lái)，如果保留這些語(yǔ)句，可以自己做一個(gè)類(lèi)似于UNDO 的東西，將已經(jīng)執(zhí)行的語(yǔ)句，進(jìn)行回滾，從中也更加理解了 data pipleline 中為什么對(duì)傳統(tǒng)數(shù)據(jù)庫(kù)要設(shè)置主鍵，這樣可能方便捕獲的數(shù)據(jù)進(jìn)行一個(gè)更新或者判斷插入或更新等等的操作。

通過(guò)上圖，其實(shí)我們就可以建立一個(gè)自己簡(jiǎn)易的CDC 系統(tǒng)，通過(guò)記錄如果表的設(shè)計(jì)上在完整一些，CDC 的一個(gè)日志系統(tǒng)將會(huì)為POSTGRESQL 數(shù)據(jù)庫(kù)的數(shù)據(jù)任意時(shí)間點(diǎn)的數(shù)據(jù) UNDO ，作為一個(gè)強(qiáng)有力的支持。

以上是“POSTGRESQL  CDC怎么用”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！