--- title: "SORT - OceanBase 数据库 V4.3.5 | OceanBase 文档中心" description: SORT SORT 算子用于对输入的数据进行排序。 SORT 算子类型 在 OceanBase 数据库中， SORT 算子根据不同的数据分布、查询语义和优化目标，具体表现为不同的形态： 算子类型 特性说明 核心原理 适用场景 SORT 用于通用的、完整的排序需求。 阻塞性排序：必须拿到下层算子的完整结果集后才能开始排… --- 切换语言 - 中文站 - 简体中文 - International - English - 日本站 - 日本語 文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*P8CuR4UJ_FkAAAAAAAAAAAAADiGDAQ/original) OceanBase 数据库分布式版 - V 4.3.5 LTS # SORT 更新时间：2026-07-19 16:40:56 [编辑](https://github.com/oceanbase/oceanbase-doc/edit/V4.3.5/zh-CN/700.reference/1000.performance-tuning-guide/500.sql-optimization/200.sql-execution-plan/400.execution-plan-operator/1100.SORT.md) `SORT` 算子用于对输入的数据进行排序。 ## SORT 算子类型 在 OceanBase 数据库中，`SORT` 算子根据不同的数据分布、查询语义和优化目标，具体表现为不同的形态： | 算子类型 | 特性说明 | 核心原理 | 适用场景 | | --- | --- | --- | --- | | SORT | 用于通用的、完整的排序需求。 | 阻塞性排序：必须拿到下层算子的完整结果集后才能开始排序。 | 下层数据无序，或下层数据的有序性无法被当前排序利用时。例如，对没有合适索引的表执行 `ORDER BY`。 | | TOP-N SORT | 针对 `ORDER BY ... LIMIT N` 语句的优化排序，效率更高。 #### 注意 `LIMIT` 子句仅适用于 MySQL 模式。 | 堆排序：只需维护一个大小为 N 的堆，无需对所有数据进行全排序，内存和计算开销更小。 | 查询中包含 `ORDER BY` 和 `LIMIT` 子句，且优化器判定使用该算子代价更低时。 | | PARTITION SORT | 作为 `MERGE GROUP BY` 等算子的预处理阶段，为数据分组合并提供有序输入。 | 预排序：按照后续算子 `MERGE GROUP BY` 所需的分组键顺序对数据进行排序，以提升合并效率。 | 当优化器选择使用 `MERGE GROUP BY` 等基于排序的算法时，其下层通常会分配此算子进行预排序。 | ## SORT 标准 `SORT` 算子是最常见的排序算子，当下层数据完全无序且需要完整排序时使用。例如，对没有合适索引的表执行 `ORDER BY` 时就会生成此算子。 ### SORT 示例 1. 创建表 `tbl1`。 ```shell obclient> CREATE TABLE tbl1(col1 INT, col2 INT); ``` 2. Q1：从表 `tbl1` 中查询 `col1` 列的所有值，并按 `col1` 降序、`col2` 升序的顺序进行排序，查看该查询的执行计划。 ```shell obclient> EXPLAIN SELECT col1 FROM tbl1 ORDER BY col1 DESC, col2 ASC; ``` 返回结果如下： ```shell +---------------------------------------------------------------------+ | Query Plan | +---------------------------------------------------------------------+ | ================================================= | | |ID|OPERATOR |NAME|EST.ROWS|EST.TIME(us)| | | ------------------------------------------------- | | |0 |SORT | |1 |3 | | | |1 |└─TABLE FULL SCAN|TBL1|1 |3 | | | ================================================= | | Outputs & filters: | | ------------------------------------- | | 0 - output([TBL1.COL1]), filter(nil), rowset=16 | | sort_keys([TBL1.COL1, DESC], [TBL1.COL2, ASC]) | | 1 - output([TBL1.COL1], [TBL1.COL2]), filter(nil), rowset=16 | | access([TBL1.COL1], [TBL1.COL2]), partitions(p0) | | is_index_back=false, is_global_index=false, | | range_key([TBL1.__pk_increment]), range(MIN ; MAX)always true | +---------------------------------------------------------------------+ 14 rows in set ``` 在 Q1 查询返回结果中，除了 `SORT` 算子（0 号算子），还展示了以下执行算子： - `TABLE FULL SCAN`：表示全表扫描。该算子属于 `TABLE SCAN` 算子，详细信息参见 [TABLE SCAN](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000002016219)。 上述 Q1 查询的执行计划展示中的 `Outputs & filters` 详细列出了 `SORT` 算子的输出信息如下： | 信息名称 | 含义 | 示例说明 | | --- | --- | --- | | output | 该算子最终输出的列或表达式列表。 | `output([TBL1.COL1])` 表示该算子输出的是表 `tbl1` 中的 `col1` 列。 | | filter | 该算子需要应用的过滤条件（谓词）。 | `filter(nil)` 表示没有需要再额外过滤的行。 | | rowset | 表示当前算子的向量化大小。 | `rowset=16` 表示当前算子的向量化大小为 16。 | | sort_keys | 表示该算子输出数据的排序键和排序方式。 - `DESC`：降序。 - `ASC`：升序。 | `sort_keys([TBL1.COL1, DESC], [TBL1.COL2, ASC])` 表示以排序键 `TBL1.COL1` 列降序和 `TBL1.COL2` 列升序。 | ## TOP-N SORT 在 OceanBase 数据库的 MySQL 模式中，当查询包含 `ORDER BY ... LIMIT N` 时，优化器可能会将其优化为 `TOP-N SORT` 算子。该算子采用堆排序算法，只需在内存中维护一个大小为 N 的堆，而无需对所有输入数据进行全排序，因此在内存使用和执行效率上通常优于普通 `SORT`。 ### TOP-N SORT 示例 1. 创建表 `tbl2`。 ```shell obclient> CREATE TABLE tbl2(col1 INT, col2 INT); ``` 2. 在表 `tbl2` 上基于列 `col1` 创建索引 `idx_tbl2`。 ```shell obclient> CREATE INDEX idx_tbl2 ON tbl2(col1); ``` 3. Q2：从表 `tbl2` 中查询所有 `col1` 大于 1 的记录，按 `col1` 和 `col2` 升序排序后，只返回前 10 条结果，查看该查询的执行计划。 ```shell obclient> EXPLAIN SELECT * FROM tbl2 WHERE col1 > 1 ORDER BY col1, col2 LIMIT 10; ``` 返回结果如下： ```shell +-------------------------------------------------------------------------------+ | Query Plan | +-------------------------------------------------------------------------------+ | ============================================================ | | |ID|OPERATOR |NAME |EST.ROWS|EST.TIME(us)| | | ------------------------------------------------------------ | | |0 |TOP-N SORT | |1 |5 | | | |1 |└─TABLE RANGE SCAN|tbl2(idx_tbl2)|1 |5 | | | ============================================================ | | Outputs & filters: | | ------------------------------------- | | 0 - output([tbl2.col1], [tbl2.col2]), filter(nil), rowset=16 | | sort_keys([tbl2.col1, ASC], [tbl2.col2, ASC]), topn(10), prefix_pos(1) | | 1 - output([tbl2.col1], [tbl2.col2]), filter(nil), rowset=16 | | access([tbl2.__pk_increment], [tbl2.col1], [tbl2.col2]), partitions(p0) | | is_index_back=true, is_global_index=false, | | range_key([tbl2.col1], [tbl2.__pk_increment]), range(1,MAX ; MAX,MAX), | | range_cond([tbl2.col1 > 1]) | +-------------------------------------------------------------------------------+ 15 rows in set ``` 在 Q2 查询返回结果中，除了 `TOP-N SORT` 算子（0 号算子），还展示了以下执行算子： - `TABLE RANGE SCAN`：表示范围扫描，会根据给定的查询条件（范围谓词）扫描索引或主表的一段连续范围，返回 0 行或多行数据。该算子属于 `TABLE SCAN` 算子，详细信息参见 [TABLE SCAN](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000002016219)。 上述 Q2 查询的执行计划展示中的 `Outputs & filters` 详细列出了 `TOP-N SORT` 算子的输出信息如下： | 信息名称 | 含义 | 示例说明 | | --- | --- | --- | | output | 该算子最终输出的列或表达式列表。 | `output([tbl2.col1], [tbl2.col2])` 表示该算子输出的是表 `tbl2` 中的 `col1`、`col2` 列。 | | filter | 该算子需要应用的过滤条件（谓词）。 | `filter(nil)` 表示没有需要再额外过滤的行。 | | rowset | 表示当前算子的向量化大小。 | `rowset=16` 表示当前算子的向量化大小为 16。 | | sort_keys | 表示该算子输出数据的排序键和排序方式。 - `DESC`：降序。 - `ASC`：升序。 | `sort_keys([tbl2.col1, ASC], [tbl2.col2, ASC])` 表示以排序键 `tbl2.col1` 列升序和 `tbl2.col2` 列升序。 | | topn | 表示需要获取的前 N 行数据量，对应查询中的 `LIMIT N`。 | `topn(10)` 表示此算子只需获取并排序出前 10 条数据。 | | prefix_pos | 排序列的有序位置。 | `prefix_pos(1)` 表示下层 `TABLE RANGE SCAN` 算子利用索引 `idx_tbl2` 扫描后，数据在 `col1` 列上已经有序，因此 `TOP-N SORT` 仅需在 `col1` 相同的数据组内对 `col2` 列进行堆排序即可。 | ## PARTITION SORT `PARTITION SORT` 表示分区排序，其主要目的并非为了最终输出结果的顺序，而是作为 `MERGE GROUP BY` 算子的预处理阶段。它通过特定的排序方式，将数据预先排列成便于合并分组的形式，从而提升分组聚合的效率。 当查询包含 `GROUP BY` 但未指定 `ORDER BY`，且优化器选择了 `MERGE GROUP BY`（也称为排序分组）作为执行方式时，下层通常会配套一个 `PARTITION SORT` 来提供有序输入。 ### PARTITION SORT 示例 1. 创建表 `tbl3`。 ```shell obclient> CREATE TABLE tbl3 (col1 INT, col2 INT); ``` 2. Q3：使用 Hint 强制优化器使用 `MERGE GROUP BY`，对表 `tbl3` 按 `col1` 分组并计算每组 `col2` 的和，同时筛选出总和大于 2 的分组，查看该查询的执行计划。 ```shell obclient> EXPLAIN SELECT /*+NO_USE_HASH_AGGREGATION*/ col1, SUM(col2) FROM tbl3 GROUP BY col1 HAVING SUM(col2) > 2; ``` 返回结果如下： ```shell +--------------------------------------------------------------------------------------------------+ | Query Plan | +--------------------------------------------------------------------------------------------------+ | =================================================== | | |ID|OPERATOR |NAME|EST.ROWS|EST.TIME(us)| | | --------------------------------------------------- | | |0 |MERGE GROUP BY | |1 |3 | | | |1 |└─PARTITION SORT | |1 |3 | | | |2 | └─TABLE FULL SCAN|TBL3|1 |3 | | | =================================================== | | Outputs & filters: | | ------------------------------------- | | 0 - output([TBL3.COL1], [T_FUN_SUM(TBL3.COL2)]), filter([T_FUN_SUM(TBL3.COL2) > 2]), rowset=16 | | group([TBL3.COL1]), agg_func([T_FUN_SUM(TBL3.COL2)]) | | 1 - output([TBL3.COL1], [TBL3.COL2]), filter(nil), rowset=16 | | sort_keys([HASH(TBL3.COL1), ASC], [TBL3.COL1, ASC]) | | 2 - output([TBL3.COL1], [TBL3.COL2]), filter(nil), rowset=16 | | access([TBL3.COL1], [TBL3.COL2]), partitions(p0) | | is_index_back=false, is_global_index=false, | | range_key([TBL3.__pk_increment]), range(MIN ; MAX)always true | +--------------------------------------------------------------------------------------------------+ 17 rows in set ``` 在 Q3 查询返回结果中，除了 `PARTITION SORT` 算子（1 号算子），还展示了以下执行算子： - `MERGE GROUP BY`：用于执行使用排序合并算法进行的分组聚合操作。该算子属于 `GROUP BY` 算子，详细信息参见 [GROUP BY](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000002016218)。 - `TABLE FULL SCAN`：表示全表扫描。该算子属于 `TABLE SCAN` 算子，详细信息参见 [TABLE SCAN](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000002016219)。 上述 Q3 查询的执行计划展示中的 `Outputs & filters` 详细列出了 `PARTITION SORT` 算子的输出信息如下： | 信息名称 | 含义 | 示例说明 | | --- | --- | --- | | output | 该算子最终输出的列或表达式列表。 | `output([TBL3.COL1], [TBL3.COL2])` 表示该算子输出的是表 `tbl3` 中的 `col1`、`col2` 列。 | | filter | 该算子需要应用的过滤条件（谓词）。 | `filter(nil)` 表示没有需要再额外过滤的行。 | | rowset | 表示当前算子的向量化大小。 | `rowset=16` 表示当前算子的向量化大小为 16。 | | sort_keys | 表示该算子输出数据的排序键和排序方式。 - `DESC`：降序。 - `ASC`：升序。 | `sort_keys([HASH(TBL3.COL1), ASC], [TBL3.COL1, ASC])` 表示： 1. 首先根据分组列 `COL1` 的哈希值进行升序排序。 2. 在哈希值相同的基础上，再按照 `COL1` 的实际值升序排序，确保分组键的完全有序。 | 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线