From 9f1ec792b33a2e4fb131d7b2eefbbf17911d4e74 Mon Sep 17 00:00:00 2001 From: Sait Talha Nisanci Date: Wed, 27 May 2020 11:10:48 +0300 Subject: [PATCH] add queryString to distributed_planner distributed_planner now takes query string as a parameter. related commit on PG side: 6aba63ef3e606db71beb596210dd95fa73c44ce2 --- src/backend/distributed/planner/distributed_planner.c | 7 ++++++- src/include/distributed/distributed_planner.h | 9 +++++++-- 2 files changed, 13 insertions(+), 3 deletions(-) diff --git a/src/backend/distributed/planner/distributed_planner.c b/src/backend/distributed/planner/distributed_planner.c index 738b3b37e..4c22b4f19 100644 --- a/src/backend/distributed/planner/distributed_planner.c +++ b/src/backend/distributed/planner/distributed_planner.c @@ -127,7 +127,12 @@ static PlannedStmt * PlanDistributedStmt(DistributedPlanningContext *planContext /* Distributed planner hook */ PlannedStmt * -distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams) +distributed_planner(Query *parse, + #if PG_VERSION_NUM >= PG_VERSION_13 + const char *query_string, + #endif + int cursorOptions, + ParamListInfo boundParams) { bool needsDistributedPlanning = false; bool fastPathRouterQuery = false; diff --git a/src/include/distributed/distributed_planner.h b/src/include/distributed/distributed_planner.h index 581eeb948..9a71b939c 100644 --- a/src/include/distributed/distributed_planner.h +++ b/src/include/distributed/distributed_planner.h @@ -183,8 +183,13 @@ typedef struct CitusCustomScanPath } CitusCustomScanPath; -extern PlannedStmt * distributed_planner(Query *parse, int cursorOptions, - ParamListInfo boundParams); +extern PlannedStmt * distributed_planner( + Query *parse, + #if PG_VERSION_NUM >= PG_VERSION_13 + const char *query_string, + #endif + int cursorOptions, + ParamListInfo boundParams); extern List * ExtractRangeTableEntryList(Query *query); extern List * ExtractReferenceTableRTEList(List *rteList); extern bool NeedsDistributedPlanning(Query *query);