前言
这并不是一篇入门教学,且不是一篇高阶教学,仅仅针对kettle的database join。
那么问题来了,kettle的database join是什么?简而言之,不同库之间sql语句传值(个人自定义,如有不当,请海涵)。
案例1——一条数据传值
数据库A中有一张学生表student,表中有一个字段最近更新时间(last_update_date),数据库B中有一张教师表teacher,同样有一个字段(last_update_date),现在需要根据学生表的最近更新时间增量获取教师表数据,即获取教师表中大于学生表MAX(last_update_date)的数据。
方案如下:
- 获取学生表MAX(last_update_date),即表输入1的sql语句为:
select
IFNULL(MAX(last_update_date),STR_TO_DATE('1970101','%Y%m%d'))
FROM student
- 将表输入1获取的查询结果传给表输入2,即表输入2的sql语句为
select * from teacher
where last_update_date >= ?
且在表输入2的sql下方"从步骤输入数据"一栏,填写表输入1的步骤名称。