? ? ? ? ? ? ? ? ? ? ? ?Kettle使用_10 存儲過程與命名參數

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

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

Step1:新建一個轉換。

Step2:拖一個獲取變量組件到轉換，該組件位于轉換的作業分類下。

Step3：配置獲取變量組件

Step4：在數據庫里編寫存儲過程（這里以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;

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

Step6：SHIFT連接組件獲取變量、DB存儲過程。

Step7：右鍵轉換設置命名參數默認值。(選作)

Step8：運行轉換并給命名參數賦值。

Step9：數據查看執行結果

完整流程示意：

總結

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

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