增量同步的方式有很多種，我使用的是: 快照表 + 觸發(fā)器
需求：

當(dāng)主庫(kù)庫(kù)表發(fā)生增刪改時(shí)，從庫(kù)庫(kù)表與主庫(kù)庫(kù)表數(shù)據(jù)保持一致。

環(huán)境：
1、Mysql
2、kettle 7.1

思路：

1、在主庫(kù)中，將需要同步的庫(kù)表新建快照表，表結(jié)構(gòu)一致。

#創(chuàng)建同步臨時(shí)表(insert) DROP TABLE IF EXISTS brch_temp_insert; CREATE TABLE brch_temp_insert like brch;#創(chuàng)建同步臨時(shí)表(delete) DROP TABLE IF EXISTS brch_temp_delete; CREATE TABLE brch_temp_delete like brch;#創(chuàng)建同步臨時(shí)表(update) DROP TABLE IF EXISTS brch_temp_update; CREATE TABLE brch_temp_update like brch;

2、在主庫(kù)中，分別新增庫(kù)表的增、刪、改的觸發(fā)器。

#創(chuàng)建同步表觸發(fā)器(insert) DROP TRIGGER IF EXISTS tri_insert_brch; CREATE TRIGGER tri_insert_brch AFTER INSERT ON brch FOR EACH ROW BEGINinsert into brch_temp_insert( ROW_ID,BRCH_ID,BRCH_NAME) values(new.ROW_ID,new.BRCH_ID,new.BRCH_NAME); END;#創(chuàng)建同步表觸發(fā)器(delete) DROP TRIGGER IF EXISTS tri_delete_brch; CREATE TRIGGER tri_delete_brch AFTER delete ON brch FOR EACH ROW BEGINinsert into brch_temp_delete(ROW_ID) values(old.ROW_ID); END;#創(chuàng)建同步表觸發(fā)器(update) DROP TRIGGER IF EXISTS tri_update_brch; CREATE TRIGGER tri_update_brch AFTER update ON brch FOR EACH ROW BEGINinsert into brch_temp_update(ROW_ID,BRCH_ID,BRCH_NAME) values(new.ROW_ID,new.BRCH_ID,new.BRCH_NAME); END;

2、新建一個(gè)轉(zhuǎn)換，該轉(zhuǎn)換只針對(duì)一張表的增刪改。

3、新建‘表輸入’控件，查詢主庫(kù)的快照表

4、新建‘插入/更新’控件，插入數(shù)據(jù)到從庫(kù)的庫(kù)表，查詢的關(guān)鍵字要求唯一。

5、新建‘刪除’控件，將主庫(kù)的快照表中的數(shù)據(jù)刪除。

注意：主庫(kù)的庫(kù)表，要新增針對(duì)增、刪、改的三張表快照，三張表的步驟同上面的1 - 5 一致。

6、新建作業(yè)控件

分別將三個(gè)轉(zhuǎn)換引用進(jìn)來(lái)。

7、配置發(fā)送郵件服務(wù)

8、完成

總結(jié)

以上是生活随笔為你收集整理的增量同步_使用Kettle工具进行增量数据同步的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。