add command execution -3

replace_m_row_insert_select
Onder Kalaci 2020-05-08 16:23:51 +02:00
parent 163de79971
commit 4395ffea96
1 changed files with 1 additions and 5 deletions

View File

@ -225,6 +225,7 @@ distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams)
planContext.convertedQuery = ConvertToInsertSelect(parse); planContext.convertedQuery = ConvertToInsertSelect(parse);
planContext.originalQuery = GetSingleValue(planContext.convertedQuery); planContext.originalQuery = GetSingleValue(planContext.convertedQuery);
planContext.query = planContext.originalQuery;
} }
else else
{ {
@ -269,11 +270,6 @@ distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams)
* 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,