kettle 教程(三):条件判断 Switch Case

介绍

Switch / Case,顾名思义,类似 Java 中的 Switch / Case,用于进行条件判断。是 kettle 中一个非常常用组件。

使用起来也非常简单,我们直接来看例子。

场景介绍

有一个 user 表,表中数据如下:

我们需要对 code 字段进行判断,如果不为空,则将数据同步到 user_copy 表(表结构相同);如果 code 为空,则记录一条错误记录,错误记录表 error_info 结构如下:

转换

整体的流程如下:

表输入:

Switch / Case :

可以看到 Switch 字段为 code,类型为 String 。如果值为空,则执行SQL,默认是插入更新。

插入更新:

执行 SQL 脚本:

可以看到下面勾选了“执行每一行“,意思就是:前一个步骤的每一行数据都要执行一次 SQL 。如果不勾选,则意思就是:前一个步骤不管有多少条数据,只执行一次 SQL 。下面传入了一个参数 id,用来替换 SQL 中的 ?。

运行结果:

user_copy 表:

error_info 表:

可以看到,一共 10 条数据,其中 7 条 code 不为空的进入了 user_copy 表,3 条 code 为空的进了异常表。

总结

Switch / Case 组件用于条件判断,可以根据 Case 值走不同的分支。是 kettle 中一个非常基础又重要的组件。

本作品采用知识共享署名-非商业性使用-禁止演绎 3.0 未本地化版本许可协议进行许可。 打赏

微信 支付宝 支付宝领红包

如果觉得我的文章对您有用,请随意赞赏~

发表评论

电子邮件地址不会被公开。 必填项已用*标注