/* Rewrite the query. The result could be 0, 1, or many queries. */
query_list = QueryRewrite(query);
- /* Generate plans for queries. Snapshot is already set. */
- plan_list = pg_plan_queries(query_list, 0, NULL, false);
+ /* Generate plans for queries. */
+ plan_list = pg_plan_queries(query_list, 0, NULL);
/*
* Save the results.
/* Need a copyObject here to keep parser from modifying raw tree */
stmt_list = pg_analyze_and_rewrite(copyObject(parsetree),
src, argtypes, nargs);
- stmt_list = pg_plan_queries(stmt_list, cursor_options,
- boundParams, false);
+ stmt_list = pg_plan_queries(stmt_list, cursor_options, boundParams);
plansource = (CachedPlanSource *) palloc0(sizeof(CachedPlanSource));
cplan = (CachedPlan *) palloc0(sizeof(CachedPlan));
/*
* Generate plans for a list of already-rewritten queries.
*
- * If needSnapshot is TRUE, we haven't yet set a snapshot for the current
- * query. A snapshot must be set before invoking the planner, since it
- * might try to evaluate user-defined functions. But we must not set a
- * snapshot if the list contains only utility statements, because some
- * utility statements depend on not having frozen the snapshot yet.
- * (We assume that such statements cannot appear together with plannable
- * statements in the rewriter's output.)
- *
* Normal optimizable statements generate PlannedStmt entries in the result
* list. Utility statements are simply represented by their statement nodes.
*/
List *
-pg_plan_queries(List *querytrees, int cursorOptions, ParamListInfo boundParams,
- bool needSnapshot)
+pg_plan_queries(List *querytrees, int cursorOptions, ParamListInfo boundParams)
{
List *stmt_list = NIL;
ListCell *query_list;
- bool snapshot_set = false;
foreach(query_list, querytrees)
{
}
else
{
- if (needSnapshot && !snapshot_set)
- {
- PushActiveSnapshot(GetTransactionSnapshot());
- snapshot_set = true;
- }
-
- stmt = (Node *) pg_plan_query(query, cursorOptions,
- boundParams);
+ stmt = (Node *) pg_plan_query(query, cursorOptions, boundParams);
}
stmt_list = lappend(stmt_list, stmt);
}
- if (snapshot_set)
- PopActiveSnapshot();
-
return stmt_list;
}
querytree_list = pg_analyze_and_rewrite(parsetree, query_string,
NULL, 0);
- plantree_list = pg_plan_queries(querytree_list, 0, NULL, false);
+ plantree_list = pg_plan_queries(querytree_list, 0, NULL);
/* Done with the snapshot used for parsing/planning */
if (snapshot_set)
}
else
{
- stmt_list = pg_plan_queries(querytree_list, 0, NULL, false);
+ stmt_list = pg_plan_queries(querytree_list, 0, NULL);
fully_planned = true;
}
*/
oldContext = MemoryContextSwitchTo(PortalGetHeapMemory(portal));
query_list = copyObject(cplan->stmt_list);
- plan_list = pg_plan_queries(query_list, 0, params, false);
+ plan_list = pg_plan_queries(query_list, 0, params);
MemoryContextSwitchTo(oldContext);
/* We no longer need the cached plan refcount ... */
extern PlannedStmt *pg_plan_query(Query *querytree, int cursorOptions,
ParamListInfo boundParams);
extern List *pg_plan_queries(List *querytrees, int cursorOptions,
- ParamListInfo boundParams, bool needSnapshot);
+ ParamListInfo boundParams);
extern bool assign_max_stack_depth(int newval, bool doit, GucSource source);