主庫為Oracle 11g數據庫，針對需要同步的表建立增量數據臨時表以及反向并通過水壺定時同步到PostgreSQL數據庫
。1，主庫創建快照表和快照
注意：快照表結構和源表結構必須一致！

--創建插入快照表 CREATE TABLE SPWUSER.WEB_CUSTOMER_INSERT_TMP (ID NUMBER NOT NULL,NAME VARCHAR2(128 BYTE) NOT NULL,CREATED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL,MODIFIED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL ); --創建更新快照表 CREATE TABLE SPWUSER.WEB_CUSTOMER_UPDATE_TMP (ID NUMBER NOT NULL,NAME VARCHAR2(128 BYTE) NOT NULL,CREATED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL,MODIFIED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL ); --創建刪除快照表 CREATE TABLE SPWUSER.WEB_CUSTOMER_DELETE_TMP (ID NUMBER NOT NULL,NAME VARCHAR2(128 BYTE) NOT NULL,CREATED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL,MODIFIED TIMESTAMP(6) WITH LOCAL TIME ZONE DEFAULT (current_timestamp) NOT NULL ); --創建插入觸發器 CREATE OR REPLACE TRIGGER SPWUSER.WEB_CUSTOMER_INSERT_TRIAFTER INSERTON SPWUSER.WEB_CUSTOMERFOR EACH ROW BEGININSERT INTO WEB_CUSTOMER_INSERT_TMP (ID,NAME,CREATED,MODIFIED)VALUES (:new.id,:new.name,:new.created,:new.modified); END; / --創建刪除觸發器 CREATE OR REPLACE TRIGGER SPWUSER.WEB_CUSTOMER_DELETE_TRIAFTER DELETEON SPWUSER.WEB_CUSTOMERFOR EACH ROW BEGININSERT INTO WEB_CUSTOMER_DELETE_TMP (ID,NAME,CREATED,MODIFIED)VALUES (:old.ID,:old.NAME,:old.created,:old.modified); END; / --創建更新觸發器 CREATE OR REPLACE TRIGGER SPWUSER.WEB_CUSTOMER_UPDATE_TRIAFTER UPDATEON SPWUSER.WEB_CUSTOMERFOR EACH ROW BEGININSERT INTO WEB_CUSTOMER_UPDATE_TMP (ID,NAME,CREATED,MODIFIED)VALUES (:old.ID,:old.NAME,:old.created,:old.modified); END; /

2，創建一個針對表增刪改改的轉換
從kettle菜單中依次選擇“文件”->“新建”->“轉換”或按ctrl + N快捷鍵創建。然后依次選擇“輸入”->“表輸入”，“輸出”->“插入/更新”和“輸出”->“刪除”，執行三次，如下圖所示：

3，“表輸入”控件，查詢主庫（Oracle）的快照表

4，“插入/更新”控件，插入數據到從庫（PostgreSQL）的表，查詢的關鍵字要求唯一

5，“刪除”控件，將主庫的快照表中的數據刪除

6，新建“作業”控件
新建作業控件，將三個轉換引用起來，總覽如下圖所示：

插入轉換：

更新轉換：

刪除轉換：

發送郵件：

總結

以上是生活随笔為你收集整理的kettle 先删除后插入_Kettle:使用触发器和快照表进行增量数据同步的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。