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

Commitae69c4f

Browse files
committed
Fix use of incorrect TupleTableSlot in DISTINCT aggregates
1349d27 added code to allow DISTINCT and ORDER BY aggregates to workmore efficiently by using presorted input. That commit added some codethat made use of the AggState's tmpcontext and adjusted theecxt_outertuple and ecxt_innertuple slots before checking if the currentrow is distinct from the previously seen row. That code forgot to set theTupleTableSlots back to what they were originally, which could result inerrors such as:ERROR: attribute 1 of type record has wrong typeThis only affects aggregate functions which have multiple arguments whenDISTINCT is used. For example: string_agg(DISTINCT col, ', ')Thanks to Tom Lane for identifying the breaking commit.Bug: #18264Reported-by: Vojtěch BenešDiscussion:https://postgr.es/m/18264-e363593d7e9feb7d@postgresql.orgBackpatch-through: 16, where1349d27 was added
1 parent007693f commitae69c4f

File tree

3 files changed

+39
-3
lines changed

3 files changed

+39
-3
lines changed

‎src/backend/executor/execExprInterp.c

Lines changed: 17 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4579,12 +4579,16 @@ ExecEvalPreOrderedDistinctSingle(AggState *aggstate, AggStatePerTrans pertrans)
45794579
/*
45804580
* ExecEvalPreOrderedDistinctMulti
45814581
*Returns true when the aggregate input is distinct from the previous
4582-
*input and returns false when the input matches the previous input.
4582+
*input and returns false when the input matches the previous input, or
4583+
*when there was no previous input.
45834584
*/
45844585
bool
45854586
ExecEvalPreOrderedDistinctMulti(AggState*aggstate,AggStatePerTranspertrans)
45864587
{
45874588
ExprContext*tmpcontext=aggstate->tmpcontext;
4589+
boolisdistinct= false;/* for now */
4590+
TupleTableSlot*save_outer;
4591+
TupleTableSlot*save_inner;
45884592

45894593
for (inti=0;i<pertrans->numTransInputs;i++)
45904594
{
@@ -4596,6 +4600,10 @@ ExecEvalPreOrderedDistinctMulti(AggState *aggstate, AggStatePerTrans pertrans)
45964600
pertrans->sortslot->tts_nvalid=pertrans->numInputs;
45974601
ExecStoreVirtualTuple(pertrans->sortslot);
45984602

4603+
/* save the previous slots before we overwrite them */
4604+
save_outer=tmpcontext->ecxt_outertuple;
4605+
save_inner=tmpcontext->ecxt_innertuple;
4606+
45994607
tmpcontext->ecxt_outertuple=pertrans->sortslot;
46004608
tmpcontext->ecxt_innertuple=pertrans->uniqslot;
46014609

@@ -4607,9 +4615,15 @@ ExecEvalPreOrderedDistinctMulti(AggState *aggstate, AggStatePerTrans pertrans)
46074615

46084616
pertrans->haslast= true;
46094617
ExecCopySlot(pertrans->uniqslot,pertrans->sortslot);
4610-
return true;
4618+
4619+
isdistinct= true;
46114620
}
4612-
return false;
4621+
4622+
/* restore the original slots */
4623+
tmpcontext->ecxt_outertuple=save_outer;
4624+
tmpcontext->ecxt_innertuple=save_inner;
4625+
4626+
returnisdistinct;
46134627
}
46144628

46154629
/*

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

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1694,6 +1694,19 @@ select aggfns(distinct a,b,c order by a,c using ~<~,b)
16941694
{"(0,,)","(1,3,foo)","(2,2,bar)","(3,1,baz)"}
16951695
(1 row)
16961696

1697+
-- test a more complex permutation that has previous caused issues
1698+
select
1699+
string_agg(distinct 'a', ','),
1700+
sum((
1701+
select sum(1)
1702+
from (values(1)) b(id)
1703+
where a.id = b.id
1704+
)) from unnest(array[1]) a(id);
1705+
string_agg | sum
1706+
------------+-----
1707+
a | 1
1708+
(1 row)
1709+
16971710
-- check node I/O via view creation and usage, also deparsing logic
16981711
create view agg_view1 as
16991712
select aggfns(a,b,c)

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

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -643,6 +643,15 @@ select aggfns(distinct a,b,c order by a,c using ~<~,b)
643643
from (values (1,3,'foo'),(0,null,null),(2,2,'bar'),(3,1,'baz')) v(a,b,c),
644644
generate_series(1,2) i;
645645

646+
-- test a more complex permutation that has previous caused issues
647+
select
648+
string_agg(distinct'a',','),
649+
sum((
650+
selectsum(1)
651+
from (values(1)) b(id)
652+
wherea.id=b.id
653+
))from unnest(array[1]) a(id);
654+
646655
-- check node I/O via view creation and usage, also deparsing logic
647656

648657
createviewagg_view1as

0 commit comments

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