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
Appearance settings

Commit 29ef1dd

Browse filesBrowse files
deanrasheeddeanrasheed
committed
Fix handling of self-modified tuples in MERGE.
When an UPDATE or DELETE action in MERGE returns TM_SelfModified, there are 2 possible causes: 1). The target tuple was already updated or deleted by the current command. This can happen if the target row joins to more than one source row, and the SQL standard explicitly says that this must be an error. 2). The target tuple was already updated or deleted by a later command in the current transaction. This can happen if the tuple is modified by a BEFORE trigger or a volatile function used in the query, and should be an error for the same reason that it is in a plain UPDATE or DELETE command. In MERGE's primary error handling block, it failed to check for (2), causing it to return a misleading error message in such cases. In the secondary error handling block, following a concurrent update from another session, it failed to check for (1), causing it to silently ignore target rows joined to more than one source row, instead of reporting an error. Fix this, and add tests for both of these cases. Per report from Wenjiang Zhang. Back-patch to v15, where MERGE was introduced. Discussion: https://postgr.es/m/tencent_41DE0FF443FE14B94A5898D373792109E408%40qq.com
1 parent e444ebc commit 29ef1dd
Copy full SHA for 29ef1dd

File tree

Expand file treeCollapse file tree

5 files changed

+106
-8
lines changed
Filter options
Expand file treeCollapse file tree

5 files changed

+106
-8
lines changed

‎src/backend/executor/nodeModifyTable.c

Copy file name to clipboardExpand all lines: src/backend/executor/nodeModifyTable.c
+38-8Lines changed: 38 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3001,15 +3001,37 @@ ExecMergeMatched(ModifyTableContext *context, ResultRelInfo *resultRelInfo,
30013001
case TM_SelfModified:
30023002

30033003
/*
3004-
* The SQL standard disallows this for MERGE.
3004+
* The target tuple was already updated or deleted by the
3005+
* current command, or by a later command in the current
3006+
* transaction. The former case is explicitly disallowed by
3007+
* the SQL standard for MERGE, which insists that the MERGE
3008+
* join condition should not join a target row to more than
3009+
* one source row.
3010+
*
3011+
* The latter case arises if the tuple is modified by a
3012+
* command in a BEFORE trigger, or perhaps by a command in a
3013+
* volatile function used in the query. In such situations we
3014+
* should not ignore the MERGE action, but it is equally
3015+
* unsafe to proceed. We don't want to discard the original
3016+
* MERGE action while keeping the triggered actions based on
3017+
* it; and it would be no better to allow the original MERGE
3018+
* action while discarding the updates that it triggered. So
3019+
* throwing an error is the only safe course.
30053020
*/
3021+
if (context->tmfd.cmax != estate->es_output_cid)
3022+
ereport(ERROR,
3023+
(errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
3024+
errmsg("tuple to be updated or deleted was already modified by an operation triggered by the current command"),
3025+
errhint("Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
3026+
30063027
if (TransactionIdIsCurrentTransactionId(context->tmfd.xmax))
30073028
ereport(ERROR,
30083029
(errcode(ERRCODE_CARDINALITY_VIOLATION),
30093030
/* translator: %s is a SQL command name */
30103031
errmsg("%s command cannot affect row a second time",
30113032
"MERGE"),
30123033
errhint("Ensure that not more than one source row matches any one target row.")));
3034+
30133035
/* This shouldn't happen */
30143036
elog(ERROR, "attempted to update or delete invisible tuple");
30153037
break;
@@ -3118,19 +3140,27 @@ ExecMergeMatched(ModifyTableContext *context, ResultRelInfo *resultRelInfo,
31183140
/*
31193141
* This can be reached when following an update
31203142
* chain from a tuple updated by another session,
3121-
* reaching a tuple that was already updated in
3122-
* this transaction. If previously modified by
3123-
* this command, ignore the redundant update,
3124-
* otherwise error out.
3125-
*
3126-
* See also response to TM_SelfModified in
3127-
* ExecUpdate().
3143+
* reaching a tuple that was already updated or
3144+
* deleted by the current command, or by a later
3145+
* command in the current transaction. As above,
3146+
* this should always be treated as an error.
31283147
*/
31293148
if (context->tmfd.cmax != estate->es_output_cid)
31303149
ereport(ERROR,
31313150
(errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
31323151
errmsg("tuple to be updated or deleted was already modified by an operation triggered by the current command"),
31333152
errhint("Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
3153+
3154+
if (TransactionIdIsCurrentTransactionId(context->tmfd.xmax))
3155+
ereport(ERROR,
3156+
(errcode(ERRCODE_CARDINALITY_VIOLATION),
3157+
/* translator: %s is a SQL command name */
3158+
errmsg("%s command cannot affect row a second time",
3159+
"MERGE"),
3160+
errhint("Ensure that not more than one source row matches any one target row.")));
3161+
3162+
/* This shouldn't happen */
3163+
elog(ERROR, "attempted to update or delete invisible tuple");
31343164
return false;
31353165

31363166
default:

‎src/test/isolation/expected/merge-update.out

Copy file name to clipboardExpand all lines: src/test/isolation/expected/merge-update.out
+43Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,27 @@ key|val
4848

4949
step c2: COMMIT;
5050

51+
starting permutation: pa_merge1 c1 pa_merge2c_dup a2
52+
step pa_merge1:
53+
MERGE INTO pa_target t
54+
USING (SELECT 1 as key, 'pa_merge1' as val) s
55+
ON s.key = t.key
56+
WHEN NOT MATCHED THEN
57+
INSERT VALUES (s.key, s.val)
58+
WHEN MATCHED THEN
59+
UPDATE set val = t.val || ' updated by ' || s.val;
60+
61+
step c1: COMMIT;
62+
step pa_merge2c_dup:
63+
MERGE INTO pa_target t
64+
USING (VALUES (1), (1)) v(a)
65+
ON t.key = v.a
66+
WHEN MATCHED THEN
67+
UPDATE set val = t.val || ' updated by pa_merge2c_dup'; -- should fail
68+
69+
ERROR: MERGE command cannot affect row a second time
70+
step a2: ABORT;
71+
5172
starting permutation: merge1 merge2a c1 select2 c2
5273
step merge1:
5374
MERGE INTO target t
@@ -312,3 +333,25 @@ key|val
312333
(2 rows)
313334

314335
step c2: COMMIT;
336+
337+
starting permutation: pa_merge1 pa_merge2c_dup c1 a2
338+
step pa_merge1:
339+
MERGE INTO pa_target t
340+
USING (SELECT 1 as key, 'pa_merge1' as val) s
341+
ON s.key = t.key
342+
WHEN NOT MATCHED THEN
343+
INSERT VALUES (s.key, s.val)
344+
WHEN MATCHED THEN
345+
UPDATE set val = t.val || ' updated by ' || s.val;
346+
347+
step pa_merge2c_dup:
348+
MERGE INTO pa_target t
349+
USING (VALUES (1), (1)) v(a)
350+
ON t.key = v.a
351+
WHEN MATCHED THEN
352+
UPDATE set val = t.val || ' updated by pa_merge2c_dup'; -- should fail
353+
<waiting ...>
354+
step c1: COMMIT;
355+
step pa_merge2c_dup: <... completed>
356+
ERROR: MERGE command cannot affect row a second time
357+
step a2: ABORT;

‎src/test/isolation/specs/merge-update.spec

Copy file name to clipboardExpand all lines: src/test/isolation/specs/merge-update.spec
+13Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
# 1. UPDATEs of PKs that change the join in the ON clause
55
# 2. UPDATEs with WHEN conditions that would fail after concurrent update
66
# 3. UPDATEs with extra ON conditions that would fail after concurrent update
7+
# 4. UPDATEs with duplicate source rows
78

89
setup
910
{
@@ -134,15 +135,26 @@ step "pa_merge2b_when"
134135
WHEN MATCHED AND t.val like 'initial%' THEN
135136
UPDATE set key = t.key + 1, val = t.val || ' updated by ' || s.val;
136137
}
138+
# Duplicate source row should fail
139+
step "pa_merge2c_dup"
140+
{
141+
MERGE INTO pa_target t
142+
USING (VALUES (1), (1)) v(a)
143+
ON t.key = v.a
144+
WHEN MATCHED THEN
145+
UPDATE set val = t.val || ' updated by pa_merge2c_dup'; -- should fail
146+
}
137147
step "select2" { SELECT * FROM target; }
138148
step "pa_select2" { SELECT * FROM pa_target; }
139149
step "c2" { COMMIT; }
150+
step "a2" { ABORT; }
140151

141152
# Basic effects
142153
permutation "merge1" "c1" "select2" "c2"
143154

144155
# One after the other, no concurrency
145156
permutation "merge1" "c1" "merge2a" "select2" "c2"
157+
permutation "pa_merge1" "c1" "pa_merge2c_dup" "a2"
146158

147159
# Now with concurrency
148160
permutation "merge1" "merge2a" "c1" "select2" "c2"
@@ -154,3 +166,4 @@ permutation "pa_merge2" "pa_merge2a" "c1" "pa_select2" "c2" # fails
154166
permutation "pa_merge2" "c1" "pa_merge2a" "pa_select2" "c2" # succeeds
155167
permutation "pa_merge3" "pa_merge2b_when" "c1" "pa_select2" "c2" # WHEN not satisfied by updated tuple
156168
permutation "pa_merge1" "pa_merge2b_when" "c1" "pa_select2" "c2" # WHEN satisfied by updated tuple
169+
permutation "pa_merge1" "pa_merge2c_dup" "c1" "a2"

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

Copy file name to clipboardExpand all lines: src/test/regress/expected/triggers.out
+8Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1745,6 +1745,10 @@ select * from parent; select * from child;
17451745
update parent set val1 = 'b' where aid = 1; -- should fail
17461746
ERROR: tuple to be updated was already modified by an operation triggered by the current command
17471747
HINT: Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.
1748+
merge into parent p using (values (1)) as v(id) on p.aid = v.id
1749+
when matched then update set val1 = 'b'; -- should fail
1750+
ERROR: tuple to be updated or deleted was already modified by an operation triggered by the current command
1751+
HINT: Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.
17481752
select * from parent; select * from child;
17491753
aid | val1 | val2 | val3 | val4 | bcnt
17501754
-----+------+------+------+------+------
@@ -1759,6 +1763,10 @@ select * from parent; select * from child;
17591763
delete from parent where aid = 1; -- should fail
17601764
ERROR: tuple to be deleted was already modified by an operation triggered by the current command
17611765
HINT: Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.
1766+
merge into parent p using (values (1)) as v(id) on p.aid = v.id
1767+
when matched then delete; -- should fail
1768+
ERROR: tuple to be updated or deleted was already modified by an operation triggered by the current command
1769+
HINT: Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.
17621770
select * from parent; select * from child;
17631771
aid | val1 | val2 | val3 | val4 | bcnt
17641772
-----+------+------+------+------+------

‎src/test/regress/sql/triggers.sql

Copy file name to clipboardExpand all lines: src/test/regress/sql/triggers.sql
+4Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1186,9 +1186,13 @@ insert into child values (10, 1, 'b');
11861186
select * from parent; select * from child;
11871187

11881188
update parent set val1 = 'b' where aid = 1; -- should fail
1189+
merge into parent p using (values (1)) as v(id) on p.aid = v.id
1190+
when matched then update set val1 = 'b'; -- should fail
11891191
select * from parent; select * from child;
11901192

11911193
delete from parent where aid = 1; -- should fail
1194+
merge into parent p using (values (1)) as v(id) on p.aid = v.id
1195+
when matched then delete; -- should fail
11921196
select * from parent; select * from child;
11931197

11941198
-- replace the trigger function with one that restarts the deletion after

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.