SQL Server性能分析与优化
io_stall_queued_write_ms AS[Resource Governor Total Write IO Latency(ms)]FROM sys.dm_io_virtual_file_stats(NULL,NULL)AS fs INNER JOIN sys.master_files AS mf WITH(NOLOCK)ON fs.database_id=mf.database_id AND fs.[file_id]=mf...
重要参数说明
CREATE TEMPORARY TABLE s1(a INT,b INT,ts TIMESTAMP(3),PRIMARY KEY(a)NOT ENFORCED,WATERMARK FOR ts AS ts-INTERVAL '1' SECOND)WITH('connector'='datagen','rows-per-second'='1','fields.ts.kind'='random','fields.ts.max-past'='...
PyODPS的列运算
Executing user script with PyODPS 0.8.0 Sql compiled:CREATE TABLE tmp_pyodps_32e39a9a_8ae6_4815_b465_4b9dfa3bf1b9 LIFECYCLE 1 AS SELECT t1.`sepallength` IS NULL AS `sepallength` FROM DQC_0221_dev.`pyodps_iris` t1 ...
alicloud_db_database
MySQL:[utf8,gbk,latin1,utf8mb4](utf8mb4 only supports versions 5.5 and 5.6).SQLServer:[Chinese_PRC_CI_AS,Chinese_PRC_CS_AS,SQL_Latin1_General_CP1_CI_AS,SQL_Latin1_General_CP1_CS_AS,Chinese_PRC_BIN]PostgreSQL:Valid values ...
SQL常见问题
本文为您介绍实时计算Flink版的SQL常见问题，包括作业常见问题、开发报错、运维报错。为什么使用POJO类作为UDTF返回类型时字段会出现“错位”?为什么数据在LocalGroupAggregate节点中长时间卡住，无输出？运行拓扑图中显示的Low Watermark...
Table/SQL JAR迁移至SQL
本文为您介绍如何将Table/SQL JAR作业迁移至Flink全托管的SQL作业中。背景信息 本文将使用开源JDBC Connector写阿里云RDS的方式进行Table/SQL JAR迁移至SQL，因此需要额外配置附加依赖文件选项。实时计算Flink全托管版集群内置了商业化的...
自建SQL Server迁移至RDS SQL Server
数据传输服务DTS（Data Transmission Service），可以将自建SQL Server迁移至 RDS SQL Server。前提条件 自建SQL Server数据库支持的版本，请参见 迁移方案概览。已创建目标 RDS SQL Server 实例，具体请参见 快速创建RDS SQL Server实例。...
数据管理
SQL MERGE INTO target AS t USING source AS s ON t.date=s.date WHEN MATCHED[AND t.name='should_update']THEN UPDATE SET target.name=source.name WHEN MATCHED[AND t.name='should_delete']THEN DELETE WHEN NOT MATCHED[AND s.name=...
SELECT
[LATERAL](select)[AS]alias[(column_alias[,.])]with_query_name[[AS]alias[(column_alias[,.])]][LATERAL]function_name([argument[,.]])[WITH ORDINALITY][[AS]alias[(column_alias[,.])]][LATERAL]function_name([argument[,.]])[AS]...
DML语句
with delete merge into h0 as target using(select 1 as id,'a1' as name,10.0 as price)source on target.id=source.id when matched then update set id=source.id,name=source.name,price=source.price when matched and name='delete'...
通过直连数据源模式创建API
sum(a)as b,min(a)as d,count(*)as e from 数据表A where c like${id_card} 模板四：select t.name as name from 数据表A c=${id_card} 模板五：select(a+b)as acd，(b+c)as bcf from 数据表A where c=${id_card} and/or b>=${num} and/or ...
CREATE TABLE AS（CTAS）语句
CREATE TABLE IF NOT EXISTS user WITH('jdbcWriteBatchSize'='1024')AS TABLE mysql.`wp.*`.`user[0-9]+`/*+OPTIONS('server-id'='8001-8004')*/ADD COLUMN(`t_idx` AS COALESCE(SPLIT_INDEX(`tbl`,'r',1),'default')FIRST,`c_id` AS `id`...
Spark SQL
{your bucket name}/{path}/' WITH DBPROPERTIES(k1='v1',k2='v2')")#create table spark.sql("create table dlatest.tp(col1 INT)PARTITIONED BY(p1 STRING,p2 STRING)location 'oss:/{your bucket name}/{path}/' STORED AS parquet ...
高级查询的SQL语法
您可以在高级查询中使用SQL语法，查询或分析您通过跟踪投递到日志服务SLS的日志事件。重要 在日志服务分析语句中，表示字符串的字符必须使用单引号（''）包裹，无符号包裹或被双引号（""）包裹的字符表示字段名或列名。例如：'status' 表示...
ModifyCollationTimeZone-修改系统字符集排序规则和...
取值：Chinese_PRC_CI_AS Chinese_PRC_CS_AS Chinese_PRC_BIN Latin1_General_CI_AS Latin1_General_CS_AS SQL_Latin1_General_CP1_CI_AS SQL_Latin1_General_CP1_CS_AS Japanese_CI_AS Japanese_CS_AS Chinese_Taiwan_Stroke_CI_AS ...
SQL变更
SQL变更作为变更SQL执行的入口，需要极高的安全性。在工单提交、审批时，通过一系列的安全规则进行校验，只有满足规则校验的SQL，才能正常执行。前提条件 用户角色为 管理员、DBA 或 安全管理员。背景信息 数据管理DMS的安全规则具备非常...
保留字
本文介绍日志服务SQL分析语句中所有的保留字。AND AS BETWEEN BY CASE CAST CROSS CUBE CURRENT_DATE CURRENT_TIME CURRENT_TIMESTAMP DISTINCT ELSE END ESCAPE EXCEPT EXISTS FROM GROUP GROUPING HAVING IN INNER INSERT INTERSECT INTO...
Delta连接器
SELECT*FROM delta_table FOR TIMESTAMP AS OF CAST('2022-02-15 20:00:00+0800' AS TIMESTAMP WITH TIME ZONE);Z-Order Trino基于Z-Order优化了Delta表查询。目前支持Parquet自身的优化和Data Skipping的优化。执行优化后，Delta会按文件...
SQL性能问题
本文介绍有关SQL性能相关的常见问题。Flink全托管如何拆分SQL作业节点？Group Aggregate优化技巧有哪些？TopN优化技巧有哪些？有哪些高效去重方案？在使用内置函数时，需要注意什么？Flink全托管如何拆分SQL作业节点？在 作业运维 页面，...
高性能Flink SQL优化技巧
本文将从作业配置和Flink SQL优化两方面为您介绍如何提升Flink SQL作业性能。作业配置优化推荐方案 资源优化技巧 VVP中限制了JobManager和TaskManager的CPU的实际使用大小，配置了多少个CPU，最大就只能使用多少个CPU。因此在资源优化时，...
Quick BI使用MaxCompute数据源创建SQL数据集时报错
A32_14_,ALL_T_1_.`code` AS T_A51_15_,ALL_T_1_.`income` AS T_AC2_16_,ALL_T_1_.`business_type` AS T_AC5_17_,ALL_T_1_.`time` AS T_AED_18_,ALL_T_1_.`account_serial_number` AS T_A49_19_,ALL_T_1_.`pid` AS T_AF1_20_,ALL_T_1_.`...
内建函数常见问题
select md5(concat(aid,bid))as id,aid,bid,sum(amountdue)as amountdue,coalesce(sum(regexp_count(get_json_object(extended_x,'$.table.tableParties'),'{')),decode(get_json_object(extended_x,'$.table'),null,0,1))as tableparty,...
SQL诊断
例如报错：column"col"with type"float4"cannot be set as"bitmap_columns"表示float4类型不能设置为bitmap columns。mismatched properties:table orientation is"column"but storage format is"sst"resharding insert select table data ...
查询计划概述
Lindorm支持查看SQL语句在数据库中的执行过程，帮助您定位和排查SQL执行问题。您可以通过 EXPLAIN 语句查看不同深度的执行计划，进一步分析优化查询逻辑，以提升查询性能。适用引擎 适用于宽表引擎和时序引擎。背景信息 查询计划（Query ...
开发ODPS SQL任务
DataWorks为您提供ODPS SQL节点，可用于周期性调度MaxCompute的SQL任务，并完成与其他类型节点的集成和联合调度。MaxCompute SQL任务采用类似SQL的语法，适用于海量数据（TB级）但实时性要求不高的分布式处理场景。本文为您介绍在DataWorks...
开发ODPS SQL任务
DataWorks为您提供ODPS SQL节点，可用于周期性调度MaxCompute的SQL任务，并完成与其他类型节点的集成和联合调度。MaxCompute SQL任务采用类似SQL的语法，适用于海量数据（TB级）但实时性要求不高的分布式处理场景。本文为您介绍在DataWorks...
CREATE TABLE LIKE
如果SQL语句中有较多单引号，可以将$符号置于SQL语句前后，通过$query_sql$改写（推荐使用该用法，操作更简便）自动实现单引号转义，用法如下：CALL HG_CREATE_TABLE_LIKE('table_name',$query_sql$[,'partition_clause'])old_table_name：...
Forall and Bulk Collect
解决方案 类似Oracle FORALL的批量插入用法，用一个数组表示条件，另一个数组表示VALUE如果有多个条件或者value时，可以用record数组或者hstore（Key-Value类型）数组来表示。CREATE OR REPLACE FUNCTION public.f_bulk_insert1(i_k ...
SQL语法
CREATE CAST(sourcetype AS targettype)WITH FUNCTION funcname(argtypes)[AS ASSIGNMENT|AS IMPLICIT]CREATE CAST(sourcetype AS targettype)WITHOUT FUNCTION[AS ASSIGNMENT|AS IMPLICIT]更多信息，请参见 CREATE CAST。CREATE ...
Flink_SQL任务开发方式
Dataphin的Flink_SQL任务支持多种开发方式，包括原生DDL+DML开发、基于Catalog开发、使用Dataphin元表进行开发、使用Dataphin数据源表进行开发、以及使用计算源物理表进行开发，且不同开发方式所创建的表支持任意混用，包括镜像表。...
Quick BI数据集预览报错：null:INTERNAL:java.sql....
问题描述 Quick BI数据集预览报错：null:INTERNAL:java.sql.SQLException:java.util.concurrent.ExecutionException:java.sql.SQLException:execute sql[SELECT ALI_T_1_.`category_name` AS T_A1D_2_,ALI_T_1_.`sku_real_price`-ALI_T_1_....
语法
[WITH with_query[,.]]SELECT[ALL|DISTINCT]select_expr[,.][FROM table_reference[,.]][WHERE condition][GROUP BY[ALL|DISTINCT]grouping_element[,.]][HAVING condition][WINDOW window_name AS(window_spec)[,window_name AS(window_...
JSON
Flink SQL类型 JSON类型 CHAR/VARCHAR/STRING string BOOLEAN boolean BINARY/VARBINARY string with encoding:base64 DECIMAL number TINYINT number SMALLINT number INT number BIGINT number FLOAT number DOUBLE number DATE string ...
Flink_SQL任务开发方式
Dataphin的Flink_SQL任务支持多种开发方式，包括原生DDL+DML开发、使用Dataphin元表进行开发、使用Dataphin数据源表进行开发、以及使用计算源物理表进行开发，且不同开发方式所创建的表支持任意混用，包括镜像表。不同开发方式的使用方法、...
其他SQL语句
交互式分析Hologres兼容PostgreSQL，除了支持创建、查询及更新数据库的表和Schema等对象的SQL语句外，同时还支持其他SQL语句。本文为您介绍Hologres支持的其他SQL语句。Hologres已支持的其他PostgreSQL功能语句如下表所示，您可以参考 ...
Create FJOB
FJOB（Flink Job，简称FJOB），用户可以在一个FJOB中通过Flink SQL语法实现业务的流计算处理逻辑（过滤、转换、增强、聚合），并将计算结果写入到Lindorm中。本文介绍通过Create FJOB语法在Lindorm流引擎中提交任务。语法 CREATE FJOB fjob...
EXPLAIN
当您需要优化查询语句时，例如查看查询是否有效的使用了索引，您可以通过...生成类型计划 EXPLAIN WITH TYPE FOR SELECT POSITION('9378' IN p1)AS lp,COUNT(c1)FROM(SELECT*FROM test WHERE p1 like '3_%')GROUP BY lp ORDER BY lp;
物化视图自动查询改写
WHERE子句 当查询SQL的WHERE子句与物化视图SQL不完全相同时，自动查询改写对WHERE子句支持情况如下：当查询SQL和物化视图SQL的WHERE都是由AND连接多个条件时：支持查询SQL的WHERE的多个条件的顺序与物化视图SQL的不同，示例如下：物化视图...
使用DLA访问
本文介绍通过数据湖分析（DLA）连接 云原生多模数据库 Lindorm 文件引擎的方法，并使用SQL查询文件引擎中的数据。前提条件 云原生多模数据库 Lindorm 实例已开通文件引擎，具体请参见 开通指南。将专有网络的IP添加至Lindorm实例的白名单中...
CREATE DATABASE AS（CDAS）语句
基本语法 CREATE DATABASE IF NOT EXISTS[COMMENT database_comment][WITH(key1=val1,key2=val2,.)]AS DATABASE<source_database>INCLUDING { ALL TABLES|TABLE 'table_name' }[EXCLUDING TABLE 'table_name'][/*+OPTIONS(key1=val1,key2=...
- 产品推荐
- 这些文档可能帮助您