关键的步骤就只有这一个:
说明:
1)数据读取里面的SQL查询,可引用传入数据流的结果集中的列;
2)也可以引用全局的一些变量设置。
后面是一个具体的配置例子,我们如何用etl实现这样一个循环:
元数据:
drop table if exists test1;
drop table if exists test2;
create table test1(v1 int);
create table test2(v1 int);
insert into test1 select level from dual connect by level<=10;
commit;
insert into test2 select level from dual connect by level<=10;
commit;
要实现的逻辑:
begin
for rs in (select v1 from test1) loop
insert into test2 select v1*3 from test2 where v1=rs.v1;
end loop;
end;
使用ETL实现这个逻辑的步骤:
具体步骤操作如下:
视频播放地址
文章
阅读量
获赞