6.1Kettle多数据源合并

一.数据准备

二.建立转换添加控件

三.配置控件

1.“CSV文件输入”控件配置

2.“字段选择”控件配置

3.“表输入”控件配置

4.“排序合并”控件配置

5.“增加序列”控件配置

6.“字段选择2”控件配置

7.“表输出”控件配置

四.配置完成并运行

一.数据准备

通过Kettle工具将A公司和B公司的手机日销售数据合并到一个数据源（数据表company）中，也就是对文件company_a.csv和数据表company_b中的数据进行合并操作，并输出到数据表company中。

Kettle安装:Kettle7.0安装_keykongbai的博客-CSDN博客

company表：

CREATE TABLE company
(salesArea VARCHAR(4)
, brand VARCHAR(4)
, model VARCHAR(37)
, unitPrice BIGINT
, number BIGINT
, id INT
)
;

company_b表：

create table `company_b` (`id` INT,`salesArea` varchar (150),`brand` varchar (150),`model` varchar (150),`unitPrice` INT,`number` INT
);
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('1','北京市','华为','华为nova 5 Pro（8GB/128GB/全网通）','2999','31');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('2','山西省','苹果','苹果iPhone 11（4GB/64GB/全网通）','5499','20');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('3','河北省','OPPO','OPPO Reno2（8GB/128GB/全网通）','2999','27');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('4','黑龙江省','华为','华为Mate30（8GB/128GB/全网通/5G版/玻璃版）','4999','34');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('5','陕西省','vivo','vivo iQOO Pro（8GB/128GB/5G全网通）','3798','38');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('6','北京市','vivo','vivo NEX 3（8GB/128GB/全网通）','4998','26');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('7','天津市','苹果','苹果iPhone 11 Pro Max（6GB/64GB/全网通）','9599','18');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('8','重庆市','小米','小米9（8GB/256GB/全网通）','2999','26');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('9','四川省','苹果','苹果iPhone 11 Pro Max（6GB/64GB/全网通）','9599','35');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('10','陕西省','小米','小米9 Pro（8GB/256GB/全网通/5G版）','3799','39');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('11','上海市','华为','华为Mate 20 X（8GB/256GB/全网通/5G版）','6199','42');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('12','北京市','三星','三星Galaxy S10+（8GB RAM/陶瓷版/全网通）','7499','27');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('13','河北省','苹果','苹果iPhone 11（4GB/128GB/全网通）','5999','20');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('14','浙江省','苹果','苹果iPhone 11（4GB/256GB/全网通）','6799','29');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('15','天津市','小米','小米9 Pro（8GB/256GB/全网通/5G版）','3799','35');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('16','上海市','华为','华为Mate30（8GB/128GB/全网通/5G版/玻璃版）','4999','30');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('17','重庆市','苹果','苹果iPhone 11（4GB/64GB/全网通）','5499','38');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('18','山东省','华为','华为Mate30 Pro（8GB/128GB/全网通）','5799','20');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('19','陕西省','小米','小米MIX 3（6GB RAM/全网通）','2299','33');
insert into `company_b` (`id`, `salesArea`, `brand`, `model`, `unitPrice`, `number`) values('20','山西省','华为','华为Mate30 Pro（8GB/256GB/全网通/5G版/玻璃版）','6899','20');

company_a.csv：

二.建立转换添加控件

三.配置控件

1.“CSV文件输入”控件配置

双击进入配置页面，点击浏览添加company_a.csv，点击获取字段获取处理文件的字段内容，如下图：

预览记录：

2.“字段选择”控件配置

双击进入配置页面，点击右侧获取选择的字段，添加字段，如下图：

点击元数据选项，点击右侧获取改变的字段，添加字段，如下图：

3.“表输入”控件配置

注：在配置这个控件时要注意连接到数据库，并准备好company_b这张表

双击进入配置页面添加如下字段，可以点击右侧获取SQL查询语句自动添加，如下图：

4.“排序合并”控件配置

双击进入配置页面，手动添加如下字段：

5.“增加序列”控件配置

双击进入配置界面，配置如下图：

6.“字段选择2”控件配置

双击进入配置页面，点击选择和修改，点击获取选择的字段，添加字段，将valuename 改为id，如下图：

7.“表输出”控件配置

双击进入配置页面，选择目标表company，勾选指定数据库字段，点击下方数据库字段选项，点击输入字段映射，点击猜一猜添加字段映射，如下图：

四.配置完成并运行

运行结果：

company表：