external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add command execution -3

replace_m_row_insert_select
Onder Kalaci 2020-05-08 15:57:04 +02:00
parent acd661b715
commit b8e42ab608
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/backend/distributed/planner/distributed_planner.c
View File

@ -268,6 +268,13 @@ distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams)
* restriction information per table and parse tree transformations made by * restriction information per table and parse tree transformations made by
* postgres' planner. * 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.plan = standard_planner(planContext.query,
planContext.cursorOptions, planContext.cursorOptions,
planContext.boundParams); planContext.boundParams);

2
src/backend/distributed/planner/insert_select_planner.c
View File

@ -322,6 +322,8 @@ DistributedInsertSelectSupported(Query *queryTree, RangeTblEntry *insertRte,
char targetPartitionMethod = PartitionMethod(targetRelationId); char targetPartitionMethod = PartitionMethod(targetRelationId);
ListCell *rangeTableCell = NULL; ListCell *rangeTableCell = NULL;
return false;
/* we only do this check for INSERT ... SELECT queries */ /* we only do this check for INSERT ... SELECT queries */
AssertArg(InsertSelectIntoCitusTable(queryTree)); AssertArg(InsertSelectIntoCitusTable(queryTree));