批量或异步插入数据
本文介绍如何在云数据库ClickHouse中批量或异步插入数据。...手动批处理的优点是，如果相同的插入语句多次发送到云数据库ClickHouse企业版（例如，由于客户端软件中的自动重试导致了一些暂时的网络连接问题），它支持表数据的默认自动去重。
Dataphin的sql代码任务中的SQL语句数有什么限制
之所以在开发环境可以执行超过100条的sql代码，是因为在开发环境手动执行的时候，前端会把多条语句拆成多个任务交给Dataphin后端执行，所以没有语句数量上的限制。但是在运维调度的时候，整个任务的语句是作为一个任务提交给OneService执行...
TCL语句
您可以通过执行 SET AUTOCOMMIT=0 或者显式事务的方式手动开启多条语句组成的交互式事务。显示事务是由用户自定义或用户指定的事务。通过START TRANSACTION，或BEGIN（被作为START TRANSACTION的别名得到支持）语句显示开始，以COMMIT或...
新建存储过程
概述 存储过程是一条或多条语句的集合，对数据库进行一系列复杂操作时，存储过程可以在数据库内将这类复杂操作封装成一个代码块，以便重复使用，从而减少数据库开发人员的工作量。存储过程旨在完成特定功能的 SQL 语句集，经编译创建并保存...
Flink
支持Multiple insert 例如，当您有多条INSERT语句读同一个Source时，结果会写到不同的Sink，默认情况下每条SQL语句都会独立运行一个Flink Job，如果您想合并多条语句到同一个Flink Job的话，您就需要设置 runAsOne 为true。JobName的设置 ...
常见错误码参考
1295 HY000 This command is not supported in the prepared statement protocol yet 不支持预准备语句时同时指定多条语句，建议修改预准备语句的指定方式。1461 42000 Can't create more than max_prepared_stmt_count statements(current...
任务管理
事务 仅当配置单个数据库时生效，支持的选项：开启：任务中的多条SQL语句将以事务的方式执行。关闭（默认）并发执行组内任务 仅当配置多个数据库时生效，支持的选项：开启：SQL语句会同步执行到所有数据库中。关闭（默认）：SQL语句会执行...
InsertListResult
名称 类型 描述 示例值 object InsertList 操作的返回值。NumberOfRecordsUpdated long 插入的记录条数。5 AutoIncrementKeys array 每条记录插入时的自增列的值。long 单条数据插入时的自增列的值。2
Oracle数据源
说明 数据库容器CDB（Container Database）是Oracle 12c及之后版本的数据库新特性，用于承载多个可插拔数据库PDB（Pluggable Database）。使用限制 当前数据集成同步数据时，仅支持UTF8、AL32UTF8、AL16UTF16及ZHS16GBK编码格式。Oracle单...
DELETE
一条DELETE语句只能删除一行数据，不支持一条语句删除多行。删除操作并非是先读取再删除，而是直接写入删除标记。所以无论被删除的行是否存在，删除都会成功。可以指定删除的时间戳，带时间戳的delete会删除指定行中，小于等于指定时间戳的...
SPL 块结构
块至少要有一个可执行部分，其中包含一条或多条SPL语句，位于关键字BEGIN与END之间。可选的声明部分用于声明可执行和异常部分中的语句使用的变量、游标、类型和子程序。声明仅在可执行部分的BEGIN关键字之前显示。根据使用块的上下文，声明...
DROP DATABASE
DROP DATABASE语句用于删除数据库。本文为您介绍DROP DATABASE的用法。使用限制 只有数据库的Superuser，或被Superuser授权为数据库Owner的用户，才可以删除该数据库。删除数据库时会同时删除数据库中的所有对象。您不能再连接使用已删除的...
通过DataWorks导入数据
云数据库 SelectDB 版 支持使用DataWorks的数据集成功能，通过SelectDB Writer导入表数据。本文以MySQL数据源为例，介绍如何通过DataWorks同步数据至 云数据库 SelectDB 版。使用限制 DataWorks的数据集成功能仅支持离线写入 云数据库 ...
风险日志
本文介绍如何以时间、客户端IP、风险等级等语句检索条件，查询匹配的风险日志。背景信息 风险日志通过列表...详情包括每条语句的访问来源信息、应用身份信息、SQL语句信息、受影响对象、SQL语句、SQL模板。单击 规则名称，可查看规则详情。
USE
目标数据库（database_identifier）database_identifier必须是当前实例中已存在的数据库。您可以通过 SHOW DATABASES 语法查看当前实例下所有的数据库。SHOW DATABASES 的使用方式，请参见 SHOW DATABASES。默认数据库（DEFAULT）USE语句中...
ALTER DATABASE
如果想要修改时序数据库的指定属性，或为其添加新的数据库属性，您可以使用 ALTER DATABASE 语句。引擎与版本 ALTER DATABASE语法 仅适用于时序引擎。无版本限制。语法 alter_database_statement:=ALTER DATABASE database_identifier[WITH...
创建数据库
您可以使用DMS（Data Management Service）、客户端（Navicat for MySQL、DBeaver、DBVisualizer、SQL WorkBench/J）、业务系统中的程序代码或者MySQL命令行工具连接 云原生数据仓库...，然后通过CREATE DATABASE语句创建数据库...
选择使用低基数列作为分区键
在云数据库ClickHouse企业版中，当您向没有使用分区键的表发送一个插入语句（插入许多行）时，插入该表所有的行数据将会在存储中写入一个新的Part（即数据片段）。然而，当您向云数据库ClickHouse企业版中有分区键的表发送一个插入语句时，...
语义意图标注
批量会话语句标注与分配：选定多条会话语句后，可在会话语句最下方进行批量分配或批量标注操作。具体如下图所示：3.完成已标注会话语句提交 进入会话语句已标注界面：在“任务标注详情”界面点击“已标注”按钮即可进入；确认已标注语句...
其他问题
Java 应用创建数据访问代理连接失败 检查以下几个要点：白名单：是否在 ODP 上将应用服务器 IP 加入了白名单，以及在物理数据库上将 ODP 实例 IP 加入了白名单。MySQL 客户端：如果直接使用命令行方式可以连接 ODP，说明网络和配置都是正确...
DROP DATABASE
DROP DATABASE语句用于删除数据库。语法 drop_database_stmt:DROP DATABASE[IF EXISTS]database_name;参数说明 参数 说明 IF EXISTS 用于防止当数据库不存在时发生错误。database_name 指定待删除的数据库名。示例 删除数据库test。drop ...
CREATE DATABASE
CREATE DATABASE语句用于创建数据库，并可以指定数据库的默认属性（如数据库默认字符集，校验规则等）。语法 create_database_stmt:CREATE {DATABASE|SCHEMA}[IF NOT EXISTS]database_name[database_option_list]database_option_list:...
Hive
支持一个段落编写多条SQL语句，每条SQL语句以分号;结尾，按照从上到下的顺序执行。支持注释功能。支持并发执行多个段落。支持参数功能。支持图表展示SQL结果。示例 多行SQL 如下图所示，在一个段落里执行2句SQL语句（以分号间隔），第一句...
DROP PREDOWNSAMPLE
删除预降采样规则。...说明 一条删除语句中可以包括一个或者多个具有相同降采样周期的聚合函数，您也可以将多个聚合函数拆分成多条删除语句。table_identifier 时序表名。示例 DROP PREDOWNSAMPLE `1d` AGGREGATORS(`sum`,`max`)ON sensor;
RDS SQL Server中无法直接删除数据库的处理方法
问题描述 在RDS SQL Server实例中删除数据库时，会出现以下场景的报错：如果数据库没有会话，对于RDS SQL Server 2008、2012和2016版，是用镜像做的主备同步，直接使用 drop database SQL语句删除数据库会存在以下报错。The database 'XX' ...
PostgreSQL数据源
否 无 fetchSize 该配置项定义了插件和数据库服务器端每次批量数据获取条数，该值决定了数据集成和服务器端的网络交互次数，能够较大的提升数据抽取性能。说明 fetchSize 值过大（>2048）可能造成数据同步进程OOM。否 512 PostgreSQL ...
索引
DROP DATABASE语句用于删除数据库。语法 drop_database_stmt:DROP DATABASE[IF EXISTS]database_name;参数说明 参数 说明 IF EXISTS 用于防止当数据库不存在时发生错误。database_name 指定待删除的数据库名。示例 删除数据库test。drop ...
CREATE PREDOWNSAMPLE
也可以将多个聚合函数拆分成多条创建语句。TTL 设置预降采样数据的有效期。说明 如果多个预降采样规则设置了TTL，那么取最大的TTL作为所有预降采样规则的TTL。table_identifier 时序数据表名。从预降采样数据中查询数据 默认情况下，降采样...
Amazon Redshift数据源
Amazon Redshift数据源为您提供读取和写入Amazon ...目前向导模式仅允许执行一条SQL语句，脚本模式可以支持多条SQL语句，例如加上某一个时间戳。否 无 batchSize 每批次导入的最大数据条数。否 2048 writeMode 目前只支持insert。否 insert
DRDS（PolarDB-X）数据源
在底层实现上，DRDS（PolarDB-X）Writer通过JDBC连接远程DRDS（PolarDB-X）数据库的Proxy，执行相应的 replace into 语句，写入数据至DRDS（PolarDB-X）。执行的SQL语句是 replace into，为避免数据重复写入，需要您的表具备主键（Primary ...
SQL Server数据源
目前向导模式仅允许执行一条SQL语句，脚本模式可以支持多条SQL语句，例如加上某一个时间戳。否 无 writeMode 选择导入模式，可以支持 insert 方式。当主键/唯一性索引冲突时，数据集成视为脏数据但保留原有的数据。否 insert batchSize ...
创建EMR Spark SQL节点
取值如下：true：表示每次执行多条SQL语句。false：表示每次执行一条SQL语句。说明 该参数仅支持用于数据开发环境测试运行流程。“ENABLE_SPARKSQL_JDBC”：提交SQL代码的方式。取值如下：true：表示采用JDBC的方式提交SQL代码。当EMR集群...
SelectDB数据源
目前向导模式仅允许执行一条SQL语句，脚本模式可以支持多条SQL语句，例如，执行前清空表中的旧数据。否 无 postSql 执行数据同步任务之后执行的SQL语句。目前向导模式仅允许执行一条SQL语句，脚本模式可以支持多条SQL语句，例如，加上某...
创建EMR Hive节点
您可以创建EMR（E-MapReduce）HIVE节点，通过类SQL语句协助读写、管理存储在分布式存储系统上的大数据集的数据仓库，完成海量日志数据的分析和开发工作。前提条件 数据开发（DataStudio）中已创建业务流程。数据开发（DataStudio）基于业务...
RDS MySQL如何使用Percona Toolkit
limit 1000：每条语句读取和归档的数据行数，默认是1。commit-each：每次获取和归档数据后，commit提交。no-version-check：不做版本检查，RDS MySQL必须设置。归档后，登录数据库，执行如下SQL语句，确认数据行数减少150行。select count...
创建EMR Impala节点
取值如下：true：表示每次执行多条SQL语句。false：表示每次执行一条SQL语句。“DATAWORKS_SESSION_DISABLE”：适用于开发环境直接测试运行场景。取值如下：true：表示每次运行SQL语句都会新建一个JDBC Connection。false：表示用户在一个...
AnalyticDB for MySQL 3.0数据源
否 无 postSql 执行数据同步任务之后执行的SQL语句，目前向导模式仅允许执行一条SQL语句，脚本模式可以支持多条SQL语句，例如加上某一个时间戳。说明 当有多条SQL语句时，不支持事务。否 无 batchSize 一次性批量提交的记录数大小，该值...
配置行列自动分流
说明 如果使用集群地址连接数据库，您需要在 SHOW STATUS LIKE 'Last_query_cost' 命令前添加 HINT 语法/*ROUTE_TO_LAST_USED*/，以确保能够在正确的节点查询到上一条语句的预估执行代价。如下：/*ROUTE_TO_LAST_USED*/SHOW STATUS LIKE '...
执行在线评估
背景信息 在线评估是直接连接目标数据库，采集源端数据库的对象、SQL 语句和数据库负载等信息，与 OceanBase 数据库的现有能力进行兼容性对标，查找其不兼容点并提供修复方法。操作步骤 新建在线评估任务。登录 OceanBase 管理控制台。在...
PolarDB MySQL版8.0.1版本发布日志
修复当数据库中存在CSV或ORC外部表时，查询 information_schema.tables 表信息异常缓慢的问题。修复因多主集群（库表）的全局Binlog中 table_id 重复，导致Flink CDC解析失败的问题。修复使用事务断点续传功能时，因启用并行查询功能而无法...
- 产品推荐
- 这些文档可能帮助您