百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 热门文章 > 正文

Kettle(PDI)转换中输出之更新详解

bigegpt 2024-08-28 12:23 3 浏览

概述

Update(更新)此步骤和插入/更新步骤步骤类似,只是只执行更新,不执行插入。

选项

Update(更新)步骤有以下选项:

Step name(步骤名称):在画布上指定Update(更新)步骤的唯一名称。您可以自定义名称或将其保留为默认名称。

Connection(数据库连接):从下拉列表中选择已连接数据库的名称。或者您可以:单击“编辑”修改当前的数据库连接;单击“新建”以建立新的数据库连接;单击Wizard,使用向导打开新的数据库连接。

Target schema(目标模式):将数据写入到的表的模式名称。这对于允许表名称中包含句点的数据源来说非常重要。

Target table(目标表):要在其中执行插入或更新操作的表的名称。

Commit size(提交记录数量):在运行提交之前要更改(插入/更新)的行数。

Use batch update(批量更新):选中此选项,启用批量的数据更新操作。

Skip lookup(跳过查询):执行更新的时候,不通过查询语句验证数据是否已经存在,直接执行更新语句。

Ignore lookup failure?(忽略查询失败?):选中此项,指定忽略查询失败的的字段。

Flag filed(key found)(标志字段(key found)):忽略查询失败的字段名。

  • 用来查询的关机键包含如下选项

指定字段值和比较符列表。

Table field(表字段):从填充目标表列的列表中指定要与之比较的字段名。

Comparator(比较符):指定要使用的比较符。注意,根据连接的数据库和目标表,可以进行区分大小写的比较。你可以选择以下其中一个作为比较符:=、<>、<、<=、>、>=、LIKE、BETWEEN、IS NULL、IS NOT NULL。

Stream field 1(流里的字段1):从传入流中指定字段的名称,该字段包含要用于与表字段值进行比较的行。

Stream field 2(流里的字段2):指定来自传入流的字段的名称,该字段包含您希望用于与流里字段1进行比较的行。

Get fields(获取字段):选择此按钮来填充转换中前面步骤中的流里字段1和流里字段2。

  • 更新字段包含如下选项

允许指定表中要插入/更新的所有字段,包括关键字。通过在更新列中指定N,避免对某些字段进行更新。

Table field(表字段):从填充目标表列的列表中指定要执行更新或插入的字段名。

Stream field(流字段):指定来自传入流的字段的名称,该字段包含用于更新或插入的值。

Update(更新):对与表字段是否执行更新操作。

示例

示例采用代码表与用户表,代码表存放有性别的名称与代码,而用户表只存了性别的代码,现在要根据用户表的性别代码,更新用户表中的姓名名称字段gender_name。为了演示,sql语句很简化,不可以作为实际业务场景,其表sql语句如下。

/*代码表*/

