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

我的博客原文地址:http://www.yujunyi.com/kettle/590.html
欢迎访问

介绍

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

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

场景介绍

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

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

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

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

转换

整体的流程如下:

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

表输入:

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

Switch / Case :

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

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

插入更新:

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

执行 SQL 脚本:

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

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

运行结果:

user_copy 表:

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

error_info 表:

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

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

总结

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