SQL表达式
WHERE中可以使用的字段和SELECT语句一致，当接收到对应Topic的消息时，WHERE语句的结果会作为是否触发规则的判断条件。具体条件表达式，请参见以下章节：条件表达式支持列表。上文两个示例中，条件语句 WHERE temperature>38 表示温度大于...
Flink数据导入
创建一张名为 csv_person 的源表，语句如下：CREATE TABLE if not exists csv_person(`user_id` STRING,`user_name` STRING,`age` INT)WITH('connector'='filesystem','path'='file:/root/data.csv','format'='csv','csv.ignore-parse-...
DMS作业调度
语句如下：CREATE EXTENSION IF NOT EXISTS oss_fdw;创建一个OSS外表。语句如下：CREATE SERVER ossserver FOREIGN DATA WRAPPER oss_fdw OPTIONS(host '<bucket_host>',id '<access_key>',key '<secret_key>',bucket '<bucket_name>');...
使用事件触发器实现DDL回收站、防火墙、增量订阅同步
text|CURRENT_USER|extended|datname|text|current_database()|extended|client_addr|inet|inet_client_addr()|main|crt_time|timestamp without time zone|now()|plain|创建语句如下：CREATE SCHEMA IF NOT EXISTS dts_audit;CREATE TABLE...
通过外表导入至数仓版
创建HDFS外表 创建文件格式为CSV的外表 语句如下：CREATE TABLE IF NOT EXISTS hdfs_import_test_external_table(uid string,other string)ENGINE='HDFS' TABLE_PROPERTIES='{"format":"csv","delimiter":",","hdfs_url":"hdfs:/172.17.*.*...
CREATE INDEX
语法 create_index_statement:=CREATE INDEX[IF NOT EXISTS][index_identifier][USING index_method_definition]ON table_identifier '(' index_key_expression ')'[INCLUDE include_expression][PARTITION BY partition_definition][{ ...
自然语言到SQL语言转义（基于大语言模型的NL2SQL）
创建问题模板表的SQL语句如下：DROP TABLE IF EXISTS `polar4ai_nl2sql_pattern`;CREATE TABLE `polar4ai_nl2sql_pattern`(`id` int(11)NOT NULL AUTO_INCREMENT COMMENT '主键',`pattern_question` text COMMENT '模板问题',`pattern_...
导出至HDFS
您可以使用以下语句在源库 adb_demo 中创建一张源表 adb_hdfs_import_source，建表语句如下：CREATE TABLE IF NOT EXISTS adb_hdfs_import_source(uid string,other string)DISTRIBUTED BY HASH(uid);往源表 adb_hdfs_import_source 中插入...
DDL 语法
DDL 基本语句 Sharding DDL 语句 DDL 基本语句 创建数据表 CREATE TABLE IF NOT EXISTS `table_name`(id INTEGER NOT NULL PRIMARY KEY,name VARCHAR(20)NOT NULL,age INTEGER NOT NULL);删除数据表 DROP TABLE table_name;修改数据表/*...
条件表达式
查询和分析语句*|SELECT sum(IF(status=200,1,0))*1.0/count(*)AS status_200_percentag 查询和分析结果 COALESCE表达式 COALESCE表达式用于返回多个表达式中第一个非null的值。语法 COALESCE(expression1,expression2,expression3.)参数...
CREATE DATABASE AS（CDAS）语句
阿里云Flink引擎会将CDAS语句中每个需要同步的表翻译成一个对应的CTAS语句。因此，CDAS还拥有CTAS的数据同步和表结构变更同步的能力，常用于全自动化的数据集成场景。此外，阿里云Flink还能对源表进行优化，复用一个源表节点读取多业务表的...
SQL
create table if not exists hive_table(id bigint,name string)创建insert_data节点。节点名称 设置为insert_data，数据源类型 选择为 HIVE，数据源实例 选择已添加的HIVE数据源，SQL类型 选择为 非查询，SQL语句 内容如下。insert into ...
Nereids全新优化器
因此，Nereids优化器可以更好的支持诸如多层子查询嵌套等更为复杂的查询语句。Nereids优化器的CBO基于先进的Cascades框架，使用了更为丰富的数据统计信息，并应用了维度更科学的代价模型，使得Nereids优化器在处理多表Join查询时，更加...
RDS增量数据同步至MaxCompute
每天增量同步 不推荐使用该方式，只有在不支持Delete语句、无法通过SQL语句查看被删除的数据等场景才会考虑。虽然实际上大多使用逻辑删除数据，将Delete转化为Update进行处理。但仍会限制一些特殊的业务场景不能实现，导致数据不一致。并且...
RDS增量数据同步至MaxCompute
每天增量同步 不推荐使用该方式，只有在不支持Delete语句、无法通过SQL语句查看被删除的数据等场景才会考虑。虽然实际上大多使用逻辑删除数据，将Delete转化为Update进行处理。但仍会限制一些特殊的业务场景不能实现，导致数据不一致。并且...
VIEW
create foreign table if not exists holo_foreign_test(amount decimal(10,2),rate decimal(10,2))server odps_server options(project_name '<projectname>',table_name '<odps_name>'));select*from holo_foreign_test limit 2;基于外部...
ALTER INDEX
语法 alter_index_statement:=ALTER INDEX[IF EXISTS]index_identifier ON table_identifier { ADD COLUMNS '(' alter_key_expression ')'|alter_state_expression }[ASYNC]alter_key_expression:=index_key_definition[(',' index_key_...
在Hue WebUI使用编辑器
当您需要使用图形化界面在集群中执行HiveQL或Spark SQL语句时，可以通过Hue完成任务。本文以EMR-4.9.0版本为例，为您介绍如何在Hue WebUI中使用Hive编辑器和Spark SQL编辑器。前提条件 已设置安全组访问。重要 设置安全组规则时要针对有限...
SQL限流
规则创建语句如下：CREATE CCL_RULE IF NOT EXISTS `selectrule` ON*.*TO 'ccltest'@'%' FOR SELECT FILTER BY KEYWORD('cclmatched')WITH MAX_CONCURRENCY=10;查看限流规则 语法 查看指定限流规则 语法如下：SHOW CCL_RULE `ccl_rule_name...
SQL限流
规则创建语句如下：CREATE CCL_RULE IF NOT EXISTS `selectrule` ON*.*TO 'ccltest'@'%' FOR SELECT FILTER BY KEYWORD('cclmatched')WITH MAX_CONCURRENCY=10;查看限流规则 语法 查看指定限流规则 语法如下：SHOW CCL_RULE `ccl_rule_name...
MaxCompute分区表数据导入
创建外部表 IMPORT FOREIGN SCHEMA maxcompute_project LIMIT to(odps_sale_detail)FROM SERVER odps_server INTO public OPTIONS(if_table_exist 'error',if_unsupported_type 'error');创建分区表（内部表）登录数据库 在 HoloWeb控制台...
管理搜索索引
CREATE TABLE IF NOT EXISTS search_table(user_id bigint,name varchar,age smallint,gender varchar,address varchar,email varchar,city varchar,primary key(user_id asc));执行以下语句在目标表中写入四条数据。UPSERT INTO search_...
使用临时查询快速查询SQL（可选）
如果您已经创建了DataWorks工作空间（MaxCompute项目），可以直接使用DataWorks临时查询功能，快速书写SQL语句操作MaxCompute。临时查询 的详情请参见 创建临时查询。进入临时查询 登录 DataWorks控制台，单击左侧导航栏的 数据建模与开发>...
配置SQL审核优化建议
INDEX 数据查询 检测项 适用的SQL语句 规则名称与规则标识 SELECT SELECT INSERT SELECT 子查询（嵌套在 UPDATE 或 DELETE 中）SELECT 语句建议指定 WHERE 条件：SELECT_SUGGEST_ASSIGN_WHERE SELECT 语句不建议使用 ORDER BY RAND()：...
通过Spark SQL读写Delta外表
CREATE TABLE if not exists external_delta_db.delta_test_tbl(id int,name string,age int)using delta partitioned by(age)location"oss:/<bucket_name>/test/delta_test_tbl;步骤三：写入 Delta外表 数据 说明 您可以选择批处理或交互...
通过Spark SQL读写OSS外表
CREATE TABLE IF NOT exists test_db.test_tbl_partitioned(id int,name string,age int)using parquet partitioned by(location string)location 'oss:/<bucket_name>/test/test_tbl_partitioned/' tblproperties('parquet.compress'='...
添加并使用Lindorm数据源
使用TSQL语句查询：单击 A 区域右上角的，可以通过输入TSQL语句完成复杂的查询操作（例如嵌套查询），数据查询结果如下图。说明 TSQL语句使用请参见 SELECT语法。timeFilter 表示时间条件，会自动替换为页面中选择的时间范围，定义为 time>...
添加并使用Lindorm数据源
使用TSQL语句查询：单击 A 区域右上角的，可以通过输入TSQL语句完成复杂的查询操作（例如嵌套查询），数据查询结果如下图。TSQL语句字段说明如下表。SELECT region,time,temperature FROM sensor WHERE$timeFilter 说明 TSQL语句使用请参见...
设备移植相关问题
ArmCC不支持在if、while、for逻辑的判断语句中有变量赋值。函数内多分支情况，ArmCC对不可达分支处的return语句严格报错导致编译失败。ArmCC不支持返回值被声明为枚举类型的函数，实际上返回值是int等gcc所认为的等价数据类型。标准库的头...
嵌套表
TYPE IS TABLE语句用于在SPL程序的声明部分中定义嵌套表类型。TYPE tbltype IS TABLE OF { datatype|rectype|objtype };tbltype是分配给嵌套表类型的标识符。datatype是标量数据类型，例如VARCHAR2或NUMBER。rectype是先前定义的记录类型。...
聚合函数
查询和分析语句（调试）*|SELECT count(request_method)AS count 查询和分析结果 count_if函数 count_if函数用于统计满足指定条件的日志条数。语法 count_if(boolean expression)参数说明 参数 说明 boolean expression 参数值为布尔表达式...
DROP INDEX
您可以通过DROP INDEX语句删除已存在的索引。引擎与版本 DROP INDEX语法仅适用于宽表引擎。无版本限制。重要 使用DROP INDEX删除 搜索索引、列存索引 要求Lindorm SQL为 2.6.1以上版本。如何查看Lindorm SQL的版本，请参见 SQL版本说明。...
使用DataWorks同步数据
CREATE TABLE IF NOT EXISTS odptabletest1(v1 TINYINT,v2 SMALLINT);分别单击 提交到开发环境 和 提交到生产环境。写入MaxCompute表数据。在 数据开发 页面，单击左侧导航栏的 临时查询。鼠标悬停至 图标，单击 新建>ODPS SQL。在 新建...
包正文
参数类型可以是基本数据类型、使用%TYPE 的现有列的类型副本，或者是用户定义的类型，例如嵌套表或对象类型。不能为任何基本类型指定长度，例如，指定 VARCHAR2 而不是 VARCHAR2(10)。列的类型通过编写 tablename.columnname%TYPE 来引用，...
数据字典
CREATE DICTIONARY[IF NOT EXISTS][db.]dictionary_name[ON CLUSTER cluster](key1 type1[DEFAULT|EXPRESSION expr1][HIERARCHICAL|INJECTIVE|IS_OBJECT_ID],key2 type2[DEFAULT|EXPRESSION expr2][HIERARCHICAL|INJECTIVE|IS_OBJECT_ID],...
Workload Group
语法 CREATE WORKLOAD GROUP[IF NOT EXISTS]'rg_name' PROPERTIES(property_list);参数说明 参数名称 必选 参数说明 rg_name 是 Workload Group名称。PROPERTIES的参数说明如下。参数名称 必选 参数说明 cpu_share 是 用于设置资源组获取...
DROP TABLE
参数 描述 IF EXISTS 如果指定 IF EXISTS，无论目标表是否存在，执行删除语句后系统都会返回成功。如果不指定 IF EXISTS，当目标表不存在时，系统会返回 ERROR:table"non_exist_table"does not exist 报错。table_name 需要删除的表名称。...
DROP PARTITION TABLE
参数 描述 IF EXISTS 如果指定 IF EXISTS，无论目标表是否存在，执行删除语句后系统都会返回成功。如果不指定 IF EXISTS，当目标表不存在时，系统会返回 ERROR:table"non_exist_table"does not exist 报错。table_name 需要删除的表名称。...
基本语句
本文介绍了基本语句的相关内容。赋值 为一个PL/SQL变量赋一个值可以被写为：variable {:=|=} expression;正如以前所解释的，这样一个语句中的表达式被以一个 SQL SELECT 命令被发送到主数据库引擎的方式计算。该表达式必须得到一个单一值...
子查询
子查询的常见问题 SELECT 语句"class="reference-link">在子查询中有多个 SELECT 语句 InfluxQL支持在主查询中有多个嵌套的子查询：SELECT_clause FROM(SELECT_clause FROM(SELECT_statement)[.])[.]-Subquery 1 Subquery 2 InfluxQL不支持...
- 产品推荐
- 这些文档可能帮助您