DROP TABLE IF EXISTS `code`;
CREATE TABLE `code` (
`code` varchar(10) NOT NULL,
`name` varchar(20) DEFAULT NULL,
PRIMARY KEY (`code`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
insert into `code`(`code`,`name`) values ('1','男');
insert into `code`(`code`,`name`) values ('2','女');
/*用户表 */
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
`username` varchar(20) NOT NULL,
`truename` varchar(50) DEFAULT NULL,
`gender_code` varchar(50) DEFAULT NULL,
`gender_name` varchar(50) DEFAULT NULL,
PRIMARY KEY (`username`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;
insert into `user`(`username`,`truename`,`gender_code`, `gender_name`) values ('hanmeimei','韩梅梅','2',NULL);
insert into `user`(`username`,`truename`,`gender_code`, `gender_name`) values ('lisi','李四','2',NULL);
insert into `user`(`username`,`truename`,`gender_code`, `gender_name`) values ('zhangsan','张三','1',NULL);

1.建立数据库连接对象

示例采用mysql数据库作为示例,首先下载mysql驱动https://mvnrepository.com/artifact/mysql/mysql-connector-java/5.1.47,然后放在在文件夹\data-integration\lib下。然后重启Spoon。如果已经添加过mysql驱动,则可由忽略此步骤。

切换至主对象树,双击DB连接。


然后选项连接类型为mysql,并维护相关的链接信息。


连接信息维护完之后,点击测试,测试连接是否成功。

2.获取代码表Code数据作为数据输入源。

添加两个表输入步骤,其中一个数据库连接上面创建的DB连接名称demo,第二个数据库连接上面创建的DB连接名称测试,然后从获取SQL查询语句中选择表Code。

最后点击预览,预览结果数据。

3.添加输出中的更新步骤,并配置更新选项

添加一个输出中的更新输出。并建立从表输入到更新的节点连接。

在更新的步骤上,配置数据连接:demo;目标表选择user。然后在用来查询的关键字中选择gender_code;比较符为:= ,然后流里的字段1选择为:code。更新字段中设置:表字段:gender_name;流字段:name;更新:Y。

最后保存并点击运行。

然后查看用户表user的数据结果。

相关推荐

得物可观测平台架构升级:基于GreptimeDB的全新监控体系实践

一、摘要在前端可观测分析场景中,需要实时观测并处理多地、多环境的运行情况,以保障Web应用和移动端的可用性与性能。传统方案往往依赖代理Agent→消息队列→流计算引擎→OLAP存储...

warm-flow新春版:网关直连和流程图重构

本期主要解决了网关直连和流程图重构,可以自此之后可支持各种复杂的网关混合、多网关直连使用。-新增Ruoyi-Vue-Plus优秀开源集成案例更新日志[feat]导入、导出和保存等新增json格式支持...

扣子空间体验报告

在数字化时代,智能工具的应用正不断拓展到我们工作和生活的各个角落。从任务规划到项目执行,再到任务管理,作者深入探讨了这款工具在不同场景下的表现和潜力。通过具体的应用实例,文章展示了扣子空间如何帮助用户...

spider-flow:开源的可视化方式定义爬虫方案

spider-flow简介spider-flow是一个爬虫平台,以可视化推拽方式定义爬取流程,无需代码即可实现一个爬虫服务。spider-flow特性支持css选择器、正则提取支持JSON/XML格式...

solon-flow 你好世界!

solon-flow是一个基础级的流处理引擎(可用于业务规则、决策处理、计算编排、流程审批等......)。提供有“开放式”驱动定制支持,像jdbc有mysql或pgsql等驱动,可...

新一代开源爬虫平台:SpiderFlow

SpiderFlow:新一代爬虫平台,以图形化方式定义爬虫流程,不写代码即可完成爬虫。-精选真开源,释放新价值。概览Spider-Flow是一个开源的、面向所有用户的Web端爬虫构建平台,它使用Ja...

通过 SQL 训练机器学习模型的引擎

关注薪资待遇的同学应该知道,机器学习相关的岗位工资普遍偏高啊。同时随着各种通用机器学习框架的出现,机器学习的门槛也在逐渐降低,训练一个简单的机器学习模型变得不那么难。但是不得不承认对于一些数据相关的工...

鼠须管输入法rime for Mac

鼠须管输入法forMac是一款十分新颖的跨平台输入法软件,全名是中州韵输入法引擎,鼠须管输入法mac版不仅仅是一个输入法,而是一个输入法算法框架。Rime的基础架构十分精良,一套算法支持了拼音、...

Go语言 1.20 版本正式发布:新版详细介绍

Go1.20简介最新的Go版本1.20在Go1.19发布六个月后发布。它的大部分更改都在工具链、运行时和库的实现中。一如既往,该版本保持了Go1的兼容性承诺。我们期望几乎所...

iOS 10平台SpriteKit新特性之Tile Maps(上)

简介苹果公司在WWDC2016大会上向人们展示了一大批新的好东西。其中之一就是SpriteKitTileEditor。这款工具易于上手,而且看起来速度特别快。在本教程中,你将了解关于TileE...

程序员简历例句—范例Java、Python、C++模板

个人简介通用简介:有良好的代码风格,通过添加注释提高代码可读性,注重代码质量,研读过XXX,XXX等多个开源项目源码从而学习增强代码的健壮性与扩展性。具备良好的代码编程习惯及文档编写能力,参与多个高...

Telerik UI for iOS Q3 2015正式发布

近日,TelerikUIforiOS正式发布了Q32015。新版本新增对XCode7、Swift2.0和iOS9的支持,同时还新增了对数轴、不连续的日期时间轴等;改进TKDataPoin...

ios使用ijkplayer+nginx进行视频直播

上两节,我们讲到使用nginx和ngixn的rtmp模块搭建直播的服务器,接着我们讲解了在Android使用ijkplayer来作为我们的视频直播播放器,整个过程中,需要注意的就是ijlplayer编...

IOS技术分享|iOS快速生成开发文档(一)

前言对于开发人员而言,文档的作用不言而喻。文档不仅可以提高软件开发效率,还能便于以后的软件开发、使用和维护。本文主要讲述Objective-C快速生成开发文档工具appledoc。简介apple...

macOS下配置VS Code C++开发环境

本文介绍在苹果macOS操作系统下,配置VisualStudioCode的C/C++开发环境的过程,本环境使用Clang/LLVM编译器和调试器。一、前置条件本文默认前置条件是,您的开发设备已...