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

Commitd16d453

Browse files
committed
Postpone aggregate checks until after collation is assigned.
Previously, parseCheckAggregates was run beforeassign_query_collations, but this causes problems if any expressionhas already had a collation assigned by some transform function (e.g.transformCaseExpr) before parseCheckAggregates runs. The differingcollations would cause expressions not to be recognized as equal tothe ones in the GROUP BY clause, leading to spurious errors aboutunaggregated column references.The result was that CASE expr WHEN val ... would fail when "expr"contained a GROUPING() expression or matched one of the group byexpressions, and where collatable types were involved; whereas thesupposedly identical CASE WHEN expr = val ... would succeed.Backpatch all the way; this appears to have been wrong ever sincecollations were introduced.Per report from Guillaume Lelarge, analysis and patch by me.Discussion:https://postgr.es/m/CAECtzeVSO_US8C2Khgfv54ZMUOBR4sWq+6_bLrETnWExHT=rFg@mail.gmail.comDiscussion:https://postgr.es/m/87muo0k0c7.fsf@news-spur.riddles.org.uk
1 parent2472ea0 commitd16d453

File tree

5 files changed

+75
-6
lines changed

5 files changed

+75
-6
lines changed

‎src/backend/parser/analyze.c

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -451,11 +451,13 @@ transformDeleteStmt(ParseState *pstate, DeleteStmt *stmt)
451451
qry->hasWindowFuncs=pstate->p_hasWindowFuncs;
452452
qry->hasTargetSRFs=pstate->p_hasTargetSRFs;
453453
qry->hasAggs=pstate->p_hasAggs;
454-
if (pstate->p_hasAggs)
455-
parseCheckAggregates(pstate,qry);
456454

457455
assign_query_collations(pstate,qry);
458456

457+
/* this must be done after collations, for reliable comparison of exprs */
458+
if (pstate->p_hasAggs)
459+
parseCheckAggregates(pstate,qry);
460+
459461
returnqry;
460462
}
461463

@@ -1319,8 +1321,6 @@ transformSelectStmt(ParseState *pstate, SelectStmt *stmt)
13191321
qry->hasWindowFuncs=pstate->p_hasWindowFuncs;
13201322
qry->hasTargetSRFs=pstate->p_hasTargetSRFs;
13211323
qry->hasAggs=pstate->p_hasAggs;
1322-
if (pstate->p_hasAggs||qry->groupClause||qry->groupingSets||qry->havingQual)
1323-
parseCheckAggregates(pstate,qry);
13241324

13251325
foreach(l,stmt->lockingClause)
13261326
{
@@ -1330,6 +1330,10 @@ transformSelectStmt(ParseState *pstate, SelectStmt *stmt)
13301330

13311331
assign_query_collations(pstate,qry);
13321332

1333+
/* this must be done after collations, for reliable comparison of exprs */
1334+
if (pstate->p_hasAggs||qry->groupClause||qry->groupingSets||qry->havingQual)
1335+
parseCheckAggregates(pstate,qry);
1336+
13331337
returnqry;
13341338
}
13351339

@@ -1791,8 +1795,6 @@ transformSetOperationStmt(ParseState *pstate, SelectStmt *stmt)
17911795
qry->hasWindowFuncs=pstate->p_hasWindowFuncs;
17921796
qry->hasTargetSRFs=pstate->p_hasTargetSRFs;
17931797
qry->hasAggs=pstate->p_hasAggs;
1794-
if (pstate->p_hasAggs||qry->groupClause||qry->groupingSets||qry->havingQual)
1795-
parseCheckAggregates(pstate,qry);
17961798

17971799
foreach(l,lockingClause)
17981800
{
@@ -1802,6 +1804,10 @@ transformSetOperationStmt(ParseState *pstate, SelectStmt *stmt)
18021804

18031805
assign_query_collations(pstate,qry);
18041806

1807+
/* this must be done after collations, for reliable comparison of exprs */
1808+
if (pstate->p_hasAggs||qry->groupClause||qry->groupingSets||qry->havingQual)
1809+
parseCheckAggregates(pstate,qry);
1810+
18051811
returnqry;
18061812
}
18071813

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

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2244,3 +2244,22 @@ SELECT min(x ORDER BY y) FROM (VALUES(1, 2)) AS d(x,y);
22442244
1
22452245
(1 row)
22462246

