普元数据集成平台 普元数据集成平台
产品介绍
安装部署
快速入门
操作指南
FAQ
  • SQL程序示例
  • 新建SQL程序
  • 编写SQL语句
  • 通用配置
  • 保存草稿
  • 运行
  • 提交版本

# SQL程序示例

本示例主要介绍开发 SQL 程序的需求场景。

主要步骤如下:

  • 新建SQL程序
  • 编写SQL语句
  • 通用配置
  • 保存草稿
  • 运行
  • 提交版本

# 新建SQL程序

点击资源树"SQL程序"节点上的【...】,选择弹出菜单【新建SQL程序】,填写"程序名称",点击【确定】按钮。

sql

sql

# 编写SQL语句

选择"数据源"、"语句类型"、"日志行数"。

SQL类型:查询、非查询。如果选择"非查询"则需要设置"分段执行符号",该符号可以是","、";"或者其他符号,默认是";"。

sql

sql

sql

编写 SQL 语句,以查询语句为例。编写时会有输入提示。可以输入:SELECT * FROM t_xueji,请确保该表存在。

sql

# 通用配置

在通用配置中可以配置任务优先级、Worker 分组、命名参数、本地参数、超时告警。

可以参考示例关系型表数据同步示例 中的"通用配置"说明。

# 保存草稿

如果所有组件属性都已设置完毕,点击【保存】按钮,可以看到保存过的历史草稿,并可以随意切换草稿。(草稿只保存最近 10 个)

可以参考示例关系型表数据同步示例 中的"保存草稿"说明。

# 运行

点击【运行】按钮,可以运行已经开发完毕的场景,在日志栏可以看运行日志及运行结果。

sql

# 提交版本

当草稿运行正常后,点击【提交】按钮可以将该版本提交到作业调度,每次修改提交都会生成新的版本,可以看到提交的历史版本,并可以随意切换版本。

提交后的版本,可以在作业调度中进行"定时"调度配置。

可以参考示例关系型表数据同步示例 中的"提交版本"说明。

← Seatunnel-CDC增量同步示例 查询类SQL程序示例 →