? ? ? ? ? ? ? ? ? ? ? ? Kettle使用_8 存儲過程結合獲取系統(tǒng)信息

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

解決方法：結合獲取系統(tǒng)信息(設置參數名)和DB存儲過程（指定數據庫連接和參數）組件解決。

Step1:新建一個轉換。

Step2: 拖動一個獲取系統(tǒng)信息到轉換里，該組件位于轉化的輸入分類下。

Step3：配置獲取系統(tǒng)信息組件（這里配置了兩個參數，詳見需求部分。）

Step4：拖動查詢分類下的DB存儲過程組件

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

Step6：配置DB存儲過程組件

新建數據庫連接示意：

Step7：按住SHIFT連接獲取系統(tǒng)信息組件和DB存儲過程組件。

Step8：點擊執(zhí)行轉換。

Step9：數據庫里驗證結果。

完整流程示意：

總結

以上是生活随笔為你收集整理的Kettle使用_8 存储过程结合获取系统信息的全部內容，希望文章能夠幫你解決所遇到的問題。

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