kettle学习--基础--3.2--案例--将MySQL的数据转化为kettle指定的文件格式

kettle学习–基础–3.2–案例–将MySQL的数据转化为kettle指定的文件格式

---

1、案例背景

将MySQL数据源里的三张表 的信息输入到kettle，通过JOB执行转换，并输出一个文本文件。

2、准备工作

2.1、准备数据

#------------创建表user------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `userid` int(10) DEFAULT NULL COMMENT '用户ID',
  `username` varchar(10) DEFAULT NULL COMMENT '用户姓名',
  `usersex` varchar(1) DEFAULT NULL COMMENT '性别',
  `userposition` varchar(20) DEFAULT NULL COMMENT '职业',
  `userage` int(3) DEFAULT NULL COMMENT '年龄'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
#------------插入数据------------
INSERT INTO `user` VALUES ('1', '陈XX', '女', '学生', '20');
INSERT INTO `user` VALUES ('2', '王XX', '男', '工程师', '30');
INSERT INTO `user` VALUES ('3', '李XX', '女', '医生', '40');



#------------创建表product------------
DROP TABLE IF EXISTS `product`;
CREATE TABLE `product` (
  `productid` int(10) DEFAULT NULL COMMENT '产品ID',
  `productname` varchar(20) DEFAULT NULL COMMENT '产品名称'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
#------------插入数据------------
INSERT INTO `product` VALUES ('1', '手机');
INSERT INTO `product` VALUES ('2', '电脑');
INSERT INTO `product` VALUES ('3', '水杯');



#------------创建表orders------------
DROP TABLE IF EXISTS `orders`;
CREATE TABLE `orders` (
  `orderid` int(10) DEFAULT NULL COMMENT '订单ID',
  `userid` int(10) DEFAULT NULL COMMENT '用户ID',
  `productid` int(10) DEFAULT NULL COMMENT '产品ID',
  `buytime` datetime DEFAULT NULL COMMENT '购买时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
#------------插入数据------------
INSERT INTO `orders` VALUES ('1', '1', '1', '2017-06-01 15:02:02');
INSERT INTO `orders` VALUES ('2', '1', '2', '2017-06-02 15:02:22');
INSERT INTO `orders` VALUES ('3', '1', '3', '2017-06-02 15:02:36');
INSERT INTO `orders` VALUES ('4', '2', '1', '2017-06-06 15:02:52');
INSERT INTO `orders` VALUES ('5', '3', '2', '2017-06-09 16:55:24');
INSERT INTO `orders` VALUES ('6', '2', '2', '2017-07-14 14:01:36');

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

2.2、准备驱动包

1. 将mysql驱动包放到/lib目录
2. 重新启动kettle

3、建立并执行作业

3.1、建立作业JOB

3.1.1、新建转换并保存转换文件

右键–>新建转换。

保存

3.1.2、连接 MySQL数据库

3.1.3、切换到核心对象，拖动3个表输入控件到设计区域

3.1.4、双击表输入控件，设置表输入控件的属性信息

3.1.5、拖动2个流查询到设计区域，并设置流查询的属性信息

3.1.6、拖动1个文本文件输出到设计区域，并设置输出的属性信息

3.1.7 连接控件

按住shift键，长按鼠标左键移动鼠标，可以连接两个控件，按如下图所示关联个控件。

3.1.8、设置 文本文件输出的字段

3.2.执行JOB

3.2.1、点击启动按钮执行JOB

3.2.2、查看执行结果

至此我们就完成了将MySQL的数据转化为kettle指定的文件格式，实验成功！