? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?Kettle使用_26 根據增刪改標識處理數據

?

需求：已知數據的狀態標簽（insert、update、delete）利用kettle對其進行相應的操作。

解決方法：主要通過過濾記錄組件來解決如上問題。

Previous work:

數據庫（以mysql為例）里準備源數據，表結構與數據見下：

DROP TABLE tb_user; CREATE TABLE tb_user( id integer, name varchar(12) );TRUNCATE TABLE tb_user; INSERT INTO tb_user VALUES(1,'上海'); INSERT INTO tb_user VALUES(2,'北京'); INSERT INTO tb_user VALUES(3,'深圳');

Step1：新建個轉換

Step2：拖個自定義常量組件，并定義結構和數據。

元數據：

數據：

Step3：拖個過濾記錄組件，命名為“是否新增”，通過SHIFT使得自定義數據常量與該組件關聯，并配置過濾記錄如下：

配置過濾記錄（這里的刪除標記字段和是否刪除分別對應下文的組件），該組件命名為“是否新增“：

Step4：拖個字段選擇組件，命名為刪除標記字段，并配置選擇字段組件。再拖個文本文件輸出組件，并配置。

SHIFT連接是否新增與刪除標記字段組件，注意這里是為TRUE時選擇。

在移除里配置字段名

配置文本文件輸出路徑和字段。

Step5：同理拖個過濾記錄，其名稱為“是否刪除”，

Step6：拖個刪除組件，該組件位于轉換的輸出分類下，SHIFT連接“是否刪除組件”與刪除組件。

Step7：同理拖個過濾記錄，其名稱為“是否更新”，SHIFT連接“是否刪除“與該組件，并配置如下：

Step8：拖個更新組件，該組件位于轉換的輸出分類下，SHIFT連接“是否更新”與更新組件。配置更新組件見下：

Step9：保存、運行、驗證該轉換。

完整的流程示意見下：

總結

以上是生活随笔為你收集整理的Kettle使用_26 根据增删改标识处理数据的全部內容，希望文章能夠幫你解決所遇到的問題。

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