? ? ? ? ? ? ? ? ? ? ? ?Kettle使用_10 存儲(chǔ)過(guò)程與命名參數(shù)

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

解決方法：結(jié)合獲取變量(設(shè)置參數(shù)名)和DB存儲(chǔ)過(guò)程（指定數(shù)據(jù)庫(kù)連接和參數(shù)）組件解決。

Step1:新建一個(gè)轉(zhuǎn)換。

Step2:拖一個(gè)獲取變量組件到轉(zhuǎn)換，該組件位于轉(zhuǎn)換的作業(yè)分類下。

Step3：配置獲取變量組件

Step4：在數(shù)據(jù)庫(kù)里編寫存儲(chǔ)過(guò)程（這里以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存儲(chǔ)過(guò)程組件。

Step6：SHIFT連接組件獲取變量、DB存儲(chǔ)過(guò)程。

Step7：右鍵轉(zhuǎn)換設(shè)置命名參數(shù)默認(rèn)值。(選作)

Step8：運(yùn)行轉(zhuǎn)換并給命名參數(shù)賦值。

Step9：數(shù)據(jù)查看執(zhí)行結(jié)果

完整流程示意：

總結(jié)

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

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