kettle连接组件应用示例

创立表

CREATE TABLE `test_a` (

  `id` int(11) NOT NULL,

  `name` varchar(255) DEFAULT NULL,

  PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE TABLE `test_b` (

  `id` int(11) NOT NULL,

  `email` varchar(255) DEFAULT NULL,

  PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

创立转换，添加数据源

文件->新建->转换

右键新建数据源

添加两个表输入

填写数据源和sql

增加一个连接，随意选择一种，不同组件略有不同

选择连接字段和连接方式，相似我们写sql的join

会提醒连接前请先排序，那么如果两个排序组件

根据连接字段排序

创立接收的目标表

CREATE TABLE `test_c` (

  `id` int(11) NOT NULL,

`name` varchar(255) DEFAULT NULL,

  `email` varchar(255) DEFAULT NULL,

  PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

添加表输出

添加测试数据

执行脚本看看结果

完成， 提醒，每一步中的填写字段时可以先获取字段再修改，这样输入比较快速，

到这里就基本完成了，假如要完美一下，比方这个脚本假如重复执行一定会报错，那么怎样办呢？可以执行之前再加一个删除c表中已有数据的操作，也可以执行表输入的时候先查询c表再对已有数据进行跟新或者插入（这种方式效率较前者慢）

# 欢迎关注我的公众号“java工会”，与君共勉