创建SA权限的数据库账号
SA（System Admin）角色是SQL Server中最强大的角色，该角色完全绕过所有安全检查，可以在SQL Server中执行任何操作。您可以在RDS SQL Server中创建具备SA权限的数据库账号（超级权限账号），可用于快速适配线下软件上云等场景。前提条件 ...
开发ODPS Script任务
IF条件为BOOLEAN类型表达式 这种类型的 IF ELSE 语句可以在编译阶段决定执行哪个分支，示例如下：数据处理 set odps.sql.allow.fullscan=true;set odps.optimizer.cbo.rule.filter.black=LM;date:='${var}';row TABLE(key int,value bigint...
开发ODPS Script任务
IF条件为BOOLEAN类型表达式 这种类型的 IF ELSE 语句可以在编译阶段决定执行哪个分支，示例如下：数据处理 set odps.sql.allow.fullscan=true;set odps.optimizer.cbo.rule.filter.black=LM;date:='${var}';row TABLE(key int,value bigint...
最佳实践：SQL组件
前提条件 已创建SQL组件节点，详情请参见 创建并管理MaxCompute节点。已在 ODPS SQL 节点中创建好输入表和输出表，建表语句请参见 附录：表结构说明。步骤一：定义组件 您需先参考 定义SQL组件 创建 get_top_n 组件，组件配置详情如下。...
会话管理
SQL限流：单击 SQL限流，在弹出的 SQL限流 页面配置限流参数，对符合限流条件的实例会话进行SQL限流，详细操作请参见 SQL限流。优化：单击 优化，在弹出的 SQL诊断优化 对话框中，查看SQL诊断结果。若您采纳诊断建议，单击页面右上角的 ...
HikariCP 连接池连接 OceanBase 数据库示例程序
也可以在 OceanBase 客户端（OBClient）中执行以下 SQL 语句查看结果。obclient[(none)]>SELECT*FROM test.test_hikaricp;返回结果如下：+-+-+|id|name|+-+-+|1|test_update|+-+-+1 row in set 项目代码介绍 点击 hikaricp-mysql-client ...
批计算
连接全局二级索引 Spark连接到表格存储数据表和全局二级索引后，通过Spark外表查询数据时，系统会根据查询条件中设置的列条件自动选择索引表进行查询。步骤一：在表格存储侧创建数据表或全局二级索引 创建表格存储的数据表。具体操作，请...
BigQuery数据源
是 无 where 筛选条件，BigQuery Reader根据指定的 column、table 和 where 条件拼接SQL，并根据该SQL进行数据抽取。例如在做测试时，可以将 where 条件指定为 LIMIT 10。在实际业务场景中，通常会选择当天的数据进行同步，可以将 where ...
UPDATE
关联更新的时候，如果只更新交集数据，不使用from子句时需要写额外的where条件，相对于from语法而言也不太简洁。使用示例 示例1：创建非分区表acid_update，并导入数据，执行 update 操作更新满足指定条件的行对应的列数据。命令示例如下：...
基础使用
本文通过示例为您介绍如何在已经创建好的E-MapReduce（简称EMR）集群中使用Iceberg。背景信息 本文以数据湖元数据为例，详细配置请参见 数据湖元数据配置。前提条件 已在E-MapReduce控制台上，创建Hadoop的EMR-5.3.0及后续版本的集群，详情...
ApsaraDB For OceanBase数据源
否 空 where ApsaraDB For OceanBase Reader根据指定的 column、table、where 条件拼接SQL，并根据该SQL进行数据抽取。例如，在进行测试时，可以指定 where 条件为 limit 10。在实际业务场景中，通常会选择当天的数据进行同步，指定 where ...
基于Go database/sql接口的应用开发
本文介绍通过Go语言的database/sql包使用SQL开发Lindorm宽表应用的方法和示例。前提条件 已下载并安装 Go环境，建议安装Go 1.17及以上版本。已将客户端IP地址添加至Lindorm实例的白名单中，具体操作，请参见 设置白名单。使用限制 本文操作...
使用Go语言database/sql接口的应用开发
本文介绍通过Go语言的database/sql包使用SQL开发Lindorm宽表应用的方法和示例。前提条件 已下载并安装 Go环境，建议安装Go 1.17及以上版本。已将客户端IP地址添加至Lindorm实例的白名单中，具体操作，请参见 设置白名单。使用限制 本文操作...
DBCP 连接池连接 OceanBase 数据库示例程序
也可以在 OceanBase 客户端（OBClient）中执行以下 SQL 语句查看结果。obclient[test]>SELECT*FROM test_tbl1;返回结果如下：+-+-+|id|name|+-+-+|5|test_update|6|test_insert6|7|test_insert7|8|test_insert8|9|test_insert9|+-+-+5 rows...
使用Databricks Delta优化Spark作业性能
numFiles)spark.conf.get("spark.sql.shuffle.partitions")sql(s"drop database if exists$dbName cascade")sql(s"create database if not exists$dbName")sql(s"use$dbName")sql(s"show tables").show(false)import scala.util.Random ...
更新或删除数据（UPDATE|DELETE）
本文中的命令您可以在如下工具平台执行：MaxCompute客户端 使用SQL分析连接 使用云命令行（odpscmd）连接 使用DataWorks连接 MaxCompute Studio 前提条件 执行 delete、update 操作前需要具备目标Transactional表的读取表数据权限（Select...
词法结构
NCHAR、SQL_NCLOB、SQL_NUMERIC、SQL_NVARCHAR、SQL_REAL、SQL_SMALLINT、SQL_TIME、SQL_TIMESTAMP、SQL_TINYINT、SQL_TSI_DAY、SQL_TSI_FRAC_SECOND、SQL_TSI_HOUR、SQL_TSI_MICROSECOND、SQL_TSI_MINUTE、SQL_TSI_MONTH、SQL_TSI_QUARTER...
SQL Server数据源
否 无 where 筛选条件，SQL Server Reader根据指定的 column、table 和 where 条件拼接SQL，并根据该SQL进行数据抽取。例如在测试时，可以将where条件指定为limit 10。在实际业务场景中，往往会选择当天的数据进行同步，将where条件指定为 ...
开发ODPS SQL任务
DataWorks为您提供ODPS SQL节点，可用于周期性调度MaxCompute的SQL任务，并完成与其他类型节点的集成和联合调度。MaxCompute SQL任务采用类似SQL的语法，适用于海量数据（TB级）但实时性要求不高的分布式处理场景。本文为您介绍在DataWorks...
开发ODPS SQL任务
DataWorks为您提供ODPS SQL节点，可用于周期性调度MaxCompute的SQL任务，并完成与其他类型节点的集成和联合调度。MaxCompute SQL任务采用类似SQL的语法，适用于海量数据（TB级）但实时性要求不高的分布式处理场景。本文为您介绍在DataWorks...
不兼容SQL重写
旧版MaxCompute会把两边都转成BIGINT类型，会导致严重的精度损失问题，例如：1.1=“1”在连接条件中会被认为是相等的。MaxCompute 2.0会与Hive兼容转为DOUBLE类型。示例 不推荐写法 select*from t1 join t2 on t1.double_value=t2.string_...
SQL洞察和审计
当您在安全合规审计、性能分析、故障排除等场景下需要监控和管理RDS MySQL实例中执行的SQL语句时，可以利用SQL洞察和审计功能对SQL语句的执行情况进行记录和聚合分析。开启该功能后会自动记录来自数据库内核的SQL语句，以及SQL语句的执行...
SQL洞察和审计
当您在安全合规审计、性能分析、故障排除等场景下需要监控和管理RDS MySQL实例中执行的SQL语句时，可以利用SQL洞察和审计功能对SQL语句的执行情况进行记录和聚合分析。开启该功能后会自动记录来自数据库内核的SQL语句，以及SQL语句的执行...
Key/Value查询场景最佳实践
需要将查询条件中的列设置为Distribution Key，一般默认主键为Distribution Key。表的存储类型需要设置为行存。建议连接Hologres实例时使用VPC网络的域名。当有TEXT、VARCHAR、CHAR类型时，建议使用TEXT类型，而不是VARCHAR或者CHAR类型。...
Amazon Redshift数据源
INTEGER SQL_INTEGER 整数 OID SQL_BIGINT 长整型 SUPER SQL_LONGVARCHAR 字符串 REAL SQL_REAL Float SMALLINT SQL_SMALLINT 短型 TEXT SQL_VARCHAR 字符串 TIME SQL_TYPE_TIME java.sql.Time TIMETZ SQL_TYPE_TIME java.sql.Time ...
自定义函数
SQL相关的执行逻辑会发送到SQL engine中执行，然后获取执行结果，控制流程等相关的逻辑会在PL engine中执行。自定义函数在真正执行前会注册到运行时函数管理中心，同时整个执行过程中单条Query的内存大小会被严格限制。函数下推 PolarDB-X ...
DELETE
DELETE操作用于删除Transactional分区表或非分区表中满足指定条件的单行或多行数据。前提条件 执行 delete、update 操作前需要具备目标Transactional表的读取表数据权限（Select）及更新表数据权限（Update）。授权操作请参见 权限列表。...
基于Go的应用开发
本文介绍使用Go语言的database/sql包和SQL语句在Lindorm宽表应用中进行开发的方法和示例。前提条件 已安装GO环境，建议安装Go 1.17及以上版本。如何安装，请参见 Go。已开通MySQL协议兼容功能。如何开通，请参见 开通MySQL协议兼容功能。已...
DM（达梦）数据源
在实际业务场景中，通常会选择当天的数据进行同步，可以将 where 条件指定为 gmt_create>$bizdate：where 条件可以有效地进行业务增量同步。where 条件不配置或为空时，则视作全表同步数据。否 无 querySql 在部分业务场景中，where 配置项...
CREATE MATERIALIZED VIEW
INNER JOIN INNER JOIN 单个JOIN 支持 不支持 支持 支持 多个JOIN 支持 不支持 支持 支持 AGGREGATE+JOIN-支持 不支持 支持 支持 使用物化视图查询改写的原则是查询语句中需要的数据必须从物化视图中得到，包括输出列、筛选条件中需要的列...
数据查询最佳实践
多表关联查询WHERE条件中，需要明确写明每一个表的过滤条件。通常在传统数据库中，都是通过索引字段关联来快速检索数据。例如：Select count(*)from t1 C join t2 O on C.t1_id=O.t1_id where O.t2_time between'2018-07-20 10:00:11' and ...
实例会话
SQL限流：单击 SQL限流，在弹出的 SQL限流 页面配置限流参数，对符合限流条件的实例会话进行SQL限流，详细操作请参见 SQL限流。优化：单击 优化，对目标实例会话进行优化，详细操作请参见 SQL优化。导出活跃会话。结束会话。结束会话时，...
Golang
前提条件 已安装了Git，并且已将Git路径添加到Path环境变量中。下载并安装 Golang。安装Golang MySQL Driver。下载 Golang MySQL Driver。使用Shell中的go工具将驱动包安装到$GOPATH 中。go get github.com/go-sql-driver/mysql连接 ...
通过Spark SQL读写Delta外表
前提条件 AnalyticDB MySQL 湖仓版（3.0）集群与OSS存储空间位于相同地域。已在湖仓版（3.0）集群中创建Job型资源组。具体操作，请参见 新建资源组。已创建湖仓版（3.0）集群的数据库账号。如果是通过阿里云账号访问，只需创建高权限账号。...
2.0版SQL开发规范
多表关联查询where条件中，需要明确写明每一个表的过滤条件。通常我们在传统数据库中，都是通过索引字段关联来快速检索数据。如下SQL：Select count(*)from customer_table C join order_table O on C.customer_id=O.customer_id where O....
GBase8a数据源
否 空 where 筛选条件，Gbase8a Reader根据指定的 column、table、where 条件拼接SQL，并根据该SQL进行数据抽取。例如，在进行测试时，可以指定 where 条件为 limit 10。在实际业务场景中，通常会选择当天的数据进行同步，指定 where 条件...
SQL洞察
PolarDB MySQL版 的 SQL洞察 功能已升级为SQL洞察和审计。SQL洞察和审计由数据库自治服务DAS提供，在全量请求和安全审计的基础上，融合了搜索、SQL洞察、安全审计以及流量回放和压测等功能，帮助您更好地获取SQL语句的具体信息、排查各种...
AnalyticDB for PostgreSQL数据源
否 无 where 筛选条件，AnalyticDB for PostgreSQLReader根据指定的 column、table 和 where 条件拼接SQL，并根据该SQL进行数据抽取。例如测试时，可以将where条件指定实际业务场景，往往会选择当天的数据进行同步，将where条件指定为 id>2...
SELECT语序
返回结果如下：+-+-+-+|shop_name|total_price|region|+-+-+-+|s3|100.3|china|s6|100.4|shanghai|s7|100.5|shanghai|+-+-+-+该命令的执行逻辑如下：从sale_detail表（from sale_detail）中取出满足 where total_price>100.2 条件的数据。...
SELECT语序
返回结果如下：+-+-+-+|shop_name|total_price|region|+-+-+-+|s3|100.3|china|s6|100.4|shanghai|s7|100.5|shanghai|+-+-+-+该命令的执行逻辑如下：从sale_detail表（from sale_detail）中取出满足 where total_price>100.2 条件的数据。...
- 产品推荐
- 这些文档可能帮助您