逻辑解码（wal2json）
结果如下：$psql-At-f/tmp/example2.sql postgres CREATE TABLE CREATE TABLE init BEGIN INSERT 0 1 INSERT 0 1 INSERT 0 1 DELETE 2 INSERT 0 1 UPDATE 1 COMMIT psql:/tmp/example2.sql:17:WARNING:table"table2_without_pk"without ...
Canal
本文为您介绍Canal格式的使用示例、配置选项和类型映射。背景信息 Canal 是一个CDC（ChangeLog Data Capture，变更日志数据捕获）工具，可以实时地将MySQL变更传输到其他系统。Canal为变更日志提供了统一的数据格式，并支持使用JSON或 ...
创建多元索引的映射关系
执行CREATE TABLE语句为已存在的表或者多元索引创建映射关系。创建映射关系时需要配置表的字段名称、字段类型和主键信息以及根据需要配置查询数据时的执行引擎。本文介绍如何为已存在的多元索引创建映射关系。说明 关于创建表的映射关系的...
SQL防火墙
（learn/active/passive三种模式，默认passive）使用test用户登录数据库targetdb，建立测试表company并执行查询、插入语句：CREATE TABLE company(name VARCHAR(100),employee_num INT);SELECT*FROM company;INSERT INTO company VALUES('...
通过SQL导出数据至MaxCompute
使用限制 仅Hologres V0.9及以上版本支持使用SQL导出数据至MaxCompute，如果您的实例是V0.9以下版本，请您使用 自助升级 或加入Hologres钉钉交流群反馈，详情请参见 如何获取更多的在线支持？Hologres的数据类型与MaxCompute的数据类型逐一...
SQL查询常见错误排查
本文介绍使用SQL查询时的常见错误处理方法，主要包括OTSUnsupportOperation、OTSQuotaExhausted、OTSParameterInvalid和OtsRequestTimeout四种类型的错误。错误码 错误信息 描述 解决办法 OTSUnsupportOperation Operation not supported ...
HybridDB for MySQL数据源
否 无 postSql 执行数据同步任务之后执行的SQL语句，目前向导模式仅允许执行一条SQL语句，脚本模式可以支持多条SQL语句，例如加上某一个时间戳。否 无 batchSize 一次性批量提交的记录数大小，该值可以极大减少数据同步系统与HybridDB for ...
配置说明
查询配置 说明 流式查询配置在EMR-3.23.0及之后版本不建议使用，最新的查询配置请参见 SCAN语句 或 STREAM语句。在使用Spark SQL进行流式查询前，您需要了解以下两个概念：数据源配置：即Table的定义。Table的定义只包含数据源的配置，例如...
使用SQL查询时序数据
创建时序表并建立SQL映射关系后，您可以通过控制台、SDK等不同方式使用SQL查询时序数据。时序表的SQL映射关系 根据每个时间线每个时刻对应一个值或者多个值，时序模型分为“单值模型”和“多值模型”。对于同一个时序表，您可以建立三种SQL...
Spark-SQL命令行工具
insert into table t1 values(4,'test')|+end+executing sql:select*from t1|id|name|1|zz|2|xx|3|yy|4|test|#spark-sql 也支持使用变量替换，您可以使用-d key=value来指定参数的值，随后可以在sql语句中使用${key}来引用key的值。...
通过Spark导入数据
本文介绍使用Spark SelectDB Connector同步数据至 云数据库 SelectDB 版 的基本原理和使用方式。功能介绍 Spark SelectDB Connector是云数据库 SelectDB 版导入大批量数据的方式之一。基于Spark的分布式计算能力，您可以将上游数据源...
SQL审核最佳实践
数据管理DMS 的SQL审核功能，支持对SQL语句进行批量审核并提供优化建议，避免无索引或不规范的SQL语句，降低SQL注入风险。本文以对XML文件中多个SQL语句进行审核为例，向您展示配置SQL审核规则、审核目标文件中SQL语句的流程。背景信息 在...
Flag参数列表
INSERT OVERWRITE CREATE TABLE SQL Session odps.optimizer.skew.join.topk.num 设置优化器运行Aggregate时获取的热值数量。具体操作，请参见 SKEWJOIN HINT。SKEWJOIN HINT SQL Session odps.optimizer.stat.collect.auto 设置是否开启...
Flink_SQL任务开发方式
Dataphin的Flink_SQL任务支持多种开发方式，包括原生DDL+DML开发、使用Dataphin元表进行开发、使用Dataphin数据源表进行开发、以及使用计算源物理表进行开发，且不同开发方式所创建的表支持任意混用，包括镜像表。不同开发方式的使用方法、...
Flink_SQL任务开发方式
Dataphin的Flink_SQL任务支持多种开发方式，包括原生DDL+DML开发、基于Catalog开发、使用Dataphin元表进行开发、使用Dataphin数据源表进行开发、以及使用计算源物理表进行开发，且不同开发方式所创建的表支持任意混用，包括镜像表。...
自然语言到SQL语言转义（基于大语言模型的NL2SQL）
在线使用LLM-based NL2SQL 您可以执行以下SQL语句来在线使用LLM-based NL2SQL：/*polar4ai*/SELECT*FROM PREDICT(MODEL_polar4ai_nl2sql,SELECT '查询年份为2008年的国家标准有哪些？')WITH(basic_index_name='schema_index');上述SQL语句...
SQL查询
使用SQL查询时，系统会根据SQL语句自动选择合适的方式来加速SQL访问。SQL查询功能适用于在海量数据中进行在线数据访问类型的场景，SQL访问的延时从毫秒、秒到分钟级别不等，包括基于数据表主键的Point Query（GetRow操作）、多元索引的精确...
创建触发器
本文介绍如果数据传输源端发生了 DDL 变更（例如新增表字段），您如何通过触发器来捕获 DDL 相关事件信息，以确保 DML 变更操作正常同步。背景信息 使用数据传输执行源端 PostgreSQL 数据库增量同步时，默认仅支持 DML 语句（包括 INSERT、...
SpringJDBC 连接 OceanBase 数据库
} }@Test public void createByOrcTypeDate(){ sql="create table D_DPRECORD(DEV_ID VARCHAR2(50),"+"CAR_SPEED NUMBER(3),"+"CAP_DATE TIMESTAMP WITH LOCAL TIME ZONE,"+"DEV_CHNID VARCHAR2(50)not null,"+"TRSFMARK NUMBER(1)default ...
使用存储过程将数据导入Hologres内部表（Beta）
Hologres V2.0版本新增存储过程（hg_insert_overwrite），使用此存储过程帮助您简单、快捷地将MaxCompute或Hologres表数据导入Hologres内部表。本文为您介绍如何使用存储过程将MaxCompute或Hologres表数据导入Hologres内部表。注意事项 ...
导出至MaxCompute
一级分区表 CREATE TABLE IF NOT EXISTS odps_table(uid STRING)PARTITIONED BY(ds STRING)LIFECYCLE 3;二级分区表 CREATE TABLE IF NOT EXISTS odps_table(uid STRING)PARTITIONED BY(ds STRING,other STRING)LIFECYCLE 3;根据 AnalyticDB...
删除映射关系
通过drop mapping table语句删除表的映射关系。说明 关于drop mapping table语句的更多信息，请参见 删除映射关系。前提条件 已初始化Client。具体操作，请参见 初始化。已创建映射关系。具体操作，请参见 创建映射关系。参数 参数 说明 ...
SQL限流
为应对突发的数据库请求流量、资源消耗过高的语句访问以及SQL访问模型的变化等问题，PolarDB-X 1.0 提供了节点级别的SQL限流功能来限制造成上述问题的SQL执行，从而保证实例的持续稳定运行。本文介绍如何使用SQL限流功能。前提条件 PolarDB...
DescribeAppliedAdvices-显示已采纳的优化
调用DescribeAppliedAdvices接口来显示已应用的优化建议。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在...
SETPROJECT
INSERT OVERWRITE CREATE TABLE SQL Session odps.optimizer.skew.join.topk.num 设置优化器运行Aggregate时获取的热值数量。具体操作，请参见 SKEWJOIN HINT。SKEWJOIN HINT SQL Session odps.optimizer.stat.collect.auto 设置是否开启...
管理MongoDB Catalog（公测中）
作为源表，使用 CREATE TABLE AS（CTAS）语句 或 CREATE DATABASE AS（CDAS）语句 将MongoDB中的数据同步至目标表中。重要 使用CTAS或CDAS语句将MongoDB中的数据同步至目标表时，必须满足以下要求：VVR版本必须为8.0.6及以上，MongoDB数据...
检查SQL语句中的表是否已创建列索引
存储过程 dbms_imci.check_columnar_index()可以解析输入的SQL语句，并得到SQL语句中使用的所有列，并检查这些列是否被列索引覆盖。如果SQL语句中使用了未被列索引覆盖的列，调用该存储过程后会返回这些列所在的库名、表名以及列名。如果...
SQL限流
为应对突发的数据库请求流量、资源消耗过高的语句访问以及SQL访问模型的变化等问题，PolarDB-X 提供了节点级别的SQL限流功能来限制造成上述问题的SQL执行，从而保证实例的持续稳定运行。本文介绍如何使用SQL限流功能。创建限流规则 语法 ...
Insert Into
StarRocks中INSERT INTO语句的使用方式和MySQL等数据库中INSERT INTO语句的使用方式类似，但在StarRocks中，所有的数据写入都是一个独立的导入作业，所以StarRocks中将INSERT INTO作为一种导入方式介绍。本文为您介绍Insert Into导入的使用...
GetStructSyncJobAnalyzeResult-获取结构同步的任务...
origin table[helloz_bak]exist,target table[helloz_bak]not exist*/*generate[helloz_bak]create table sql*/create table `helloz_bak`(\t`id` bigint(20)UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '主键',\t`gmt_create` datetime NOT...
SQL诊断
SET_TABLE_PROPERTY and CREATE TABLE statement are not in the same transaction create table 语句需要和CALL SET_TABLE_PROPERTY在一个事务里（使用 begin;和 commit;ERRCODE_AMBIGUOUS_COLUMN 模棱两可的列。一般是SQL中同一列名可能...
Maxwell
本文为您介绍Maxwell格式的使用示例、配置选项和类型映射。背景信息 Maxwell 是一个CDC(Changelog Data Capture，变更数据获取）工具，可以把来自MySQL的更改实时流传输到Kafka、Kinesis和其他流连接器中。Maxwell为变更日志提供了统一的...
MaxCompute JSON类型使用指南
MaxCompute当前支持JSON数据类型，提高了表中带有JSON类型数据的计算和分析的性能，本文为您介绍JSON类型的使用方法。JSON类型简介 背景信息 半结构化数据介于结构和非结构化数据之间，数据中有一定的Schema，但是Schema灵活，没有强约束，...
特殊用法
上界的写法 FORALL i IN lower_bound.upper_bound single SQL-仅允许使用单条 SQL 或动态 SQL 语句-遍历索引的写法(对于关联数组来说，仅支持使用索引为数值的关联数组)FORALL i IN INDICES OF collection single SQL-遍历值的写法(仅支持...
DescribeSqlPattern-查询SQL模式
查看指定日期内AnalyticDB MySQL版集群下的SQL模板详情。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在...
Phoenix
Apache Phoenix是构建在HBase上的SQL中间层，允许使用标准的SQL语法来查询和管理存储在HBase中的数据。前提条件 已创建选择了Phoenix和HBase服务的DataServing或Custom类型的集群，详情请参见 创建集群。使用Phoenix客户端 使用SSH方式连接...
查询表的描述信息
通过describe语句查询表的描述信息，例如字段名称、字段类型等。说明 关于describe语句的更多信息，请参见 查询表的描述信息。前提条件 已初始化Client。具体操作，请参见 初始化OTSClient。已创建映射关系。具体操作，请参见 创建表的映射...
Zeppelin概述
示例 以下内容只适用于EMR-3.33.0及之后版本和EMR-4.6.0及之后版本：如何使用Spark 如何使用Flink 如何使用Presto 如何使用Impala 如何使用Hive 如何使用Spark 在Zeppelin页面，单击 Create new note。在 Create new note 对话框，输入 ...
DescribeSqlPattern-查询SQL Pattern详情
查看指定日期内AnalyticDB MySQL湖仓版（3.0）集群下的SQL Pattern详情。接口说明 当前服务的接入地址请参见 服务接入点。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动...
Presto Server配置和SQL示例
SQL语句CREATE TABLE中的table_name用于映射到Tablestore中实际的表。您可以为Tablestore中的同一个数据表创建多个不同的映射表。映射表中必须包括数据表的所有主键列，但是支持只包括部分属性列。映射表中主键列的名称和顺序必须与...
- 产品推荐
- 这些文档可能帮助您