1. 概述
1.1 应用场景
当用户需要对数据库中的数据进行处理时,例如创建、更新、删除、读取、关联、汇总这样的操作,此可以通过「SQL脚本」节点实现。
1.2 功能简介
节点设置起来比较简单,选择数据源类型和数据连接后,写SQL语句即可,需要注意的是:
SQL 语句的语法要按照连接的数据库类型来写
可以在SQL语句中引用 自定义的参数
在本示例中,我们在数据开发中使用「SQL脚本」创建新表、并对表数据进行分组汇总。
2. 示例
此处给出一个示例,通过「SQL脚本」节点创建两个表,并将其中一张表的数据汇总处理后存到另一张表里去。
2.1 创建任务
新建一个 ETL 任务,点击该任务进入设计界面,操作如下图所示:
2.2 创建数据库表
1)将一个「SQL脚本」节点拖到设计界面,如下图设置,SQL 语句的作用是创建两个表 order1 和 order2 ,且它们有相同的字段 ID 和 inventory 。
2)右键节点将其名称修改为「创建数据库表」,如下图所示:
2.3 表中插入数据
1)再将一个「SQL脚本」节点拖到设计界面,如下图设置,SQL 语句的作用是将 9 条数据插入到表 order1 中去。
2)右键节点将其名称修改为「order1插入数据」,并用线将其与上游节点连接起来,如下图所示:
2.4 数据汇总
1)再将一个「SQL脚本」节点拖到设计界面,如下图设置,SQL 语句的作用是将 order1 的数据分类汇总后插入到 order2 中。
2)右键节点将其名称修改为「汇总插入order2」,并用线将其与上游节点连接起来,如下图所示:
2.5 运行任务
保存并运行节点,出现执行成功提示表示任务运行成功,如下图所示:
运行成功后,可以看到数据库中多了两张表:
order1:
order2:
3. 节点支持的SQL语法
类型 | 语法 | 作用 |
---|---|---|
数据处理 | insert | 插入数据 |
delete | 删除数据 | |
update | 修改数据 | |
select | 查询数据 | |
数据库表操作 | create table | 创建数据库表 |
drop table | 删除数据库表 | |
存储过程相关 | call 数据库模式.存储过程名 | 调用存储过程 |