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 存储过程与设置变量相关推荐

kettle设置变量中变量范围的设置说明
kettle设置变量中变量范围的设置说明变量类型的作用域范围 "设置变量"插件中的"变量类型"有四个选项对应着四个不同的作用域范围"s" ...
Kettle使用_10 存储过程与命名参数
Kettle使用_10 存储过程与命名参数需求: 通过传递给kettle位置参数的方式执行存储过程.其中存储过程的需求是往tb_user(字段user_id, name)里插入一条记录(覆盖式,即有 ...
Kettle使用_8 存储过程结合获取系统信息
Kettle使用_8 存储过程结合获取系统信息需求: 通过传递给kettle位置参数的方式执行存储过程.其中存储过程的需求是往tb_user(字段user_id, name)里插入一条记录(覆盖式, ...
mysql 存储过程如何声明多个变量赋值_mysql存储过程：定义变量，赋值，判断，输出...
1.定义变量,赋值,判断,输出 DROP PROCEDURE IF EXISTS proc_first; -- 如果proc_first存在就删除 create procedure proc_firs ...
mysql声明存储过程_MySQL 声明变量及存储过程分析
声明变量设置全局变量 set @a='一个新变量'; 在函数和储存过程中使用的变量declear declear a int unsigned default 1; 这种变量需要设置变量类型而且只 ...
oracle存储过程、声明变量、for循环|转|
oracle存储过程.声明变量.for循环 1.创建存储过程 create or replace procedure test(var_name_1 in type,var_name_2 out ty ...
oracle存储过程、声明变量、for循环（转）
oracle存储过程.声明变量.for循环 1.创建存储过程 create or replace procedure test(var_name_1 in type,var_name_2 out ty ...
oracle的存储过程替换,为什么在存储过程中，变量替换无法使用索引？
CREATE OR REPLACE PROCEDURE ss(eff_day VARCHAR2) -- eff_day 统计日期,格式为 'yyyymmdd' AS v_year INT ...
Set集合设置变量自增长
* 在jsp页面中,有时候需要设置变量进行自增长,像java中的i++, 1)设置变量,<s:set name="abc" value="0">&l ...

Kettle使用_9 存储过程与设置变量

Kettle使用_9 存储过程与设置变量

Kettle使用_9 存储过程与设置变量相关推荐

最新文章

热门文章