首页 > 其他分享 >Kettle应用场景--增量插入

Kettle应用场景--增量插入

时间:2022-11-29 15:31:07浏览次数:27  
标签:-- 数据库 Kettle jar 选择 插入 点击 userA 输入

Kettle应用场景

​在此,我们主要对示例1进行说明。

为方便演示,我们在数据库A和数据库B中分别创建表userA和表userB。最终目标为将数据表userA中的数据插入到数据表userB中。

create database testA; use testA; create table `userA`( `id`int(10) primary key, `name` varchar(50), `age` int(3) )ENGINE=InnoDB DEFAULT CHARSET=utf8; insert into userA values(1,'张三',20); insert into userA values(2,'李四',21); insert into userA values(3,'王五',22); create database testB; use testB; create table `userB`( `idB`int(10) primary key, `nameB` varchar(50), `ageB` int(3) )ENGINE=InnoDB DEFAULT CHARSET=utf8;

操作步骤

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

Kettle应用场景--增量插入_字段

2、点击面板左侧的 主对象树 ,选择 DB连接 右键,选择 新建新建数据库连接向导。

Kettle应用场景--增量插入_数据库连接_02

Kettle应用场景--增量插入_数据库_03

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

Kettle应用场景--增量插入_数据库连接_04

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

Kettle应用场景--增量插入_数据库_05

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

Kettle应用场景--增量插入_数据库连接_06

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

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

Kettle应用场景--增量插入_数据库连接_07

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

Kettle应用场景--增量插入_数据库连接_08

4、双击编辑区的“表输入”图标,编辑数据输入源。

Kettle应用场景--增量插入_数据库_09

5、点击面板左侧的 核心对象 ,选择 转换文件夹下的 字段选择并把它拖到右侧的编辑区中。

Kettle应用场景--增量插入_字段_10

6、按住 shift同时鼠标从 “testA表输入”到“字段选择”拉出一条连接线连接起来。

Kettle应用场景--增量插入_字段_11

​7、双击编辑区的“字段选择”,选择“元数据”面板,点击右侧“获取改变的字段”,将自动列出输入表中所有字段。根据要抽取的目标表中的字段名,给每一个输入字段修改为对应的输出字段。

注意:此时必须在Encoding栏中选择输出库的编码格式

Kettle应用场景--增量插入_字段_12

8、点击面板左侧的 核心对象 ,选择 输出文件夹下的 表输出 并把它拖到右侧的编辑区中,按住 shift划线连接 “字段选择”。

Kettle应用场景--增量插入_数据库连接_13

Kettle应用场景--增量插入_数据库_14

9、双击编辑区的“表输出”图标,编辑数据输出目标。

Kettle应用场景--增量插入_数据库连接_15

10、然后勾选 指定数据库字段 ,选择 数据库字段 ,点击 输入字段映射,映射输入输出关系。

Kettle应用场景--增量插入_数据库连接_16

注意:如果在点击 输入字段映射 时,提示如下错误:

Kettle应用场景--增量插入_数据库_17

检查我们的数据库驱动jar包版本 mysql-connector-java-5.1.6-bin.jar , 因为测试数据库版本为 MySQL 6.3 , 而使用此版本的数据库驱动包,会在创建数据库连接的时候发送测试语句 SET OPTION SQL_SELECT_LIMIT=DEFAULT , 但是5.6及以后的版本都不再支持SET...,此时,我们只需要将驱动版本升级,只需要将数据库驱动版本修改为5.2以上即可。

11、因为我们在“字段选择”中修改了每个输入字段对应的输出字段的名称,此处,我们点击 猜一猜 ,将会自动根据字段近似度自动匹配映射关系。

Kettle应用场景--增量插入_数据库连接_18

12、到这里,我们最简单的一个提取数据的转换已经建立完成了,点击“校验这个转换”,Kettle会校验并给出简单的报告。没有任何问题。

Kettle应用场景--增量插入_数据库_19

13、点击“运行这个转换”,选择“本地执行”,点击“启动”来执行这个转换。、

Kettle应用场景--增量插入_数据库_20

14、转换成功后,我们可以在控制台中看到如下信息。检查本地数据库,数据库A的userA表中的数据已经全部被导入到了数据库B的userB表中。

Kettle应用场景--增量插入_数据库连接_21

注:此示例只适用于目标表为空,或者目标表与源表没有主键冲突的情况

Kettle应用场景--增量插入_数据库_22

标签:--,数据库,Kettle,jar,选择,插入,点击,userA,输入
From: https://blog.51cto.com/u_15867943/5895273

相关文章

  • 实验五
    #include<iostream>#include<string>usingnamespacestd;classMachinePets{public:MachinePets(strings=""){nickname=s;}virtualstr......
  • 大咖说·图书分享|深入浅出 Node.js
    Node.js有哪些特性?在应用构建的时候有哪些注意事项?入门同学如何实现技术进阶?本期大咖说,阿里云高级技术专家朴灵携作品《深入浅出Node.js》展开分享。 嘉宾介绍......
  • Java的ExecutorService的shutdownNow()方法并不能保证一定会结束线程的解决办法
    这几天使用ExecutorService的时候遇到了在Task内部进行读取文件操作而导致死循环的问题,当我试图调用shutdownNow()方法的时候,发现并不是像我预想的一样会理解结束线程。我......
  • 汇编实验:基于BIOS调用(10H)的多窗口输出程序
    汇编实验报告-屏幕窗口程序实验1.题目要求:自行编写一个键盘输入并且在屏幕输出的程序,它可以完成键盘读入并且在屏幕显示出来。具体要求:2.运行环境:Windows11+MASM3.......
  • day07_java_数组
    d07Java数组(p51-p59)1.什么是数组?数组就是一组数的集合。数组是相同类型数据的有序集合。数组描述的是相同类型的若干个数据,按照一定的先后顺序排列组合而成。......
  • StringUtils 使用更新对象的非空值去覆盖待更新对象
    //使用更新对象的非空值去覆盖待更新对象StringUtils.copyPropertiesIgnoreNull(device,dev);//用device对象去覆盖dev对象复制属性:将attr实体中的属性一一拷贝给attrE......
  • Luke的在线笔记
    --WorkingTable备份INSERTINTOFIN.PP_AnM_ActivityExpenseTypeSnapshot(FInDataSnapshotId,Year,BudgetOwnerId,BrandId,ActivityId,ExpenseTypeId,Q1Value,Q2Value,Q3V......
  • oracle清空用户下的所有数据及表
    !!!注意这种方式会删除用户下面的所有表和数据,所以只能在新建的普通用户(只授权了指定的表空间)下面执行。1、先禁用数据库中所有的约束select'altertable'||table_......
  • Mysql
    基础篇通用语法及分类DDL:数据定义语言,用来定义数据库对象(数据库、表、字段)DML:数据操作语言,用来对数据库表中的数据进行增删改DQL:数据查询语言,用来查询数据库中......
  • WordPress编辑器支持Word导入
    ​ 百度ueditor新增的将word内容导入到富文本编辑框的功能怎么没有啊,...ueditor实现word文档的导入和下载功能的方法:1、UEditor没有提供word的导入功能,只能说是粘贴复......