Kettle 中的循环

说道循环，小伙伴们肯定不陌生，就是重复干一件事；而kettle中的循环一般是发生在job中，因为job是串行执行的；

kettle的循环有两种，一种是通过js脚本，另外一种是通过遍历前面步骤返回的每一行。

下面是我写的伪代码，我将使用Kettle来实现这段代码：

array = [‘sys1‘,‘sys2‘,‘sys3‘,‘sys4‘]

for variable in array:
     if variable == ‘sys1‘ :
         print(‘%s被调用‘%(variable,))

     elif variable == ‘sys2‘ :
         print(‘%s被调用‘%(variable,))

     elif variable == ‘sys3‘ :
         print(‘%s被调用‘%(variable,))

     elif variable == ‘sys4‘ :
         print(‘%s被调用‘%(variable,))

     else :
         print(‘没有被调用‘)

代码里循环变量是variable，用for遍历完整个数组，则表示循环结束。

循环体中有一组判断条件，判断数组中的元素归于哪一个分支。

如果所有判断条件都不符合，则打印“没有被调用”

1. Kettle作业介绍

schedule_job.kjb ：用来关联循环变量和循环体的作业，也是调用的入口，可以理解main

get_data_from_datagrid.ktr ：生成数组，也就是循环条件。

cycle_body_job.kjb ：循环体，数组里有几条数据，循环体就执行几次。

2. 下图是 schedule_job 的结构，它的作用是连接循环条件和循环体，所以这个作业中包含其他两个步骤