? ? ? ? ? ? ? ? ? ? ? ?Kettle使用_9 存儲過程與設置變量

需求: 通過傳遞給kettle位置參數的方式執行存儲過程。其中存儲過程的需求是往tb_user（字段user_id, name）里插入一條記錄(覆蓋式，即有則刪除；參數是用戶id和用戶名)。

解決方法：結合設置變量(設置參數名)和DB存儲過程（指定數據庫連接和參數）組件解決。

Step1:新建一個轉換。

Step2: 拖動一個表輸入或者自定義常量組件到轉換里，該組件位于轉換的輸入分類下。

Step3: 配置表輸入組件，自定義常量較為簡單，這里用的是表輸入。其中SQL編輯器區域可以寫從某個表讀取參數值，這里寫的固定值。即user_id=3000,name=300$。

Step4:拖個設置變量組件，并將表輸入通過SHIFT連接。

Step5:配置設置變量。

Step6：在數據庫里編寫存儲過程（這里以Mysql為例）

DROP PROCEDURE IF EXISTS kettlexp.sp_adduser_v2; CREATE PROCEDURE kettlexp.`sp_adduser_v2`( IN userid int,v_name varchar(100)) BEGINDELETE FROM tb_user WHERE id = userid AND name = v_name;INSERT INTO tb_user(id,name) VALUES(userid,v_name);commit; END;

Step7：拖并配置DB存儲過程組件。

Step8：SHIFT連接組件設置變量、DB存儲過程。

Step9：點擊運行該轉換

Step10：數據庫查看結果

完整流程示意：

總結

以上是生活随笔為你收集整理的Kettle使用_9 存储过程与设置变量的全部內容，希望文章能夠幫你解決所遇到的問題。

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