DescribeDbInstanceDbs
调用DescribeDbInstanceDbs接口查看目标存储实例下的数据库列表。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述...
Python
usr/bin/python#-*-coding:UTF-8-*-import MySQLdb#打开数据库连接。host是AnalyticDB MySQL集群的URL或IP。port是AnalyticDB MySQL集群的URL对应的端口。user是AnalyticDB MySQL集群的用户账号：高权限账号或者普通账号。passwd是...
原理架构
系统架构 数据同步服务的逻辑架构图：全量同步：负责将表数据从源端数据库同步到目的端数据库，支持异构数据库间同步。增量同步：负责将源端的增量数据同步到目的端，主要包含 Store 和 JDBCWriter 两个组件。存储：采集源端 DB 的变更到...
创建表 CREATE TABLE 的不兼容点
本文为您介绍迁移 MySQL 数据库的数据至 OceanBase 数据库 MySQL 租户时，MySQL 数据库执行的 CREATE TABLE DDL 支持被数据传输的 DDL 同步组件转换，但 OceanBase 数据库 MySQL 租户不支持执行的场景。在生成列的基础上再定义生成列 通过 ...
自动添加数据源
数据库备份DBS 支持自动添加数据源功能，可以将阿里云上的RDS实例自动同步到DBS数据源中，以便后续对数据源进行管理与备份。功能说明 该功能当前仅支持自动接入RDS实例，包含 RDS MySQL、RDS SQL Server、RDS PostgreSQL、RDS MariaDB。...
逻辑订阅
本文简单介绍逻辑订阅的使用流程，示例的流程如下：源实例的数据库src创建发布，发布表public.t1，然后在目的实例的数据库dst创建订阅sub1_from_pub1，订阅源库表public.t1。更多详情请参见 逻辑订阅原理与最佳实践。注意事项 您可以在单个...
ALTER DATABASE
如果想要修改时序数据库的指定属性，或为其添加新的数据库属性，您可以使用 ALTER DATABASE 语句。引擎与版本 ALTER DATABASE语法 仅适用于时序引擎。无版本限制。语法 alter_database_statement:=ALTER DATABASE database_identifier[WITH...
设置列索引查询过滤算法
执行查询语句时，您可以通过列存索引的pruner功能，过滤掉数据库中不需要访问的数据块，以提高SQL语句的查询速度。本文介绍pruner的适用场景、注意事项、语法和相关参数等内容。简介 列存索引数据以单列数据块（默认包含64K行，可以通过 表...
收缩膨胀表和索引（pg_squeeze）
例如，以rds_superuser的身份（必须是高权限用户）清理数据库 database1 和 database2：说明 清理前，已分别在数据库 database1 和 database2 中创建了pg_squeeze插件，详情请参见 创建和删除插件。squeeze.worker_autostart='database1 ...
CREATE DATABASE
示例 创建数据库 CREATE DATABASE DB1;结果验证 您可以通过 SHOW DATABASES;语句，查看数据库是否创建成功。指定数据库属性 创建数据库DB1，其中数据存满30天后转入冷存储，存满60天后会被清除。CREATE DATABASE DB1 WITH(cold_boundary=30...
配置跨库Spark SQL节点
name，trade_date,COUNT(*)cnt,SUM(amt)amt FROM mysql_db.sales t1 JOIN oracle_db.users t2 ON t1.emp_id=t2.id WHERE t1.trade_date=${bizdate} GROUP BY t2.dept_name 功能特性 跨库数据处理：支持使用SQL语句操作不同数据库中的数据，...
CREATE DATABASE
CREATE DATABASE语句用于创建数据库，并可以指定数据库的默认属性（如数据库默认字符集，校验规则等）。语法 create_database_stmt:CREATE {DATABASE|SCHEMA}[IF NOT EXISTS]database_name[database_option_list]database_option_list:...
DescribeAccountAuthority-查看账号权限
string db.dict 形式，代表某数据库的某字典 test1.range_key_dict 示例 正常返回示例 JSON 格式 {"RequestId":"F5178C10-1407-4987-9133-DE4DC9119F75","Data":{"DBInstanceId":"cc-bp100p4q1g9z3*","Account":"test1","DmlAuthority":0,...
复制数据库SQL Server 2012及以上版本
您可以使用SQL命令复制数据库，您只需要使用存储过程sp_rds_copy_database指定源数据库和目的数据库即可。复制时间与数据库大小有关。说明 关于如何复制SQL Server 2008 R2版本实例的数据库，请参见 复制数据库SQL Server 2008 R2版。前提...
DROP DATABASE
DROP DATABASE语法用于删除指定的数据库。引擎与版本 DROP DATABASE语法适用于宽表引擎和时序引擎。宽表引擎仅2.2.16及以上版本支持DROP DATABASE语法。时序引擎无版本限制。语法 drop_database_statement:=DROP DATABASE[IF EXISTS]...
数据建模
创建时序数据库 Lindorm实例创建成功后，系统会默认创建default数据库，将数据默认写入该数据库，您无法删除default数据库。时序引擎也支持创建多个数据库，不同的数据库在存储层面进行物理隔离，支持设置不同的数据有效期（TTL）、时间...
支持的数据库类型
RDB MySQL 1.0、2.0、3.0 SG-RDB PostgreSQL 1.0、2.0、3.0 Greenplum 5.0~5.11 Informix 9、10、11、12 Intersystems Cache 8 Hbase 1.2 Elasticsearch 2.4.2、6.3.0 GaussDB T 1.0.1 GaussDB A 6.5.1 TIDB 1.0、2.0、2.1、3.0 Spark SQL ...
rds_dbsync迁移或同步MySQL数据到AnalyticDB ...
rds_dbsync为开源的数据同步迁移工具，支持多线程导入（每个工作线程负责导入一部分数据库表），可同时连接源端和目的端数据库，从源端MySQL库中查询要导出的数据，然后通过COPY命令导入目的端，其mysql2pgsql功能支持不落地的把MySQL中的...
Kafka兼容说明
例如数据库default中一个名为t1的流表，对应的Kafka Topic的名称为-LINSTREAM-default.t1。重要 如果Database或流表名称中含有下划线（_），则需要将下划线替换为短横线（-）。将流表中的数据写入Kafka Topic。具体操作，请参见 通过开源...
条件下推（WHERE条件下推派生表）
条件下推变换后结果为：SELECT f1 FROM(SELECT(SELECT f1 FROM t1 LIMIT 1)AS f1 FROM t1 UNION SELECT f2 FROM t2 WHERE f2=1)dt WHERE f1=1;示例3：SELECT*FROM(SELECT f1,f2 FROM t1)dt GROUP BY f1 HAVING f1< 3 AND f2 >11 AND MAX(f3)>12...
DescribeAccountAuthority-查看账号权限
dt1 AllowDatabases array 已授权的数据库列表。string 已授权的数据库列表。db1 AccountName string 数据库账号。test 示例 正常返回示例 JSON 格式 {"DdlAuthority":true,"DmlAuthority":"all","RequestId":"F5178C10-1407-4987-9133-DE4...
湖仓一体
本章节介绍如何通过 云数据库SelectDB 提供的联邦查询技术，对数据湖、数据库、远端文件等外部数据源进行联邦分析。为您提供简单、快速的数据分析体验。概述 云数据库SelectDB 提供多源数据目录功能（Multi-Catalog或Catalog），支持对接...
DescribeActiveSQLRecords-查询活跃SQL记录
gp-bp12ga6v69h86*Database string 否 数据库名，默认为所有数据库。testdb User string 否 用户名。testuser StartTime string 否 查询开始日期，格式：yyyy-MM-ddTHH:mm:ssZ。2021-08-03T09:30Z EndTime string 否 查询结束时间，格式如...
数据倾斜诊断
AnalyticDB PostgreSQL版 提供的智能诊断数据倾斜功能，可以每小时定期自动诊断数据库内的所有表，并生成相应的诊断信息表，供您检测库内所有表的倾斜情况。注意事项 智能诊断数据倾斜功能仅支持存储弹性模式实例，且内核版本须满足以下...
检查SQL语句中的表是否已创建列索引
执行结果如下：+-+-+-+|TABLE_SCHEMA|TABLE_NAME|COLUMN_NAME|+-+-+-+|test|t1|a|test|t1|b|test|t2|a|+-+-+-+3 rows in set(0.01 sec)SQL语句中使用了 t1.a、t1.b 以及 t2.a 三列，且这三列没有被列索引覆盖。因此，调用该存储过程时，...
扫描全部/部分分库分表
在指定分库分表上执行，显式指定物理表名：SELECT/*+TDDL:scan('t1',real_table=("t1_00","t1_01"))*/COUNT(1)FROM t1 执行后会下发SQL语句到所有分库的 t1_00``t1_01 分表上，合并结果集后返回。在指定分库分表上执行，显式指定物理表名,...
扫描全部/部分分库分表
在指定分库分表上执行，显式指定物理表名：SELECT/*+TDDL:scan('t1',real_table=("t1_00","t1_01"))*/COUNT(1)FROM t1 执行后会下发SQL语句到所有分库的 t1_00``t1_01 分表上，合并结果集后返回。在指定分库分表上执行，显式指定物理表名,...
如何使用HINT（5.2及以下版本适用）
TDDL:t1.id=1 and t2.id=1*/UPDATE t1 SET val=(SELECT val FROM t2 WHERE id=1)WHERE id=1\G*1.row*GROUP_NAME:TEST_DRDS_1485327111630IXLWTEST_DRDS_IGHF_0001_RDS SQL:UPDATE `t1_2` AS `t1` SET `val`=(SELECT val FROM `t2_2` AS `t2...
DescribeWaitingSQLRecords-获取锁诊断列表
1 示例 正常返回示例 JSON 格式 {"Items":[{"PID":"100","SessionID":"50","StartTime":1660902033374,"WaitingTime":26911000,"Status":"LockWaiting","SQLStmt":"Select*from t1,t2 where t1.id=t2.id;User":"testUser","Database":...
查询性能优化指导
segments:3)(cost=0.00.2.00 rows=1 width=16)->Index Scan using i_t_b on t(cost=0.00.2.00 rows=1 width=16)Index Cond:b=1 Settings:optimizer=on Optimizer status:PQO version 1.609(5 rows)查看执行计划 执行计划是数据库运行SQL的...
通过LOCALITY指定存储位置（DRDS模式）
0-master|db1|DB1_P00000_GROUP|db1_p00000|1|3|polardbx-storage-0-master|db1|DB1_SINGLE_GROUP|db1_single|0|+-+-+-+-+-+-+4 rows in set 说明 以返回结果中ID为0的一行为例，表示在存储节点 polardbx-storage-0-master 中的数据库db1下...
日志字段
db_name PolarDB-X 1.0 数据库名称。user 执行SQL的用户名。client_ip 访问 PolarDB-X 1.0 实例的客户端IP。client_port 访问 PolarDB-X 1.0 实例的客户端端口。sql 被执行的SQL语句。trace_id SQL执行的TRACE ID。如果是事务的话，会以...
存储过程
实例内复制数据库 设置数据库在线 数据库全局授权 删除数据库 设置更改跟踪 开启数据库变更捕获 关闭数据库变更捕获 配置实例参数 增加链接服务器Linked Server 设置跟踪标志 更改数据库的名称 Server级别角色授予 关于SQL Server存储过程...
日志字段
db_name string 数据库名称。fail int SQL执行是否出错，取值范围如下：0：未出错 1：出错 fetched_rows int 从存储拉取的记录行数。hint string SQL执行使用的HINT。instance_id string PolarDB-X 实例ID。memory_reject int 是否因为内存...
GRANT
GRANT ALL ON DATABASE db1 TO user1;或者 GRANT ALL ON SCHEMA db1 TO user1;授予指定权限 为用户user2授予数据库db2中的表table2的管理员权限。GRANT ADMIN ON TABLE db2.table2 TO user2;为用户user3授予当前数据库中表table3的写权限。...
查询改写与下推
shardCount=2,sql="SELECT `id` FROM `t1` AS `t1`")JOIN下推 JOIN下推需要满足以下条件：t1与t2表的拆分方式一致（包括分库键、分表键、拆分函数、分库分表数目）。JOIN条件中包含t1，t2表拆分键的等值关系。此外，任意表JOIN广播表总是...
查询改写与下推
拆分键为 c_nationkey 情况：拆分键不为 c_nationkey 情况：JOIN下推 JOIN下推需要满足以下条件：t1与t2表的拆分方式一致（包括分库键、分表键、拆分函数、分库分表数目）。JOIN条件中包含t1，t2表拆分键的等值关系。此外，任意表JOIN广播...
TDE 透明加密
说明 OceanBase 数据库 V3.2.3、V3.2.4 和 V4.2.1 版本支持 TDE 加密功能。TDE 透明加密功能当前支持服务密钥和自定义密钥两种方式。服务密钥 由 OceanBase 云数据库生成和管理的密钥。自定义密钥 采用阿里云 KMS 服务创建的密钥，当您购买...
DESCRIBE
如果您想要新建结构相似的表或数据库，可以通过DESCRIBE语法获取原表或原数据库的结构。适用引擎 DESCRIBE语法适用于宽表引擎和时序引擎。语法 describe_statement:={ DESCRIBE|DESC }[{ DATABASE|TABLE }]identifier 差异说明 宽表引擎和...
规则和拓扑查询语句
k_1_cewR_{00}|((#k,1,80#).longValue().abs()%80)|k|TEST1_SINGLE_GROUP|1|k_2|0|NULL|1|TEST1_{000000}_GROUP|((#k,1,80#).longValue().abs()%80).intdiv(2)|k_2_1xsQ_{00}|((#k,1,80#).longValue().abs()%80)|k|TEST1_SINGLE_GROUP|2|...
- 产品推荐
- 这些文档可能帮助您