From 163de79971150980a686c6d2889ed0946ade2ef1 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Fri, 8 May 2020 16:03:09 +0200 Subject: [PATCH] add command execution -3 --- src/backend/distributed/planner/distributed_planner.c | 8 ++++---- src/backend/distributed/planner/insert_select_planner.c | 4 +++- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/src/backend/distributed/planner/distributed_planner.c b/src/backend/distributed/planner/distributed_planner.c index b74117278..585f09b76 100644 --- a/src/backend/distributed/planner/distributed_planner.c +++ b/src/backend/distributed/planner/distributed_planner.c @@ -269,10 +269,10 @@ distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams) * 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)); +// 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, diff --git a/src/backend/distributed/planner/insert_select_planner.c b/src/backend/distributed/planner/insert_select_planner.c index 19310ec77..355835dfb 100644 --- a/src/backend/distributed/planner/insert_select_planner.c +++ b/src/backend/distributed/planner/insert_select_planner.c @@ -322,7 +322,9 @@ DistributedInsertSelectSupported(Query *queryTree, RangeTblEntry *insertRte, char targetPartitionMethod = PartitionMethod(targetRelationId); ListCell *rangeTableCell = NULL; - return false; + return DeferredError(ERRCODE_FEATURE_NOT_SUPPORTED, + "cannot insert into view over distributed table", + NULL, NULL); /* we only do this check for INSERT ... SELECT queries */ AssertArg(InsertSelectIntoCitusTable(queryTree));