新建ADB_PG_SQL任务
本文为您介绍在绑定了AnalyticDB for PostgreSQL计算引擎的项目下如何创建ADB_PG_SQL任务。操作步骤 在Dataphin首页，单击顶部菜单栏中的 研发。默认进入 开发 页面。按照下图操作指引，进入 新建ADB_PG_SQL任务 对话框。编写并运行代码。...
CreateTask-创建任务流任务
3*示例 正常返回示例 JSON 格式 {"RequestId":"CFD8FE00-36D9-4C1B-940D-65A7B73D9066","ErrorCode":"InvalidParameterValid","ErrorMessage":"InvalidParameterValid","Success":true,"NodeId":0 } 错误码 访问 错误中心 查看更多错误码。...
获取结构同步的执行SQL脚本
示例 正常返回示例 JSON 格式 {"RequestId":"1810E635-A2D7-428B-BAA9-85DAEB9B1A77","Success":true,"ErrorMessage":"UnknownError","ErrorCode":"UnknownError","StructSyncExecSqlDetail":{"TotalSqlCount":1,"ExecSql":"/*origin table...
清理表空间（pg_repack）
说明 pg_repack会在第a、b步和第f、g步短暂持有ACCESS EXCLUSIVE锁。其余步骤pg_repack只需要持有原表的ACCESS SHARE锁，不影响原表的INSERT、UPDATE和DELETE。对表中索引进行repack的实现原理如下：以CONCURRENTLY方式创建新索引。在...
SQL操作符
A/B或者A DIV B 除法 返回A÷B的结果。A%B或者A MOD B 取余 返回A÷B后取余数的结果。关系运算符 关系运算符用于判断表中符合指定条件的行数据。如果比较结果为真（TRUE），则返回1。如果比较结果为假（FALSE），则返回0。关系运算符可应用...
sample-txc-simple 样例
在 txc-yun-sample/sql/目录下执行 sample-txc-simple.sql，在 RDS 1 中创建 user_money_a 表，在 RDS 2 中创建 user_money_b 表。下载样例 txc-yun-sample 并上传到 ECS 上。修改样例配置。找到并打开 sample-txc-simple/src/main/...
自动故障转移和读写分离
}$sql=pg_query($conn,"select pg_is_in_recovery()");while($row=pg_fetch_row($sql)){ echo"Recovery-status:$row[0];}?php -f pg_conn.php Connection status ok Recovery-status: f Server: xxx.xxx.xx.xx JDBC实现读写分离和自动故障转移 您...
ListNodesByOutput
test_n*</NodeName><DqcType>1</DqcType><Priority>1</Priority><ParamValues>a=b</ParamValues><Connection>odps_source</Connection><ProjectId>33671</ProjectId><RelatedFlowId>1235655464</RelatedFlowId><SchedulerType>NORMAL</...
Group Aggregate
select a/2,avg(b),min(c),count(c)from(select a,sum(b),max(c)from MyTable group by a)group by a/2;删除了所有统计指标，该修改属于不兼容修改。（所有统计指标的状态数据都被丢弃，没有状态复用。原始SQL。select a,sum(b),max(c)from...
GORM 连接 OceanBase 数据库示例程序
验证安装：在 Shell 命令行中输入以下命令，查看 Go 语言的版本信息，以验证安装是否成功：C:\Users\admin\>go version go version go1.20.6 windows/amd64 安装 Go-SQL-Driver/MySQL 驱动 根据 Go 语言的不同版本，可以选择不同的安装方式...
GetNode
SQL</ProgramType><Priority>1</Priority><OwnerId>17366294*</OwnerId><Connection>odps_source_dev</Connection><ParamValues>a=b</ParamValues><RelatedFlowId>123</RelatedFlowId><DqcType>1</DqcType><BaselineId>123456</BaselineId>...
Split Size Hint
MaxCompute支持通过调整Split Size控制并发度，调整计算性能。...使用示例-设置split size大小为1MB，此hint会在读表src时，按照1M的大小来切分task select a.key from src a/*+split_size(1)*/join src2 b on a.key=b.key;
创建安全联合分析任务
场景描述 A有一张数据表datatrust_a/host_train_adult_10用于记录人群属性（记录年龄、工作等信息），id作为主键，有一张数据表datatrust_a/sj_mpcsql_out，用于统计结果输出；B有一张数据表datatrust_b/slave_train_adult_10用于记录人群...
计算下推
例如有一张表exampletable有a,b,c,d四列，多元索引中包含了b,c,d三列并均建立了索引，只有当SQL语句中只涉及b,c,d中的数据列时，才会多元索引读取数据。SELECT a,b,c,d FROM exampletable;多元索引不包含a,b,c,d，扫描全表读取数据，不支持...
如何限流慢SQL
创建限流规则 如果这个SQL模板的SQL不应该在当时执行，而是应该在业务低峰期执行，可以创建SQL限流规则不让它执行：CREATE CCL_RULE `KILL_CCL`/限流规则名称为KILL_CCL ON `analy_db`.`*`/&匹配analy_db下的所有表上执行的SQL TO '...
ListInnerNodes
SQL</ProgramType><Priority>1</Priority><OwnerId>19337906836551</OwnerId><Connection>odps_source</Connection><ParamValues>a=b</ParamValues><DqcType>1</DqcType><BaselineId>1234</BaselineId><Description>test</Description>...
SQL Server性能分析与优化
name='Buffer cache hit ratio base' AND object_name LIKE '%Buffer Manager%')b ON a.object_name=b.object_name WHERE a.counter_name='Buffer cache hit ratio' AND a.object_name LIKE '%Buffer Manager%';查看数据库IO使用情况 ...
增强E-R
id,a.user_name,a.gender,b.amt,b.cnt FROM(SELECT user_id,user_name,gender FROM user WHERE user_type='taobao')a LEFT OUTER JOIN(SELECT user_id,sum(amt)AS amt,sum(1)as cnt FROM trade WHERE is_pay=1 GROUP BY user_id)b ON a....
秒级闪回实时容灾
postgres=>select pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_flush_lsn(),sent_lsn))as sent_delay,pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_flush_lsn(),replay_lsn))as replay_dealy,*from pg_stat_replication;[RECORD 1]-...
SHOW PROCESSLIST
PROCESSLIST\G*1.row*ID:0-0-521414 USER:tddl5 DB:tddl5_00 COMMAND:Query TIME:0 STATE:init INFO:show processlist*2.row*ID:0-0-521570 USER:tddl5 DB:tddl5_00 COMMAND:Query TIME:0 STATE:User sleep INFO:/*DRDS/88.88.88.88/b67a0e...
SHOW PROCESSLIST
PROCESSLIST\G*1.row*ID:0-0-521414 USER:tddl5 DB:tddl5_00 COMMAND:Query TIME:0 STATE:init INFO:show processlist*2.row*ID:0-0-521570 USER:tddl5 DB:tddl5_00 COMMAND:Query TIME:0 STATE:User sleep INFO:/*DRDS/88.88.88.88/b67a0e...
自然语言到SQL语言转义（基于大语言模型的NL2SQL）
为了让不熟悉SQL语言的用户能方便地从数据库中取数分析，PolarDB for AI推出自研的基于大语言模型的自然语言到数据库查询语言转义（Large Language Model based Nature Language to SQL，简称LLM-based NL2SQL）解决方案，PolarDB for AI会...
DescribeDrdsSlowSqls
Sql></Item></Items><Success>true</Success></DescribeDrdsSlowSqlsReponse>JSON 格式 {"DescribeDrdsSlowSqlsReponse":{"RequestId":"509BDE17-505A-4B3B-854D-30D3F0*","PageSize":20,"PageNumber":1,"Total":1,"Items":{"Item":{...
背景信息
ASYNC_TASK_ID|+-+|q201811021109sh8d1a0b750000182|+-+1 row in set(0.04 sec)通过 show query_task 查询ID，得到异步SQL执行详情。mysql>show query_task where id='q201811021109sh8d1a0b750000182' \G*1.row*id:q201811021109sh8d1a0b...
通过Spark SQL访问MySQL数据
AnalyticDB MySQL 湖仓版（3.0）支持提交Spark SQL作业，您可以通过View或Catalog两种方式访问自建MySQL数据库或云数据库RDS MySQL、云原生数据库 PolarDB MySQL。本文以RDS MySQL为例，介绍如何通过Spark SQL访问RDS MySQL数据。前提条件 ...
8.0.1和8.0.2版功能对比
支持 支持 联邦引擎支持 支持跨实例访问，在实例A中用SQL查询远程实例B中的数据，支持远程OSS的csv/orc访问。支持 支持 分区表 分区表能力增强 对标Oracle支持全量二级分区，INTERVAL间隔分区，混合分区，List Default HASH，分区性能增强...
Quick BI如何实现去重后的累计计算
该案例中，用户数是需要去重计数的，无法通过上述配置的方式求得累计的去重计数的值，需要通过SQL取出该字段，可参考如下SQL select a.report_date,count(distinct a.customer_name)as cust_num,count(distinct b.customer_name)as all_...
链上数据导出到数据库
data:'eyJu.In0=' } Data pushed to blockchain with transaction 7810e0496a1c91a16102736b00a6f26da0baa42874a907fff26bff1b7eb3bf27 { id:'7810e0496a1c91a16102736b00a6f26da0baa42874a907fff26bff1b7eb3bf27',status:'200',events:[]...
SQL调优
设置split size大小为1MB，此hint会在读src表时，按照1MB的大小来切分task select a.key from src a/*+split_size(1)*/join src2 b on a.key=b.key;非读表的Task 主要有如下三种方式调整并发度：调整 odps.sql.mapper.split.size 值：非读...
Spark FAQ
DLA SQL支持多层嵌套目录 oss/db/table/partition1=a/partiion2=b/extral_folder/data.csv，但Spark SQL暂不支持。DLA SQL的语法和Spark SQL的语法略有区别，如何调试SQL，请参见 Spark SQL。为什么Spark作业提示错误日志oss object 403？...
全局集合类型
区别于定义在PL/SQL定义域中的局部集合类型，您可以直接用一条SQL语句定义全局集合类型（standalone collection type）。注意事项 目前，PL/SQL支持声明全局变长数组和全局嵌套表。声明它们的语法与声明局部集合类型的语法除了多加一个 ...
如何在较大结果集中使用ORDER BY
ORDER BY c1/该SQL不支持ORDER BY，c1为非主键列 SELECT*FROM test WHERE p1=a or p1=b ORDER BY p2/该SQL不支持ORDER BY，要求单值前缀，而p1给了好几个值 在数据量较大的结果集场景中，如果您必须使用ORDER BY排序，提供以下解决方案。...
通过JDBC协议分析日志
逻辑运算 and or not 例如 a="x"and b="y"或 a="x"and not b="y。全文搜索_line_="abc"如果使用全文索引搜索，需使用特殊的key（_line_）。计算语法 支持计算操作符。更多信息，请参见 分析语法。SQL92语法 过滤语法和计算语法组合成为SQL...
空间函数
当且仅当几何B的所有点都不位于几何A的外部，并且几何B内部至少一个点位于几何A的内部时，几何A才包含几何B。参数说明 geometryA：必填，几何类型。几何A。geometryB：必填，几何类型。几何B。返回值说明 几何A是否包含几何B的判定结果。...
pg_similarity
pg_similarity.levenshtein_threshold-0.5(1 row)SELECT a,b,lev(a,b)FROM foo,bar WHERE a~=b;a|b|lev-+-+-Euler|Euller|0.8333333333333334 Oiler|Euller|0.5 Euler Taveira de Oliveira|Euler T.de Oliveira|0.76(3 rows)SET pg_...
DBMS_SQL
DBMS_SQL包提供查询 PolarDB PostgreSQL版（兼容Oracle）动态SQL的功能，可以在应用运行时构建查询。PolarDB PostgreSQL版（兼容Oracle）支持查询动态SQL，且以与Oracle兼容的方式来使用动态SQL。表 1.DBMS_SQL函数/存储过程 函数/存储过程...
动态过滤器（Dynamic Filter）
优化思路 一个典型的包含JOIN的SQL语句如下：select*from(table1)A join(table2)B on A.a=B.b;基于JOIN等值连接的特性，MaxCompute可以通过表A的数据生成一个过滤器，在Shuffle或JOIN之前提前过滤表B的数据，甚至可以将过滤器下推到底层...
动态过滤器（Dynamic Filter）
优化思路 一个典型的包含JOIN的SQL语句如下：select*from(table1)A join(table2)B on A.a=B.b;基于JOIN等值连接的特性，MaxCompute可以通过表A的数据生成一个过滤器，在Shuffle或JOIN之前提前过滤表B的数据，甚至可以将过滤器下推到底层...
GetFullRequestSampleByInstanceId-按照SQL ID查询SQL...
0A74B755-98B7-59DB-8724-1321B394*Data object[]返回数据 Timestamp long 执行 SQL 的时间，格式为 Unix 时间戳，单位为毫秒。1660100753556 SqlId string SQL ID。651b56fe9418d48edb8fdf0980ec*Sql string SQL 样本。select*from testdb...
新功能试用申请
命令将关闭Schema语法开关，即SQL中无法识别 a.b.c 格式的语句，将SQL中 a.b 格式的语句识别为 project.table。详情请参见 Schema操作。2022年11月 开启租户级别元数据服务InformationSchema MaxCompute的 Information Schema 提供了项目...
- 产品推荐
- 这些文档可能帮助您