SQL脚本

1 概述

1.1 版本

1.2 应用场景

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

1.3 功能简介

可通过SQL语句对数据进行处理，一般会作为数据前置处理节点进行使用，先对数据进行简单的处理。

2 功能说明

脚本配置包括：数据源、配置方式。

1、数据源
展示当前应用内已配置过的数据连接且当前用户有使用权限的选项。
目前支持的数据连接类型包括：MySQL、SQL Server、Oracle、达梦、PostgreSql、PolarDB O、ClickHouse，后续将逐步进行扩充。
2、配置方式
支持两种配置方式：SQL、存储过程
1）SQL
按照业务场景编写对应的SQL语句，SQL语句的语法需要按照所选数据源对应的数据库类型进行编写。如下图：

支持引用变量或上游节点的参数，进行数据库增删改。
其中，变量格式为“${变量名称}”，参数格式为“${参数名称}”。
2）存储过程
“MySQL、Oracle、SQLServer ”数据库类型支持调用存储过程，可选择准备好的存储过程，并设置对应的参数值，如下图：

参数值支持设置为常量或表达式，选择表达式时可以引用函数、变量和任务参数。

3 示例

1、清除数据
为提供同步效率，可以先清除数据库表中对应数据后再进行同步。
添加【SQL脚本】节点，如下图设置，SQL语句的作用是清除 ods_hwkq 表中上个月26号至当前日期的数据。如下图所示：

2、更新数据
更新 lcz_table_sync_times 表中的部分数据。设置如下图：

完整SQL语句如下：

update lcz_table_sync_times set LAST_SYNC_TIME=${当前最大更新时间} where TABLE_NAME='dn_m_templete_l'