From b8e42ab608a3b59befc2c351e49ddc0974c1c192 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Fri, 8 May 2020 15:57:04 +0200 Subject: [PATCH] add command execution -3 --- src/backend/distributed/planner/distributed_planner.c | 7 +++++++ src/backend/distributed/planner/insert_select_planner.c | 2 ++ 2 files changed, 9 insertions(+) diff --git a/src/backend/distributed/planner/distributed_planner.c b/src/backend/distributed/planner/distributed_planner.c index 9d45d2008..b74117278 100644 --- a/src/backend/distributed/planner/distributed_planner.c +++ b/src/backend/distributed/planner/distributed_planner.c @@ -268,6 +268,13 @@ distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams) * restriction information per table and parse tree transformations made by * postgres' planner. */ + + RangeTblEntry *subqueryRte = ExtractSelectRangeTableEntry(planContext.originalQuery); + subqueryRte = linitial(subqueryRte->subquery->rtable); + RangeTblEntry *valuesRte = linitial(subqueryRte->subquery->rtable); + elog(INFO, "valuesRte: %d len: %d",valuesRte->rtekind, list_length(valuesRte->values_lists)); + + planContext.plan = standard_planner(planContext.query, planContext.cursorOptions, planContext.boundParams); diff --git a/src/backend/distributed/planner/insert_select_planner.c b/src/backend/distributed/planner/insert_select_planner.c index 153e0cba3..19310ec77 100644 --- a/src/backend/distributed/planner/insert_select_planner.c +++ b/src/backend/distributed/planner/insert_select_planner.c @@ -322,6 +322,8 @@ DistributedInsertSelectSupported(Query *queryTree, RangeTblEntry *insertRte, char targetPartitionMethod = PartitionMethod(targetRelationId); ListCell *rangeTableCell = NULL; + return false; + /* we only do this check for INSERT ... SELECT queries */ AssertArg(InsertSelectIntoCitusTable(queryTree));