覆盖主要内容
版本: 6.1.0

数据同步

组件介绍

组件作用

数据同步”该组件可以与“合并记录”组件结合使用。“合并记录”步骤为每行附加一个标志列,标记为该行为“相同”,“有变动”,“新记录”或“已删除”。该组件使用此标志列对一已连接的表进行更新/插入/删除。

输入输出描述


  • 输入:数据库连接、目标表
  • 输出:被更新的数据库数据
  • 参数:查询字段、更新字段

组件图标

页面介绍

运行“数据同步”组件得到下图所示的界面:

参数选项

数据同步”组件页面包含如下选项:


选项说明
数据库连接选择连接的数据库。如何建立连接参考建立数据库连接页面
目标模式表中要写入数据的模式的名称
目标表选择数据输出的目标要写入数据的目标表的名称。选择目标表后,目的模式会根据表的信息自动填充。
提交的记录数量运行提交之前要更新的行数
批量更新进行批量更新的操作方式
表名在字段里定义如果表名位于字段中,勾选此选项。并在表明字段中输出该字段
表名字段输入有表明的字段

查询关键字字段表


选项说明
表字段数据表中用于匹配的字段
比较字符=,=〜NULL,<>,<,<=,>,> =,LIKE,BETWEEN,IS NULL,IS NOT NULL 等比较规则
流里的字段1流数据中用于匹配的字段1
流里的字段2为了满足某些二元运算而提供的流数据字段2

更新字段表


选项说明
表字段数据表中被更新的字段
流字段流数据用于更新的字段
更新是或否

高级操作选项


选项说明
操作字段名**必填字段.**该步骤将使用此字段来获取当前行的操作标志
当值相等时插入指定“操作”字段名称的值,该值表示应执行插入操作
当值相等时更新定“操作”字段名称的值,该值表示应执行更新
当值相等时删除指定“操作”字段名称的值,该值表示应执行“删除”
执行查询删除或更新时执行查找。如果未找到查找字段,则引发异常。如果您希望在执行更新/删除之前对其进行检查,则可以将该选项用作额外的检查

案例示例

该案例读取自定义常量中的数据,包含3个字段,actor_id,first_name,last_name,并与数据库actor表进行比较,若actor_id与自定义常量中的actor_id相同,则更新对应的first_name与last_name字段,若id不相同,则插入一条新数据,总体流程如下图所示:

案例操作

自定义常量数据

该步骤定义需要操作的actor表中的数据以及操作类型。 actor表预览:

该组件配置主要分为 2 步: 第一步:在字段标签页插入需要生成的字段名称并设置字段类型,其中actor_id,first_name,last_name 对应 actor 表中的字段,flag 为操作标志字段;

第二步:在数据标签页插入需要生成的数据;

数据同步

改变数据库中的actor表中的数据。 actor表预览:

该组件配置主要分为 5 步:

第一步:配置数据库连接,点击新建按钮,弹出数据库配置弹框,选择需要配置的数据库类型,下面的有关配置项会进行更新,这里进行Mysql数据库的配置;

配置项说明:Mysql数据库的配置项如下表所示

选项说明样例值
连接名称指定配置的数据库连接的名称。192.168.1.123
连接类型指定连接的数据库的类型。Mysql
用户名登录数据库的用户名。root
密码登录数据库的密码。"
服务器主机名连接的数据库的 IP 地址。192.168.1.123
端口号数据库在服务器运行的端口号。3306
数据库名称指定要连接的数据库的名称。
使用结果流选择是否以结果流的形式输出。
驱动类型选择连接数据库的驱动类型,Mysql数据库由两个版本,Mysql与Mysql8+。
自定义JDBC URL自定义的 JDBC 的下载链接。

配置完数据库基本信息后,还需要点击左侧页面栏的选项窗口来配置连接选项

第二步:设置要操作的数据表;

第三步:选择要比较的字段,在用来查询的关键字表格中,右键点击插入来插入一条数据;

第四步:选择要更新的字段,在更新字段表格中,右键点击插入来插入一条数据;

第五步:在高级选项选择要操作的字段,选中要操作的字段名,在填写需要进行插入,更新,删除操作时字段的值;

结果预览

最终 actor 表数据如下图所示: