概述
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的数据结果。