sql 插入text字段包含特殊字符_Kettle（PDI）转换中输出之插入/更新详解

作者：你好赵伟 | 2024-03-01 12:10:15

踩

update sql 插入文本

概述

Insert / update(插入 / 更新)此步骤首先使用一个或多个查询关键字查找表中的一行。如果找不到该行，则插入该行。如果可以找到它，并且要更新的字段相同，则不执行任何操作。如果它们不完全相同，则更新表中的行。

注意：如果有多个匹配关键字的行，则只比较找到的第一行。这可能会导致不同的结果，这取决于所找到的行是否与给定值匹配。更新场景是这样的：如果在多个行具有相同关键字的情况下发现差异，则对数据库触发一个update语句，该语句使用匹配的关键字更新所有行。该注意也适用于更新步骤。

选项

Insert / update(插入 / 更新)步骤有以下选项：

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

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

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

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

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

Don't perform any updates(不执行任何更新)：如果启用，数据库中的值永远不会更新，而只执行插入。

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

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

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(更新)：对与表字段是否执行更新操作。

示例

示例采用代码表与用户表，代码表里存放用户性别代码跟名称，用户里面存放用户跟用户的性别代码。为了演示，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);

演示效果是用户表字段gender_code中只存了性别的代码，而性别名称的字段gender_name 都为空，现在需要根据字典表更新用户表中的性别名称，

1.建立数据库连接对象

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

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