From 1353a4b7e7d08b13cbaa85a5f9ae26819b5cf2c8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fr=C3=A9d=C3=A9ric=20Yhuel?= Date: Sun, 6 Feb 2022 13:31:55 +0100 Subject: [PATCH] Allow parallel plan for referential integrity checks --- src/backend/utils/adt/ri_triggers.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/backend/utils/adt/ri_triggers.c b/src/backend/utils/adt/ri_triggers.c index 96269fc2ad..84c16b6962 100644 --- a/src/backend/utils/adt/ri_triggers.c +++ b/src/backend/utils/adt/ri_triggers.c @@ -1317,6 +1317,7 @@ RI_Initial_Check(Trigger *trigger, Relation fk_rel, Relation pk_rel) char workmembuf[32]; int spi_result; SPIPlanPtr qplan; + SPIPrepareOptions options; riinfo = ri_FetchConstraintInfo(trigger, fk_rel, false); @@ -1483,10 +1484,12 @@ RI_Initial_Check(Trigger *trigger, Relation fk_rel, Relation pk_rel) * Generate the plan. We don't need to cache it, and there are no * arguments to the plan. */ - qplan = SPI_prepare(querybuf.data, 0, NULL); + memset(&options, 0, sizeof(options)); + options.cursorOptions = CURSOR_OPT_PARALLEL_OK; + qplan = SPI_prepare_extended(querybuf.data, &options); if (qplan == NULL) - elog(ERROR, "SPI_prepare returned %s for %s", + elog(ERROR, "SPI_prepare_extended returned %s for %s", SPI_result_code_string(SPI_result), querybuf.data); /* -- 2.30.2