数据准备与预处理
select age,(case sex when 'male' then 1 else 0 end)as sex,(case cp when 'angina' then 0 when 'notang' then 1 else 2 end)as cp,trestbps,chol,(case fbs when 'true' then 1 else 0 end)as fbs,(case restecg when 'norm' then 0 ...
使用Copilot+增强分析实现一站式智能数据查询与可视化
Copilot是您在DataWorks的智能助手，它能够根据自然语言快速完成多种SQL相关操作，包括生成SQL、改写SQL、SQL错误纠正及生成注释等。使用DataWorks的Copilot，可帮助您轻松、高效、便捷地完成数据ETL及数据分析工作，节省大量时间和精力。...
DBMS_SQL
DBMS_SQL包提供查询 PolarDB PostgreSQL版（兼容Oracle）动态SQL的功能，可以在应用运行时构建查询。PolarDB PostgreSQL版（兼容Oracle）支持查询动态SQL，且以与Oracle兼容的方式来使用动态SQL。表 1.DBMS_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...
使用方法
aliyun-sql插件是基于Apache Calcite开发的部署在服务端的SQL解析插件，使用此插件您可以像使用普通数据库一样使用SQL语句查询Elasticsearch中的数据，从而极大地降低您学习和使用Elasticsearch的成本。背景信息 与开源的SQL插件相比，...
Go-SQL-Driver/MySQL 连接 OceanBase 数据库示例程序
本文将介绍如何使用 Go-SQL-Driver/MySQL 驱动和 OceanBase 数据库构建一个应用程序，实现创建表、插入数据和查询数据等基本操作。点击下载 go-oceanbase 示例工程 前提条件 安装 OceanBase 数据库、Go 语言和相关驱动，并确保已经正确配置...
基于Go的应用开发
本文介绍使用Go语言的database/sql包和SQL语句在Lindorm宽表应用中进行开发的方法和示例。前提条件 已安装GO环境，建议安装Go 1.17及以上版本。如何安装，请参见 Go。已开通MySQL协议兼容功能。如何开通，请参见 开通MySQL协议兼容功能。已...
大数据AI公共数据集分析
SELECT CAST(SUBSTR(behavior_time,12)AS BIGINT)AS 时间段,CASE WHEN behavior_type='1' THEN '商品页浏览' WHEN behavior_type='3' THEN '加入购物车' WHEN behavior_type='4' THEN '购买成功' ELSE behavior_type END AS 用户操作,COUNT...
Go
本文介绍 Go 代码示例如何通过驱动 Go-SQL-Driver/MySQL 连接并使用 OceanBase 数据库。前提条件 确保本地已部署 Go 语言环境。Go 驱动连接数据库 步骤一：获取数据库连接参数 参考 获取连接参数 文档，获取相应的租户连接参数，例如：$...
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....
Spark SQL创建C-Store表
AnalyticDB MySQL 支持使用Spark SQL创建C-Store表，本文主要介绍使用Spark SQL创建C-Store表的语法、示例以及数据类型的映射关系。背景信息 AnalyticDB MySQL Spark SQL创建C-Store表的语法与开源社区Spark SQL的建表语法存在差异，...
Golang访问（2.0版）
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....
COUNT_IF
如果您用到的函数涉及新数据类型（TINYINT、SMALLINT、INT、FLOAT、VARCHAR、TIMESTAMP或BINARY），在使用扩展函数时，需要执行如下语句开启新数据类型开关：Session级别：如果使用新数据类型，您需要在SQL语句前加上语句 set odps.sql....
在本地环境上使用PyODPS
o.create_table('my_t','num bigint,id string',if_not_exists=True)使用 execute_sql 方法执行SQL查询。result=o.execute_sql('SELECT*FROM pyodps_iris LIMIT 3')with result.open_reader()as reader:for record in reader:print(record)...
alicloud_slb_listeners
session-Indicate whether session persistence is enabled or not.If enabled,all session requests from the same client are sent to the same backend server.Possible values are on and off.Only available when the protocol is ...
alicloud_ens_disk
Provides a ENS Disk resource.The disk.When you use it for the first time,please contact the product classmates to add a resource whitelist.For information about ENS Disk and how to use it,see What is Disk.->NOTE:Available ...
ALTER FOREIGN TABLE
ALTER FOREIGN TABLE[IF EXISTS]name RENAME TO new_name;示例SQL语句如下。ALTER FOREIGN TABLE test RENAME TO new_test_table;增加列 使用Hologres创建外部表查询数据时，当MaxCompute表增加字段后，Hologres不会自动更新Schema，需要您...
ClickHouse SQL
ClickHouse SQL可实现分布式SQL查询及处理结构化数据，提高作业的执行效率。DataWorks的ClickHouse SQL节点可进行ClickHouse SQL任务的开发和周期性调度，以及与其他作业的集成操作。本文为您介绍使用ClickHouse SQL节点进行任务开发的主要...
获取时间类型数据
nil { println("[INFO:]get column error,name:",name,",error:",err.Error())continue } if isnull { println("[INFO]:column is SQL NULL,name:",name)continue } switch columns[i].Type { case tablestore.ColumnType_DATETIME:time,...
SQL任务快速入门
EMR Serverless Spark支持通过SQL代码编辑和运行任务。本文带您快速体验Spark SQL任务的创建、启动和运维等操作。前提条件 已准备阿里云账号，详情请参见 账号注册。已完成角色授权，详情请参见 阿里云账号角色授权。已创建工作空间和...
通过应用程序访问数据库
} } } Python import pymysql connection=pymysql.connect(host='<Host>',port=,user='<myUsername>',passwd='<myPassword>',db='<myDatabase>')try:with connection.cursor()as cursor:sql="SELECT*FROM `courses`"#输入希望执行的SQL。...
Phoenix
Apache Phoenix是构建在HBase上的SQL中间层，允许使用标准的SQL语法来查询和管理存储在HBase中的数据。前提条件 已创建选择了Phoenix和HBase服务的DataServing或Custom类型的集群，详情请参见 创建集群。使用Phoenix客户端 使用SSH方式连接...
alicloud_instance
id.When it is changed,the instance will reboot to make the change take effect.If you do not use launch_template_id or launch_template_name to specify a launch template,you must specify image_id.instance_type-(Optional)The ...
HIVECLI
HIVECLI任务类型用于执行SQL脚本语句或者SQL任务文件。本文为您介绍创建HIVECLI类型任务时涉及的参数，并提供了HIVECLI任务的示例。参数说明 参数 说明 节点名称 任务的名称。一个工作流定义中的节点名称是唯一的。运行标志 正常（默认）：...
通过Spark SQL读写OSS外表
本文以OSS Parquet格式为例介绍如何通过Spark SQL读写OSS外表。前提条件 已创建 湖仓版（3.0）集群。详情请参见 创建湖仓版集群。已创建Job型资源组。详情请参见 新建资源组。已创建数据库普通账号，并将RAM用户（子账号）绑定到 ...
DBMS_SQL
DBMS_SQL内置包提供了动态SQL的功能，可以在运行期间动态执行SQL语句。DBMS_SQL子程序总览 子程序 说明 BIND_ARRAY Procedure 将数组类型的值绑定到变量。BIND_VARIABLE Procedure 将给定值绑定到变量。BIND_VARIABLE_CHAR Procedure 将...
Delta Lake 快速入门
SQL%sql MERGE INTO events USING updates ON events.eventId=updates.eventId WHEN MATCHED THEN UPDATE SET events.data=updates.data WHEN NOT MATCHED THEN INSERT(date,eventId,data)VALUES(date,eventId,data)执行INSERT时（例如，当...
开发ODPS SQL任务
SQL示例如下：创建一张分区表test1 create table if not exists students(id BIGINT,name STRING,age BIGINT,birth DATE)partitioned by(gender STRING);插入数据 您可使用 INSERT INTO 或 INSERT OVERWRITE 语句向目标表中插入更新数据，...
开发ODPS SQL任务
SQL示例如下：创建一张分区表test1 create table if not exists students(id BIGINT,name STRING,age BIGINT,birth DATE)partitioned by(gender STRING);插入数据 您可使用 INSERT INTO 或 INSERT OVERWRITE 语句向目标表中插入更新数据，...
查询表的描述信息
fmt.Println("response resultset:")resultSet:=response.ResultSet for resultSet.HasNext(){ row:=resultSet.Next()for i:=range columns { if i>0 { fmt.Printf(",")} value,err:=row.GetString(i)if err!nil { panic(err)} fmt.Printf...
列出表名称列表
columns:=response.ResultSet.Columns()fmt.Printf("response table schema:%v",columns)/通过SQL ResultSet遍历获取SQL的返回结果。fmt.Println("response resultset:")resultSet:=response.ResultSet for resultSet.HasNext(){ row:=...
查找最耗费资源的 SQL（Top SQL）
SQL 优化是数据库优化的手段之一，而为了达到 SQL 优化的最佳效果，您首先需要了解最消耗资源的 SQL（Top SQL），例如 IO 消耗最高的 SQL。数据库资源分为多个维度，包括CPU、内存、IO 等，为能够从各个维度层面查找最消耗数据库资源的 SQL...
通过Python SDK使用SQL独享版
print("cpu_cores:%s"%res.get_cpu_cores())if_name_='_main_':main()execute_logstore_sql接口 调用execute_logstore_sql接口使用SQL独享版，格式为 res=client.execute_logstore_sql(project,logstoreName,from,to,query,powerSql)，各个...
SQL限流
为应对突发的数据库请求流量、资源消耗过高的语句访问以及SQL访问模型的变化等问题，PolarDB-X 提供了节点级别的SQL限流功能来限制造成上述问题的SQL执行，从而保证实例的持续稳定运行。本文介绍如何使用SQL限流功能。创建限流规则 语法 ...
基于PHP的应用开发
if(mysqli_query($lindorm_conn,$insert_sql)){ printf("insert data successfully");} else { printf("insert data error:%s",mysqli_error($lindorm_conn));exit;}/查询数据$select_sql="select*from user_test;result=mysqli_query($...
管理数据集
数据集是基于特定数据库和SQL查询生成，并且以二维表呈现的一种数据集合。本文介绍创建、编辑、删除数据集的方法。注意事项 数据分析后续所有的分析工作、仪表盘制作和大屏制作都是基于数据集进行的，因此在进行其他功能前，必须先创建数据...
创建EMR Spark SQL节点
您可以通过创建EMR（E-MapReduce）Spark SQL节点，实现分布式SQL查询引擎处理结构化数据，提高作业的执行效率。前提条件 数据开发（DataStudio）中已创建业务流程。数据开发（DataStudio）基于业务流程对不同开发引擎进行具体开发操作，...
创建EMR Impala节点
您可以创建EMR（E-MapReduce）Impala节点，对PB级大数据进行快速、实时的交互式SQL查询。前提条件 数据开发（DataStudio）中已创建业务流程。数据开发（DataStudio）基于业务流程对不同开发引擎进行具体开发操作，所以您创建节点前需要先...
DROP INDEX
如何查看Lindorm SQL的版本，请参见 SQL版本说明。语法 drop_index_statement:=DROP INDEX[IF EXISTS]index_identifier ON table_identifier;重要 使用DROP INDEX语句删除 二级索引 或 搜索索引 前，必须通过 ALTER INDEX 语句禁用索引，并...
- 产品推荐
- 这些文档可能帮助您