1.使用方法
通过该组件可直接调用执行数据库中编写好的存储过程。一般情况下存储过程组件可单独使用,不依赖其他的组件。
2.使用场景
首先需要在数据库中创建一个存储过程,不同的数据库存储过程的创建语法不一致。此处以PG数据库为例。
CREATE OR REPLACE PROCEDURE ZC.InsertData(
p_Column1Value IN VARCHAR2,
p_Column2Value IN NUMBER
)
AS
BEGIN
INSERT INTO PROCEDURE_TABLE (NAME,ID) VALUES (p_Column1Value, p_Column2Value);
COMMIT;
END;
该存储过程的作用是向PROCEDURE_TABLE 该表中插入一条数据,参数p_Column1Value对应的name字段,参数p_Column2Value对应的id字段。
创建好存储过程后,进入ETL页面选择存储过程组件。选择刚创建的存储过程PROCEDURE,由于存储过程中存在参数,所以在的ETL任务中也可以设置两个参数,用于参数值的传递。
选择对应的存储过程后,我们产品会对该存储过程进行解析,自动识别里面的参数,我们可以在参数列表页面查看存储过程中的参数,我们需要对这些参数设置一些特定的值。此处我们使用宏表达式给参数赋值,见下图。
编辑好后,我们运行该ETL任务,运行完成后可去指定的库表中查看PROCEDURE_TABLE 该表,检查数据是否成功的插入。
注意:
1.不同版本不同类型的数据库存储过程的调用方法不一致,当存储过程组件遇到没有兼容的数据库版本时,我们可以通过sql组件,通过手动编写调用存储过程的sql语句来进行变通解决。
2.存储过程组件暂不支持输出类型的参数的使用。
请先登录