覆盖主要内容
版本: 6.1.0

等待 SQL

组件介绍

该步骤可以指定数据库中的表进行查询,可以设置定时循环执行SQL查询,还可以自定义SQL查询语句。


  • 输入:无
  • 输出:无
  • 参数:无

组件图标

页面介绍

参数选项

选项说明样例值
作业项名称该步骤的名称等待 SQL
数据库连接读取数据的 JDBC 连接
目标模式输入的行集写数据的表 Schema 的名称
目标表名行集写入数据的表名
当行数下拉框选择成功条件大于
指定行数的值
最大超时时间指定等待超时的时间,单位是“秒”
循环检查时间间隔指定循环执行 SQL 查询的间隔时间,单位是“秒”
超时时成功勾选之后,等待超时仍然继续
自定义SQL勾选后,激活下面的参数
使用变量替换如果自定义 SQL 语句中要引用变量,则需勾选
在执行前清空结果行列勾选后,会在执行结果前清除结果行列表中的信息
添加行到结果勾选后,执行结果添加到结果列表中,可以被其他作业项获取
SQL 脚本在框中编写 SQL 查询语句

使用案例

案例数据

1、“等待SQL”组件的使用需要先准备一个已有的数据库连接。在本案例中选择mysql数据库,表名为“test”,这个表共包含三个字段:“name”、“age”、“sex”。总共包含七行数据。

2、如果没有数据库连接,需要先新建一个数据库连接,具体步骤为: 点击左侧“数据源管理”--->右键“rdbms”--->点击“新建数据源”。弹出一个数据库信息编辑的窗口,并做如下配置:

1)选择连接类型为“mysql”;

2)填写数据连接信息。点击“测试”按钮,弹出以下窗口表示连接成功,如下图所示。

  • 注意:如果是使用 MySQL8.0 及以上版本,需要在数据库连接信息的“选项”配置下图所示信息。

案例示例

案例介绍验证数据库表中的行数是否超过给定值。

总体流程如下:

案例操作

1、拖动“等待SQL”组件到画布,双击打开画布。配置数据库连接,并选择模式和数据库表。在本案例中具体配置如下图。

  • 注意:不是所有数据库都有模式信息,只有PostgreSQL/Oracle等数据库有模式,常见的Mysql等数据库是没有模式的,没有的就不用填。

2、填写成功条件。在本案例中选择“当行数”选择“大于”,“值”为“5”其他的保持默认设置。可以根据实际情况自行选择。

3、配置完成后,点击保存。本案例总体流程如下。

4、点击运行,选择从“Start”开始执行作业,点击启动。

6、运行结果如下图所示,可以看到运行结果为true,证明数据库中的数据行数大于5成立。如果不满足该条件,运行结果就是false.