*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/executor/functions.c,v 1.31 2000/01/26 05:56:22 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/executor/functions.c,v 1.32 2000/04/04 21:44:39 tgl Exp $
*
*-------------------------------------------------------------------------
*/
execution_state *nextes;
execution_state *preves;
List *queryTree_list,
- *planTree_list,
*qtl_item;
int nargs = fcache->nargs;
nextes = newes;
preves = (execution_state *) NULL;
- planTree_list = pg_parse_and_plan(fcache->src, fcache->argOidVect,
- nargs, &queryTree_list, None, FALSE);
+ queryTree_list = pg_parse_and_rewrite(fcache->src, fcache->argOidVect,
+ nargs, FALSE);
foreach(qtl_item, queryTree_list)
{
Query *queryTree = lfirst(qtl_item);
- Plan *planTree = lfirst(planTree_list);
+ Plan *planTree;
EState *estate;
+ planTree = pg_plan_query(queryTree);
+
if (!nextes)
nextes = (execution_state *) palloc(sizeof(execution_state));
if (preves)
nextes->estate = estate;
preves = nextes;
nextes = (execution_state *) NULL;
-
- planTree_list = lnext(planTree_list);
}
return newes;
static TupleDesc
postquel_start(execution_state *es)
{
-#ifdef FUNC_UTIL_PATCH
-
/*
* Do nothing for utility commands. (create, destroy...) DZ -
* 30-8-1996
*/
if (es->qd->operation == CMD_UTILITY)
return (TupleDesc) NULL;
-#endif
return ExecutorStart(es->qd, es->estate);
}
{
int feature;
-#ifdef FUNC_UTIL_PATCH
if (es->qd->operation == CMD_UTILITY)
{
-
/*
- * Process an utility command. (create, destroy...) DZ -
+ * Process a utility command. (create, destroy...) DZ -
* 30-8-1996
*/
ProcessUtility(es->qd->parsetree->utilityStmt, es->qd->dest);
CommandCounterIncrement();
return (TupleTableSlot *) NULL;
}
-#endif
feature = (LAST_POSTQUEL_COMMAND(es)) ? EXEC_RETONE : EXEC_RUN;
static void
postquel_end(execution_state *es)
{
-#ifdef FUNC_UTIL_PATCH
-
/*
* Do nothing for utility commands. (create, destroy...) DZ -
* 30-8-1996
*/
if (es->qd->operation == CMD_UTILITY)
return;
-#endif
ExecutorEnd(es->qd, es->estate);
}
* spi.c
* Server Programming Interface
*
- * $Id: spi.c,v 1.44 1999/12/16 22:19:44 wieck Exp $
+ * $Id: spi.c,v 1.45 2000/04/04 21:44:39 tgl Exp $
*
*-------------------------------------------------------------------------
*/
List *queryTree_list;
List *planTree_list;
List *queryTree_list_item;
- List *ptlist;
QueryDesc *qdesc;
Query *queryTree;
Plan *planTree;
nargs = plan->nargs;
argtypes = plan->argtypes;
}
- ptlist = planTree_list =
- pg_parse_and_plan(src, argtypes, nargs, &queryTree_list, None, FALSE);
+
+ queryTree_list = pg_parse_and_rewrite(src, argtypes, nargs, FALSE);
_SPI_current->qtlist = queryTree_list;
+ planTree_list = NIL;
+
foreach(queryTree_list_item, queryTree_list)
{
queryTree = (Query *) lfirst(queryTree_list_item);
- planTree = lfirst(planTree_list);
- planTree_list = lnext(planTree_list);
- islastquery = (planTree_list == NIL); /* assume lists are same
- * len */
+ islastquery = (lnext(queryTree_list_item) == NIL);
+
+ planTree = pg_plan_query(queryTree);
+ planTree_list = lappend(planTree_list, planTree);
if (queryTree->commandType == CMD_UTILITY)
{
}
plan->qtlist = queryTree_list;
- plan->ptlist = ptlist;
+ plan->ptlist = planTree_list;
return res;
}
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/tcop/postgres.c,v 1.148 2000/03/23 23:16:48 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/tcop/postgres.c,v 1.149 2000/04/04 21:44:39 tgl Exp $
*
* NOTES
* this is the "main" module of the postgres backend and
return result;
}
+
+/*
+ * Parse a query string and pass it through the rewriter.
+ *
+ * A list of Query nodes is returned, since the string might contain
+ * multiple queries and/or the rewriter might expand one query to several.
+ */
List *
-pg_parse_and_plan(char *query_string, /* string to execute */
- Oid *typev, /* argument types */
- int nargs, /* number of arguments */
- List **queryListP, /* returned pointer to the parse
- * trees */
- CommandDest dest, /* where results should go */
- bool aclOverride)
+pg_parse_and_rewrite(char *query_string, /* string to execute */
+ Oid *typev, /* argument types */
+ int nargs, /* number of arguments */
+ bool aclOverride)
{
- List *querytree_list = NIL;
- List *plan_list = NIL;
+ List *querytree_list;
List *querytree_list_item;
Query *querytree;
- Plan *plan;
List *new_list;
- List *rewritten;
if (DebugPrintQuery)
{
else
{
/* rewrite regular queries */
- rewritten = QueryRewrite(querytree);
+ List *rewritten = QueryRewrite(querytree);
new_list = nconc(new_list, rewritten);
}
}
querytree_list = new_list;
- /*
- * Override ACL checking if requested
+ /* ----------------
+ * (3) If ACL override is requested, mark queries for no ACL check.
+ * ----------------
*/
if (aclOverride)
{
}
}
- foreach(querytree_list_item, querytree_list)
- {
- querytree = (Query *) lfirst(querytree_list_item);
-
- /*
- * For each query that isn't a utility invocation, generate a
- * plan.
- */
-
- if (querytree->commandType != CMD_UTILITY)
- {
+ return querytree_list;
+}
- if (IsAbortedTransactionBlockState())
- {
- /* ----------------
- * the EndCommand() stuff is to tell the frontend
- * that the command ended. -cim 6/1/90
- * ----------------
- */
- char *tag = "*ABORT STATE*";
- EndCommand(tag, dest);
+/* Generate a plan for a single query. */
+Plan *
+pg_plan_query(Query *querytree)
+{
+ Plan *plan;
- elog(NOTICE, "(transaction aborted): %s",
- "queries ignored until END");
+ /* Utility commands have no plans. */
+ if (querytree->commandType == CMD_UTILITY)
+ return NULL;
- if (queryListP)
- *queryListP = NIL;
- return NIL;
- }
+ if (ShowPlannerStats)
+ ResetUsage();
- if (ShowPlannerStats)
- ResetUsage();
+ /* call that optimizer */
+ plan = planner(querytree);
- /* call that optimizer */
- plan = planner(querytree);
+ if (ShowPlannerStats)
+ {
+ fprintf(stderr, "! Planner Stats:\n");
+ ShowUsage();
+ }
- if (ShowPlannerStats)
- {
- fprintf(stderr, "! Planner Stats:\n");
- ShowUsage();
- }
- plan_list = lappend(plan_list, plan);
-#ifdef INDEXSCAN_PATCH
- /* ----------------
- * Print plan if debugging.
- * This has been moved here to get debugging output
- * also for queries in functions. DZ - 27-8-1996
- * ----------------
- */
- if (DebugPrintPlan || DebugPPrintPlan)
- {
- if (DebugPPrintPlan)
- {
- TPRINTF(TRACE_PRETTY_PLAN, "plan:");
- nodeDisplay(plan);
- }
- else
- {
- TPRINTF(TRACE_PLAN, "plan:");
- printf("\n%s\n\n", nodeToString(plan));
- }
- }
-#endif
+ /* ----------------
+ * Print plan if debugging.
+ * ----------------
+ */
+ if (DebugPrintPlan || DebugPPrintPlan)
+ {
+ if (DebugPPrintPlan)
+ {
+ TPRINTF(TRACE_PRETTY_PLAN, "plan:");
+ nodeDisplay(plan);
}
-
- /*
- * If the command is an utility append a null plan. This is needed
- * to keep the plan_list aligned with the querytree_list or the
- * function executor will crash. DZ - 30-8-1996
- */
else
- plan_list = lappend(plan_list, NULL);
+ {
+ TPRINTF(TRACE_PLAN, "plan:");
+ printf("\n%s\n\n", nodeToString(plan));
+ }
}
- if (queryListP)
- *queryListP = querytree_list;
-
- return plan_list;
+ return plan;
}
+
/* ----------------------------------------------------------------
* pg_exec_query()
*
* of superusers */
{
List *querytree_list;
- List *plan_list;
- Query *querytree;
- Plan *plan;
- int j;
- /* plan the queries */
- plan_list = pg_parse_and_plan(query_string, NULL, 0,
- &querytree_list, dest, aclOverride);
-
- /* if we got a cancel signal whilst planning, quit */
- if (QueryCancel)
- CancelQuery();
-
- /* OK, do it to it! */
+ /* parse and rewrite the queries */
+ querytree_list = pg_parse_and_rewrite(query_string, NULL, 0,
+ aclOverride);
/*
* NOTE: we do not use "foreach" here because we want to be sure the
- * list pointers have been advanced before the query is executed. We
+ * list pointer has been advanced before the query is executed. We
* need to do that because VACUUM has a nasty little habit of doing
* CommitTransactionCommand at startup, and that will release the
- * memory holding our parse/plan lists :-(. This needs a better
+ * memory holding our parse list :-(. This needs a better
* solution --- currently, the code will crash if someone submits
* "vacuum; something-else" in a single query string. But memory
* allocation needs redesigned anyway, so this will have to do for
* now.
*/
-
while (querytree_list)
{
- querytree = (Query *) lfirst(querytree_list);
+ Query *querytree = (Query *) lfirst(querytree_list);
+
querytree_list = lnext(querytree_list);
- plan = (Plan *) lfirst(plan_list);
- plan_list = lnext(plan_list);
+
+ /* if we got a cancel signal in parsing or prior command, quit */
+ if (QueryCancel)
+ CancelQuery();
if (querytree->commandType == CMD_UTILITY)
{
else if (Verbose)
TPRINTF(TRACE_VERBOSE, "ProcessUtility");
- /*
- * We have to set query SnapShot in the case of FETCH or COPY TO.
- */
- if (nodeTag(querytree->utilityStmt) == T_FetchStmt ||
- (nodeTag(querytree->utilityStmt) == T_CopyStmt &&
- ((CopyStmt *)(querytree->utilityStmt))->direction != FROM))
- SetQuerySnapshot();
ProcessUtility(querytree->utilityStmt, dest);
}
else
{
-#ifdef INDEXSCAN_PATCH
+ Plan *plan;
+ int j;
- /*
- * Print moved in pg_parse_and_plan. DZ - 27-8-1996
- */
-#else
- /* ----------------
- * print plan if debugging
- * ----------------
- */
- if (DebugPrintPlan || DebugPPrintPlan)
+ /* If aborted transaction, quit now */
+ if (IsAbortedTransactionBlockState())
{
- if (DebugPPrintPlan)
- {
- TPRINTF(TRACE_PRETTY_PLAN, "plan:");
- nodeDisplay(plan);
- }
- else
- {
- TPRINTF(TRACE_PLAN, "plan:");
- printf("\n%s\n\n", nodeToString(plan));
- }
+ /* ----------------
+ * the EndCommand() stuff is to tell the frontend
+ * that the command ended. -cim 6/1/90
+ * ----------------
+ */
+ char *tag = "*ABORT STATE*";
+
+ elog(NOTICE, "current transaction is aborted, "
+ "queries ignored until end of transaction block");
+
+ EndCommand(tag, dest);
+
+ break;
}
-#endif
+ plan = pg_plan_query(querytree);
+
+ /* if we got a cancel signal whilst planning, quit */
+ if (QueryCancel)
+ CancelQuery();
+
+ /* Initialize snapshot state for query */
SetQuerySnapshot();
/*
if (!IsUnderPostmaster)
{
puts("\nPOSTGRES backend interactive interface ");
- puts("$Revision: 1.148 $ $Date: 2000/03/23 23:16:48 $\n");
+ puts("$Revision: 1.149 $ $Date: 2000/04/04 21:44:39 $\n");
}
/*
projects / thirdparty / postgresql.git / commitdiff
