Kettle初步测试
2018-12-17 本文已影响0人
郑码
需求
从MS Sql Server迁移数据到MySQL中
环境信息:
- Window10 64位
- pdi-ce-8.2.0.0-342
- SqlServer2017 Docker版本
- MySQL5.7.23 Docker版本
操作
软件准备
pdi-ce-8.2.0.0-342.zip版本下载
解压出该版本,运行Sqoon.bat即可
![](https://img.haomeiwen.com/i13639652/4e99ae69be352cae.png)
流程配置
新建转换
打开Kettle软体,新建一个转换任务,“文件”-->“新建”-->“转换
![](https://img.haomeiwen.com/i13639652/6ed1a9d2645d8833.png)
配置SqlServer源数据库
在“核心对象”-->“输入”-->“表输入”,将“表输入”图标直接拖拽到右侧区域
![](https://img.haomeiwen.com/i13639652/3c9aa1f8ad163698.png)
没有SqlServer jar包导致JDBC测试失败,解决方法就是下载mssql-jdbc-7.0.0.jre8.jar存入到lib目录下。
![](https://img.haomeiwen.com/i13639652/5dd66e49c59f384c.png)
![](https://img.haomeiwen.com/i13639652/de41bc77d0ff129c.png)
获取目标表
![](https://img.haomeiwen.com/i13639652/3ef62fefaab787d7.png)
配置“字段选择”
过滤,转换字段信息
![](https://img.haomeiwen.com/i13639652/8128bb459be8be88.png)
![](https://img.haomeiwen.com/i13639652/38afa8edc79c316d.png)
双击“字段选择”图标打开配置界面
“选择和修改窗口”:可以修改字段名称
“移除”:可以选择不需要传输数据的列,选择后将不会传输此字段里的值到目标表,我们这里选择的是TS字段,因为此字段是timestamp类型数据(时间戳)
“元数据”:在此可以对源数据表中的所有字段进行转换设置,比如类型,长度,精度,字符集等,如果想一次性将源表的所有字段均加载进来的话,点击右侧“获取改变的字段”。
![](https://img.haomeiwen.com/i13639652/54ce28d4c75a220f.png)
![](https://img.haomeiwen.com/i13639652/a009095039cee2b4.png)
配置“插入/更新”---目标数据库
![](https://img.haomeiwen.com/i13639652/fcb59d0b6d766086.png)
![](https://img.haomeiwen.com/i13639652/e03531cc2fcc6925.png)
-
新建我们需要导入的目标数据库连接,按照上面的步骤教程新建连接,
-
“浏览”选择需要导入数据的table
-
在此区域内选择查询数据时依据的字段,其实也就是根据此字段来判断两个表中的数据是否是同一笔记录
-
点击“获取和更新字段”可以在“更新字段”区加载所有字段,注意选择是否所有字段都需要更新数据,我在这里将carid的更新状态改成了Y。
![](https://img.haomeiwen.com/i13639652/1d0d10ce768872d3.png)
校验连接情况
![](https://img.haomeiwen.com/i13639652/be3de86d74cdb2fb.png)
出现报错信息,根据详细,检查刚才的字段配置内容
![](https://img.haomeiwen.com/i13639652/8200d395567cb524.png)
得到问题原因
![](https://img.haomeiwen.com/i13639652/70d984fd2c49fe00.png)
![](https://img.haomeiwen.com/i13639652/db2e2141e4f0ef37.png)
![](https://img.haomeiwen.com/i13639652/af400c74b4f5ee18.png)
测试执行任务
![](https://img.haomeiwen.com/i13639652/890562f63264833c.png)
执行结果
源数据库
![](https://img.haomeiwen.com/i13639652/3063226be04dc07e.png)
目标数据库
![](https://img.haomeiwen.com/i13639652/c56086fd1038f53b.png)
定时任务
新建作业
![](https://img.haomeiwen.com/i13639652/d1c21d936a941b63.png)
部署作业
![](https://img.haomeiwen.com/i13639652/39a0c57c45837d3d.png)
设置执行频率
![](https://img.haomeiwen.com/i13639652/6cf169b31581e9bf.png)
选择执行任务项
![](https://img.haomeiwen.com/i13639652/18406ee022e865e5.png)
![](https://img.haomeiwen.com/i13639652/506523e8b341a8fd.png)