rdelaage
/
postgresql
mirror of https://git.postgresql.org/git/postgresql.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove faulty support for MergeAppend plan with WHERE CURRENT OF. 

Somebody extended search_plan_tree() to treat MergeAppend exactly
like Append, which is 100% wrong, because unlike Append we can't
assume that only one input node is actively returning tuples.
Hence a cursor using a MergeAppend across a UNION ALL or inheritance
tree could falsely match a WHERE CURRENT OF query at a row that
isn't actually the cursor's current output row, but coincidentally
has the same TID (in a different table) as the current output row.

Delete the faulty code; this means that such a case will now return
an error like 'cursor "foo" is not a simply updatable scan of table
"bar"', instead of silently misbehaving.  Users should not find that
surprising though, as the same cursor query could have failed that way
already depending on the chosen plan.  (It would fail like that if the
sort were done with an explicit Sort node instead of MergeAppend.)

Expand the clearly-inadequate commentary to be more explicit about
what this code is doing, in hopes of forestalling future mistakes.

It's been like this for awhile, so back-patch to all supported
branches.

Discussion: https://postgr.es/m/482865.1611075182@sss.pgh.pa.us
This commit is contained in:
Tom Lane 2021-01-19 13:25:33 -05:00
parent f18aa1b203
commit a0efda88a6
1 changed files with 27 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
src/backend/executor/execCurrent.c
View File

@ -299,6 +299,10 @@ fetch_cursor_param_value(ExprContext *econtext, int paramId)
* Search through a PlanState tree for a scan node on the specified table.
* Return NULL if not found or multiple candidates.
*
* CAUTION: this function is not charged simply with finding some candidate
* scan, but with ensuring that that scan returned the plan tree's current
* output row. That's why we must reject multiple-match cases.
*
* If a candidate is found, set *pending_rescan to true if that candidate
* or any node above it has a pending rescan action, i.e. chgParam != NULL.
* That indicates that we shouldn't consider the node to be positioned on a
@ -317,7 +321,9 @@ search_plan_tree(PlanState *node, Oid table_oid,
switch (nodeTag(node))
{
/*
* Relation scan nodes can all be treated alike. Note that
* Relation scan nodes can all be treated alike: check to see if
* they are scanning the specified table.
*
* ForeignScan and CustomScan might not have a currentRelation, in
* which case we just ignore them. (We dare not descend to any
* child plan nodes they might have, since we do not know the
@ -342,8 +348,26 @@ search_plan_tree(PlanState *node, Oid table_oid,
}
/*
* For Append, we must look through the members; watch out for
* multiple matches (possible if it was from UNION ALL)
* For Append, we can check each input node. It is safe to
* descend to the inputs because only the input that resulted in
* the Append's current output node could be positioned on a tuple
* at all; the other inputs are either at EOF or not yet started.
* Hence, if the desired table is scanned by some
* currently-inactive input node, we will find that node but then
* our caller will realize that it didn't emit the tuple of
* interest.
*
* We do need to watch out for multiple matches (possible if
* Append was from UNION ALL rather than an inheritance tree).
*
* Note: we can NOT descend through MergeAppend similarly, since
* its inputs are likely all active, and we don't know which one
* returned the current output tuple. (Perhaps that could be
* fixed if we were to let this code know more about MergeAppend's
* internal state, but it does not seem worth the trouble. Users
* should not expect plans for ORDER BY queries to be considered
* simply-updatable, since they won't be if the sorting is
* implemented by a Sort node.)
*/
case T_AppendState:
{
@ -365,29 +389,6 @@ search_plan_tree(PlanState *node, Oid table_oid,
break;
}
/*
* Similarly for MergeAppend
*/
case T_MergeAppendState:
{
MergeAppendState *mstate = (MergeAppendState *) node;
int i;
for (i = 0; i < mstate->ms_nplans; i++)
{
ScanState *elem = search_plan_tree(mstate->mergeplans[i],
table_oid,
pending_rescan);
if (!elem)
continue;
if (result)
return NULL; /* multiple matches */
result = elem;
}
break;
}
/*
* Result and Limit can be descended through (these are safe
* because they always return their input's current row)