Flink Connector
smt可以根据MySQL和StarRocks的集群信息和表结构自动生成Source table和Sink table的建表语句。操作步骤 准备工作 下载Flink。推荐使用1.13，最低支持1.11版本。下载Flink CDC connector。下载对应Flink版本的Flink-MySQL-CDC。下载 Flink ...
连接条件下推
通过将derived table外层的连接条件下推到derived table内部，使derived table内部的执行计划可以更加高效的利用索引，从而可以大幅的提升复杂查询的执行性能。前提条件 集群版本需为 PolarDB MySQL版 8.0版本且修订版本需为8.0.2.2.10或...
锁以及排查锁
SchU：Schema更新锁，用于修改表结构的DDL语句包含 ALTER TABLE 和 set_table_property 命令。SchE：Schema存在锁，用户DML和DQL语句，确保读写数据期间表不会被删除。说明 SchU是DDL锁更细粒度的管控，允许ALTER TABLE期间DQL正常运行，...
Hologres SQL语句的常见问题
报错：SET_TABLE_PROPERTY and CREATE TABLE statement are not in the same transaction for table 问题原因：建表时CREATE TABLE和call属性不在一个事务（transaction）中，导致报错。解决方法：建表时CREATE TABLE需要和call...
GetMetaTableChangeLog
ChangeType String 否 ALTER_TABLE 变更类型，包括CREATE_TABLE、ALTER_TABLE、DROP_TABLE、ADD_PARTITION和DROP_PARTITION。ObjectType String 否 TABLE 变更主体类别，包括TABLE和PARTITION。StartDate String 否 2020-06-01 00:00:00 表...
SHOW VARIABLES
variables_statement:=SHOW scope_expression VARIABLES[FROM table_identifier][LIKE pattern_expression]scop_expression:={ SYSTEM|TABLE } 使用说明 范围关键字（scope_expression）范围关键字用于指定属性范围，支持TABLE和SYSTEM两种...
DM（达梦）数据源
类型分类 DM数据类型 整数类 INT、TINYINT、SMALLINT和BIGINT 浮点类 REAL、FLOAT、DOUBLE、NUMBER和DECIMAL 字符串类 CHAR、VARCHAR、LONGVARCHAR和TEXT 日期时间类 DATE、DATETIME、TIMESTAMP和TIME 布尔型 BIT 二进制类 BINARY、...
Amazon Redshift数据源
Amazon Redshift数据源为您提供读取和写入Amazon Redshift的双向通道，方便您后续可以通过向导模式和脚本模式配置数据同步任务。本文为您介绍Amazon Redshift数据同步能力支持情况。支持的Amazon Redshift版本 Amazon Redshift使用的驱动...
扫描全部/部分分库分表
CONDITION="condition_string"#使用TABLE和CONDITION中的内容计算物理库表名称[,NODE="node_list"])#过滤通过CONDITION计算出的结果，仅保留指定物理库#将SQL语句下发到指定分库分表上执行，显式指定物理表名 SCAN([TABLE=]"table_name_...
扫描全部/部分分库分表
CONDITION="condition_string"#使用TABLE和CONDITION中的内容计算物理表名称[,NODE="node_list"])#过滤通过CONDITION计算出的结果，仅保留指定物理库#将SQL语句下发到指定分库分表上执行，显式指定物理表名 SCAN([TABLE=]"table_name_list...
SET_TABLE_PROPERTY
如果您需要对创建的表进行修改、更新和删除，具体操作请参见 ALTER TABLE 或 DROP TABLE。命令格式 CALL SET_TABLE_PROPERTY(table_name,property,value)WHERE PROPERTY IN orientation clustering_key segment_key bitmap_columns ...
DCL
DCL（Data Control Language）主要包含用户角色管理（Database Role）语法和权限管理（Permission）语法。本节介绍DCL语法的说明和示例。用户角色管理 Lindorm CQL语法使用Database Roles来表示用户角色。Role的定义如下：role_name:=...
ALTER TABLE…RENAME PARTITION
ALTER TABLE…RENAME PARTITION命令在分区和子分区之间没有任何区别。您可以使用 RENAME PARTITION 或 RENAME SUBPARTITION 子句来重命名分区。您可以使用RENAME PARTITION 或 RENAME SUBPARTITION 子句来重命名子分区。描述 ALTER TABLE…...
DML操作
select_statement>中的列必须和<table_name>中 非分区键 的列数量相同，且数据类型一一对应。更多信息请参见 单值分区表插入数据。修改数据-单条数据 UPDATE TABLE<table_name>SET column_name=value WHERE;更多信息请参见 修改数据-单...
Table Group设置最佳实践
本文为您介绍Hologres中Table Group和Shard Count选定的基本原则、适用场景、设置策略以及常见问题，以助您获取更优的查询性能。实例规格推荐 在实践过程中存在数据量可预估，最适宜的Shard数区间应该设置为多少的问题，由于最适宜Shard数...
运行SQL命令并导出结果数据
步骤一：运行SQL命令 在MaxCompute客户端，基于非分区表bank_data和分区表bank_data_pt，查询各个学历下的贷款买房的单身人士数量，并将结果分别保存到result_table1和result_table2中。命令示例如下。查询非分区表bank_data中各个学历下的...
管理MySQL Catalog
分库分表的逻辑表会返回额外的_db_name(STRING)和_table_name(STRING)两个系统字段，且这两个字段与原分表的主键会作为逻辑表的新联合主键以保证主键的唯一性。如果user01~user99的主键均为id，则user逻辑表的联合主键为(_db_name,_table_...
CREATE TABLE AS
CREATE TABLE AS 创建一个表，并且用由一个 SELECT 命令计算出来的数据填充该表。简介 CREATE TABLE AS 创建一个表，并且用由一个 SELECT 命令计算出来的数据填充该表。该表的列具有和 SELECT 的输出列相关的名称和数据类型（不过可以通过...
建表概述
表是存储和组织数据的基本单位，合理地创建表、设置表索引及属性，可以为您提供高效的数据处理和分析能力。本文为您介绍在Hologres中的建表语法、设置索引和HoloWeb可视化建表。建表语法 命令格式 Hologres的建表语法兼容PostgreSQL，通过...
Python 2 UDTF读取MaxCompute资源示例
2.准备表数据 登录MaxCompute客户端创建资源表table_resource1和内部表tmp1（后续执行DML操作写入的目标表）并插入数据，准备资源文件test_json.txt并放置于MaxCompute客户端的 bin 目录中。更多登录MaxCompute客户端操作，请参见 安装并...
实时计算Flink版实时消费Hologres
Hologres Binlog实现原理 一条Binlog的字段由Binlog系统字段和用户Table字段组成，字段定义如下：字段名 字段类型 说明 hg_binlog_lsn BIGINT Binlog系统字段，表示Binlog序号，Shard内部单调递增不保证连续，不同Shard之间不保证唯一和...
RDS MySQL Online DDL 使用
Inplace和Copy Table是相反的2种处理方式；但即使DDL支持Inplace选项，某些操作在整个执行过程中也会部分涉及到Copy Table，例如上表中的添加列操作。Online DDL选项建议 Algorithm=Inplace：为了避免Copy Table导致的实例性能问题（空间、...
RDS MySQL Online DDL 使用
Inplace和Copy Table是相反的2种处理方式；但即使DDL支持Inplace选项，某些操作在整个执行过程中也会部分涉及到Copy Table，例如上表中的添加列操作。Online DDL选项建议 Algorithm=Inplace：为了避免Copy Table导致的实例性能问题（空间、...
订阅Hologres Binlog
Hologres V1.3.14和V1.1.82之前的版本仅支持Superuser消费Binlog，如果使用其他低权限账号消费Binlog会出现没有权限的报错：permission denied for table hg_replication_slot_properties。从Hologres V1.3.14和V1.1.82版本开始，若使用...
Presto Server配置和SQL示例
配置PrestoDB对接Tablestore时，您需要根据实际进行Presto Server的Catalog配置和Schema配置。对接完成后，您可以参考常见SQL示例进行数据操作。Server配置 根据需要对Presto Server进行Catalog配置和Schema配置。Catalog配置主要包括连接...
表批读写
读取表 您可以通过指定表名或路径将Delta表加载到DataFrame中：SQL%sql SELECT*FROM events-query table in the metastore SELECT*FROM delta.`/mnt/delta/events`-query table by path Python%pyspark spark.table("events")#query table ...
查看Worker倾斜关系
此时可能出现了计算资源倾斜，Hologres建立了新的系统视图hologres.hg_worker_info，通过此视图可以查询当前数据库Worker、Table Group和Shard之间的关系，便于您判断资源倾斜等关系，解决资源负载不均问题，提高资源利用率。本文为您介绍...
ALTER TABLE
ADD table_constraint[NOT VALID]这种形式使用和 CREATE TABLE 相同的约束语法外加 NOT VALID 选项为一个表增加一个新的约束，该选项当前只被允许用于外键和 CHECK 约束。通常，此窗体将导致对表进行扫描，以验证表中的所有现有行是否满足...
创建GLOBAL INDEX
全局分区索引（Global Partitioned Index）：Global Partitioned Index支持将GLOBAL INDEX进行range或hash分区，分区的语法和partition table类似。Global Partitioned Index不支持按照List分区。Global Partitioned Index只支持在分区表主...
通过PrestoDB使用Tablestore
运行PrestoDB后，通过 create schema 和 create table 语句来动态创建所需Schema和映射表。由上表可知，本地静态文件配置方式必须预先定义要使用的表信息，如果表信息之前未配置，则需要手动添加后才能进行访问。Meta表动态配置方式支持在...
DBMS_METADATA
使用指南 基本用法 以table类型和public模式（schema）为例，介绍如何使用get_ddl获取对象的DDL语句。在public模式下创建表 t，然后使用get_ddl获取其DDL语句。其中，对象类型为 table，对象名为 t，对象所属的模式为 public。create table...
使用Flink写入数据（Transaction Table2.0）
当前MaxCompute为您提供了新版的Flink Connector插件，新版插件支持将Flink数据写入至MaxCompute的普通表和Transaction Table2.0类型表，提高了Flink数据写入MaxCompute的便捷性。本文为您介绍新版Flink Connector写入MaxCompute的能力支持...
获取RDS MySQL数据语法错误
table 参数和 sql 参数，必须配置其中一个。输出字段错误 加工规则 e_table_map(res_rds_mysql(address="x",username="xx",password="xx",database="xx",table="test"),field="processid",output_fields=["name","xixi"])错误日志 trans_...
从RDS MySQL数据库获取数据进行数据富化
结合e_table_map函数进行数据富化 本示例介绍使用e_table_map函数和res_rds_mysql函数完成数据富化的方法。原始数据 RDS MySQL数据库表中的数据样例如下表所示。province city population cid eid 上海 上海 2000 1 00001 天津 天津 800 1 ...
TDE批量加解密插件（rds_tde_utils）
批量加密当前数据库下的所有表（table_a和table_b）及其关联索引。SELECT rds_tde_lazy_encrypt_database();SELECT rds_tde_encrypt_database();批量解密。说明 解密过程会对表进行重写，您可以选择 rds_tde_lazy_decrypt_table 或 rds_tde...
元数据库数据字典
云原生数据仓库AnalyticDB MySQL版 的元数据库为INFORMATION_SCHEMA库，兼容MySQL的元数据库。查询元数据库可以直接在JDBC连接中使用SQL语句...如果希望了解某一个表包含的所有列信息，可以根据TABLE_SCHEMA和TABLE_NAME查询需要的列信息。
元数据库数据字典
云原生数据仓库MySQL版的元数据库分为记载性能相关信息的performance_schema库和记载元数据的information_schema库，并和MySQL...如果希望了解某一个表包含的所有列信息，可以根据TABLE_CATALOG，TABLE_GROUP和TABLE_SCHEMA查询需要的列信息。
使用OPTIMIZE TABLE命令或DMS工具回收表空间
OPTIMIZE TABLE[$Database1].[Table1],[$Database2].[Table2]其中，[$Database1]和[$Database2]为数据库名称，[Table1]和[Table2]为表名。在InnoDB引擎中执行 OPTIMIZE TABLE 语句时，会出现以下提示信息，该信息是正常返回的结果，您可以...
交换分区
如果使用 EXCHANGE PARTITION 指定 EXCLUDING INDEXES 子句，则将交换 target_partition 和 source_table 中匹配的索引，但 source_table 中与 target_partition 中不匹配的索引将被标记为无效，反之亦然（即 target_partition 中与 source...
图解MySQL 8.0优化器查询解析篇
解析查询块Derived Table、View、Table的函数（resolve_placeholder_tables）resolve_placeholder_tables 函数用于处理derived table、view和table function。说明 如果该table已经merged过了，或者是由于使用transform_grouped_to_derived...
- 产品推荐
- 这些文档可能帮助您