开发PyODPS 3任务
import os.#get DataWorks sheduler runtime parameters skynet_hints={} for k,v in os.environ.items():if k.startswith('SKYNET_'):skynet_hints[k]=v.#setting hints while submiting a task o.execute_sql('INSERT OVERWRITE TABLE ...
开发PyODPS 3任务
import os.#get DataWorks sheduler runtime parameters skynet_hints={} for k,v in os.environ.items():if k.startswith('SKYNET_'):skynet_hints[k]=v.#setting hints while submiting a task o.execute_sql('INSERT OVERWRITE TABLE ...
IF
IF函数用于根据判断条件选择执行的语句。本文为您介绍实时数仓Hologres中IF函数的用法。使用限制 仅Hologres V2.1版本起支持IF函数。如果您的实例版本为V2.0及以下版本，请先升级实例版本，详情请参见 实例升级。命令语法 IF(condition,...
表达式
例如，当你写一个这样的PL/SQL语句时：IF expression THEN.PL/SQL将通过给主 SQL 引擎发送一个查询 SELECT expression 来计算该表达式。在构造该 SELECT 命令时，PL/SQL变量名的每一次出现会被参数所替换。这允许 SELECT 的查询计划仅被...
SQL其他常见问题
本文为您介绍在MaxCompute中执行SQL时，与数据类型、SQL限制等相关的常见问题。问题类别 常见问题 数据类型 MaxCompute的时间类型字段是否可以不带时分秒？在执行MaxCompute SQL过程中，对DOUBLE类型的数据进行等值比较，为什么结果不符合...
自定义SQL Console的使用规范
if@fac.sql_count>5 then@act.reject_execute '单次执行SQL个数不能超过5个' else@act.allow_execute end 说明 该段安全规则DSL表示：在SQL Console中，单次执行的SQL语句大于5个（系统默认值1000个）则拒绝执行，小于或等于5个则允许执行...
在DMS中执行SQL语句后出现“禁止未知SQL执行”报错
if@fac.sql_type in['INSERT','INSERT_SELECT','REPLACE','REPLACE_INTO','UPDATE','DELETE','MERGE','REMOVE','EXEC']then@act.allow_execute_direct end 说明：DMS定义了一套领域专用语言DSL（Domain Specific Language）用来描述安全...
SQL 诊断概述
执行计划变动且性能下降 需 DBA 确认，可使用 OUTLINE 进行执行计划固化，以判断是否为异常 SQL。执行次数突刺 需确认业务量，可能导致整体性能下降。CPU 负载过高 请确认业务场景、数据分布变化、请求量突涨、执行计划变化等情况。疑似锁...
内置的安全审计规则
数据库审计规则按照以下攻击场景进行分类：异常操作 应用账号风险操作 运维人员风险操作 数据库探测 数据泄露 拖库攻击 数据库外联 大流量返回 漏洞攻击 缓冲区溢出 存储过程滥用 拒绝服务漏洞 隐通道攻击 SQL注入 SQL注入尝试利用 疑似SQL...
SQL 诊断概述
执行计划变动且性能下降 需 DBA 确认，可使用 OUTLINE 进行执行计划固化，以判断是否为异常 SQL。执行次数突刺 需确认业务量，可能导致整体性能下降。CPU 负载过高 请确认业务场景、数据分布变化、请求量突涨、执行计划变化等情况。疑似锁...
普通数据变更
您可以在DMS中通过SQL窗口直接输入SQL语法或通过数据变更工单提交数据变更。同时，您可以自定义安全规则，实现对不同环境库定义不同的数据变更执行配置。本文将通过以下4个例子向您介绍典型场景下的安全规则设定与对应提交数据变更的方式。...
Delta Lake 快速开始一
order）%sql DESCRIBE HISTORY events 优化后，文件被自动合并做性能优化，表中只有5个文件%sql DESCRIBE DETAIL events Describe formatted 命令也在DDI中支持%sql DESCRIBE FORMATTED events 附录 清理数据库%sql/*DROP DATABASE IF ...
Spark SQL开发介绍
Here are your sql statements.CREATE DATABASE IF NOT EXISTS testdb LOCATION 'oss:/<bucket_name>/test';CREATE EXTERNAL TABLE if not EXISTS `testdb`.`catalog_json_test`(`a` string COMMENT 'from deserializer',`b` string ...
方案实现
SQL客户端用于批流的SQL计算，其中emr-datasources_shaded_*.jar为准备工作中下载的EMR最新版SDK包。streaming-sql-driver-class-path emr-datasources_shaded_*.jar-jars emr-datasources_shaded_*.jar-master yarn-client-num-executors ...
基于ODBC的应用开发
if(ret=SQL_SUCCESS|ret=SQL_SUCCESS_WITH_INFO){ printf("连接成功");执行查询 SQLAllocHandle(SQL_HANDLE_STMT,dbc,&stmt);SQLExecDirect(stmt,(SQLCHAR*)"show databases",SQL_NTS);获取查询结果 SQLCHAR result[50];while(SQLFetch...
Cava 分支结构
} } if…else if…else语句 if…else if…else语句主要用于有多种情况需要判断时，在使用if…else if…else语句时需要注意以下几点：语句中至多只有一个else，并且必须在else if之后。语句中可以有多个else if分支，并且必须在else之前。...
Cava 分支结构
} } if…else if…else语句 if…else if…else语句主要用于有多种情况需要判断时，在使用if…else if…else语句时需要注意以下几点：语句中至多只有一个else，并且必须在else if之后。语句中可以有多个else if分支，并且必须在else之前。...
如何使用HINT（5.2及以下版本适用）
只读实例延时切断会根据主备复制最大延时时间判断将所执行的SQL下发到主实例还是只读实例。语法/!TDDL:SQL_DELAY_CUTOFF=time*/在自定义HINT中指定 SQL_DELAY_CUTOFF 的值，当备库的 SQL_DELAY 值（MySQL主备复制延迟）达到或超过 time 的...
SQL变更
if@fac.env_type not in['product']and@fac.sql_type in['UPDATE','DELETE','INSERT']then@act.allow_submit end 代码含义：如果数据库环境为非线上生产环境，并且SQL语句是 UPDATE、DELETE、INSERT 类型，则允许执行该SQL语句。...
SQL脚本模式
当您面对大数据集的ETL任务、自动化定期任务、复杂查询编排等场景时，可以使用MaxCompute当前SQL引擎支持的脚本模式（Script Mode SQL）。在脚本模式下，一个多语句的SQL脚本文件将被作为一个整体进行编译，无需对单个语句进行编译；提交...
数据类型版本说明
查看 odps.sql.type.system.odps2、odps.sql.decimal.odps2、odps.sql.hive.compatible 属性判断当前项目的数据类型版本。修改项目的数据类型版本 如果发现项目当前选择的数据类型版本不能满足业务需求，可以修改数据类型版本。项目管理员...
SQL
SQL任务类型，用于连接数据库并执行相应SQL。本文为您介绍创建SQL类型任务时涉及的参数，并提供了SQL任务的示例。参数说明 参数 说明 节点名称 任务的名称。一个工作流定义中的节点名称是唯一的。运行标志 正常（默认）：运行工作流时执行...
错误码
DTX-504 sql parser result is empty,sql:[%s]SQL 语句解析结果为空 检查 SQL 语法是否为分布式事务支持。DTX-505‘INSERT INGORE’and‘INSERT ON DUPLICATE UPDATE’statement must contain primaryKey colmun(s),sql:[%s]INSERT INGORE ...
配置行列自动分流
自动分流方案说明 PolarDB MySQL版 的数据库代理功能支持将 SQL语句的预估执行代价 作为判断指标，通过判断预估执行代价是否会超过特定阈值（该阈值可配置），决定将该SQL请求分流到行存或是列存节点上处理，从而发挥出行存和列存的最佳...
UDT概述
MaxCompute基于新一代的SQL引擎推出新功能UDT（User Defined Type）。MaxCompute的UDT功能允许您在SQL中直接调用第三方语言的类使用其方法，或直接使用第三方对象获取其数据内容。UDT介绍 很多SQL引擎中UDT与MaxCompute的复杂类型STRUCT...
通过脚本模式生成API
高级SQL支持的Mybatis标签类型包括if、choose、when、otherwise、trim、foreach和where，您可以借助标签语法来灵活实现空值校验、多值遍历、动态查表、动态排序及聚合等复杂查询逻辑，常见场景的代码示例请参见 脚本模式实践：高级SQL...
基于Python DB-API的应用开发
宽表引擎版本为2.2.16至2.4.1时，删除表前需先禁用表 sql_offline_table="offline table test_python"print(sql_offline_table)statement.execute(sql_offline_table)#删除表 sql_drop_table="drop table if exists test_python"print(sql_...
Java程序如何连接RDS MySQL
if(result!1){ sql="insert into teacher(NO,name)values('2016001','wangsan');result=stmt.executeUpdate(sql);sql="insert into teacher(NO,name)values('2016002','zhaosi');result=stmt.executeUpdate(sql);查询数据。sql="select*...
使用SQL查询时序数据
创建时序表并建立SQL映射关系后，您可以通过控制台、SDK等不同方式使用SQL查询时序数据。时序表的SQL映射关系 根据每个时间线每个时刻对应一个值或者多个值，时序模型分为“单值模型”和“多值模型”。对于同一个时序表，您可以建立三种SQL...
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控制台...
基于Python的应用开发
sql_create_table="create table if not exists test_python(c1 integer,c2 integer,primary key(c1))"print(sql_create_table)statement.execute(sql_create_table)完整示例 完整示例代码如下：#!usr/bin/python#-*-coding:UTF-8-*-import...
DQL操作常见问题
如何用正则表达式判断字段是否为中文？在执行MaxCompute SQL过程中，报错Repeated key in GROUP BY，如何解决？问题现象 在执行MaxCompute SQL过程中，返回报错如下。FAILED:ODPS-0130071:Semantic analysis exception-Repeated key in ...
SQL脚本
SQL脚本是自定义SQL组件，您可以通过SQL脚本编辑器编写SQL语句，并提交至MaxCompute执行。本文为您介绍SQL脚本的组件配置和使用场景。组件配置 Designer 仅支持通过可视化方式，配置SQL脚本组件的参数，组件参数配置如下所示。参数 描述 ...
通过直连数据源模式创建API
{age}</if>格式化 支持对SQL语句格式化处理展示，仅支持对基础SQL。字段参考 在 字段参考 弹框，为您展示已选择数据表中的所有字段。支持复制表名称、全表字段或单个字段。单击 SQL试运行，在 请求参数输入 对话框中，选择 参数类型、操作...
自动SQL限流
SQL限流是限制数据库上执行SQL的并发度，通过限制问题SQL的并发度后，保障数据库正常响应业务请求，保障大部分的业务正常运转，即通过小部分业务受损，保障大部分业务正常运行。背景信息 随着技术的发展，尤其是云数据库的普及，数据库系统...
DBMS_SQL
DBMS_SQL内置包提供了动态SQL的功能，可以在运行期间动态执行SQL语句。DBMS_SQL子程序总览 子程序 说明 BIND_ARRAY Procedure 将数组类型的值绑定到变量。BIND_VARIABLE Procedure 将给定值绑定到变量。BIND_VARIABLE_CHAR Procedure 将...
基于Go的应用开发
本文介绍使用Go语言的database/sql包和SQL语句在Lindorm宽表应用中进行开发的方法和示例。前提条件 已安装GO环境，建议安装Go 1.17及以上版本。如何安装，请参见 Go。已开通MySQL协议兼容功能。如何开通，请参见 开通MySQL协议兼容功能。已...
Golang
timeout=s",user,password,host,port,database,connectTimeout)db,err:=sql.Open("mysql",url)if err!nil { panic(err.Error())}/设置可打开连接数的最大值，默认值为0，表示不限制。db.SetMaxOpenConns(2)/设置最大闲置连接数。db....
使用SSMS和BCP迁移SQL Server数据库
除了DTS，您也可以使用其他工具迁移数据库，本文以本地SQL Server数据库到阿里云云数据库SQL Server 2012的数据全量迁移为例，介绍了如何通过使用SQL Server Management Studio（SSMS）和大容量复制程序实用工具（BCP）来迁移SQL Server...
Spark SQL创建C-Store表
AnalyticDB MySQL 支持使用Spark SQL创建C-Store表，本文主要介绍使用Spark SQL创建C-Store表的语法、示例以及数据类型的映射关系。背景信息 AnalyticDB MySQL Spark SQL创建C-Store表的语法与开源社区Spark SQL的建表语法存在差异，...
- 产品推荐
- 这些文档可能帮助您