Kettle入门之七 Kettle应用场景（多表级联）

2017-12-14 本文已影响271人开心跳蚤

Kettle应用场景

在此，我们主要对示例4进行说明。

为方便演示，我们在数据库A中创建“用户表”、“商品表”、“订单表”，在数据库B中创建“订单详细信息表”。最终目标为根据用户表、商品表、订单表获取订单详细信息表，最终目标结果如下。

create database testA;
use testA;
-- 用户表
create table `user`(
    `id`int(10) primary key,
    `name` varchar(50),
    `age` int(3)
)ENGINE=InnoDB DEFAULT CHARSET=utf8;

insert into user values(10001,'张三',20);
insert into user values(10002,'李四',25);
insert into user values(10003,'王五',22);

-- 商品表
create table `goods`(
    `id`int(10) primary key,
    `name` varchar(50),
    `price` float(16)
)ENGINE=InnoDB DEFAULT CHARSET=utf8;

insert into goods values(1000001,'苹果',6.5);
insert into goods values(1000002,'橘子',2.5);
insert into goods values(1000003,'香蕉',1.5);

-- 订单表
create table `order`(
    `id`int(10) primary key,
    `user_id` varchar(50),
    `goods_id` int(10)
)ENGINE=InnoDB DEFAULT CHARSET=utf8;

insert into `order` values(1,10001,1000001);
insert into `order` values(2,10001,1000002);
insert into `order` values(3,10003,1000001);
insert into `order` values(4,10003,1000001);
insert into `order` values(5,10002,1000002);
insert into `order` values(6,10002,1000003);


create database testB;
use testB;
-- 订单详情表
create table `order_detail`(
    `id`int(10) primary key,
    `user_name` varchar(50),
    `user_age` int(3),
    `goods_name` varchar(50),
    `goods_price` float(16)
)ENGINE=InnoDB DEFAULT CHARSET=utf8;

操作步骤

1、运行软件，进入主界面。点击左上角的 文件 → 新建 → 转换新建一个转换，并保存，转换的后缀名为ktr。

2、点击面板左侧的 主对象树 ，选择 DB连接 右键，选择新建或 新建数据库连接向导 分别创建对数据库A和数据库B的连接。

选择“新建”选项的操作视图

选择“新建数据库连接向导”选项的操作视图 1

选择“新建数据库连接向导”选项的操作视图 2

选择“新建数据库连接向导”选项的操作视图 3

注意： 如果在点击测试连接时出现下图所示错误，检查我们的安装目录下的lib中是否有对应数据库连接的jar包文件（如mysql的jar文件：mysql-connector-java-5.1.6-bin.jar），下载对应的jar，放到lib文件夹下，重启kettle软件，即可。

3、点击面板左侧的 核心对象 ，选择输入文件夹下的 表输入 并把它拖到右侧的编辑区中。

4、双击编辑区的“表输出”图标，编辑数据输入源。此处为多表联合查询，所以表输入我们配置的表为订单表（关联关系表）

5、点击面板左侧的** 核心对象 ，选择 查询 ** 文件夹下的 ** 数据库查询 **，并把它拖到右侧的编辑区中，按住 shift 画线连接 “表输入”，如下图。

6、双击编辑区的“数据库查询”，图标，配置级联查询关系。

配置用户表关联查询：
（1）步骤名称写入“user”，数据库连接选择我们user表所在的数据库，如果数据源未配置，可查看步骤2，进行配置。
（2）选择数据库之后，我们通过“表名”后的 “浏览”按钮，选择我们的关联表“user”。
（3）查询所需关键，即为两表之间的关联字段，操作符根据需要，此处选择 “=”。
（4）查询表返回的值，即为我们需要通过关联表“user”，获取到的字段。