Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitd016763

Browse files
committed
Disallow SRFs when considering sorts below Gather Merge
While we do allow SRFs in ORDER BY, scan/join processing should notconsider such cases - such sorts should only happen via final Sort atopa ProjectSet. So make sure we don't try adding such sorts below GatherMerge, just like we do for expressions that are volatile and/or notparallel safe.Backpatch to PostgreSQL 13, where this code was introduced as part ofthe Incremental Sort patch.Author: James ColemanReviewed-by: Tomas VondraBackpatch-through: 13Discussion:https://postgr.es/m/CAAaqYe8cK3g5CfLC4w7bs=hC0mSksZC=H5M8LSchj5e5OxpTAg@mail.gmail.comDiscussion:https://postgr.es/m/295524.1606246314%40sss.pgh.pa.us
1 parent38d30a1 commitd016763

File tree

5 files changed

+26
-5
lines changed

5 files changed

+26
-5
lines changed

‎src/backend/optimizer/path/equivclass.c

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -837,6 +837,13 @@ find_em_expr_usable_for_sorting_rel(PlannerInfo *root, EquivalenceClass *ec,
837837
if (require_parallel_safe&& !is_parallel_safe(root, (Node*)em_expr))
838838
continue;
839839

840+
/*
841+
* Disallow SRFs so that all of them can be evaluated at the correct
842+
* time as determined by make_sort_input_target.
843+
*/
844+
if (IS_SRF_CALL((Node*)em_expr))
845+
continue;
846+
840847
/*
841848
* As long as the expression isn't volatile then
842849
* prepare_sort_from_pathkeys is able to generate a new target entry,

‎src/backend/optimizer/util/tlist.c

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,11 +21,6 @@
2121
#include"optimizer/tlist.h"
2222

2323

24-
/* Test if an expression node represents a SRF call. Beware multiple eval! */
25-
#defineIS_SRF_CALL(node) \
26-
((IsA(node, FuncExpr) && ((FuncExpr *) (node))->funcretset) || \
27-
(IsA(node, OpExpr) && ((OpExpr *) (node))->opretset))
28-
2924
/*
3025
* Data structures for split_pathtarget_at_srfs(). To preserve the identity
3126
* of sortgroupref items even if they are textually equal(), what we track is

‎src/include/optimizer/optimizer.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,11 @@
2424

2525
#include"nodes/parsenodes.h"
2626

27+
/* Test if an expression node represents a SRF call. Beware multiple eval! */
28+
#defineIS_SRF_CALL(node) \
29+
((IsA(node, FuncExpr) && ((FuncExpr *) (node))->funcretset) || \
30+
(IsA(node, OpExpr) && ((OpExpr *) (node))->opretset))
31+
2732
/*
2833
* We don't want to include nodes/pathnodes.h here, because non-planner
2934
* code should generally treat PlannerInfo as an opaque typedef.

‎src/test/regress/expected/incremental_sort.out

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1620,3 +1620,15 @@ order by 1, 2;
16201620
-> Function Scan on generate_series
16211621
(7 rows)
16221622

1623+
-- Disallow pushing down sort when pathkey is an SRF.
1624+
explain (costs off) select unique1 from tenk1 order by unnest('{1,2}'::int[]);
1625+
QUERY PLAN
1626+
-------------------------------------------------------------------------
1627+
Sort
1628+
Sort Key: (unnest('{1,2}'::integer[]))
1629+
-> Gather
1630+
Workers Planned: 2
1631+
-> ProjectSet
1632+
-> Parallel Index Only Scan using tenk1_unique1 on tenk1
1633+
(6 rows)
1634+

‎src/test/regress/sql/incremental_sort.sql

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -267,3 +267,5 @@ from tenk1, lateral (select tenk1.unique1 from generate_series(1, 1000)) as sub;
267267
explain (costs off)selectsub.unique1, stringu1|| random()::text
268268
from tenk1, lateral (selecttenk1.unique1from generate_series(1,1000))as sub
269269
order by1,2;
270+
-- Disallow pushing down sort when pathkey is an SRF.
271+
explain (costs off)select unique1from tenk1order by unnest('{1,2}'::int[]);

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp