mirror of
https://github.com/postgres/postgres.git
synced 2025-04-21 12:05:57 +03:00
In postgres_fdw, don't try to ship MULTIEXPR updates to remote server.
In a statement like "UPDATE remote_tab SET (x,y) = (SELECT ...)", we'd conclude that the statement could be directly executed remotely, because the sub-SELECT is in a resjunk tlist item that's not examined for shippability. Currently that ends up crashing if the sub-SELECT contains any remote Vars. Prevent the crash by deeming MULTIEXEC Params to be unshippable. This is a bit of a brute-force solution, since if the sub-SELECT *doesn't* contain any remote Vars, the current execution technology would work; but that's not a terribly common use-case for this syntax, I think. In any case, we generally don't try to ship sub-SELECTs, so it won't surprise anybody that this doesn't end up as a remote direct update. I'd be inclined to see if that general limitation can be fixed before worrying about this case further. Per report from Lukáš Sobotka. Back-patch to 9.6. 9.5 had MULTIEXPR, but we didn't try to perform remote direct updates then, so the case didn't arise anyway. Discussion: https://postgr.es/m/CAJif3k+iA_ekBB5Zw2hDBaE1wtiQa4LH4_JUXrrMGwTrH0J01Q@mail.gmail.com
This commit is contained in:
parent
b9a9cb1bfd
commit
603e03b4c9
@ -387,6 +387,22 @@ foreign_expr_walker(Node *node,
|
|||||||
{
|
{
|
||||||
Param *p = (Param *) node;
|
Param *p = (Param *) node;
|
||||||
|
|
||||||
|
/*
|
||||||
|
* If it's a MULTIEXPR Param, punt. We can't tell from here
|
||||||
|
* whether the referenced sublink/subplan contains any remote
|
||||||
|
* Vars; if it does, handling that is too complicated to
|
||||||
|
* consider supporting at present. Fortunately, MULTIEXPR
|
||||||
|
* Params are not reduced to plain PARAM_EXEC until the end of
|
||||||
|
* planning, so we can easily detect this case. (Normal
|
||||||
|
* PARAM_EXEC Params are safe to ship because their values
|
||||||
|
* come from somewhere else in the plan tree; but a MULTIEXPR
|
||||||
|
* references a sub-select elsewhere in the same targetlist,
|
||||||
|
* so we'd be on the hook to evaluate it somehow if we wanted
|
||||||
|
* to handle such cases as direct foreign updates.)
|
||||||
|
*/
|
||||||
|
if (p->paramkind == PARAM_MULTIEXPR)
|
||||||
|
return false;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Collation rule is same as for Consts and non-foreign Vars.
|
* Collation rule is same as for Consts and non-foreign Vars.
|
||||||
*/
|
*/
|
||||||
|
@ -5535,6 +5535,37 @@ DELETE FROM ft2 WHERE c1 = 9999 RETURNING tableoid::regclass;
|
|||||||
ft2
|
ft2
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
|
-- Test UPDATE with a MULTIEXPR sub-select
|
||||||
|
-- (maybe someday this'll be remotely executable, but not today)
|
||||||
|
EXPLAIN (verbose, costs off)
|
||||||
|
UPDATE ft2 AS target SET (c2, c7) = (
|
||||||
|
SELECT c2 * 10, c7
|
||||||
|
FROM ft2 AS src
|
||||||
|
WHERE target.c1 = src.c1
|
||||||
|
) WHERE c1 > 1100;
|
||||||
|
QUERY PLAN
|
||||||
|
---------------------------------------------------------------------------------------------------------------------------------------------------
|
||||||
|
Update on public.ft2 target
|
||||||
|
Remote SQL: UPDATE "S 1"."T 1" SET c2 = $2, c7 = $3 WHERE ctid = $1
|
||||||
|
-> Foreign Scan on public.ft2 target
|
||||||
|
Output: target.c1, $1, NULL::integer, target.c3, target.c4, target.c5, target.c6, $2, target.c8, (SubPlan 1 (returns $1,$2)), target.ctid
|
||||||
|
Remote SQL: SELECT "C 1", c3, c4, c5, c6, c8, ctid FROM "S 1"."T 1" WHERE (("C 1" > 1100)) FOR UPDATE
|
||||||
|
SubPlan 1 (returns $1,$2)
|
||||||
|
-> Foreign Scan on public.ft2 src
|
||||||
|
Output: (src.c2 * 10), src.c7
|
||||||
|
Remote SQL: SELECT c2, c7 FROM "S 1"."T 1" WHERE (($1::integer = "C 1"))
|
||||||
|
(9 rows)
|
||||||
|
|
||||||
|
UPDATE ft2 AS target SET (c2, c7) = (
|
||||||
|
SELECT c2 * 10, c7
|
||||||
|
FROM ft2 AS src
|
||||||
|
WHERE target.c1 = src.c1
|
||||||
|
) WHERE c1 > 1100;
|
||||||
|
UPDATE ft2 AS target SET (c2) = (
|
||||||
|
SELECT c2 / 10
|
||||||
|
FROM ft2 AS src
|
||||||
|
WHERE target.c1 = src.c1
|
||||||
|
) WHERE c1 > 1100;
|
||||||
-- Test that trigger on remote table works as expected
|
-- Test that trigger on remote table works as expected
|
||||||
CREATE OR REPLACE FUNCTION "S 1".F_BRTRIG() RETURNS trigger AS $$
|
CREATE OR REPLACE FUNCTION "S 1".F_BRTRIG() RETURNS trigger AS $$
|
||||||
BEGIN
|
BEGIN
|
||||||
|
@ -1138,6 +1138,26 @@ EXPLAIN (verbose, costs off)
|
|||||||
DELETE FROM ft2 WHERE c1 = 9999 RETURNING tableoid::regclass; -- can be pushed down
|
DELETE FROM ft2 WHERE c1 = 9999 RETURNING tableoid::regclass; -- can be pushed down
|
||||||
DELETE FROM ft2 WHERE c1 = 9999 RETURNING tableoid::regclass;
|
DELETE FROM ft2 WHERE c1 = 9999 RETURNING tableoid::regclass;
|
||||||
|
|
||||||
|
-- Test UPDATE with a MULTIEXPR sub-select
|
||||||
|
-- (maybe someday this'll be remotely executable, but not today)
|
||||||
|
EXPLAIN (verbose, costs off)
|
||||||
|
UPDATE ft2 AS target SET (c2, c7) = (
|
||||||
|
SELECT c2 * 10, c7
|
||||||
|
FROM ft2 AS src
|
||||||
|
WHERE target.c1 = src.c1
|
||||||
|
) WHERE c1 > 1100;
|
||||||
|
UPDATE ft2 AS target SET (c2, c7) = (
|
||||||
|
SELECT c2 * 10, c7
|
||||||
|
FROM ft2 AS src
|
||||||
|
WHERE target.c1 = src.c1
|
||||||
|
) WHERE c1 > 1100;
|
||||||
|
|
||||||
|
UPDATE ft2 AS target SET (c2) = (
|
||||||
|
SELECT c2 / 10
|
||||||
|
FROM ft2 AS src
|
||||||
|
WHERE target.c1 = src.c1
|
||||||
|
) WHERE c1 > 1100;
|
||||||
|
|
||||||
-- Test that trigger on remote table works as expected
|
-- Test that trigger on remote table works as expected
|
||||||
CREATE OR REPLACE FUNCTION "S 1".F_BRTRIG() RETURNS trigger AS $$
|
CREATE OR REPLACE FUNCTION "S 1".F_BRTRIG() RETURNS trigger AS $$
|
||||||
BEGIN
|
BEGIN
|
||||||
|
Loading…
x
Reference in New Issue
Block a user