kettle 教程(三):条件判断 Switch Case
我的博客原文地址:http://www.yujunyi.com/kettle/590.html
欢迎访问
介绍
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 中一个非常基础又重要的组件。