diff options
Diffstat (limited to 'src/backend/tcop/utility.c')
| -rw-r--r-- | src/backend/tcop/utility.c | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/backend/tcop/utility.c b/src/backend/tcop/utility.c index 4474658ddf4..b2c58bf8622 100644 --- a/src/backend/tcop/utility.c +++ b/src/backend/tcop/utility.c @@ -396,6 +396,7 @@ standard_ProcessUtility(PlannedStmt *pstmt, pstate = make_parsestate(NULL); pstate->p_sourcetext = queryString; + pstate->p_queryEnv = queryEnv; switch (nodeTag(parsetree)) { @@ -500,8 +501,8 @@ standard_ProcessUtility(PlannedStmt *pstmt, * Portal (cursor) manipulation */ case T_DeclareCursorStmt: - PerformCursorOpen((DeclareCursorStmt *) parsetree, params, - queryString, isTopLevel); + PerformCursorOpen(pstate, (DeclareCursorStmt *) parsetree, params, + isTopLevel); break; case T_ClosePortalStmt: @@ -558,13 +559,14 @@ standard_ProcessUtility(PlannedStmt *pstmt, case T_PrepareStmt: CheckRestrictedOperation("PREPARE"); - PrepareQuery((PrepareStmt *) parsetree, queryString, + PrepareQuery(pstate, (PrepareStmt *) parsetree, pstmt->stmt_location, pstmt->stmt_len); break; case T_ExecuteStmt: - ExecuteQuery((ExecuteStmt *) parsetree, NULL, - queryString, params, + ExecuteQuery(pstate, + (ExecuteStmt *) parsetree, NULL, + params, dest, completionTag); break; @@ -667,8 +669,7 @@ standard_ProcessUtility(PlannedStmt *pstmt, break; case T_ExplainStmt: - ExplainQuery(pstate, (ExplainStmt *) parsetree, queryString, params, - queryEnv, dest); + ExplainQuery(pstate, (ExplainStmt *) parsetree, params, dest); break; case T_AlterSystemStmt: @@ -1490,9 +1491,8 @@ ProcessUtilitySlow(ParseState *pstate, break; case T_CreateTableAsStmt: - address = ExecCreateTableAs((CreateTableAsStmt *) parsetree, - queryString, params, queryEnv, - completionTag); + address = ExecCreateTableAs(pstate, (CreateTableAsStmt *) parsetree, + params, queryEnv, completionTag); break; case T_RefreshMatViewStmt: |