覆盖主要内容
版本: 下个版本

数据同步

组件介绍​

组件作用​

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

输入输出描述​

  • 输入：数据库连接、目标表
  • 输出：被更新的数据库数据

组件图标​

页面介绍​

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

参数选项​

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

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

查询关键字字段表​

选项说明
表字段数据表中用于匹配的字段
比较字符=，=〜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 步：

  1. 在字段标签页插入需要生成的字段名称并设置字段类型，其中actor_id，first_name，last_name 对应 actor 表中的字段，flag 为操作标志字段；

  1. 在数据标签页插入需要生成的数据；

数据同步​

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

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

  1. 配置数据库连接，点击新建按钮，弹出数据库配置弹框，选择需要配置的数据库类型，下面的有关配置项会进行更新，这里进行Mysql数据库的配置；

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

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

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

  1. 设置要操作的数据表；

  1. 选择要比较的字段，在用来查询的关键字表格中，右键点击插入来插入一条数据；

  1. 选择要更新的字段，在更新字段表格中，右键点击插入来插入一条数据；

  1. 在高级选项选择要操作的字段，选中要操作的字段名，在填写需要进行插入，更新，删除操作时字段的值；

结果预览​

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

最后一次更新 更新于