HikariCP 连接池连接 OceanBase 数据库示例程序
本文将介绍如何使用 HikariCP 连接池、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、更新和查询数据等。点击下载 hikaricp-mysql-client 示例工程 前提条件 您已安装 OceanBase...
一键诊断
AnalyticDB for MySQL 推出 一键诊断 功能，可针对指定时间段的集群运行状况发起诊断，结合监控数据、日志数据以及库表状态等信息进行联合分析，从集群的资源水位、负载变化、查询SQL、算子、存储等多方面评估集群的健康状况，帮助您提高...
DQL操作常见问题
横向合并可以通过 row_number 函数实现，两个表都新加一个ID列，进行ID关联，然后取两张表的字段。更多信息，请参见 并集 或 ROW_NUMBER。在执行UNION ALL操作时，报错ValidateJsonSize error，如何解决？问题现象 执行包含200个UNION All...
基本概念
本文为您介绍DataWorks中，工作空间、业务流程、解决方案、组件、任务、实例、业务日期、定时时间、提交、脚本开发、资源、函数和输出名称等基本概念。工作空间 工作空间 是DataWorks管理任务、成员，分配角色和权限的基本单元。工作空间...
新建存储过程
操作步骤 以在 ODC 中创建部门预算存储过程（proc_total）为例，存储过程 proc_total 中包含 budget_r 和 budget_s 两个 INT 类型的输入参数，计算两个参数之和。具体操作步骤如下：步骤 1：指定存储过程名称 在 OceanBase 开发者中心...
调优原理和执行计划
SHIPPRIORITY`,`O_COMMENT` FROM `orders` AS `orders`")示例2是典型的两张表做关联（join），由于两表分区键没对齐，所有join没有下推，整个执行过程是将两个表数据都扫描出来，在CN层做关联计算。LogicalView：扫描表数据。Exchange：...
步骤三：设置任务调度策略并发布
一个自定义存储表，仅可作为一个数据解析或SQL任务的输出表。数据写入策略 SQL分析任务在调度生产数据过程中，写入数据时的策略。根据选择的自定义存储表类型，自动选中对应策略，不支持修改。分区表 和 时序表 使用 分区覆盖：每次任务重...
ePQ Hint Injection
在不改造SQL的情况下，可以让指定的SQL运行或者不运行ePQ。使用指南 创建插件并设置开关 说明 推荐根据 DB/角色 来设置开关。例如，当前的DB为postgres。create extension polar_sql_mapping;create extension pg_hint_plan;alter database...
设备数据存储和计算实践
选择在自定义存储表中存储时，根据处理功能节点的输出配置，自动匹配显示可输出的字段。您可根据需要删除、修改字段，完成最终输出结果配置。详细使用内容，请参见 数据解析。交互查询 为了满⾜数据洞察分析，物联网平台提供了SQL⼯作台，...
ePQ Hint Injection
说明 其中：polar_sql_mapping.insert_px_mapping：表示写入SQL至 polar_sql_mapping.polar_px_mapping_table，该表在 polar_enable_px 关闭时使用，目的是将在 polar_px_mapping_table 表中匹配到的SQL加上/*+PX()*/。例如，select count...
配置同步任务
多表：适用于将多个表的业务数据同步至同一个目标表的场景。多个表的数据写入同一个数据表时，使用union算法。更多union说明，请参见 交集（INTERSECT）、并集（UNION）和补集（EXCEPT）。表 选择来源数据表。如果 模式 选择了 单表，则...
CREATE FUNCTION
如果两个函数具有相同的名称和输入参数类型，它们被认为相同（不考虑任何 OUT 参数）。因此这些声明会冲突：CREATE FUNCTION foo(int).CREATE FUNCTION foo(int,out text).具有不同参数类型列表的函数在创建时将不会被认为是冲突的，但是...
算子
背景信息 AnalyticDB MySQL版 中的一个算子负责完成一个基本的数据处理逻辑，一组算子按照执行计划完成数据的一组处理规则。AnalyticDB MySQL版 是一个分布式系统，大多数算子可以达到在多个节点上并行完成计算任务，来提高数据处理效率。...
TRIM
trim 是一个过程，用于从变长数组或嵌套表的末尾删除元素并销毁位置（以下简称为销毁元素）。trim 的形式如下：collection.trim()：如果集合至少有一个元素，则TRIM从集合末尾销毁元素；否则，会引发预定义的异常 SUBSCRIPT_BEYOND_COUNT。...
SQL脚本模式
同一个脚本中，引用的表不能超过10000个，如果包含View，会计算建View时引用了多少张表。同一张表出现多次，按出现次数算表数。Script Mode的SQL语句书写便利，您只需要按照业务逻辑，用类似于普通编程语言的方式书写，无需考虑如何组织...
日期/时间类型
日期/时间输出 时间/日期类型的输出格式可以设成四种风格之一：ISO 8601、SQL（Ingres）Unix 的date格式或 German。缺省是 ISO 格式（ISO 标准要求使用 ISO 8601 格式。ISO 输出格式的名字是历史偶然）。date 和 time 类型的输出通常只有...
概述
重要 如果源表中存在一条未来的乱序数据或者某个subtask或上游源表的某个分区中没有数据，则可能会无法触发窗口结束，从而导致结果数据异常。因此您需要根据数据乱序的程度设置合理的offset大小，并保证所有subtask和上游源表的所有分区...
pg_dump
pg_dump是 PolarDB PostgreSQL版（兼容Oracle）提供的一种逻辑备份工具，用于将集群中的单个数据库备份为脚本文件或其他存档文件。简介 pg_dump用于备份单个数据库。即使当前数据库正在被访问，也会对正在访问的数据进行一致的备份，并且在...
SCAN语句
例如，您可以定义一个Kafka数据源表，然后定义两个SCAN，分别对应批式读和流式读。SCAN语法定义Table时只需要定义Table数据源的基本信息，无需定义如何读这个Table的参数。SCAN语法约束如下：SCAN语法定义的视图，仅能用作数据源表，不可以...
SELECT TRANSFORM
语法中有两个 row fromat 子句，第一个子句指定输入数据的格式，第二个子句指定输出数据的格式。默认情况下使用 \t 作为列分隔符，作为行分隔符，使用 \N 表示NULL。说明 field_delimiter、character_escape 和 line_separator 只接受一个...
MaxCompute数据开发规范
说明 建议通过DataWorks数据管理中的管理配置模块进行表的分类管理，同时通过DataWorks数据开发中的表管理模块将表与对应分类关联。视图设计规范 视图的命名规范与表保持一致。建议创建独立的刷新任务以产生视图，创建视图的脚本如下。...
SELECT TRANSFORM
语法中有两个 row format 子句，第一个子句指定输入数据的格式，第二个子句指定输出数据的格式。默认情况下使用 \t 作为列分隔符，作为行分隔符，使用 \N 表示NULL。说明 field_delimiter、character_escape 只接受一个字符。如果指定的是...
交互分析管理
添加文本类型 说明 通过输入值或从数据源中生成字符类变量，并从字符串列表中选择值用于使用字符列筛选数据源。单击 添加参数，打开 新建SQL参数 窗口。选择 文本类型，单击 下一步。请根据表格内容，填写配置项。模块 参数 说明 SQL过滤...
SQL脚本
场景2：SQL脚本组件从多个上游表读取数据做联合分析 取消选中 是否由系统添加Create Table语句 复选框，通过变量${o1} 和${lifecycle} 创建一个临时表作为输出。SQL脚本代码配置如下所示。create table if not exists${o1} lifecycle${...
作业实例详情
基本信息页面 基本信息页面展示了作业的基本信息，包括ID、创建人、状态、起止时间、计算资源用量、输入项（作业的输入表）、输出项（作业的输出表）等。运行中作业的基本信息会自动定时刷新。双击表名即可查看对应表的基本信息页面。执行...
文档更新动态（2023年）
支持配置数据源编码，配置数据源编码后，可在Flink SQL任务中通过 数据源编码.table 或 数据源编码.schema.table 的格式引用MySQL、Hologres和MaxCompute数据源中的表。更新说明 创建FTP数据源 创建Salesforce数据源 创建OSS数据源 管理...
使用mysqldump导入导出数据
说明 上述两个命令中 default-character-set 要设置成实际的数据编码。如果是Windows平台，source命令指定的文件路径需要对分隔符转义。第一种方式会把所有的步骤回显到屏幕上，速度略慢，但是可以观察导入过程。导入时由于某些 PolarDB-X ...
逻辑数仓
但在实际落地过程中有两个常见问题影响了数据驱动的实现和效率：资源和成本问题 建仓和管仓成本高，中小企业缺少资源和技术手段构建数仓支持业务分析和决策，使得大多数企业望而却步。大型企业业务复杂度高，数仓开发门槛高，专业开发人员...
使用执行计划分析查询
AnalyticDB MySQL版 的SQL诊断功能支持以树形图的形式展现SQL查询的执行计划。执行计划树分为两层：第一层是Stage层，第二层是算子（Operator）层。本文介绍如何使用Stage层和算子层执行计划树来分析查询。Stage层执行计划树 Stage层执行...
UDT概述
说明 目前除隐式类型转换变成内置类型外，UDT对象不能存储到硬盘，即不能将UDT对象 INSERT 到表中（实际上DDL不支持UDT，不能创建这样的表）。内置类型支持BINARY，即支持自己实现序列化的过程，将 byte[]的数据存储到硬盘，下次读出时再...
SelectObject
未编码前的值最多为两个字符，以字符的ANSI值表示，例如在Java中使用 表示换行。子节点：None 父节点：CSV（输入、输出），JSON（输出）FieldDelimiter 字符串 指定CSV列分隔符，以Base64编码。默认值为,（可选）。未编码前的值必须为一个...
数据接入概述
功能 支持说明 数据解析 作为一个数据解析任务的输出对象，以存储所需数据。冷数据存储 以表格的形式，展示云产品数据。分析洞察 作为一个SQL分析任务的输出对象，以存储所需数据。作为多个SQL分析任务的查询对象。IoT孪生引擎数据源 开启...
MySQL性能排查解析
检查备库是否存在无主键表的删除或者更新操作，可以通过在备库上执行 show engine innodb status \G 语句查看，或者执行 show open tables 语句后，查看输出结果的 in_use 列的值为1的表。解决方法 本节列出以下四种常见的解决方法，您可以...
功能更新动态（2023年）
配置FTP输入组件 配置Microsoft SQL Server输入组件 通过整库迁移配置集成任务 配置OSS输出组件 实时研发 实时任务研发体验流程优化：Flink SQL任务支持通过数据源编码的方式访问MySQL、Hologres和MaxCompute数据源中的表。元表、镜像表在...
新功能发布记录
SQL回放 会话与事务 新增 开启会话后，同一SQL Console页签下执行的所有SQL将在同一个Session中执行。开启会话与事务 10月 功能名称 变更类型 功能描述 相关文档 任务编排新增仪表盘推送节点 新增 仪表盘推送节点通过联动数据服务功能，可...
数据倾斜调优
数据倾斜示例 在下面这个表中，eleme_uid 中存在很多热点数据，容易发生数据倾斜。SELECT eleme_uid,.FROM(SELECT eleme_uid,.FROM)t1 LEFT JOIN(SELECT eleme_uid,.FROM)t2 on t1.eleme_uid=t2.eleme_uid;解决方案。可以通过如下四种方法...
高温报警
本文以高温报警（传感器温度>80度时，输出报警信息到本地文件中）的场景为例，详细说明如何使用SQL进行流数据分析作业的编写以及流数据分析作业如何运作。流程图如下所示。前提条件 请您确保已创建边缘实例，具体操作请参见 专业版环境搭建...
DescribeDiagnosisRecords-查询诊断记录
59.82.xx.xx Order string 否 根据指定字段对 SQL 语句进行排序，格式为 JSON，是一个有序 JSON 数组，按输入数组的顺序进行复合排序，包含 Field 和 Type 两个字段，例如[{"Field":"StartTime","Type":"desc"}]。其中：Field 表示需要排序...
设置白名单
您可以将两个实例切换至同一个VPC下，然后在IP白名单中添加私有IP地址。两个实例均为经典网络 添加ECS实例私有IP地址。ECS实例为经典网络 RDS实例为专有网络 不同网络类型的实例无法内网互通，您可以参考如下方案：将ECS实例从经典网络迁移...
设置白名单
您可以将两个实例切换至同一个VPC下，然后在IP白名单中添加私有IP地址。两个实例均为经典网络 添加ECS实例私有IP地址。ECS实例为经典网络 RDS实例为专有网络 不同网络类型的实例无法内网互通，您可以参考如下方案：将ECS实例从经典网络迁移...
- 产品推荐
- 这些文档可能帮助您