2247+
-- check collation-sensitive matching between grouping expressions
2248+
select v||'a', case v||'a' when 'aa' then 1 else 0 end, count(*)
2249+
from unnest(array['a','b']) u(v)
2250+
group by v||'a' order by 1;
2251+
?column? | case | count
2252+
----------+------+-------
2253+
aa | 1 | 1
2254+
ba | 0 | 1
2255+
(2 rows)
2256+
2257+
select v||'a', case when v||'a' = 'aa' then 1 else 0 end, count(*)
2258+
from unnest(array['a','b']) u(v)
2259+
group by v||'a' order by 1;
2260+
?column? | case | count
2261+
----------+------+-------
2262+
aa | 1 | 1
2263+
ba | 0 | 1
2264+
(2 rows)
2265+

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

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1540,4 +1540,29 @@ explain (costs off)
15401540
-> Seq Scan on tenk1
15411541
(12 rows)
15421542

1543+
-- check collation-sensitive matching between grouping expressions
1544+
-- (similar to a check for aggregates, but there are additional code
1545+
-- paths for GROUPING, so check again here)
1546+
select v||'a', case grouping(v||'a') when 1 then 1 else 0 end, count(*)
1547+
from unnest(array[1,1], array['a','b']) u(i,v)
1548+
group by rollup(i, v||'a') order by 1,3;
1549+
?column? | case | count
1550+
----------+------+-------
1551+
aa | 0 | 1
1552+
ba | 0 | 1
1553+
| 1 | 2
1554+
| 1 | 2
1555+
(4 rows)
1556+
1557+
select v||'a', case when grouping(v||'a') = 1 then 1 else 0 end, count(*)
1558+
from unnest(array[1,1], array['a','b']) u(i,v)
1559+
group by rollup(i, v||'a') order by 1,3;
1560+
?column? | case | count
1561+
----------+------+-------
1562+
aa | 0 | 1
1563+
ba | 0 | 1
1564+
| 1 | 2
1565+
| 1 | 2
1566+
(4 rows)
1567+
15431568
-- end

‎src/test/regress/sql/aggregates.sql

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -976,3 +976,11 @@ SELECT dense_rank(x) WITHIN GROUP (ORDER BY x) FROM (VALUES (1),(1),(2),(2),(3),
976976
-- 2a505161-2727-2473-7c46-591ed108ac52@email.cz
977977
SELECTmin(xORDER BY y)FROM (VALUES(1,NULL))AS d(x,y);
978978
SELECTmin(xORDER BY y)FROM (VALUES(1,2))AS d(x,y);
979+
980+
-- check collation-sensitive matching between grouping expressions
981+
select v||'a', case v||'a' when'aa' then1 else0 end,count(*)
982+
from unnest(array['a','b']) u(v)
983+
group by v||'a'order by1;
984+
select v||'a', case when v||'a'='aa' then1 else0 end,count(*)
985+
from unnest(array['a','b']) u(v)
986+
group by v||'a'order by1;

‎src/test/regress/sql/groupingsets.sql

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -415,4 +415,15 @@ explain (costs off)
415415
count(*)
416416
from tenk1group by grouping sets (unique1,twothousand,thousand,hundred,ten,four,two);
417417

418+
-- check collation-sensitive matching between grouping expressions
419+
-- (similar to a check for aggregates, but there are additional code
420+
-- paths for GROUPING, so check again here)
421+
422+
select v||'a', case grouping(v||'a') when1 then1 else0 end,count(*)
423+
from unnest(array[1,1], array['a','b']) u(i,v)
424+
group by rollup(i, v||'a')order by1,3;
425+
select v||'a', case when grouping(v||'a')=1 then1 else0 end,count(*)
426+
from unnest(array[1,1], array['a','b']) u(i,v)
427+
group by rollup(i, v||'a')order by1,3;
428+
418429
-- end

0 commit comments

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