SQL脚本

1.1 应用场景

当用户需要对数据库中的数据进行处理时，例如创建、更新、删除、读取、关联、汇总这样的操作，此可以通过「SQL脚本」节点实现。

1.2 功能简介

节点设置起来比较简单，选择数据源类型和数据连接后，写SQL语句即可，需要注意的是：

• SQL 语句的语法要按照连接的数据库类型来写

• 可以在SQL语句中引用 自定义的参数

在本示例中，我们在数据开发中使用「SQL脚本」创建新表、并对表数据进行分组汇总。

此处给出一个示例，通过「SQL脚本」节点创建两个表，并将其中一张表的数据汇总处理后存到另一张表里去。

2.1 创建任务

新建一个 ETL 任务，点击该任务进入设计界面，操作如下图所示：

2.2 创建数据库表

1）将一个「SQL脚本」节点拖到设计界面，如下图设置，SQL 语句的作用是创建两个表 order1 和 order2 ，且它们有相同的字段 ID 和 inventory 。

SQL 语句为：

CREATE table if not exists order1
(
  ID int,
  inventory int
 );
 create table if not exists order2
 (
   ID int,
   inventory int
   );

2）右键节点将其名称修改为「创建数据库表」，如下图所示：

2.3 表中插入数据

1）再将一个「SQL脚本」节点拖到设计界面，如下图设置，SQL 语句的作用是将 9 条数据插入到表 order1 中去。

SQL 语句为：

INSERT INTO order1 VALUES(1,20);
INSERT INTO order1 VALUES(1,18);
INSERT INTO order1 VALUES(1,26);
INSERT INTO order1 VALUES(2,34);
INSERT INTO order1 VALUES(2,56);
INSERT INTO order1 VALUES(2,17);
INSERT INTO order1 VALUES(3,24);
INSERT INTO order1 VALUES(3,14);
INSERT INTO order1 VALUES(3,28);

2）右键节点将其名称修改为「order1插入数据」，并用线将其与上游节点连接起来，如下图所示：

2.4 数据汇总

1）再将一个「SQL脚本」节点拖到设计界面，如下图设置，SQL 语句的作用是将 order1 的数据分类汇总后插入到 order2 中。

SQL 语句为：

insert into order2
select ID,sum(inventory) from order1 group by ID

2）右键节点将其名称修改为「汇总插入order2」，并用线将其与上游节点连接起来，如下图所示：

2.5 运行任务

保存并运行节点，出现执行成功提示表示任务运行成功，如下图所示：

运行成功后，可以看到数据库中多了两张表：

order1：

order2：