前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >在Kettle里使用参照表进行数据校验(子转换实现)

在Kettle里使用参照表进行数据校验(子转换实现)

作者头像
用户1148526
发布2019-05-25 19:42:57
1.8K0
发布2019-05-25 19:42:57
举报
文章被收录于专栏:Hadoop数据仓库Hadoop数据仓库

有一种参照表叫数据确认主表。性别编码就是这种参照表的例子。有的系统使用字母M、F和U,分别代表男、女、未知;有的系统使用NULL来代表未知的性别;有的系统使用Male和Female代表男、女;而有的系统则使用完全不同的编码,如0(男)、1(女)或0(未知)、1(男)、2(女),等等。还有更复杂的情况,有的系统使用C代表儿童,使用F代表父亲,M代表母亲,各种变化和组合都有可能。要把从这些来源的数据整合到一起,要有一套统一的编码规范,然后把已有的编码映射到规范的编码上。使用单一的查询表比每个系统都有一个查询表要更好,便于维护。这里要满足两个基本的需求:

  • 源系统中的每个可能的值都需要映射
  • 要映射到唯一的一组值。

基于前面说的性别的例子,需要建立下面的主表。ref_code和ref_name字段,是要获取的标准数据,src_system字段是数据来源于哪个应用或系统,src_code字段包含了这个系统里可能的值。

代码语言:javascript
复制
create table lkp_codes (  
    id int primary key,  
    ref_code varchar(1),  
    ref_name varchar(10),  
    src_system varchar(10),  
    src_code varchar(10)  
)  engine=myisam;  
  
insert into lkp_codes values(1,'M','Male','Sales','1');  
insert into lkp_codes values(2,'F','Female','Sales','2');  
insert into lkp_codes values(3,'M','Male','Web','male');  
insert into lkp_codes values(4,'F','Female','Web','female');  
insert into lkp_codes values(5,'M','Male','CRM','F');  
insert into lkp_codes values(6,'F','Female','CRM','M');  
insert into lkp_codes values(7,'U','Unknown','CRM','C');  

为了便于查询,数据是以非正规的结构来组织。但这种结构适合要求,而且容易查询,根据源系统的名称和原始的数据,就能查询到标准的三个值:M、F、U。 主转换流程的结构如下:

要给子转换步骤定义一个变量,在映射步骤“参数”标签下设置变量。在这个例子里,把值为Web的变量传递给子转换genderlookup。

子转换流程的结构如下:

在子转换里使用这个变量:

子转换里的流查询步骤非常简单:只需设置好条件,输入数据的src_code1等于参照表的src_code字段,并指定要返回的字段即可。注意这里必须要设置一个默认值,来处理NULL和未知的值。完整的流查询步骤如下:

说明:原始数据里可能会包含NULL值,但NULL并不是数据库里的一个真正的值。NULL=NULL这样的比较条件也不会成功。这就是为什么没有把对NULL值的匹配放到参照表里,以及为什么在流查询步骤里一定要设置一个默认值的原因。

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2016年12月26日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档