可选：运维SQL分析任务
如果SQL分析任务的输出表作为另一个SQL分析任务的查询对象，则后者为前者的下游任务。数据开发名称/编号 选择要执行的SQL分析任务的名称。查看SQL分析任务执行情况 在 任务运维 页面下，找到要查看执行情况的任务。周期实例 页签下，查看...
Forall and Bulk Collect
比如用户提交一个数组，要求PL/SQL将这个数组的元素一条条插入到表里面，或者拿来更新表里面的值，又或是删除表里的值。解决方案 类似Oracle FORALL的批量插入用法，用一个数组表示条件，另一个数组表示VALUE如果有多个条件或者value时，...
触发器函数
另一种记录对表的改变的方法涉及到创建一个新表来为每一个发生的插入、更新或删除保持一行。这种方法可以被认为是对一个表的改变的审计。一个用于审计的 PL/SQL 触发器函数 这个例子触发器保证了在 emp 表上的任何插入、更新或删除一行的...
表删除，更新和合并
在这个部分：写入Delta表时的重复数据删除 缓慢将数据（SCD）类型2操作更改为Delta表 将更改数据写入Delta表 使用Upsert 从流式处理查询foreachBatch 写入Delta表时的重复数据删除 一个常见的ETL用例是通过将日志附加到表中来将日志收集到...
特殊用法
FORALL i IN lower_bound.upper_bound SAVE EXCEPTIONS single SQL 如果在执行的过程中出现异常，您可以通过另一个特殊的关联数组 SQL%BULK_EXCEPTIONS 来访问每条出错语句的具体错误信息。以下是一个查看异常SQL错误信息的示例。保证语句...
时序模型介绍
在表格存储的时序模型中，采用一张二维的时序表来存储时序数据。每行代表一个时间线在某个时间点的数据，该行的主键部分为时间线标识和时间戳，该行的数据列部分为该时间线在该时间戳下的数据点，可以有多个数据列。主键结构和数据列的结构...
功能发布记录
Join功能允许将两个表或多个表进行连接，并返回符合连接条件和查询条件的数据。2023-05-23 华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华北6（乌兰察布）、华南1（深圳）、中国香港、德国（法兰克福）、美国...
迁移指南
始终使用本指南中描述的命令来代替手动修改存储在Delta表中的文件。外部读取器：直接读取存储在Delta Lake中的数据。有关如何读取Delta表的信息，请参阅Integrations。示例 假设您已将Parquet数据存储在directory/data-pipeline 中，并希望...
写入或更新调优指南
通常情况是这个表既有Fixed Plan的SDK写入或更新，又有HQE的写入或更新，HQE是表锁，会导致SDK的写入因为等锁而耗时较长。可以根据如下SQL查询当前表是否有HQE的操作，根据业务情况优化为SDK的SQL。可以通过HoloWeb Query洞察快速识别出...
CREATE TRIGGER
下面的表格总结了哪些触发器类型可以被用在表、视图和外部表上：何时 事件 行级 语句级 BEFORE INSERT/UPDATE/DELETE 表和外部表 表、视图和外部表 TRUNCATE—表 AFTER INSERT/UPDATE/DELETE 表和外部表 表、视图和外部表 TRUNCATE—表 ...
DECLARE
另一个使用 FOR UPDATE 的原因是，如果没有它，当游标查询不符合 SQL 标准的“简单可更新”规则时，后续的 WHERE CURRENT OF 可能会失败（特别地，该游标必须只引用一个表并且没有使用分组或者 ORDER BY）。不是简单可更新的游标可能成功也...
文档更新动态（2023年）
更新说明 创建Flink SQL任务 新建元表 新建镜像表 新增支持创建补数据任务 新增支持创建补数据任务：支持配置补数据任务，可设置定时补数据或手动触发补数据，以回刷节点范围和业务日期相对规律，确定补数据的场景，减少人工投入。...
DAO 存储
upgrade 按照 SQL update 来执行，如果 SQL 不止一个，可以用括起来，类似的实现。如果需要使用 upgrade 块定义的操作来升级表，那么 module 里的 resetOnUpgrade 必须设置为 false。crypt描述 class 这个类的 property 属性进行加密处理，...
DBCP 连接池连接 OceanBase 数据库示例程序
本文将介绍如何使用 DBCP 连接池、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、更新和查询数据等。点击下载 dbcp-mysql-client 示例工程 前提条件 您已安装 OceanBase 数据库...
数据集常见问题
如果有特殊需求，例如需要筛选两个图表，其中一个图表展示某一天数据，另一个图表展示该天起，最近3天的数据，则可以通过参数SQL来实现。参考SQL如下：select report_date,area,product_type,count(distinct order_id)order_num from ...
2021年
2021-11-29 华北2（北京）华东2（上海）华北3（张家口）华东1（杭州）华南1（深圳）网络开通流程 MaxCompute支持清空分区表中指定分区的数据 MaxCompute支持用户手动清空分区表中指定的一个或者多个分区的数据，但不会删除分区表或者分区表...
PolarDB HTAP实时数据分析技术解密
由于一份数据在多个副本之间完全独立，因此在不同副本上使用不同格式进行存储，来服务不同的查询负载是一个易于实施的方案。例如，TiDB从TiDB4.0开始，在Raft Group的其中一个副本上使用列式存储（TiFlash）来响应AP型负载，并通过TiDB的...
列存索引技术架构介绍
在IMCI执行引擎中，每个Operator也使用迭代器函数来访问数据，但不同的是每次调用迭代器会返回一批数据，而不是一行，可以认为这是一个使用了向量化模式的火山模型。串行执行受制于单核计算效率、访存延时、IO延迟等限制，执行能力有限。而...
使用Logview 2.0查看作业运行信息
例如，您可以通过Fuxi Sensor查看机器学习作业Fuxi Instance的以下资源使用情况：CPU使用量 CPU指标包括两条线，一条显示申请的CPU量（cpu_plan），另一条显示实际的CPU使用量（cpu_usage）。纵坐标中的400，表示4个Processor。目前用户只...
时空数据库版本发布记录
本文介绍PolarDB PostgreSQL版时空数据库（Ganos）的版本更新说明。6.X 6.3 类别 说明 新增特性 Trajectory SQL 新增 ST_InsertAttr 函数，支持为轨迹增加新的属性。GeomGrid SQL 新增 ST_Degeneralize 函数，支持将低层级网格分解成高层级...
时空数据库版本发布记录
本文介绍PolarDB PostgreSQL版（兼容Oracle）时空数据库（Ganos）的版本更新说明。6.X 6.3 类别 说明 新增特性 Trajectory SQL 新增 ST_InsertAttr 函数，支持为轨迹增加新的属性。GeomGrid SQL 新增 ST_Degeneralize 函数，支持将低层级...
一般SQL优化方法
在SQL语句中可以使用SQL优化，如添加索引、选择合适数据类型、避免使用 SELECT*、...JOIN 一个查询中产于JOIN的表数量控制在12个以内，多于12个表JOIN，可以考虑使用临时表拆分语句。存储过程或函数 能使用SQL语句实现的，不要用循环去实现。
SQL查询介绍
一个数据库中可以包含一个或者多个表。表 表 由行和列组成。索引 二级索引、多元索引 为加速数据查询而创建的一种存储结构。功能特性 SQL功能 支持单次请求单条SQL。支持基础的DDL语句，主要包括 创建表的映射关系、创建多元索引的映射关系...
使用流程
您也可以快速创建一张测试表来快速体验功能。4 写入数据 向时序表中写入时序数据。时序数据由元数据和数据两部分组成，如果未预先新建元数据，则系统会根据写入的数据自动提取元数据。5 查询时序数据 查询时序时，如果不确定要查询的时间线...
数据查询
除了使用HBase shell来写Get、Scan请求，Lindorm insight提供了一个简单的SQL查询入口，您可以使用SQL语法来查询HBase增强版宽表数据。前提条件 已登录目标集群的集群管理系统，具体操作，请参见 登录集群管理系统。使用限制 为确保数据...
Spark SQL
在Spark中执行SQL时,操作表之前需要使用 USE DatabaseName SQL语句来切换到目标数据。或者显式指定某个表属于哪个数据库,例如 SELECT*FROM db1.table1。4.当前在Spark中执行 ALTER 语句有部分限制。用户可以通过类似 ALTER DATABASE.等语句...
在本地环境上使用PyODPS
您可以使用 execute_sql()/run_sql()来执行SQL命令，示例如下：使用 create_table 方法创建一个新的表。o.create_table('my_t','num bigint,id string',if_not_exists=True)使用 execute_sql 方法执行SQL查询。result=o.execute_sql('...
基础数据操作
如果要进行批量写入时序数据、一次写入多个表、统计写入状态等操作，请使用时序Writer实现数据写入。具体操作，请参见 使用时序Writer写入时序数据。如果要迁移Kafka数据源的数据到表格存储时序表中，您可以通过Tablestore Sink Connector...
SQL防火墙
SQL/Protect插件提供了一个学习模块，动态跟踪一位用户访问的表之间的关联关系。该模块可以在学习模式（leanrn）下主动学习一个用户访问的表集合，当插件进入被动模式（passive）或者主动模式（active）后，便可以根据学习得到的表集合来...
代码模板
创建临时表 如果您只需要在当前会话或SQL脚本中使用某些表，则可以使用临时表。创建临时视图 如果您需要在Flink SQL开发过程中，重用代码，组织长查询或者SQL脚本来简化开发，则可以使用临时视图。INSERT INTO 如果您需要将查询结果写入到...
Delta Lake 快速入门
读一个表 在这个部分：显示表格历史记录 查询表的早期版本（时间行程）您可以通过在DBFS（"/mnt/delta/events"）或表名（"event"）上指定路径来访问Delta表中的数据：Scala%spark SELECT*FROM delta.`/mnt/delta/events` 或%spark val ...
CPU使用率高排查方法
定位读取Buffer数量较多的慢查询 当一张表缺少索引，而对该表的查询基本上都是点查时，数据库将不得不使用全表扫描，并在内存中使用过滤条件来过滤掉大量的无效记录，导致CPU使用率大幅上升。通过 pg_stat_statements 插件的统计信息，参考...
词法结构
一个美元引用的字符串常量由一个美元符号（$）、一个可选的另个或更多字符的“标签”、另一个美元符号、一个构成字符串内容的任意字符序列、一个美元符号、开始这个美元引用的相同标签和一个美元符号组成。例如，这里有两种不同的方法使用...
管理健康报告
例如，对于以下两个SQL语句，当它们经过参数化处理后，它们属于同一类SQL。原始SQL SELECT*FROM orders WHERE customer_id=10 AND quantity>20 SELECT*FROM orders WHERE customer_id=20 AND quantity>100 参数化后SQL SELECT*FROM orders ...
表批读写
一种常见的模式是在执行Databricks作业期间使用Delta表的最新状态来更新下游应用程序。由于 Delta 表会自动更新，因此，如果基础数据进行了更新，则在多次调用时，从 Delta 表加载的DataFrame可能返回不同的结果。通过使用按时间顺序查看，...
使用OPTIMIZE和Z-ORDER优化商品库存查询性能
INSERT 或 UPDATE parquet文件的七个步骤 在使用Databricks Delta之前，我们先来看下，在通常情况下如何插入或更新表记录。确定需要插入的新记录。确定将会被替换的记录（例如，更新updated）。确定不会被INSERT或UPDATE操作影响的记录。...
使用SQL查询时序数据
时序表的SQL映射关系 根据每个时间线每个时刻对应一个值或者多个值，时序模型分为“单值模型”和“多值模型”。对于同一个时序表，您可以建立三种SQL映射关系用于数据查询，详细说明请参见下表。映射关系类型 描述 创建方式 在SQL中的表名 ...
SQL限流
说明 仅当一个SQL语句满足所有的匹配参数条件时，才会根据该规则的WITH选项进行限流。限流结果 一条SQL匹配到该规则后，根据限流规则中WITH选项里配置的参数，会出现如下几种结果：RUN（可运行）若并发度还未达到最大并发度（即 MAX_...
Commons Pool 连接 OceanBase 数据库示例程序
本文将介绍如何使用 Commons Pool、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入数据、更新数据、删除数据、查询数据和删除表等。点击下载 commonpool-mysql-client 示例工程 前提条件...
基本语句
一个使用 format()的例子（这假设你用美元符号引用了函数体，因此引号不需要被双写）：EXECUTE format('UPDATE tbl SET%I=$1 ' 'WHERE key=$2',colname)USING newvalue,keyvalue;还可以直接调用引用函数：EXECUTE 'UPDATE tbl SET '|quote_...
- 产品推荐
- 这些文档可能帮助您