Kettle入门（一）

一、创建资料库

1、在mysql数据库创建一个数据库&＃xff0c;用来存放数据。

create database target01;


2、在kettle建立连接&＃xff0c;点击右上角的【Connect】&＃xff0c;选择【Other Repositories】&＃xff0c;选择【Database Repository】&＃xff0c;点击【Get Started】进入下一设置。

3、给连接命名&＃xff0c;并点击【Database Connection】&＃xff0c;选择【Create New Connection】进入数据库连接设置

4、按照要求&＃xff0c;填写数据库配置&＃xff0c;点击【测试】&＃xff0c;显示【正确连接到数据库***】即表示数据库连接成功&＃xff0c;点击【确定】关闭弹窗&＃xff0c;然后点击右下角的【确认】进入下一步&＃xff0c;点击【Back】进入选择数据库连接的界面


5、选择上面设置好的数据库连接&＃xff0c;完成数据库连接

二、单表抽取

源表&＃xff1a;Oracle的EMP表
目标表&＃xff1a;MySQL

1、创建转换

2、kettle中建立Oracle连接&＃xff1a;

3、kettle中建立mysql连接&＃xff08;参照上面创建资料库流程&＃xff09;

• 如果MySQL为8.0以前的版本&＃xff0c;需要将 若mysql版本为8以前&＃xff0c;需要将mysql的jar包&＃xff08;mysql-connector-java-5.1.44-bin.jar&＃xff09;放入到kettle的lib文件夹中&＃xff0c;然后根据图示进行连接。
  
• 如果MySQL为8.0&＃xff0c;先将对应jar包&＃xff08;mysql-connector-java-5.1.44-bin.jar、mysql-connector-java-8.0.27.jar&＃xff09;放入lib文件夹&＃xff0c;然后需要找到 data-integration\simple-jndi\jdbc.properties 文件编辑&＃xff0c;在末尾加上连接信息&＃xff1a;

MYSQL8_DB/type&＃61;javax.sql.DataSource //MYSQL8_DB可以随便更改
MYSQL8_DB/driver&＃61;com.mysql.cj.jdbc.Driver
MYSQL8_DB/url&＃61;jdbc:mysql://localhost:3306/xxxxx?useUnicode&＃61;true&characterEncoding&＃61;utf8&useSSL&＃61;false&serverTimezone&＃61;GMT //xxxxx为想要连接数据库名称
MYSQL8_DB/user&＃61;root //用户名
MYSQL8_DB/password&＃61;root //密码


4、源、目标设置

• 源设置
  
  
• 目标设置
  
  目标表不需要提前建立&＃xff0c;在输出设置中&＃xff0c;进行创建。
  

4、运行转换

5、查看传输状态

6、验证数据

select * from emp;


三、多表抽取

• 图示
  
• 排序记录设置&＃xff1a;选择关联的字段进行排序
  
• 连接设置&＃xff1a;输入上一步排序记录&＃xff0c;选择关联字段
  
• 输出设置&＃xff1a;选择需要的字段
  
• 执行结果