PostgreSQL Source Code  git master
Functions | Variables
utility.c File Reference
#include "postgres.h"
#include "access/htup_details.h"
#include "access/reloptions.h"
#include "access/twophase.h"
#include "access/xact.h"
#include "access/xlog.h"
#include "catalog/catalog.h"
#include "catalog/index.h"
#include "catalog/namespace.h"
#include "catalog/pg_inherits.h"
#include "catalog/toasting.h"
#include "commands/alter.h"
#include "commands/async.h"
#include "commands/cluster.h"
#include "commands/collationcmds.h"
#include "commands/comment.h"
#include "commands/conversioncmds.h"
#include "commands/copy.h"
#include "commands/createas.h"
#include "commands/dbcommands.h"
#include "commands/defrem.h"
#include "commands/discard.h"
#include "commands/event_trigger.h"
#include "commands/explain.h"
#include "commands/extension.h"
#include "commands/lockcmds.h"
#include "commands/matview.h"
#include "commands/policy.h"
#include "commands/portalcmds.h"
#include "commands/prepare.h"
#include "commands/proclang.h"
#include "commands/publicationcmds.h"
#include "commands/schemacmds.h"
#include "commands/seclabel.h"
#include "commands/sequence.h"
#include "commands/subscriptioncmds.h"
#include "commands/tablecmds.h"
#include "commands/tablespace.h"
#include "commands/trigger.h"
#include "commands/typecmds.h"
#include "commands/user.h"
#include "commands/vacuum.h"
#include "commands/view.h"
#include "miscadmin.h"
#include "parser/parse_utilcmd.h"
#include "postmaster/bgwriter.h"
#include "rewrite/rewriteDefine.h"
#include "rewrite/rewriteRemove.h"
#include "storage/fd.h"
#include "tcop/pquery.h"
#include "tcop/utility.h"
#include "utils/acl.h"
#include "utils/guc.h"
#include "utils/lsyscache.h"
#include "utils/rel.h"
#include "utils/syscache.h"
Include dependency graph for utility.c:

Go to the source code of this file.

Functions

static int ClassifyUtilityCommandAsReadOnly (Node *parsetree)
 
static void ProcessUtilitySlow (ParseState *pstate, PlannedStmt *pstmt, const char *queryString, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
 
static void ExecDropStmt (DropStmt *stmt, bool isTopLevel)
 
bool CommandIsReadOnly (PlannedStmt *pstmt)
 
void PreventCommandIfReadOnly (const char *cmdname)
 
void PreventCommandIfParallelMode (const char *cmdname)
 
void PreventCommandDuringRecovery (const char *cmdname)
 
static void CheckRestrictedOperation (const char *cmdname)
 
void ProcessUtility (PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
 
void standard_ProcessUtility (PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
 
void ProcessUtilityForAlterTable (Node *stmt, AlterTableUtilityContext *context)
 
bool UtilityReturnsTuples (Node *parsetree)
 
TupleDesc UtilityTupleDescriptor (Node *parsetree)
 
Query * UtilityContainsQuery (Node *parsetree)
 
static CommandTag AlterObjectTypeCommandTag (ObjectType objtype)
 
CommandTag CreateCommandTag (Node *parsetree)
 
LogStmtLevel GetCommandLogLevel (Node *parsetree)
 

Variables

ProcessUtility_hook_type ProcessUtility_hook = NULL
 

Function Documentation

◆ AlterObjectTypeCommandTag()

static CommandTag AlterObjectTypeCommandTag ( ObjectType  objtype)
static

Definition at line 2191 of file utility.c.

References OBJECT_AGGREGATE, OBJECT_ATTRIBUTE, OBJECT_CAST, OBJECT_COLLATION, OBJECT_COLUMN, OBJECT_CONVERSION, OBJECT_DATABASE, OBJECT_DOMAIN, OBJECT_DOMCONSTRAINT, OBJECT_EVENT_TRIGGER, OBJECT_EXTENSION, OBJECT_FDW, OBJECT_FOREIGN_SERVER, OBJECT_FOREIGN_TABLE, OBJECT_FUNCTION, OBJECT_INDEX, OBJECT_LANGUAGE, OBJECT_LARGEOBJECT, OBJECT_MATVIEW, OBJECT_OPCLASS, OBJECT_OPERATOR, OBJECT_OPFAMILY, OBJECT_POLICY, OBJECT_PROCEDURE, OBJECT_PUBLICATION, OBJECT_ROLE, OBJECT_ROUTINE, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_SEQUENCE, OBJECT_STATISTIC_EXT, OBJECT_SUBSCRIPTION, OBJECT_TABCONSTRAINT, OBJECT_TABLE, OBJECT_TABLESPACE, OBJECT_TRIGGER, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, and OBJECT_VIEW.

Referenced by CreateCommandTag().

2192 {
2193  CommandTag tag;
2194 
2195  switch (objtype)
2196  {
2197  case OBJECT_AGGREGATE:
2198  tag = CMDTAG_ALTER_AGGREGATE;
2199  break;
2200  case OBJECT_ATTRIBUTE:
2201  tag = CMDTAG_ALTER_TYPE;
2202  break;
2203  case OBJECT_CAST:
2204  tag = CMDTAG_ALTER_CAST;
2205  break;
2206  case OBJECT_COLLATION:
2207  tag = CMDTAG_ALTER_COLLATION;
2208  break;
2209  case OBJECT_COLUMN:
2210  tag = CMDTAG_ALTER_TABLE;
2211  break;
2212  case OBJECT_CONVERSION:
2213  tag = CMDTAG_ALTER_CONVERSION;
2214  break;
2215  case OBJECT_DATABASE:
2216  tag = CMDTAG_ALTER_DATABASE;
2217  break;
2218  case OBJECT_DOMAIN:
2219  case OBJECT_DOMCONSTRAINT:
2220  tag = CMDTAG_ALTER_DOMAIN;
2221  break;
2222  case OBJECT_EXTENSION:
2223  tag = CMDTAG_ALTER_EXTENSION;
2224  break;
2225  case OBJECT_FDW:
2226  tag = CMDTAG_ALTER_FOREIGN_DATA_WRAPPER;
2227  break;
2228  case OBJECT_FOREIGN_SERVER:
2229  tag = CMDTAG_ALTER_SERVER;
2230  break;
2231  case OBJECT_FOREIGN_TABLE:
2232  tag = CMDTAG_ALTER_FOREIGN_TABLE;
2233  break;
2234  case OBJECT_FUNCTION:
2235  tag = CMDTAG_ALTER_FUNCTION;
2236  break;
2237  case OBJECT_INDEX:
2238  tag = CMDTAG_ALTER_INDEX;
2239  break;
2240  case OBJECT_LANGUAGE:
2241  tag = CMDTAG_ALTER_LANGUAGE;
2242  break;
2243  case OBJECT_LARGEOBJECT:
2244  tag = CMDTAG_ALTER_LARGE_OBJECT;
2245  break;
2246  case OBJECT_OPCLASS:
2247  tag = CMDTAG_ALTER_OPERATOR_CLASS;
2248  break;
2249  case OBJECT_OPERATOR:
2250  tag = CMDTAG_ALTER_OPERATOR;
2251  break;
2252  case OBJECT_OPFAMILY:
2253  tag = CMDTAG_ALTER_OPERATOR_FAMILY;
2254  break;
2255  case OBJECT_POLICY:
2256  tag = CMDTAG_ALTER_POLICY;
2257  break;
2258  case OBJECT_PROCEDURE:
2259  tag = CMDTAG_ALTER_PROCEDURE;
2260  break;
2261  case OBJECT_ROLE:
2262  tag = CMDTAG_ALTER_ROLE;
2263  break;
2264  case OBJECT_ROUTINE:
2265  tag = CMDTAG_ALTER_ROUTINE;
2266  break;
2267  case OBJECT_RULE:
2268  tag = CMDTAG_ALTER_RULE;
2269  break;
2270  case OBJECT_SCHEMA:
2271  tag = CMDTAG_ALTER_SCHEMA;
2272  break;
2273  case OBJECT_SEQUENCE:
2274  tag = CMDTAG_ALTER_SEQUENCE;
2275  break;
2276  case OBJECT_TABLE:
2277  case OBJECT_TABCONSTRAINT:
2278  tag = CMDTAG_ALTER_TABLE;
2279  break;
2280  case OBJECT_TABLESPACE:
2281  tag = CMDTAG_ALTER_TABLESPACE;
2282  break;
2283  case OBJECT_TRIGGER:
2284  tag = CMDTAG_ALTER_TRIGGER;
2285  break;
2286  case OBJECT_EVENT_TRIGGER:
2287  tag = CMDTAG_ALTER_EVENT_TRIGGER;
2288  break;
2289  case OBJECT_TSCONFIGURATION:
2290  tag = CMDTAG_ALTER_TEXT_SEARCH_CONFIGURATION;
2291  break;
2292  case OBJECT_TSDICTIONARY:
2293  tag = CMDTAG_ALTER_TEXT_SEARCH_DICTIONARY;
2294  break;
2295  case OBJECT_TSPARSER:
2296  tag = CMDTAG_ALTER_TEXT_SEARCH_PARSER;
2297  break;
2298  case OBJECT_TSTEMPLATE:
2299  tag = CMDTAG_ALTER_TEXT_SEARCH_TEMPLATE;
2300  break;
2301  case OBJECT_TYPE:
2302  tag = CMDTAG_ALTER_TYPE;
2303  break;
2304  case OBJECT_VIEW:
2305  tag = CMDTAG_ALTER_VIEW;
2306  break;
2307  case OBJECT_MATVIEW:
2308  tag = CMDTAG_ALTER_MATERIALIZED_VIEW;
2309  break;
2310  case OBJECT_PUBLICATION:
2311  tag = CMDTAG_ALTER_PUBLICATION;
2312  break;
2313  case OBJECT_SUBSCRIPTION:
2314  tag = CMDTAG_ALTER_SUBSCRIPTION;
2315  break;
2316  case OBJECT_STATISTIC_EXT:
2317  tag = CMDTAG_ALTER_STATISTICS;
2318  break;
2319  default:
2320  tag = CMDTAG_UNKNOWN;
2321  break;
2322  }
2323 
2324  return tag;
2325 }
CommandTag
CommandTag
Definition: cmdtag.h:20

◆ CheckRestrictedOperation()

static void CheckRestrictedOperation ( const char *  cmdname)
static

Definition at line 463 of file utility.c.

References ereport, errcode(), errmsg(), ERROR, and InSecurityRestrictedOperation().

Referenced by standard_ProcessUtility().

464 {
465  if (InSecurityRestrictedOperation())
466  ereport(ERROR,
467  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
468  /* translator: %s is name of a SQL command, eg PREPARE */
469  errmsg("cannot execute %s within security-restricted operation",
470  cmdname)));
471 }
errcode
int errcode(int sqlerrcode)
Definition: elog.c:698
ERROR
#define ERROR
Definition: elog.h:46
ereport
#define ereport(elevel,...)
Definition: elog.h:157
InSecurityRestrictedOperation
bool InSecurityRestrictedOperation(void)
Definition: miscinit.c:627
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:909

◆ ClassifyUtilityCommandAsReadOnly()

static int ClassifyUtilityCommandAsReadOnly ( Node *  parsetree)
static

Definition at line 133 of file utility.c.

References COMMAND_IS_NOT_READ_ONLY, COMMAND_IS_STRICTLY_READ_ONLY, COMMAND_OK_IN_READ_ONLY_TXN, COMMAND_OK_IN_RECOVERY, elog, ERROR, CopyStmt::is_from, TransactionStmt::kind, LockStmt::mode, nodeTag, RowExclusiveLock, T_AlterCollationStmt, T_AlterDatabaseSetStmt, T_AlterDatabaseStmt, T_AlterDefaultPrivilegesStmt, T_AlterDomainStmt, T_AlterEnumStmt, T_AlterEventTrigStmt, T_AlterExtensionContentsStmt, T_AlterExtensionStmt, T_AlterFdwStmt, T_AlterForeignServerStmt, T_AlterFunctionStmt, T_AlterObjectDependsStmt, T_AlterObjectSchemaStmt, T_AlterOperatorStmt, T_AlterOpFamilyStmt, T_AlterOwnerStmt, T_AlterPolicyStmt, T_AlterPublicationStmt, T_AlterRoleSetStmt, T_AlterRoleStmt, T_AlterSeqStmt, T_AlterStatsStmt, T_AlterSubscriptionStmt, T_AlterSystemStmt, T_AlterTableMoveAllStmt, T_AlterTableSpaceOptionsStmt, T_AlterTableStmt, T_AlterTSConfigurationStmt, T_AlterTSDictionaryStmt, T_AlterTypeStmt, T_AlterUserMappingStmt, T_CallStmt, T_CheckPointStmt, T_ClosePortalStmt, T_ClusterStmt, T_CommentStmt, T_CompositeTypeStmt, T_ConstraintsSetStmt, T_CopyStmt, T_CreateAmStmt, T_CreateCastStmt, T_CreateConversionStmt, T_CreatedbStmt, T_CreateDomainStmt, T_CreateEnumStmt, T_CreateEventTrigStmt, T_CreateExtensionStmt, T_CreateFdwStmt, T_CreateForeignServerStmt, T_CreateForeignTableStmt, T_CreateFunctionStmt, T_CreateOpClassStmt, T_CreateOpFamilyStmt, T_CreatePLangStmt, T_CreatePolicyStmt, T_CreatePublicationStmt, T_CreateRangeStmt, T_CreateRoleStmt, T_CreateSchemaStmt, T_CreateSeqStmt, T_CreateStatsStmt, T_CreateStmt, T_CreateSubscriptionStmt, T_CreateTableAsStmt, T_CreateTableSpaceStmt, T_CreateTransformStmt, T_CreateTrigStmt, T_CreateUserMappingStmt, T_DeallocateStmt, T_DeclareCursorStmt, T_DefineStmt, T_DiscardStmt, T_DoStmt, T_DropdbStmt, T_DropOwnedStmt, T_DropRoleStmt, T_DropStmt, T_DropSubscriptionStmt, T_DropTableSpaceStmt, T_DropUserMappingStmt, T_ExecuteStmt, T_ExplainStmt, T_FetchStmt, T_GrantRoleStmt, T_GrantStmt, T_ImportForeignSchemaStmt, T_IndexStmt, T_ListenStmt, T_LoadStmt, T_LockStmt, T_NotifyStmt, T_PrepareStmt, T_ReassignOwnedStmt, T_RefreshMatViewStmt, T_ReindexStmt, T_RenameStmt, T_RuleStmt, T_SecLabelStmt, T_TransactionStmt, T_TruncateStmt, T_UnlistenStmt, T_VacuumStmt, T_VariableSetStmt, T_VariableShowStmt, T_ViewStmt, TRANS_STMT_BEGIN, TRANS_STMT_COMMIT, TRANS_STMT_COMMIT_PREPARED, TRANS_STMT_PREPARE, TRANS_STMT_RELEASE, TRANS_STMT_ROLLBACK, TRANS_STMT_ROLLBACK_PREPARED, TRANS_STMT_ROLLBACK_TO, TRANS_STMT_SAVEPOINT, and TRANS_STMT_START.

Referenced by standard_ProcessUtility().

134 {
135  switch (nodeTag(parsetree))
136  {
137  case T_AlterCollationStmt:
138  case T_AlterDatabaseSetStmt:
139  case T_AlterDatabaseStmt:
140  case T_AlterDefaultPrivilegesStmt:
141  case T_AlterDomainStmt:
142  case T_AlterEnumStmt:
143  case T_AlterEventTrigStmt:
144  case T_AlterExtensionContentsStmt:
145  case T_AlterExtensionStmt:
146  case T_AlterFdwStmt:
147  case T_AlterForeignServerStmt:
148  case T_AlterFunctionStmt:
149  case T_AlterObjectDependsStmt:
150  case T_AlterObjectSchemaStmt:
151  case T_AlterOpFamilyStmt:
152  case T_AlterOperatorStmt:
153  case T_AlterOwnerStmt:
154  case T_AlterPolicyStmt:
155  case T_AlterPublicationStmt:
156  case T_AlterRoleSetStmt:
157  case T_AlterRoleStmt:
158  case T_AlterSeqStmt:
159  case T_AlterStatsStmt:
160  case T_AlterSubscriptionStmt:
161  case T_AlterTSConfigurationStmt:
162  case T_AlterTSDictionaryStmt:
163  case T_AlterTableMoveAllStmt:
164  case T_AlterTableSpaceOptionsStmt:
165  case T_AlterTableStmt:
166  case T_AlterTypeStmt:
167  case T_AlterUserMappingStmt:
168  case T_CommentStmt:
169  case T_CompositeTypeStmt:
170  case T_CreateAmStmt:
171  case T_CreateCastStmt:
172  case T_CreateConversionStmt:
173  case T_CreateDomainStmt:
174  case T_CreateEnumStmt:
175  case T_CreateEventTrigStmt:
176  case T_CreateExtensionStmt:
177  case T_CreateFdwStmt:
178  case T_CreateForeignServerStmt:
179  case T_CreateForeignTableStmt:
180  case T_CreateFunctionStmt:
181  case T_CreateOpClassStmt:
182  case T_CreateOpFamilyStmt:
183  case T_CreatePLangStmt:
184  case T_CreatePolicyStmt:
185  case T_CreatePublicationStmt:
186  case T_CreateRangeStmt:
187  case T_CreateRoleStmt:
188  case T_CreateSchemaStmt:
189  case T_CreateSeqStmt:
190  case T_CreateStatsStmt:
191  case T_CreateStmt:
192  case T_CreateSubscriptionStmt:
193  case T_CreateTableAsStmt:
194  case T_CreateTableSpaceStmt:
195  case T_CreateTransformStmt:
196  case T_CreateTrigStmt:
197  case T_CreateUserMappingStmt:
198  case T_CreatedbStmt:
199  case T_DefineStmt:
200  case T_DropOwnedStmt:
201  case T_DropRoleStmt:
202  case T_DropStmt:
203  case T_DropSubscriptionStmt:
204  case T_DropTableSpaceStmt:
205  case T_DropUserMappingStmt:
206  case T_DropdbStmt:
207  case T_GrantRoleStmt:
208  case T_GrantStmt:
209  case T_ImportForeignSchemaStmt:
210  case T_IndexStmt:
211  case T_ReassignOwnedStmt:
212  case T_RefreshMatViewStmt:
213  case T_RenameStmt:
214  case T_RuleStmt:
215  case T_SecLabelStmt:
216  case T_TruncateStmt:
217  case T_ViewStmt:
218  {
219  /* DDL is not read-only, and neither is TRUNCATE. */
220  return COMMAND_IS_NOT_READ_ONLY;
221  }
222 
223  case T_AlterSystemStmt:
224  {
225  /*
226  * Surprisingly, ALTER SYSTEM meets all our definitions of
227  * read-only: it changes nothing that affects the output of
228  * pg_dump, it doesn't write WAL or imperil the application of
229  * future WAL, and it doesn't depend on any state that needs
230  * to be synchronized with parallel workers.
231  *
232  * So, despite the fact that it writes to a file, it's read
233  * only!
234  */
235  return COMMAND_IS_STRICTLY_READ_ONLY;
236  }
237 
238  case T_CallStmt:
239  case T_DoStmt:
240  {
241  /*
242  * Commands inside the DO block or the called procedure might
243  * not be read only, but they'll be checked separately when we
244  * try to execute them. Here we only need to worry about the
245  * DO or CALL command itself.
246  */
247  return COMMAND_IS_STRICTLY_READ_ONLY;
248  }
249 
250  case T_CheckPointStmt:
251  {
252  /*
253  * You might think that this should not be permitted in
254  * recovery, but we interpret a CHECKPOINT command during
255  * recovery as a request for a restartpoint instead. We allow
256  * this since it can be a useful way of reducing switchover
257  * time when using various forms of replication.
258  */
259  return COMMAND_IS_STRICTLY_READ_ONLY;
260  }
261 
262  case T_ClosePortalStmt:
263  case T_ConstraintsSetStmt:
264  case T_DeallocateStmt:
265  case T_DeclareCursorStmt:
266  case T_DiscardStmt:
267  case T_ExecuteStmt:
268  case T_FetchStmt:
269  case T_LoadStmt:
270  case T_PrepareStmt:
271  case T_UnlistenStmt:
272  case T_VariableSetStmt:
273  {
274  /*
275  * These modify only backend-local state, so they're OK to run
276  * in a read-only transaction or on a standby. However, they
277  * are disallowed in parallel mode, because they either rely
278  * upon or modify backend-local state that might not be
279  * synchronized among cooperating backends.
280  */
281  return COMMAND_OK_IN_RECOVERY | COMMAND_OK_IN_READ_ONLY_TXN;
282  }
283 
284  case T_ClusterStmt:
285  case T_ReindexStmt:
286  case T_VacuumStmt:
287  {
288  /*
289  * These commands write WAL, so they're not strictly
290  * read-only, and running them in parallel workers isn't
291  * supported.
292  *
293  * However, they don't change the database state in a way that
294  * would affect pg_dump output, so it's fine to run them in a
295  * read-only transaction. (CLUSTER might change the order of
296  * rows on disk, which could affect the ordering of pg_dump
297  * output, but that's not semantically significant.)
298  */
299  return COMMAND_OK_IN_READ_ONLY_TXN;
300  }
301 
302  case T_CopyStmt:
303  {
304  CopyStmt *stmt = (CopyStmt *) parsetree;
305 
306  /*
307  * You might think that COPY FROM is not at all read only, but
308  * it's OK to copy into a temporary table, because that
309  * wouldn't change the output of pg_dump. If the target table
310  * turns out to be non-temporary, DoCopy itself will call
311  * PreventCommandIfReadOnly.
312  */
313  if (stmt->is_from)
314  return COMMAND_OK_IN_READ_ONLY_TXN;
315  else
316  return COMMAND_IS_STRICTLY_READ_ONLY;
317  }
318 
319  case T_ExplainStmt:
320  case T_VariableShowStmt:
321  {
322  /*
323  * These commands don't modify any data and are safe to run in
324  * a parallel worker.
325  */
326  return COMMAND_IS_STRICTLY_READ_ONLY;
327  }
328 
329  case T_ListenStmt:
330  case T_NotifyStmt:
331  {
332  /*
333  * NOTIFY requires an XID assignment, so it can't be permitted
334  * on a standby. Perhaps LISTEN could, since without NOTIFY it
335  * would be OK to just do nothing, at least until promotion,
336  * but we currently prohibit it lest the user get the wrong
337  * idea.
338  *
339  * (We do allow T_UnlistenStmt on a standby, though, because
340  * it's a no-op.)
341  */
342  return COMMAND_OK_IN_READ_ONLY_TXN;
343  }
344 
345  case T_LockStmt:
346  {
347  LockStmt *stmt = (LockStmt *) parsetree;
348 
349  /*
350  * Only weaker locker modes are allowed during recovery. The
351  * restrictions here must match those in
352  * LockAcquireExtended().
353  */
354  if (stmt->mode > RowExclusiveLock)
355  return COMMAND_OK_IN_READ_ONLY_TXN;
356  else
357  return COMMAND_IS_STRICTLY_READ_ONLY;
358  }
359 
360  case T_TransactionStmt:
361  {
362  TransactionStmt *stmt = (TransactionStmt *) parsetree;
363 
364  /*
365  * PREPARE, COMMIT PREPARED, and ROLLBACK PREPARED all write
366  * WAL, so they're not read-only in the strict sense; but the
367  * first and third do not change pg_dump output, so they're OK
368  * in a read-only transactions.
369  *
370  * We also consider COMMIT PREPARED to be OK in a read-only
371  * transaction environment, by way of exception.
372  */
373  switch (stmt->kind)
374  {
375  case TRANS_STMT_BEGIN:
376  case TRANS_STMT_START:
377  case TRANS_STMT_COMMIT:
378  case TRANS_STMT_ROLLBACK:
379  case TRANS_STMT_SAVEPOINT:
380  case TRANS_STMT_RELEASE:
381  case TRANS_STMT_ROLLBACK_TO:
382  return COMMAND_IS_STRICTLY_READ_ONLY;
383 
384  case TRANS_STMT_PREPARE:
385  case TRANS_STMT_COMMIT_PREPARED:
386  case TRANS_STMT_ROLLBACK_PREPARED:
387  return COMMAND_OK_IN_READ_ONLY_TXN;
388  }
389  elog(ERROR, "unrecognized TransactionStmtKind: %d",
390  (int) stmt->kind);
391  return 0; /* silence stupider compilers */
392  }
393 
394  default:
395  elog(ERROR, "unrecognized node type: %d",
396  (int) nodeTag(parsetree));
397  return 0; /* silence stupider compilers */
398  }
399 }
COMMAND_OK_IN_RECOVERY
#define COMMAND_OK_IN_RECOVERY
Definition: utility.h:58
ERROR
#define ERROR
Definition: elog.h:46
RowExclusiveLock
#define RowExclusiveLock
Definition: lockdefs.h:38
nodeTag
#define nodeTag(nodeptr)
Definition: nodes.h:541
COMMAND_IS_NOT_READ_ONLY
#define COMMAND_IS_NOT_READ_ONLY
Definition: utility.h:68
CopyStmt::is_from
bool is_from
Definition: parsenodes.h:2126
elog
#define elog(elevel,...)
Definition: elog.h:232
COMMAND_IS_STRICTLY_READ_ONLY
#define COMMAND_IS_STRICTLY_READ_ONLY
Definition: utility.h:65
COMMAND_OK_IN_READ_ONLY_TXN
#define COMMAND_OK_IN_READ_ONLY_TXN
Definition: utility.h:56
TransactionStmt::kind
TransactionStmtKind kind
Definition: parsenodes.h:3197

◆ CommandIsReadOnly()

bool CommandIsReadOnly ( PlannedStmt *  pstmt)

Definition at line 100 of file utility.c.

References Assert, CMD_DELETE, CMD_INSERT, CMD_SELECT, CMD_UPDATE, CMD_UTILITY, PlannedStmt::commandType, elog, PlannedStmt::hasModifyingCTE, IsA, NIL, PlannedStmt::rowMarks, and WARNING.

Referenced by _SPI_execute_plan(), CreateCommandName(), init_execution_state(), and SPI_cursor_open_internal().

101 {
102  Assert(IsA(pstmt, PlannedStmt));
103  switch (pstmt->commandType)
104  {
105  case CMD_SELECT:
106  if (pstmt->rowMarks != NIL)
107  return false; /* SELECT FOR [KEY] UPDATE/SHARE */
108  else if (pstmt->hasModifyingCTE)
109  return false; /* data-modifying CTE */
110  else
111  return true;
112  case CMD_UPDATE:
113  case CMD_INSERT:
114  case CMD_DELETE:
115  return false;
116  case CMD_UTILITY:
117  /* For now, treat all utility commands as read/write */
118  return false;
119  default:
120  elog(WARNING, "unrecognized commandType: %d",
121  (int) pstmt->commandType);
122  break;
123  }
124  return false;
125 }
NIL
#define NIL
Definition: pg_list.h:65
IsA
#define IsA(nodeptr, _type_)
Definition: nodes.h:587
WARNING
#define WARNING
Definition: elog.h:40
PlannedStmt::commandType
CmdType commandType
Definition: plannodes.h:46
PlannedStmt::rowMarks
List * rowMarks
Definition: plannodes.h:78
Assert
#define Assert(condition)
Definition: c.h:804
PlannedStmt::hasModifyingCTE
bool hasModifyingCTE
Definition: plannodes.h:52
elog
#define elog(elevel,...)
Definition: elog.h:232

◆ CreateCommandTag()

CommandTag CreateCommandTag ( Node *  parsetree)

Definition at line 2337 of file utility.c.

References AlterObjectTypeCommandTag(), CMD_DELETE, CMD_INSERT, CMD_SELECT, CMD_UPDATE, CMD_UTILITY, PlannedStmt::commandType, Query::commandType, CreateCommandTag(), DISCARD_ALL, DISCARD_PLANS, DISCARD_SEQUENCES, DISCARD_TEMP, elog, GrantStmt::is_grant, GrantRoleStmt::is_grant, FetchStmt::ismove, TransactionStmt::kind, LCS_FORKEYSHARE, LCS_FORNOKEYUPDATE, LCS_FORSHARE, LCS_FORUPDATE, linitial, DeallocateStmt::name, NIL, nodeTag, OBJECT_ACCESS_METHOD, OBJECT_AGGREGATE, OBJECT_CAST, OBJECT_COLLATION, OBJECT_COLUMN, OBJECT_CONVERSION, OBJECT_DOMAIN, OBJECT_EVENT_TRIGGER, OBJECT_EXTENSION, OBJECT_FDW, OBJECT_FOREIGN_SERVER, OBJECT_FOREIGN_TABLE, OBJECT_FUNCTION, OBJECT_INDEX, OBJECT_LANGUAGE, OBJECT_MATVIEW, OBJECT_OPCLASS, OBJECT_OPERATOR, OBJECT_OPFAMILY, OBJECT_POLICY, OBJECT_PROCEDURE, OBJECT_PUBLICATION, OBJECT_ROUTINE, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_SEQUENCE, OBJECT_STATISTIC_EXT, OBJECT_TABLE, OBJECT_TRANSFORM, OBJECT_TRIGGER, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, OBJECT_VIEW, ClosePortalStmt::portalname, PlannedStmt::rowMarks, Query::rowMarks, T_AlterCollationStmt, T_AlterDatabaseSetStmt, T_AlterDatabaseStmt, T_AlterDefaultPrivilegesStmt, T_AlterDomainStmt, T_AlterEnumStmt, T_AlterEventTrigStmt, T_AlterExtensionContentsStmt, T_AlterExtensionStmt, T_AlterFdwStmt, T_AlterForeignServerStmt, T_AlterFunctionStmt, T_AlterObjectDependsStmt, T_AlterObjectSchemaStmt, T_AlterOperatorStmt, T_AlterOpFamilyStmt, T_AlterOwnerStmt, T_AlterPolicyStmt, T_AlterPublicationStmt, T_AlterRoleSetStmt, T_AlterRoleStmt, T_AlterSeqStmt, T_AlterStatsStmt, T_AlterSubscriptionStmt, T_AlterSystemStmt, T_AlterTableMoveAllStmt, T_AlterTableSpaceOptionsStmt, T_AlterTableStmt, T_AlterTSConfigurationStmt, T_AlterTSDictionaryStmt, T_AlterTypeStmt, T_AlterUserMappingStmt, T_CallStmt, T_CheckPointStmt, T_ClosePortalStmt, T_ClusterStmt, T_CommentStmt, T_CompositeTypeStmt, T_ConstraintsSetStmt, T_CopyStmt, T_CreateAmStmt, T_CreateCastStmt, T_CreateConversionStmt, T_CreatedbStmt, T_CreateDomainStmt, T_CreateEnumStmt, T_CreateEventTrigStmt, T_CreateExtensionStmt, T_CreateFdwStmt, T_CreateForeignServerStmt, T_CreateForeignTableStmt, T_CreateFunctionStmt, T_CreateOpClassStmt, T_CreateOpFamilyStmt, T_CreatePLangStmt, T_CreatePolicyStmt, T_CreatePublicationStmt, T_CreateRangeStmt, T_CreateRoleStmt, T_CreateSchemaStmt, T_CreateSeqStmt, T_CreateStatsStmt, T_CreateStmt, T_CreateSubscriptionStmt, T_CreateTableAsStmt, T_CreateTableSpaceStmt, T_CreateTransformStmt, T_CreateTrigStmt, T_CreateUserMappingStmt, T_DeallocateStmt, T_DeclareCursorStmt, T_DefineStmt, T_DeleteStmt, T_DiscardStmt, T_DoStmt, T_DropdbStmt, T_DropOwnedStmt, T_DropRoleStmt, T_DropStmt, T_DropSubscriptionStmt, T_DropTableSpaceStmt, T_DropUserMappingStmt, T_ExecuteStmt, T_ExplainStmt, T_FetchStmt, T_GrantRoleStmt, T_GrantStmt, T_ImportForeignSchemaStmt, T_IndexStmt, T_InsertStmt, T_ListenStmt, T_LoadStmt, T_LockStmt, T_NotifyStmt, T_PlannedStmt, T_PLAssignStmt, T_PrepareStmt, T_Query, T_RawStmt, T_ReassignOwnedStmt, T_RefreshMatViewStmt, T_ReindexStmt, T_RenameStmt, T_RuleStmt, T_SecLabelStmt, T_SelectStmt, T_TransactionStmt, T_TruncateStmt, T_UnlistenStmt, T_UpdateStmt, T_VacuumStmt, T_VariableSetStmt, T_VariableShowStmt, T_ViewStmt, TRANS_STMT_BEGIN, TRANS_STMT_COMMIT, TRANS_STMT_COMMIT_PREPARED, TRANS_STMT_PREPARE, TRANS_STMT_RELEASE, TRANS_STMT_ROLLBACK, TRANS_STMT_ROLLBACK_PREPARED, TRANS_STMT_ROLLBACK_TO, TRANS_STMT_SAVEPOINT, TRANS_STMT_START, PlannedStmt::utilityStmt, Query::utilityStmt, VAR_RESET, VAR_RESET_ALL, VAR_SET_CURRENT, VAR_SET_DEFAULT, VAR_SET_MULTI, VAR_SET_VALUE, and WARNING.

Referenced by _SPI_prepare_oneshot_plan(), _SPI_prepare_plan(), CreateCommandName(), CreateCommandTag(), EventTriggerCommonSetup(), exec_parse_message(), exec_simple_query(), interpret_AS_clause(), PrepareQuery(), and standard_ProcessUtility().

2338 {
2339  CommandTag tag;
2340 
2341  switch (nodeTag(parsetree))
2342  {
2343  /* recurse if we're given a RawStmt */
2344  case T_RawStmt:
2345  tag = CreateCommandTag(((RawStmt *) parsetree)->stmt);
2346  break;
2347 
2348  /* raw plannable queries */
2349  case T_InsertStmt:
2350  tag = CMDTAG_INSERT;
2351  break;
2352 
2353  case T_DeleteStmt:
2354  tag = CMDTAG_DELETE;
2355  break;
2356 
2357  case T_UpdateStmt:
2358  tag = CMDTAG_UPDATE;
2359  break;
2360 
2361  case T_SelectStmt:
2362  tag = CMDTAG_SELECT;
2363  break;
2364 
2365  case T_PLAssignStmt:
2366  tag = CMDTAG_SELECT;
2367  break;
2368 
2369  /* utility statements --- same whether raw or cooked */
2370  case T_TransactionStmt:
2371  {
2372  TransactionStmt *stmt = (TransactionStmt *) parsetree;
2373 
2374  switch (stmt->kind)
2375  {
2376  case TRANS_STMT_BEGIN:
2377  tag = CMDTAG_BEGIN;
2378  break;
2379 
2380  case TRANS_STMT_START:
2381  tag = CMDTAG_START_TRANSACTION;
2382  break;
2383 
2384  case TRANS_STMT_COMMIT:
2385  tag = CMDTAG_COMMIT;
2386  break;
2387 
2388  case TRANS_STMT_ROLLBACK:
2389  case TRANS_STMT_ROLLBACK_TO:
2390  tag = CMDTAG_ROLLBACK;
2391  break;
2392 
2393  case TRANS_STMT_SAVEPOINT:
2394  tag = CMDTAG_SAVEPOINT;
2395  break;
2396 
2397  case TRANS_STMT_RELEASE:
2398  tag = CMDTAG_RELEASE;
2399  break;
2400 
2401  case TRANS_STMT_PREPARE:
2402  tag = CMDTAG_PREPARE_TRANSACTION;
2403  break;
2404 
2405  case TRANS_STMT_COMMIT_PREPARED:
2406  tag = CMDTAG_COMMIT_PREPARED;
2407  break;
2408 
2409  case TRANS_STMT_ROLLBACK_PREPARED:
2410  tag = CMDTAG_ROLLBACK_PREPARED;
2411  break;
2412 
2413  default:
2414  tag = CMDTAG_UNKNOWN;
2415  break;
2416  }
2417  }
2418  break;
2419 
2420  case T_DeclareCursorStmt:
2421  tag = CMDTAG_DECLARE_CURSOR;
2422  break;
2423 
2424  case T_ClosePortalStmt:
2425  {
2426  ClosePortalStmt *stmt = (ClosePortalStmt *) parsetree;
2427 
2428  if (stmt->portalname == NULL)
2429  tag = CMDTAG_CLOSE_CURSOR_ALL;
2430  else
2431  tag = CMDTAG_CLOSE_CURSOR;
2432  }
2433  break;
2434 
2435  case T_FetchStmt:
2436  {
2437  FetchStmt *stmt = (FetchStmt *) parsetree;
2438 
2439  tag = (stmt->ismove) ? CMDTAG_MOVE : CMDTAG_FETCH;
2440  }
2441  break;
2442 
2443  case T_CreateDomainStmt:
2444  tag = CMDTAG_CREATE_DOMAIN;
2445  break;
2446 
2447  case T_CreateSchemaStmt:
2448  tag = CMDTAG_CREATE_SCHEMA;
2449  break;
2450 
2451  case T_CreateStmt:
2452  tag = CMDTAG_CREATE_TABLE;
2453  break;
2454 
2455  case T_CreateTableSpaceStmt:
2456  tag = CMDTAG_CREATE_TABLESPACE;
2457  break;
2458 
2459  case T_DropTableSpaceStmt:
2460  tag = CMDTAG_DROP_TABLESPACE;
2461  break;
2462 
2463  case T_AlterTableSpaceOptionsStmt:
2464  tag = CMDTAG_ALTER_TABLESPACE;
2465  break;
2466 
2467  case T_CreateExtensionStmt:
2468  tag = CMDTAG_CREATE_EXTENSION;
2469  break;
2470 
2471  case T_AlterExtensionStmt:
2472  tag = CMDTAG_ALTER_EXTENSION;
2473  break;
2474 
2475  case T_AlterExtensionContentsStmt:
2476  tag = CMDTAG_ALTER_EXTENSION;
2477  break;
2478 
2479  case T_CreateFdwStmt:
2480  tag = CMDTAG_CREATE_FOREIGN_DATA_WRAPPER;
2481  break;
2482 
2483  case T_AlterFdwStmt:
2484  tag = CMDTAG_ALTER_FOREIGN_DATA_WRAPPER;
2485  break;
2486 
2487  case T_CreateForeignServerStmt:
2488  tag = CMDTAG_CREATE_SERVER;
2489  break;
2490 
2491  case T_AlterForeignServerStmt:
2492  tag = CMDTAG_ALTER_SERVER;
2493  break;
2494 
2495  case T_CreateUserMappingStmt:
2496  tag = CMDTAG_CREATE_USER_MAPPING;
2497  break;
2498 
2499  case T_AlterUserMappingStmt:
2500  tag = CMDTAG_ALTER_USER_MAPPING;
2501  break;
2502 
2503  case T_DropUserMappingStmt:
2504  tag = CMDTAG_DROP_USER_MAPPING;
2505  break;
2506 
2507  case T_CreateForeignTableStmt:
2508  tag = CMDTAG_CREATE_FOREIGN_TABLE;
2509  break;
2510 
2511  case T_ImportForeignSchemaStmt:
2512  tag = CMDTAG_IMPORT_FOREIGN_SCHEMA;
2513  break;
2514 
2515  case T_DropStmt:
2516  switch (((DropStmt *) parsetree)->removeType)
2517  {
2518  case OBJECT_TABLE:
2519  tag = CMDTAG_DROP_TABLE;
2520  break;
2521  case OBJECT_SEQUENCE:
2522  tag = CMDTAG_DROP_SEQUENCE;
2523  break;
2524  case OBJECT_VIEW:
2525  tag = CMDTAG_DROP_VIEW;
2526  break;
2527  case OBJECT_MATVIEW:
2528  tag = CMDTAG_DROP_MATERIALIZED_VIEW;
2529  break;
2530  case OBJECT_INDEX:
2531  tag = CMDTAG_DROP_INDEX;
2532  break;
2533  case OBJECT_TYPE:
2534  tag = CMDTAG_DROP_TYPE;
2535  break;
2536  case OBJECT_DOMAIN:
2537  tag = CMDTAG_DROP_DOMAIN;
2538  break;
2539  case OBJECT_COLLATION:
2540  tag = CMDTAG_DROP_COLLATION;
2541  break;
2542  case OBJECT_CONVERSION:
2543  tag = CMDTAG_DROP_CONVERSION;
2544  break;
2545  case OBJECT_SCHEMA:
2546  tag = CMDTAG_DROP_SCHEMA;
2547  break;
2548  case OBJECT_TSPARSER:
2549  tag = CMDTAG_DROP_TEXT_SEARCH_PARSER;
2550  break;
2551  case OBJECT_TSDICTIONARY:
2552  tag = CMDTAG_DROP_TEXT_SEARCH_DICTIONARY;
2553  break;
2554  case OBJECT_TSTEMPLATE:
2555  tag = CMDTAG_DROP_TEXT_SEARCH_TEMPLATE;
2556  break;
2557  case OBJECT_TSCONFIGURATION:
2558  tag = CMDTAG_DROP_TEXT_SEARCH_CONFIGURATION;
2559  break;
2560  case OBJECT_FOREIGN_TABLE:
2561  tag = CMDTAG_DROP_FOREIGN_TABLE;
2562  break;
2563  case OBJECT_EXTENSION:
2564  tag = CMDTAG_DROP_EXTENSION;
2565  break;
2566  case OBJECT_FUNCTION:
2567  tag = CMDTAG_DROP_FUNCTION;
2568  break;
2569  case OBJECT_PROCEDURE:
2570  tag = CMDTAG_DROP_PROCEDURE;
2571  break;
2572  case OBJECT_ROUTINE:
2573  tag = CMDTAG_DROP_ROUTINE;
2574  break;
2575  case OBJECT_AGGREGATE:
2576  tag = CMDTAG_DROP_AGGREGATE;
2577  break;
2578  case OBJECT_OPERATOR:
2579  tag = CMDTAG_DROP_OPERATOR;
2580  break;
2581  case OBJECT_LANGUAGE:
2582  tag = CMDTAG_DROP_LANGUAGE;
2583  break;
2584  case OBJECT_CAST:
2585  tag = CMDTAG_DROP_CAST;
2586  break;
2587  case OBJECT_TRIGGER:
2588  tag = CMDTAG_DROP_TRIGGER;
2589  break;
2590  case OBJECT_EVENT_TRIGGER:
2591  tag = CMDTAG_DROP_EVENT_TRIGGER;
2592  break;
2593  case OBJECT_RULE:
2594  tag = CMDTAG_DROP_RULE;
2595  break;
2596  case OBJECT_FDW:
2597  tag = CMDTAG_DROP_FOREIGN_DATA_WRAPPER;
2598  break;
2599  case OBJECT_FOREIGN_SERVER:
2600  tag = CMDTAG_DROP_SERVER;
2601  break;
2602  case OBJECT_OPCLASS:
2603  tag = CMDTAG_DROP_OPERATOR_CLASS;
2604  break;
2605  case OBJECT_OPFAMILY:
2606  tag = CMDTAG_DROP_OPERATOR_FAMILY;
2607  break;
2608  case OBJECT_POLICY:
2609  tag = CMDTAG_DROP_POLICY;
2610  break;
2611  case OBJECT_TRANSFORM:
2612  tag = CMDTAG_DROP_TRANSFORM;
2613  break;
2614  case OBJECT_ACCESS_METHOD:
2615  tag = CMDTAG_DROP_ACCESS_METHOD;
2616  break;
2617  case OBJECT_PUBLICATION:
2618  tag = CMDTAG_DROP_PUBLICATION;
2619  break;
2620  case OBJECT_STATISTIC_EXT:
2621  tag = CMDTAG_DROP_STATISTICS;
2622  break;
2623  default:
2624  tag = CMDTAG_UNKNOWN;
2625  }
2626  break;
2627 
2628  case T_TruncateStmt:
2629  tag = CMDTAG_TRUNCATE_TABLE;
2630  break;
2631 
2632  case T_CommentStmt:
2633  tag = CMDTAG_COMMENT;
2634  break;
2635 
2636  case T_SecLabelStmt:
2637  tag = CMDTAG_SECURITY_LABEL;
2638  break;
2639 
2640  case T_CopyStmt:
2641  tag = CMDTAG_COPY;
2642  break;
2643 
2644  case T_RenameStmt:
2645 
2646  /*
2647  * When the column is renamed, the command tag is created from its
2648  * relation type
2649  */
2650  tag = AlterObjectTypeCommandTag(((RenameStmt *) parsetree)->renameType == OBJECT_COLUMN ?
2651  ((RenameStmt *) parsetree)->relationType :
2652  ((RenameStmt *) parsetree)->renameType);
2653  break;
2654 
2655  case T_AlterObjectDependsStmt:
2656  tag = AlterObjectTypeCommandTag(((AlterObjectDependsStmt *) parsetree)->objectType);
2657  break;
2658 
2659  case T_AlterObjectSchemaStmt:
2660  tag = AlterObjectTypeCommandTag(((AlterObjectSchemaStmt *) parsetree)->objectType);
2661  break;
2662 
2663  case T_AlterOwnerStmt:
2664  tag = AlterObjectTypeCommandTag(((AlterOwnerStmt *) parsetree)->objectType);
2665  break;
2666 
2667  case T_AlterTableMoveAllStmt:
2668  tag = AlterObjectTypeCommandTag(((AlterTableMoveAllStmt *) parsetree)->objtype);
2669  break;
2670 
2671  case T_AlterTableStmt:
2672  tag = AlterObjectTypeCommandTag(((AlterTableStmt *) parsetree)->objtype);
2673  break;
2674 
2675  case T_AlterDomainStmt:
2676  tag = CMDTAG_ALTER_DOMAIN;
2677  break;
2678 
2679  case T_AlterFunctionStmt:
2680  switch (((AlterFunctionStmt *) parsetree)->objtype)
2681  {
2682  case OBJECT_FUNCTION:
2683  tag = CMDTAG_ALTER_FUNCTION;
2684  break;
2685  case OBJECT_PROCEDURE:
2686  tag = CMDTAG_ALTER_PROCEDURE;
2687  break;
2688  case OBJECT_ROUTINE:
2689  tag = CMDTAG_ALTER_ROUTINE;
2690  break;
2691  default:
2692  tag = CMDTAG_UNKNOWN;
2693  }
2694  break;
2695 
2696  case T_GrantStmt:
2697  {
2698  GrantStmt *stmt = (GrantStmt *) parsetree;
2699 
2700  tag = (stmt->is_grant) ? CMDTAG_GRANT : CMDTAG_REVOKE;
2701  }
2702  break;
2703 
2704  case T_GrantRoleStmt:
2705  {
2706  GrantRoleStmt *stmt = (GrantRoleStmt *) parsetree;
2707 
2708  tag = (stmt->is_grant) ? CMDTAG_GRANT_ROLE : CMDTAG_REVOKE_ROLE;
2709  }
2710  break;
2711 
2712  case T_AlterDefaultPrivilegesStmt:
2713  tag = CMDTAG_ALTER_DEFAULT_PRIVILEGES;
2714  break;
2715 
2716  case T_DefineStmt:
2717  switch (((DefineStmt *) parsetree)->kind)
2718  {
2719  case OBJECT_AGGREGATE:
2720  tag = CMDTAG_CREATE_AGGREGATE;
2721  break;
2722  case OBJECT_OPERATOR:
2723  tag = CMDTAG_CREATE_OPERATOR;
2724  break;
2725  case OBJECT_TYPE:
2726  tag = CMDTAG_CREATE_TYPE;
2727  break;
2728  case OBJECT_TSPARSER:
2729  tag = CMDTAG_CREATE_TEXT_SEARCH_PARSER;
2730  break;
2731  case OBJECT_TSDICTIONARY:
2732  tag = CMDTAG_CREATE_TEXT_SEARCH_DICTIONARY;
2733  break;
2734  case OBJECT_TSTEMPLATE:
2735  tag = CMDTAG_CREATE_TEXT_SEARCH_TEMPLATE;
2736  break;
2737  case OBJECT_TSCONFIGURATION:
2738  tag = CMDTAG_CREATE_TEXT_SEARCH_CONFIGURATION;
2739  break;
2740  case OBJECT_COLLATION:
2741  tag = CMDTAG_CREATE_COLLATION;
2742  break;
2743  case OBJECT_ACCESS_METHOD:
2744  tag = CMDTAG_CREATE_ACCESS_METHOD;
2745  break;
2746  default:
2747  tag = CMDTAG_UNKNOWN;
2748  }
2749  break;
2750 
2751  case T_CompositeTypeStmt:
2752  tag = CMDTAG_CREATE_TYPE;
2753  break;
2754 
2755  case T_CreateEnumStmt:
2756  tag = CMDTAG_CREATE_TYPE;
2757  break;
2758 
2759  case T_CreateRangeStmt:
2760  tag = CMDTAG_CREATE_TYPE;
2761  break;
2762 
2763  case T_AlterEnumStmt:
2764  tag = CMDTAG_ALTER_TYPE;
2765  break;
2766 
2767  case T_ViewStmt:
2768  tag = CMDTAG_CREATE_VIEW;
2769  break;
2770 
2771  case T_CreateFunctionStmt:
2772  if (((CreateFunctionStmt *) parsetree)->is_procedure)
2773  tag = CMDTAG_CREATE_PROCEDURE;
2774  else
2775  tag = CMDTAG_CREATE_FUNCTION;
2776  break;
2777 
2778  case T_IndexStmt:
2779  tag = CMDTAG_CREATE_INDEX;
2780  break;
2781 
2782  case T_RuleStmt:
2783  tag = CMDTAG_CREATE_RULE;
2784  break;
2785 
2786  case T_CreateSeqStmt:
2787  tag = CMDTAG_CREATE_SEQUENCE;
2788  break;
2789 
2790  case T_AlterSeqStmt:
2791  tag = CMDTAG_ALTER_SEQUENCE;
2792  break;
2793 
2794  case T_DoStmt:
2795  tag = CMDTAG_DO;
2796  break;
2797 
2798  case T_CreatedbStmt:
2799  tag = CMDTAG_CREATE_DATABASE;
2800  break;
2801 
2802  case T_AlterDatabaseStmt:
2803  tag = CMDTAG_ALTER_DATABASE;
2804  break;
2805 
2806  case T_AlterDatabaseSetStmt:
2807  tag = CMDTAG_ALTER_DATABASE;
2808  break;
2809 
2810  case T_DropdbStmt:
2811  tag = CMDTAG_DROP_DATABASE;
2812  break;
2813 
2814  case T_NotifyStmt:
2815  tag = CMDTAG_NOTIFY;
2816  break;
2817 
2818  case T_ListenStmt:
2819  tag = CMDTAG_LISTEN;
2820  break;
2821 
2822  case T_UnlistenStmt:
2823  tag = CMDTAG_UNLISTEN;
2824  break;
2825 
2826  case T_LoadStmt:
2827  tag = CMDTAG_LOAD;
2828  break;
2829 
2830  case T_CallStmt:
2831  tag = CMDTAG_CALL;
2832  break;
2833 
2834  case T_ClusterStmt:
2835  tag = CMDTAG_CLUSTER;
2836  break;
2837 
2838  case T_VacuumStmt:
2839  if (((VacuumStmt *) parsetree)->is_vacuumcmd)
2840  tag = CMDTAG_VACUUM;
2841  else
2842  tag = CMDTAG_ANALYZE;
2843  break;
2844 
2845  case T_ExplainStmt:
2846  tag = CMDTAG_EXPLAIN;
2847  break;
2848 
2849  case T_CreateTableAsStmt:
2850  switch (((CreateTableAsStmt *) parsetree)->objtype)
2851  {
2852  case OBJECT_TABLE:
2853  if (((CreateTableAsStmt *) parsetree)->is_select_into)
2854  tag = CMDTAG_SELECT_INTO;
2855  else
2856  tag = CMDTAG_CREATE_TABLE_AS;
2857  break;
2858  case OBJECT_MATVIEW:
2859  tag = CMDTAG_CREATE_MATERIALIZED_VIEW;
2860  break;
2861  default:
2862  tag = CMDTAG_UNKNOWN;
2863  }
2864  break;
2865 
2866  case T_RefreshMatViewStmt:
2867  tag = CMDTAG_REFRESH_MATERIALIZED_VIEW;
2868  break;
2869 
2870  case T_AlterSystemStmt:
2871  tag = CMDTAG_ALTER_SYSTEM;
2872  break;
2873 
2874  case T_VariableSetStmt:
2875  switch (((VariableSetStmt *) parsetree)->kind)
2876  {
2877  case VAR_SET_VALUE:
2878  case VAR_SET_CURRENT:
2879  case VAR_SET_DEFAULT:
2880  case VAR_SET_MULTI:
2881  tag = CMDTAG_SET;
2882  break;
2883  case VAR_RESET:
2884  case VAR_RESET_ALL:
2885  tag = CMDTAG_RESET;
2886  break;
2887  default:
2888  tag = CMDTAG_UNKNOWN;
2889  }
2890  break;
2891 
2892  case T_VariableShowStmt:
2893  tag = CMDTAG_SHOW;
2894  break;
2895 
2896  case T_DiscardStmt:
2897  switch (((DiscardStmt *) parsetree)->target)
2898  {
2899  case DISCARD_ALL:
2900  tag = CMDTAG_DISCARD_ALL;
2901  break;
2902  case DISCARD_PLANS:
2903  tag = CMDTAG_DISCARD_PLANS;
2904  break;
2905  case DISCARD_TEMP:
2906  tag = CMDTAG_DISCARD_TEMP;
2907  break;
2908  case DISCARD_SEQUENCES:
2909  tag = CMDTAG_DISCARD_SEQUENCES;
2910  break;
2911  default:
2912  tag = CMDTAG_UNKNOWN;
2913  }
2914  break;
2915 
2916  case T_CreateTransformStmt:
2917  tag = CMDTAG_CREATE_TRANSFORM;
2918  break;
2919 
2920  case T_CreateTrigStmt:
2921  tag = CMDTAG_CREATE_TRIGGER;
2922  break;
2923 
2924  case T_CreateEventTrigStmt:
2925  tag = CMDTAG_CREATE_EVENT_TRIGGER;
2926  break;
2927 
2928  case T_AlterEventTrigStmt:
2929  tag = CMDTAG_ALTER_EVENT_TRIGGER;
2930  break;
2931 
2932  case T_CreatePLangStmt:
2933  tag = CMDTAG_CREATE_LANGUAGE;
2934  break;
2935 
2936  case T_CreateRoleStmt:
2937  tag = CMDTAG_CREATE_ROLE;
2938  break;
2939 
2940  case T_AlterRoleStmt:
2941  tag = CMDTAG_ALTER_ROLE;
2942  break;
2943 
2944  case T_AlterRoleSetStmt:
2945  tag = CMDTAG_ALTER_ROLE;
2946  break;
2947 
2948  case T_DropRoleStmt:
2949  tag = CMDTAG_DROP_ROLE;
2950  break;
2951 
2952  case T_DropOwnedStmt:
2953  tag = CMDTAG_DROP_OWNED;
2954  break;
2955 
2956  case T_ReassignOwnedStmt:
2957  tag = CMDTAG_REASSIGN_OWNED;
2958  break;
2959 
2960  case T_LockStmt:
2961  tag = CMDTAG_LOCK_TABLE;
2962  break;
2963 
2964  case T_ConstraintsSetStmt:
2965  tag = CMDTAG_SET_CONSTRAINTS;
2966  break;
2967 
2968  case T_CheckPointStmt:
2969  tag = CMDTAG_CHECKPOINT;
2970  break;
2971 
2972  case T_ReindexStmt:
2973  tag = CMDTAG_REINDEX;
2974  break;
2975 
2976  case T_CreateConversionStmt:
2977  tag = CMDTAG_CREATE_CONVERSION;
2978  break;
2979 
2980  case T_CreateCastStmt:
2981  tag = CMDTAG_CREATE_CAST;
2982  break;
2983 
2984  case T_CreateOpClassStmt:
2985  tag = CMDTAG_CREATE_OPERATOR_CLASS;
2986  break;
2987 
2988  case T_CreateOpFamilyStmt:
2989  tag = CMDTAG_CREATE_OPERATOR_FAMILY;
2990  break;
2991 
2992  case T_AlterOpFamilyStmt:
2993  tag = CMDTAG_ALTER_OPERATOR_FAMILY;
2994  break;
2995 
2996  case T_AlterOperatorStmt:
2997  tag = CMDTAG_ALTER_OPERATOR;
2998  break;
2999 
3000  case T_AlterTypeStmt:
3001  tag = CMDTAG_ALTER_TYPE;
3002  break;
3003 
3004  case T_AlterTSDictionaryStmt:
3005  tag = CMDTAG_ALTER_TEXT_SEARCH_DICTIONARY;
3006  break;
3007 
3008  case T_AlterTSConfigurationStmt:
3009  tag = CMDTAG_ALTER_TEXT_SEARCH_CONFIGURATION;
3010  break;
3011 
3012  case T_CreatePolicyStmt:
3013  tag = CMDTAG_CREATE_POLICY;
3014  break;
3015 
3016  case T_AlterPolicyStmt:
3017  tag = CMDTAG_ALTER_POLICY;
3018  break;
3019 
3020  case T_CreateAmStmt:
3021  tag = CMDTAG_CREATE_ACCESS_METHOD;
3022  break;
3023 
3024  case T_CreatePublicationStmt:
3025  tag = CMDTAG_CREATE_PUBLICATION;
3026  break;
3027 
3028  case T_AlterPublicationStmt:
3029  tag = CMDTAG_ALTER_PUBLICATION;
3030  break;
3031 
3032  case T_CreateSubscriptionStmt:
3033  tag = CMDTAG_CREATE_SUBSCRIPTION;
3034  break;
3035 
3036  case T_AlterSubscriptionStmt:
3037  tag = CMDTAG_ALTER_SUBSCRIPTION;
3038  break;
3039 
3040  case T_DropSubscriptionStmt:
3041  tag = CMDTAG_DROP_SUBSCRIPTION;
3042  break;
3043 
3044  case T_AlterCollationStmt:
3045  tag = CMDTAG_ALTER_COLLATION;
3046  break;
3047 
3048  case T_PrepareStmt:
3049  tag = CMDTAG_PREPARE;
3050  break;
3051 
3052  case T_ExecuteStmt:
3053  tag = CMDTAG_EXECUTE;
3054  break;
3055 
3056  case T_CreateStatsStmt:
3057  tag = CMDTAG_CREATE_STATISTICS;
3058  break;
3059 
3060  case T_AlterStatsStmt:
3061  tag = CMDTAG_ALTER_STATISTICS;
3062  break;
3063 
3064  case T_DeallocateStmt:
3065  {
3066  DeallocateStmt *stmt = (DeallocateStmt *) parsetree;
3067 
3068  if (stmt->name == NULL)
3069  tag = CMDTAG_DEALLOCATE_ALL;
3070  else
3071  tag = CMDTAG_DEALLOCATE;
3072  }
3073  break;
3074 
3075  /* already-planned queries */
3076  case T_PlannedStmt:
3077  {
3078  PlannedStmt *stmt = (PlannedStmt *) parsetree;
3079 
3080  switch (stmt->commandType)
3081  {
3082  case CMD_SELECT:
3083 
3084  /*
3085  * We take a little extra care here so that the result
3086  * will be useful for complaints about read-only
3087  * statements
3088  */
3089  if (stmt->rowMarks != NIL)
3090  {
3091  /* not 100% but probably close enough */
3092  switch (((PlanRowMark *) linitial(stmt->rowMarks))->strength)
3093  {
3094  case LCS_FORKEYSHARE:
3095  tag = CMDTAG_SELECT_FOR_KEY_SHARE;
3096  break;
3097  case LCS_FORSHARE:
3098  tag = CMDTAG_SELECT_FOR_SHARE;
3099  break;
3100  case LCS_FORNOKEYUPDATE:
3101  tag = CMDTAG_SELECT_FOR_NO_KEY_UPDATE;
3102  break;
3103  case LCS_FORUPDATE:
3104  tag = CMDTAG_SELECT_FOR_UPDATE;
3105  break;
3106  default:
3107  tag = CMDTAG_SELECT;
3108  break;
3109  }
3110  }
3111  else
3112  tag = CMDTAG_SELECT;
3113  break;
3114  case CMD_UPDATE:
3115  tag = CMDTAG_UPDATE;
3116  break;
3117  case CMD_INSERT:
3118  tag = CMDTAG_INSERT;
3119  break;
3120  case CMD_DELETE:
3121  tag = CMDTAG_DELETE;
3122  break;
3123  case CMD_UTILITY:
3124  tag = CreateCommandTag(stmt->utilityStmt);
3125  break;
3126  default:
3127  elog(WARNING, "unrecognized commandType: %d",
3128  (int) stmt->commandType);
3129  tag = CMDTAG_UNKNOWN;
3130  break;
3131  }
3132  }
3133  break;
3134 
3135  /* parsed-and-rewritten-but-not-planned queries */
3136  case T_Query:
3137  {
3138  Query *stmt = (Query *) parsetree;
3139 
3140  switch (stmt->commandType)
3141  {
3142  case CMD_SELECT:
3143 
3144  /*
3145  * We take a little extra care here so that the result
3146  * will be useful for complaints about read-only
3147  * statements
3148  */
3149  if (stmt->rowMarks != NIL)
3150  {
3151  /* not 100% but probably close enough */
3152  switch (((RowMarkClause *) linitial(stmt->rowMarks))->strength)
3153  {
3154  case LCS_FORKEYSHARE:
3155  tag = CMDTAG_SELECT_FOR_KEY_SHARE;
3156  break;
3157  case LCS_FORSHARE:
3158  tag = CMDTAG_SELECT_FOR_SHARE;
3159  break;
3160  case LCS_FORNOKEYUPDATE:
3161  tag = CMDTAG_SELECT_FOR_NO_KEY_UPDATE;
3162  break;
3163  case LCS_FORUPDATE:
3164  tag = CMDTAG_SELECT_FOR_UPDATE;
3165  break;
3166  default:
3167  tag = CMDTAG_UNKNOWN;
3168  break;
3169  }
3170  }
3171  else
3172  tag = CMDTAG_SELECT;
3173  break;
3174  case CMD_UPDATE:
3175  tag = CMDTAG_UPDATE;
3176  break;
3177  case CMD_INSERT:
3178  tag = CMDTAG_INSERT;
3179  break;
3180  case CMD_DELETE:
3181  tag = CMDTAG_DELETE;
3182  break;
3183  case CMD_UTILITY:
3184  tag = CreateCommandTag(stmt->utilityStmt);
3185  break;
3186  default:
3187  elog(WARNING, "unrecognized commandType: %d",
3188  (int) stmt->commandType);
3189  tag = CMDTAG_UNKNOWN;
3190  break;
3191  }
3192  }
3193  break;
3194 
3195  default:
3196  elog(WARNING, "unrecognized node type: %d",
3197  (int) nodeTag(parsetree));
3198  tag = CMDTAG_UNKNOWN;
3199  break;
3200  }
3201 
3202  return tag;
3203 }
NIL
#define NIL
Definition: pg_list.h:65
CommandTag
CommandTag
Definition: cmdtag.h:20
AlterObjectTypeCommandTag
static CommandTag AlterObjectTypeCommandTag(ObjectType objtype)
Definition: utility.c:2191
Query::rowMarks
List * rowMarks
Definition: parsenodes.h:175
Query::utilityStmt
Node * utilityStmt
Definition: parsenodes.h:128
linitial
#define linitial(l)
Definition: pg_list.h:174
PlannedStmt::utilityStmt
Node * utilityStmt
Definition: plannodes.h:86
GrantStmt::is_grant
bool is_grant
Definition: parsenodes.h:2026
WARNING
#define WARNING
Definition: elog.h:40
T_Query
Definition: nodes.h:314
FetchStmt::ismove
bool ismove
Definition: parsenodes.h:2871
PlannedStmt::commandType
CmdType commandType
Definition: plannodes.h:46
PlannedStmt::rowMarks
List * rowMarks
Definition: plannodes.h:78
Query::commandType
CmdType commandType
Definition: parsenodes.h:120
CreateCommandTag
CommandTag CreateCommandTag(Node *parsetree)
Definition: utility.c:2337
nodeTag
#define nodeTag(nodeptr)
Definition: nodes.h:541
elog
#define elog(elevel,...)
Definition: elog.h:232
TransactionStmt::kind
TransactionStmtKind kind
Definition: parsenodes.h:3197

◆ ExecDropStmt()

static void ExecDropStmt ( DropStmt *  stmt,
bool  isTopLevel 
)
static

Definition at line 1971 of file utility.c.

References DropStmt::concurrent, OBJECT_FOREIGN_TABLE, OBJECT_INDEX, OBJECT_MATVIEW, OBJECT_SEQUENCE, OBJECT_TABLE, OBJECT_VIEW, PreventInTransactionBlock(), RemoveObjects(), RemoveRelations(), and DropStmt::removeType.

Referenced by ProcessUtilitySlow(), and standard_ProcessUtility().

1972 {
1973  switch (stmt->removeType)
1974  {
1975  case OBJECT_INDEX:
1976  if (stmt->concurrent)
1977  PreventInTransactionBlock(isTopLevel,
1978  "DROP INDEX CONCURRENTLY");
1979  /* fall through */
1980 
1981  case OBJECT_TABLE:
1982  case OBJECT_SEQUENCE:
1983  case OBJECT_VIEW:
1984  case OBJECT_MATVIEW:
1985  case OBJECT_FOREIGN_TABLE:
1986  RemoveRelations(stmt);
1987  break;
1988  default:
1989  RemoveObjects(stmt);
1990  break;
1991  }
1992 }
RemoveObjects
void RemoveObjects(DropStmt *stmt)
Definition: dropcmds.c:57
DropStmt::removeType
ObjectType removeType
Definition: parsenodes.h:2767
RemoveRelations
void RemoveRelations(DropStmt *drop)
Definition: tablecmds.c:1307
DropStmt::concurrent
bool concurrent
Definition: parsenodes.h:2770
PreventInTransactionBlock
void PreventInTransactionBlock(bool isTopLevel, const char *stmtType)
Definition: xact.c:3389

◆ GetCommandLogLevel()

LogStmtLevel GetCommandLogLevel ( Node *  parsetree)

Definition at line 3216 of file utility.c.

References analyze(), CMD_DELETE, CMD_INSERT, CMD_SELECT, CMD_UPDATE, CMD_UTILITY, PlannedStmt::commandType, Query::commandType, defGetBoolean(), DefElem::defname, elog, FetchPreparedStatement(), GetCommandLogLevel(), lfirst, LOGSTMT_ALL, LOGSTMT_DDL, LOGSTMT_MOD, ExecuteStmt::name, nodeTag, ExplainStmt::options, PreparedStatement::plansource, ExplainStmt::query, PrepareStmt::query, CachedPlanSource::raw_parse_tree, RawStmt::stmt, T_AlterCollationStmt, T_AlterDatabaseSetStmt, T_AlterDatabaseStmt, T_AlterDefaultPrivilegesStmt, T_AlterDomainStmt, T_AlterEnumStmt, T_AlterEventTrigStmt, T_AlterExtensionContentsStmt, T_AlterExtensionStmt, T_AlterFdwStmt, T_AlterForeignServerStmt, T_AlterFunctionStmt, T_AlterObjectDependsStmt, T_AlterObjectSchemaStmt, T_AlterOperatorStmt, T_AlterOpFamilyStmt, T_AlterOwnerStmt, T_AlterPolicyStmt, T_AlterPublicationStmt, T_AlterRoleSetStmt, T_AlterRoleStmt, T_AlterSeqStmt, T_AlterStatsStmt, T_AlterSubscriptionStmt, T_AlterSystemStmt, T_AlterTableMoveAllStmt, T_AlterTableSpaceOptionsStmt, T_AlterTableStmt, T_AlterTSConfigurationStmt, T_AlterTSDictionaryStmt, T_AlterTypeStmt, T_AlterUserMappingStmt, T_CallStmt, T_CheckPointStmt, T_ClosePortalStmt, T_ClusterStmt, T_CommentStmt, T_CompositeTypeStmt, T_ConstraintsSetStmt, T_CopyStmt, T_CreateAmStmt, T_CreateCastStmt, T_CreateConversionStmt, T_CreatedbStmt, T_CreateDomainStmt, T_CreateEnumStmt, T_CreateEventTrigStmt, T_CreateExtensionStmt, T_CreateFdwStmt, T_CreateForeignServerStmt, T_CreateForeignTableStmt, T_CreateFunctionStmt, T_CreateOpClassStmt, T_CreateOpFamilyStmt, T_CreatePLangStmt, T_CreatePolicyStmt, T_CreatePublicationStmt, T_CreateRangeStmt, T_CreateRoleStmt, T_CreateSchemaStmt, T_CreateSeqStmt, T_CreateStatsStmt, T_CreateStmt, T_CreateSubscriptionStmt, T_CreateTableAsStmt, T_CreateTableSpaceStmt, T_CreateTransformStmt, T_CreateTrigStmt, T_CreateUserMappingStmt, T_DeallocateStmt, T_DeclareCursorStmt, T_DefineStmt, T_DeleteStmt, T_DiscardStmt, T_DoStmt, T_DropdbStmt, T_DropOwnedStmt, T_DropRoleStmt, T_DropStmt, T_DropSubscriptionStmt, T_DropTableSpaceStmt, T_DropUserMappingStmt, T_ExecuteStmt, T_ExplainStmt, T_FetchStmt, T_GrantRoleStmt, T_GrantStmt, T_ImportForeignSchemaStmt, T_IndexStmt, T_InsertStmt, T_ListenStmt, T_LoadStmt, T_LockStmt, T_NotifyStmt, T_PlannedStmt, T_PLAssignStmt, T_PrepareStmt, T_Query, T_RawStmt, T_ReassignOwnedStmt, T_RefreshMatViewStmt, T_ReindexStmt, T_RenameStmt, T_RuleStmt, T_SecLabelStmt, T_SelectStmt, T_TransactionStmt, T_TruncateStmt, T_UnlistenStmt, T_UpdateStmt, T_VacuumStmt, T_VariableSetStmt, T_VariableShowStmt, T_ViewStmt, PlannedStmt::utilityStmt, Query::utilityStmt, and WARNING.

Referenced by check_log_statement(), CreateCommandName(), and GetCommandLogLevel().

3217 {
3218  LogStmtLevel lev;
3219 
3220  switch (nodeTag(parsetree))
3221  {
3222  /* recurse if we're given a RawStmt */
3223  case T_RawStmt:
3224  lev = GetCommandLogLevel(((RawStmt *) parsetree)->stmt);
3225  break;
3226 
3227  /* raw plannable queries */
3228  case T_InsertStmt:
3229  case T_DeleteStmt:
3230  case T_UpdateStmt:
3231  lev = LOGSTMT_MOD;
3232  break;
3233 
3234  case T_SelectStmt:
3235  if (((SelectStmt *) parsetree)->intoClause)
3236  lev = LOGSTMT_DDL; /* SELECT INTO */
3237  else
3238  lev = LOGSTMT_ALL;
3239  break;
3240 
3241  case T_PLAssignStmt:
3242  lev = LOGSTMT_ALL;
3243  break;
3244 
3245  /* utility statements --- same whether raw or cooked */
3246  case T_TransactionStmt:
3247  lev = LOGSTMT_ALL;
3248  break;
3249 
3250  case T_DeclareCursorStmt:
3251  lev = LOGSTMT_ALL;
3252  break;
3253 
3254  case T_ClosePortalStmt:
3255  lev = LOGSTMT_ALL;
3256  break;
3257 
3258  case T_FetchStmt:
3259  lev = LOGSTMT_ALL;
3260  break;
3261 
3262  case T_CreateSchemaStmt:
3263  lev = LOGSTMT_DDL;
3264  break;
3265 
3266  case T_CreateStmt:
3267  case T_CreateForeignTableStmt:
3268  lev = LOGSTMT_DDL;
3269  break;
3270 
3271  case T_CreateTableSpaceStmt:
3272  case T_DropTableSpaceStmt:
3273  case T_AlterTableSpaceOptionsStmt:
3274  lev = LOGSTMT_DDL;
3275  break;
3276 
3277  case T_CreateExtensionStmt:
3278  case T_AlterExtensionStmt:
3279  case T_AlterExtensionContentsStmt:
3280  lev = LOGSTMT_DDL;
3281  break;
3282 
3283  case T_CreateFdwStmt:
3284  case T_AlterFdwStmt:
3285  case T_CreateForeignServerStmt:
3286  case T_AlterForeignServerStmt:
3287  case T_CreateUserMappingStmt:
3288  case T_AlterUserMappingStmt:
3289  case T_DropUserMappingStmt:
3290  case T_ImportForeignSchemaStmt:
3291  lev = LOGSTMT_DDL;
3292  break;
3293 
3294  case T_DropStmt:
3295  lev = LOGSTMT_DDL;
3296  break;
3297 
3298  case T_TruncateStmt:
3299  lev = LOGSTMT_MOD;
3300  break;
3301 
3302  case T_CommentStmt:
3303  lev = LOGSTMT_DDL;
3304  break;
3305 
3306  case T_SecLabelStmt:
3307  lev = LOGSTMT_DDL;
3308  break;
3309 
3310  case T_CopyStmt:
3311  if (((CopyStmt *) parsetree)->is_from)
3312  lev = LOGSTMT_MOD;
3313  else
3314  lev = LOGSTMT_ALL;
3315  break;
3316 
3317  case T_PrepareStmt:
3318  {
3319  PrepareStmt *stmt = (PrepareStmt *) parsetree;
3320 
3321  /* Look through a PREPARE to the contained stmt */
3322  lev = GetCommandLogLevel(stmt->query);
3323  }
3324  break;
3325 
3326  case T_ExecuteStmt:
3327  {
3328  ExecuteStmt *stmt = (ExecuteStmt *) parsetree;
3329  PreparedStatement *ps;
3330 
3331  /* Look through an EXECUTE to the referenced stmt */
3332  ps = FetchPreparedStatement(stmt->name, false);
3333  if (ps && ps->plansource->raw_parse_tree)
3334  lev = GetCommandLogLevel(ps->plansource->raw_parse_tree->stmt);
3335  else
3336  lev = LOGSTMT_ALL;
3337  }
3338  break;
3339 
3340  case T_DeallocateStmt:
3341  lev = LOGSTMT_ALL;
3342  break;
3343 
3344  case T_RenameStmt:
3345  lev = LOGSTMT_DDL;
3346  break;
3347 
3348  case T_AlterObjectDependsStmt:
3349  lev = LOGSTMT_DDL;
3350  break;
3351 
3352  case T_AlterObjectSchemaStmt:
3353  lev = LOGSTMT_DDL;
3354  break;
3355 
3356  case T_AlterOwnerStmt:
3357  lev = LOGSTMT_DDL;
3358  break;
3359 
3360  case T_AlterOperatorStmt:
3361  lev = LOGSTMT_DDL;
3362  break;
3363 
3364  case T_AlterTypeStmt:
3365  lev = LOGSTMT_DDL;
3366  break;
3367 
3368  case T_AlterTableMoveAllStmt:
3369  case T_AlterTableStmt:
3370  lev = LOGSTMT_DDL;
3371  break;
3372 
3373  case T_AlterDomainStmt:
3374  lev = LOGSTMT_DDL;
3375  break;
3376 
3377  case T_GrantStmt:
3378  lev = LOGSTMT_DDL;
3379  break;
3380 
3381  case T_GrantRoleStmt:
3382  lev = LOGSTMT_DDL;
3383  break;
3384 
3385  case T_AlterDefaultPrivilegesStmt:
3386  lev = LOGSTMT_DDL;
3387  break;
3388 
3389  case T_DefineStmt:
3390  lev = LOGSTMT_DDL;
3391  break;
3392 
3393  case T_CompositeTypeStmt:
3394  lev = LOGSTMT_DDL;
3395  break;
3396 
3397  case T_CreateEnumStmt:
3398  lev = LOGSTMT_DDL;
3399  break;
3400 
3401  case T_CreateRangeStmt:
3402  lev = LOGSTMT_DDL;
3403  break;
3404 
3405  case T_AlterEnumStmt:
3406  lev = LOGSTMT_DDL;
3407  break;
3408 
3409  case T_ViewStmt:
3410  lev = LOGSTMT_DDL;
3411  break;
3412 
3413  case T_CreateFunctionStmt:
3414  lev = LOGSTMT_DDL;
3415  break;
3416 
3417  case T_AlterFunctionStmt:
3418  lev = LOGSTMT_DDL;
3419  break;
3420 
3421  case T_IndexStmt:
3422  lev = LOGSTMT_DDL;
3423  break;
3424 
3425  case T_RuleStmt:
3426  lev = LOGSTMT_DDL;
3427  break;
3428 
3429  case T_CreateSeqStmt:
3430  lev = LOGSTMT_DDL;
3431  break;
3432 
3433  case T_AlterSeqStmt:
3434  lev = LOGSTMT_DDL;
3435  break;
3436 
3437  case T_DoStmt:
3438  lev = LOGSTMT_ALL;
3439  break;
3440 
3441  case T_CreatedbStmt:
3442  lev = LOGSTMT_DDL;
3443  break;
3444 
3445  case T_AlterDatabaseStmt:
3446  lev = LOGSTMT_DDL;
3447  break;
3448 
3449  case T_AlterDatabaseSetStmt:
3450  lev = LOGSTMT_DDL;
3451  break;
3452 
3453  case T_DropdbStmt:
3454  lev = LOGSTMT_DDL;
3455  break;
3456 
3457  case T_NotifyStmt:
3458  lev = LOGSTMT_ALL;
3459  break;
3460 
3461  case T_ListenStmt:
3462  lev = LOGSTMT_ALL;
3463  break;
3464 
3465  case T_UnlistenStmt:
3466  lev = LOGSTMT_ALL;
3467  break;
3468 
3469  case T_LoadStmt:
3470  lev = LOGSTMT_ALL;
3471  break;
3472 
3473  case T_CallStmt:
3474  lev = LOGSTMT_ALL;
3475  break;
3476 
3477  case T_ClusterStmt:
3478  lev = LOGSTMT_DDL;
3479  break;
3480 
3481  case T_VacuumStmt:
3482  lev = LOGSTMT_ALL;
3483  break;
3484 
3485  case T_ExplainStmt:
3486  {
3487  ExplainStmt *stmt = (ExplainStmt *) parsetree;
3488  bool analyze = false;
3489  ListCell *lc;
3490 
3491  /* Look through an EXPLAIN ANALYZE to the contained stmt */
3492  foreach(lc, stmt->options)
3493  {
3494  DefElem *opt = (DefElem *) lfirst(lc);
3495 
3496  if (strcmp(opt->defname, "analyze") == 0)
3497  analyze = defGetBoolean(opt);
3498  /* don't "break", as explain.c will use the last value */
3499  }
3500  if (analyze)
3501  return GetCommandLogLevel(stmt->query);
3502 
3503  /* Plain EXPLAIN isn't so interesting */
3504  lev = LOGSTMT_ALL;
3505  }
3506  break;
3507 
3508  case T_CreateTableAsStmt:
3509  lev = LOGSTMT_DDL;
3510  break;
3511 
3512  case T_RefreshMatViewStmt:
3513  lev = LOGSTMT_DDL;
3514  break;
3515 
3516  case T_AlterSystemStmt:
3517  lev = LOGSTMT_DDL;
3518  break;
3519 
3520  case T_VariableSetStmt:
3521  lev = LOGSTMT_ALL;
3522  break;
3523 
3524  case T_VariableShowStmt:
3525  lev = LOGSTMT_ALL;
3526  break;
3527 
3528  case T_DiscardStmt:
3529  lev = LOGSTMT_ALL;
3530  break;
3531 
3532  case T_CreateTrigStmt:
3533  lev = LOGSTMT_DDL;
3534  break;
3535 
3536  case T_CreateEventTrigStmt:
3537  lev = LOGSTMT_DDL;
3538  break;
3539 
3540  case T_AlterEventTrigStmt:
3541  lev = LOGSTMT_DDL;
3542  break;
3543 
3544  case T_CreatePLangStmt:
3545  lev = LOGSTMT_DDL;
3546  break;
3547 
3548  case T_CreateDomainStmt:
3549  lev = LOGSTMT_DDL;
3550  break;
3551 
3552  case T_CreateRoleStmt:
3553  lev = LOGSTMT_DDL;
3554  break;
3555 
3556  case T_AlterRoleStmt:
3557  lev = LOGSTMT_DDL;
3558  break;
3559 
3560  case T_AlterRoleSetStmt:
3561  lev = LOGSTMT_DDL;
3562  break;
3563 
3564  case T_DropRoleStmt:
3565  lev = LOGSTMT_DDL;
3566  break;
3567 
3568  case T_DropOwnedStmt:
3569  lev = LOGSTMT_DDL;
3570  break;
3571 
3572  case T_ReassignOwnedStmt:
3573  lev = LOGSTMT_DDL;
3574  break;
3575 
3576  case T_LockStmt:
3577  lev = LOGSTMT_ALL;
3578  break;
3579 
3580  case T_ConstraintsSetStmt:
3581  lev = LOGSTMT_ALL;
3582  break;
3583 
3584  case T_CheckPointStmt:
3585  lev = LOGSTMT_ALL;
3586  break;
3587 
3588  case T_ReindexStmt:
3589  lev = LOGSTMT_ALL; /* should this be DDL? */
3590  break;
3591 
3592  case T_CreateConversionStmt:
3593  lev = LOGSTMT_DDL;
3594  break;
3595 
3596  case T_CreateCastStmt:
3597  lev = LOGSTMT_DDL;
3598  break;
3599 
3600  case T_CreateOpClassStmt:
3601  lev = LOGSTMT_DDL;
3602  break;
3603 
3604  case T_CreateOpFamilyStmt:
3605  lev = LOGSTMT_DDL;
3606  break;
3607 
3608  case T_CreateTransformStmt:
3609  lev = LOGSTMT_DDL;
3610  break;
3611 
3612  case T_AlterOpFamilyStmt:
3613  lev = LOGSTMT_DDL;
3614  break;
3615 
3616  case T_CreatePolicyStmt:
3617  lev = LOGSTMT_DDL;
3618  break;
3619 
3620  case T_AlterPolicyStmt:
3621  lev = LOGSTMT_DDL;
3622  break;
3623 
3624  case T_AlterTSDictionaryStmt:
3625  lev = LOGSTMT_DDL;
3626  break;
3627 
3628  case T_AlterTSConfigurationStmt:
3629  lev = LOGSTMT_DDL;
3630  break;
3631 
3632  case T_CreateAmStmt:
3633  lev = LOGSTMT_DDL;
3634  break;
3635 
3636  case T_CreatePublicationStmt:
3637  lev = LOGSTMT_DDL;
3638  break;
3639 
3640  case T_AlterPublicationStmt:
3641  lev = LOGSTMT_DDL;
3642  break;
3643 
3644  case T_CreateSubscriptionStmt:
3645  lev = LOGSTMT_DDL;
3646  break;
3647 
3648  case T_AlterSubscriptionStmt:
3649  lev = LOGSTMT_DDL;
3650  break;
3651 
3652  case T_DropSubscriptionStmt:
3653  lev = LOGSTMT_DDL;
3654  break;
3655 
3656  case T_CreateStatsStmt:
3657  lev = LOGSTMT_DDL;
3658  break;
3659 
3660  case T_AlterStatsStmt:
3661  lev = LOGSTMT_DDL;
3662  break;
3663 
3664  case T_AlterCollationStmt:
3665  lev = LOGSTMT_DDL;
3666  break;
3667 
3668  /* already-planned queries */
3669  case T_PlannedStmt:
3670  {
3671  PlannedStmt *stmt = (PlannedStmt *) parsetree;
3672 
3673  switch (stmt->commandType)
3674  {
3675  case CMD_SELECT:
3676  lev = LOGSTMT_ALL;
3677  break;
3678 
3679  case CMD_UPDATE:
3680  case CMD_INSERT:
3681  case CMD_DELETE:
3682  lev = LOGSTMT_MOD;
3683  break;
3684 
3685  case CMD_UTILITY:
3686  lev = GetCommandLogLevel(stmt->utilityStmt);
3687  break;
3688 
3689  default:
3690  elog(WARNING, "unrecognized commandType: %d",
3691  (int) stmt->commandType);
3692  lev = LOGSTMT_ALL;
3693  break;
3694  }
3695  }
3696  break;
3697 
3698  /* parsed-and-rewritten-but-not-planned queries */
3699  case T_Query:
3700  {
3701  Query *stmt = (Query *) parsetree;
3702 
3703  switch (stmt->commandType)
3704  {
3705  case CMD_SELECT:
3706  lev = LOGSTMT_ALL;
3707  break;
3708 
3709  case CMD_UPDATE:
3710  case CMD_INSERT:
3711  case CMD_DELETE:
3712  lev = LOGSTMT_MOD;
3713  break;
3714 
3715  case CMD_UTILITY:
3716  lev = GetCommandLogLevel(stmt->utilityStmt);
3717  break;
3718 
3719  default:
3720  elog(WARNING, "unrecognized commandType: %d",
3721  (int) stmt->commandType);
3722  lev = LOGSTMT_ALL;
3723  break;
3724  }
3725 
3726  }
3727  break;
3728 
3729  default:
3730  elog(WARNING, "unrecognized node type: %d",
3731  (int) nodeTag(parsetree));
3732  lev = LOGSTMT_ALL;
3733  break;
3734  }
3735 
3736  return lev;
3737 }
PreparedStatement::plansource
CachedPlanSource * plansource
Definition: prepare.h:31
LogStmtLevel
LogStmtLevel
Definition: tcopprot.h:36
ExplainStmt::options
List * options
Definition: parsenodes.h:3389
Query::utilityStmt
Node * utilityStmt
Definition: parsenodes.h:128
ExplainStmt::query
Node * query
Definition: parsenodes.h:3388
defGetBoolean
bool defGetBoolean(DefElem *def)
Definition: define.c:106
RawStmt::stmt
Node * stmt
Definition: parsenodes.h:1572
PlannedStmt::utilityStmt
Node * utilityStmt
Definition: plannodes.h:86
WARNING
#define WARNING
Definition: elog.h:40
T_Query
Definition: nodes.h:314
PlannedStmt::commandType
CmdType commandType
Definition: plannodes.h:46
Query::commandType
CmdType commandType
Definition: parsenodes.h:120
lfirst
#define lfirst(lc)
Definition: pg_list.h:169
PrepareStmt::query
Node * query
Definition: parsenodes.h:3552
CachedPlanSource::raw_parse_tree
struct RawStmt * raw_parse_tree
Definition: plancache.h:99
nodeTag
#define nodeTag(nodeptr)
Definition: nodes.h:541
elog
#define elog(elevel,...)
Definition: elog.h:232
ExecuteStmt::name
char * name
Definition: parsenodes.h:3564
DefElem::defname
char * defname
Definition: parsenodes.h:758
FetchPreparedStatement
PreparedStatement * FetchPreparedStatement(const char *stmt_name, bool throwError)
Definition: prepare.c:468
analyze
static long analyze(struct nfa *nfa)
Definition: regc_nfa.c:3044
GetCommandLogLevel
LogStmtLevel GetCommandLogLevel(Node *parsetree)
Definition: utility.c:3216

◆ PreventCommandDuringRecovery()

void PreventCommandDuringRecovery ( const char *  cmdname)

Definition at line 445 of file utility.c.

References ereport, errcode(), errmsg(), ERROR, and RecoveryInProgress().

Referenced by pg_current_xact_id(), pg_notify(), and standard_ProcessUtility().

446 {
447  if (RecoveryInProgress())
448  ereport(ERROR,
449  (errcode(ERRCODE_READ_ONLY_SQL_TRANSACTION),
450  /* translator: %s is name of a SQL command, eg CREATE */
451  errmsg("cannot execute %s during recovery",
452  cmdname)));
453 }
errcode
int errcode(int sqlerrcode)
Definition: elog.c:698
RecoveryInProgress
bool RecoveryInProgress(void)
Definition: xlog.c:8328
ERROR
#define ERROR
Definition: elog.h:46
ereport
#define ereport(elevel,...)
Definition: elog.h:157
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:909

◆ PreventCommandIfParallelMode()

void PreventCommandIfParallelMode ( const char *  cmdname)

Definition at line 426 of file utility.c.

References ereport, errcode(), errmsg(), ERROR, and IsInParallelMode().

Referenced by do_setval(), ExecCheckXactReadOnly(), nextval_internal(), and standard_ProcessUtility().

427 {
428  if (IsInParallelMode())
429  ereport(ERROR,
430  (errcode(ERRCODE_INVALID_TRANSACTION_STATE),
431  /* translator: %s is name of a SQL command, eg CREATE */
432  errmsg("cannot execute %s during a parallel operation",
433  cmdname)));
434 }
errcode
int errcode(int sqlerrcode)
Definition: elog.c:698
IsInParallelMode
bool IsInParallelMode(void)
Definition: xact.c:1012
ERROR
#define ERROR
Definition: elog.h:46
ereport
#define ereport(elevel,...)
Definition: elog.h:157
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:909

◆ PreventCommandIfReadOnly()

void PreventCommandIfReadOnly ( const char *  cmdname)

Definition at line 408 of file utility.c.

References ereport, errcode(), errmsg(), ERROR, and XactReadOnly.

Referenced by do_setval(), DoCopy(), ExecCheckXactReadOnly(), nextval_internal(), and standard_ProcessUtility().

409 {
410  if (XactReadOnly)
411  ereport(ERROR,
412  (errcode(ERRCODE_READ_ONLY_SQL_TRANSACTION),
413  /* translator: %s is name of a SQL command, eg CREATE */
414  errmsg("cannot execute %s in a read-only transaction",
415  cmdname)));
416 }
errcode
int errcode(int sqlerrcode)
Definition: elog.c:698
ERROR
#define ERROR
Definition: elog.h:46
ereport
#define ereport(elevel,...)
Definition: elog.h:157
XactReadOnly
bool XactReadOnly
Definition: xact.c:78
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:909

◆ ProcessUtility()

void ProcessUtility ( PlannedStmt *  pstmt,
const char *  queryString,
bool  readOnlyTree,
ProcessUtilityContext  context,
ParamListInfo  params,
QueryEnvironment *  queryEnv,
DestReceiver *  dest,
QueryCompletion *  qc 
)

Definition at line 503 of file utility.c.

References Assert, CMD_UTILITY, QueryCompletion::commandTag, PlannedStmt::commandType, generate_unaccent_rules::dest, IsA, ProcessUtility_hook, and standard_ProcessUtility().

Referenced by _SPI_execute_plan(), CreateSchemaCommand(), execute_sql_string(), ImportForeignSchema(), PortalRunUtility(), postquel_getnext(), ProcessUtilityForAlterTable(), and ProcessUtilitySlow().

511 {
512  Assert(IsA(pstmt, PlannedStmt));
513  Assert(pstmt->commandType == CMD_UTILITY);
514  Assert(queryString != NULL); /* required as of 8.4 */
515  Assert(qc == NULL || qc->commandTag == CMDTAG_UNKNOWN);
516 
517  /*
518  * We provide a function hook variable that lets loadable plugins get
519  * control when ProcessUtility is called. Such a plugin would normally
520  * call standard_ProcessUtility().
521  */
522  if (ProcessUtility_hook)
523  (*ProcessUtility_hook) (pstmt, queryString, readOnlyTree,
524  context, params, queryEnv,
525  dest, qc);
526  else
527  standard_ProcessUtility(pstmt, queryString, readOnlyTree,
528  context, params, queryEnv,
529  dest, qc);
530 }
IsA
#define IsA(nodeptr, _type_)
Definition: nodes.h:587
ProcessUtility_hook
ProcessUtility_hook_type ProcessUtility_hook
Definition: utility.c:76
generate_unaccent_rules.dest
dest
Definition: generate_unaccent_rules.py:282
standard_ProcessUtility
void standard_ProcessUtility(PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
Definition: utility.c:544
PlannedStmt::commandType
CmdType commandType
Definition: plannodes.h:46
QueryCompletion::commandTag
CommandTag commandTag
Definition: cmdtag.h:30
Assert
#define Assert(condition)
Definition: c.h:804

◆ ProcessUtilityForAlterTable()

void ProcessUtilityForAlterTable ( Node *  stmt,
AlterTableUtilityContext *  context 
)

Definition at line 1935 of file utility.c.

References PlannedStmt::canSetTag, CMD_UTILITY, PlannedStmt::commandType, EventTriggerAlterTableEnd(), EventTriggerAlterTableRelid(), EventTriggerAlterTableStart(), makeNode, None_Receiver, AlterTableUtilityContext::params, PROCESS_UTILITY_SUBCOMMAND, ProcessUtility(), AlterTableUtilityContext::pstmt, AlterTableUtilityContext::queryEnv, AlterTableUtilityContext::queryString, AlterTableUtilityContext::relid, PlannedStmt::stmt_len, PlannedStmt::stmt_location, and PlannedStmt::utilityStmt.

Referenced by ATParseTransformCmd(), and ATRewriteTables().

1936 {
1937  PlannedStmt *wrapper;
1938 
1939  /*
1940  * For event triggers, we must "close" the current complex-command set,
1941  * and start a new one afterwards; this is needed to ensure the ordering
1942  * of command events is consistent with the way they were executed.
1943  */
1944  EventTriggerAlterTableEnd();
1945 
1946  /* Create a suitable wrapper */
1947  wrapper = makeNode(PlannedStmt);
1948  wrapper->commandType = CMD_UTILITY;
1949  wrapper->canSetTag = false;
1950  wrapper->utilityStmt = stmt;
1951  wrapper->stmt_location = context->pstmt->stmt_location;
1952  wrapper->stmt_len = context->pstmt->stmt_len;
1953 
1954  ProcessUtility(wrapper,
1955  context->queryString,
1956  false,
1957  PROCESS_UTILITY_SUBCOMMAND,
1958  context->params,
1959  context->queryEnv,
1960  None_Receiver,
1961  NULL);
1962 
1963  EventTriggerAlterTableStart(context->pstmt->utilityStmt);
1964  EventTriggerAlterTableRelid(context->relid);
1965 }
AlterTableUtilityContext::pstmt
PlannedStmt * pstmt
Definition: utility.h:32
None_Receiver
DestReceiver * None_Receiver
Definition: dest.c:96
PlannedStmt::stmt_len
int stmt_len
Definition: plannodes.h:90
EventTriggerAlterTableStart
void EventTriggerAlterTableStart(Node *parsetree)
Definition: event_trigger.c:1548
ProcessUtility
void ProcessUtility(PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
Definition: utility.c:503
PlannedStmt::stmt_location
int stmt_location
Definition: plannodes.h:89
PlannedStmt::utilityStmt
Node * utilityStmt
Definition: plannodes.h:86
AlterTableUtilityContext::queryString
const char * queryString
Definition: utility.h:33
AlterTableUtilityContext::queryEnv
QueryEnvironment * queryEnv
Definition: utility.h:36
PlannedStmt::canSetTag
bool canSetTag
Definition: plannodes.h:54
PlannedStmt::commandType
CmdType commandType
Definition: plannodes.h:46
makeNode
#define makeNode(_type_)
Definition: nodes.h:584
EventTriggerAlterTableRelid
void EventTriggerAlterTableRelid(Oid objectId)
Definition: event_trigger.c:1582
AlterTableUtilityContext::params
ParamListInfo params
Definition: utility.h:35
EventTriggerAlterTableEnd
void EventTriggerAlterTableEnd(void)
Definition: event_trigger.c:1635

◆ ProcessUtilitySlow()

static void ProcessUtilitySlow ( ParseState *  pstate,
PlannedStmt *  pstmt,
const char *  queryString,
ProcessUtilityContext  context,
ParamListInfo  params,
QueryEnvironment *  queryEnv,
DestReceiver *  dest,
QueryCompletion *  qc 
)
static

Definition at line 1088 of file utility.c.

References AlterCollation(), AlterDomainAddConstraint(), AlterDomainDefault(), AlterDomainDropConstraint(), AlterDomainNotNull(), AlterDomainValidateConstraint(), AlterEnum(), AlterForeignDataWrapper(), AlterForeignServer(), AlterFunction(), AlterOperator(), AlterOpFamily(), AlterPolicy(), AlterPublication(), AlterSequence(), AlterStatistics(), AlterSubscription(), AlterTable(), AlterTableGetLockLevel(), AlterTableLookupRelation(), AlterTableMoveAll(), AlterTSConfiguration(), AlterTSDictionary(), AlterType(), AlterUserMapping(), DefineStmt::args, Assert, AT_DetachPartition, CreateForeignTableStmt::base, AlterDomainStmt::behavior, PlannedStmt::canSetTag, CMD_UTILITY, AlterTableStmt::cmds, CompositeTypeStmt::coldeflist, CommandCounterIncrement(), PlannedStmt::commandType, CommentObject(), IndexStmt::concurrent, CreateAccessMethod(), CreateCast(), CreateConversionCommand(), CreateExtension(), CreateForeignDataWrapper(), CreateForeignServer(), CreateForeignTable(), CreateFunction(), CreatePolicy(), CreateProceduralLanguage(), CreatePublication(), CreateSchemaCommand(), CreateStatistics(), CreateSubscription(), CreateTransform(), CreateTrigger(), CreateUserMapping(), AlterTableCmd::def, AlterDomainStmt::def, DefineAggregate(), DefineCollation(), DefineCompositeType(), DefineDomain(), DefineEnum(), DefineIndex(), DefineOpClass(), DefineOperator(), DefineOpFamily(), DefineRange(), DefineRelation(), DefineRule(), DefineSequence(), DefineTSConfiguration(), DefineTSDictionary(), DefineTSParser(), DefineTSTemplate(), DefineType(), DefineView(), DefineStmt::definition, DefineStmt::defnames, DropOwnedObjects(), DropSubscription(), elog, ereport, errcode(), errdetail(), errmsg(), ERROR, EventTriggerAlterTableEnd(), EventTriggerAlterTableRelid(), EventTriggerAlterTableStart(), EventTriggerBeginCompleteQuery(), EventTriggerCollectAlterDefPrivs(), EventTriggerCollectSimpleCommand(), EventTriggerDDLCommandEnd(), EventTriggerDDLCommandStart(), EventTriggerEndCompleteQuery(), EventTriggerInhibitCommandCollection(), EventTriggerSQLDrop(), EventTriggerUndoInhibitCommandCollection(), ExecAlterDefaultPrivilegesStmt(), ExecAlterExtensionContentsStmt(), ExecAlterExtensionStmt(), ExecAlterObjectDependsStmt(), ExecAlterObjectSchemaStmt(), ExecAlterOwnerStmt(), ExecCreateTableAs(), ExecDropStmt(), ExecRefreshMatView(), ExecRenameStmt(), ExecSecLabelStmt(), ExecuteGrantStmt(), expandTableLikeClause(), find_all_inheritors(), get_rel_relkind(), HEAP_RELOPT_NAMESPACES, heap_reloptions(), DefineStmt::if_not_exists, ImportForeignSchema(), RangeVar::inh, InvalidObjectAddress, InvalidOid, IsA, DefineStmt::kind, lfirst, lfirst_oid, linitial, list_concat(), list_delete_first(), list_free(), makeNode, AlterDomainStmt::missing_ok, AlterDomainStmt::name, NewRelationCreateToastTable(), NIL, nodeTag, None_Receiver, NOTICE, OBJECT_AGGREGATE, OBJECT_COLLATION, OBJECT_OPERATOR, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, ObjectAddress::objectId, OidIsValid, DefineStmt::oldstyle, CreateStmt::options, AlterTableUtilityContext::params, PG_END_TRY, PG_FINALLY, PG_TRY, PreventInTransactionBlock(), IndexStmt::primary, PROCESS_UTILITY_SUBCOMMAND, PROCESS_UTILITY_TOPLEVEL, ProcessUtility(), AlterTableUtilityContext::pstmt, AlterTableUtilityContext::queryEnv, AlterTableUtilityContext::queryString, RangeVarCallbackOwnsRelation(), RangeVarGetRelid, RangeVarGetRelidExtended(), AlterTableStmt::relation, CreateStmt::relation, IndexStmt::relation, CreateStatsStmt::relations, AlterTableUtilityContext::relid, RangeVar::relname, RemoveUserMapping(), DefineStmt::replace, ShareLock, ShareUpdateExclusiveLock, PlannedStmt::stmt_len, PlannedStmt::stmt_location, AlterTableCmd::subtype, AlterDomainStmt::subtype, T_AlterCollationStmt, T_AlterDefaultPrivilegesStmt, T_AlterDomainStmt, T_AlterEnumStmt, T_AlterExtensionContentsStmt, T_AlterExtensionStmt, T_AlterFdwStmt, T_AlterForeignServerStmt, T_AlterFunctionStmt, T_AlterObjectDependsStmt, T_AlterObjectSchemaStmt, T_AlterOperatorStmt, T_AlterOpFamilyStmt, T_AlterOwnerStmt, T_AlterPolicyStmt, T_AlterPublicationStmt, T_AlterSeqStmt, T_AlterStatsStmt, T_AlterSubscriptionStmt, T_AlterTableMoveAllStmt, T_AlterTableStmt, T_AlterTSConfigurationStmt, T_AlterTSDictionaryStmt, T_AlterTypeStmt, T_AlterUserMappingStmt, T_CommentStmt, T_CompositeTypeStmt, T_CreateAmStmt, T_CreateCastStmt, T_CreateConversionStmt, T_CreateDomainStmt, T_CreateEnumStmt, T_CreateExtensionStmt, T_CreateFdwStmt, T_CreateForeignServerStmt, T_CreateForeignTableStmt, T_CreateFunctionStmt, T_CreateOpClassStmt, T_CreateOpFamilyStmt, T_CreatePLangStmt, T_CreatePolicyStmt, T_CreatePublicationStmt, T_CreateRangeStmt, T_CreateSchemaStmt, T_CreateSeqStmt, T_CreateStatsStmt, T_CreateStmt, T_CreateSubscriptionStmt, T_CreateTableAsStmt, T_CreateTransformStmt, T_CreateTrigStmt, T_CreateUserMappingStmt, T_DefineStmt, T_DropOwnedStmt, T_DropStmt, T_DropSubscriptionStmt, T_DropUserMappingStmt, T_GrantStmt, T_ImportForeignSchemaStmt, T_IndexStmt, T_RefreshMatViewStmt, T_RenameStmt, T_RuleStmt, T_SecLabelStmt, T_ViewStmt, transformCreateStmt(), IndexStmt::transformed, transformIndexStmt(), transformRelOptions(), transformStatsStmt(), AlterDomainStmt::typeName, CompositeTypeStmt::typevar, IndexStmt::unique, and PlannedStmt::utilityStmt.

Referenced by standard_ProcessUtility().

1096 {
1097  Node *parsetree = pstmt->utilityStmt;
1098  bool isTopLevel = (context == PROCESS_UTILITY_TOPLEVEL);
1099  bool isCompleteQuery = (context != PROCESS_UTILITY_SUBCOMMAND);
1100  bool needCleanup;
1101  bool commandCollected = false;
1102  ObjectAddress address;
1103  ObjectAddress secondaryObject = InvalidObjectAddress;
1104 
1105  /* All event trigger calls are done only when isCompleteQuery is true */
1106  needCleanup = isCompleteQuery && EventTriggerBeginCompleteQuery();
1107 
1108  /* PG_TRY block is to ensure we call EventTriggerEndCompleteQuery */
1109  PG_TRY();
1110  {
1111  if (isCompleteQuery)
1112  EventTriggerDDLCommandStart(parsetree);
1113 
1114  switch (nodeTag(parsetree))
1115  {
1116  /*
1117  * relation and attribute manipulation
1118  */
1119  case T_CreateSchemaStmt:
1120  CreateSchemaCommand((CreateSchemaStmt *) parsetree,
1121  queryString,
1122  pstmt->stmt_location,
1123  pstmt->stmt_len);
1124 
1125  /*
1126  * EventTriggerCollectSimpleCommand called by
1127  * CreateSchemaCommand
1128  */
1129  commandCollected = true;
1130  break;
1131 
1132  case T_CreateStmt:
1133  case T_CreateForeignTableStmt:
1134  {
1135  List *stmts;
1136  RangeVar *table_rv = NULL;
1137 
1138  /* Run parse analysis ... */
1139  stmts = transformCreateStmt((CreateStmt *) parsetree,
1140  queryString);
1141 
1142  /*
1143  * ... and do it. We can't use foreach() because we may
1144  * modify the list midway through, so pick off the
1145  * elements one at a time, the hard way.
1146  */
1147  while (stmts != NIL)
1148  {
1149  Node *stmt = (Node *) linitial(stmts);
1150 
1151  stmts = list_delete_first(stmts);
1152 
1153  if (IsA(stmt, CreateStmt))
1154  {
1155  CreateStmt *cstmt = (CreateStmt *) stmt;
1156  Datum toast_options;
1157  static char *validnsps[] = HEAP_RELOPT_NAMESPACES;
1158 
1159  /* Remember transformed RangeVar for LIKE */
1160  table_rv = cstmt->relation;
1161 
1162  /* Create the table itself */
1163  address = DefineRelation(cstmt,
1164  RELKIND_RELATION,
1165  InvalidOid, NULL,
1166  queryString);
1167  EventTriggerCollectSimpleCommand(address,
1168  secondaryObject,
1169  stmt);
1170 
1171  /*
1172  * Let NewRelationCreateToastTable decide if this
1173  * one needs a secondary relation too.
1174  */
1175  CommandCounterIncrement();
1176 
1177  /*
1178  * parse and validate reloptions for the toast
1179  * table
1180  */
1181  toast_options = transformRelOptions((Datum) 0,
1182  cstmt->options,
1183  "toast",
1184  validnsps,
1185  true,
1186  false);
1187  (void) heap_reloptions(RELKIND_TOASTVALUE,
1188  toast_options,
1189  true);
1190 
1191  NewRelationCreateToastTable(address.objectId,
1192  toast_options);
1193  }
1194  else if (IsA(stmt, CreateForeignTableStmt))
1195  {
1196  CreateForeignTableStmt *cstmt = (CreateForeignTableStmt *) stmt;
1197 
1198  /* Remember transformed RangeVar for LIKE */
1199  table_rv = cstmt->base.relation;
1200 
1201  /* Create the table itself */
1202  address = DefineRelation(&cstmt->base,
1203  RELKIND_FOREIGN_TABLE,
1204  InvalidOid, NULL,
1205  queryString);
1206  CreateForeignTable(cstmt,
1207  address.objectId);
1208  EventTriggerCollectSimpleCommand(address,
1209  secondaryObject,
1210  stmt);
1211  }
1212  else if (IsA(stmt, TableLikeClause))
1213  {
1214  /*
1215  * Do delayed processing of LIKE options. This
1216  * will result in additional sub-statements for us
1217  * to process. Those should get done before any
1218  * remaining actions, so prepend them to "stmts".
1219  */
1220  TableLikeClause *like = (TableLikeClause *) stmt;
1221  List *morestmts;
1222 
1223  Assert(table_rv != NULL);
1224 
1225  morestmts = expandTableLikeClause(table_rv, like);
1226  stmts = list_concat(morestmts, stmts);
1227  }
1228  else
1229  {
1230  /*
1231  * Recurse for anything else. Note the recursive
1232  * call will stash the objects so created into our
1233  * event trigger context.
1234  */
1235  PlannedStmt *wrapper;
1236 
1237  wrapper = makeNode(PlannedStmt);
1238  wrapper->commandType = CMD_UTILITY;
1239  wrapper->canSetTag = false;
1240  wrapper->utilityStmt = stmt;
1241  wrapper->stmt_location = pstmt->stmt_location;
1242  wrapper->stmt_len = pstmt->stmt_len;
1243 
1244  ProcessUtility(wrapper,
1245  queryString,
1246  false,
1247  PROCESS_UTILITY_SUBCOMMAND,
1248  params,
1249  NULL,
1250  None_Receiver,
1251  NULL);
1252  }
1253 
1254  /* Need CCI between commands */
1255  if (stmts != NIL)
1256  CommandCounterIncrement();
1257  }
1258 
1259  /*
1260  * The multiple commands generated here are stashed
1261  * individually, so disable collection below.
1262  */
1263  commandCollected = true;
1264  }
1265  break;
1266 
1267  case T_AlterTableStmt:
1268  {
1269  AlterTableStmt *atstmt = (AlterTableStmt *) parsetree;
1270  Oid relid;
1271  LOCKMODE lockmode;
1272  ListCell *cell;
1273 
1274  /*
1275  * Disallow ALTER TABLE .. DETACH CONCURRENTLY in a
1276  * transaction block or function. (Perhaps it could be
1277  * allowed in a procedure, but don't hold your breath.)
1278  */
1279  foreach(cell, atstmt->cmds)
1280  {
1281  AlterTableCmd *cmd = (AlterTableCmd *) lfirst(cell);
1282 
1283  /* Disallow DETACH CONCURRENTLY in a transaction block */
1284  if (cmd->subtype == AT_DetachPartition)
1285  {
1286  if (((PartitionCmd *) cmd->def)->concurrent)
1287  PreventInTransactionBlock(isTopLevel,
1288  "ALTER TABLE ... DETACH CONCURRENTLY");
1289  }
1290  }
1291 
1292  /*
1293  * Figure out lock mode, and acquire lock. This also does
1294  * basic permissions checks, so that we won't wait for a
1295  * lock on (for example) a relation on which we have no
1296  * permissions.
1297  */
1298  lockmode = AlterTableGetLockLevel(atstmt->cmds);
1299  relid = AlterTableLookupRelation(atstmt, lockmode);
1300 
1301  if (OidIsValid(relid))
1302  {
1303  AlterTableUtilityContext atcontext;
1304 
1305  /* Set up info needed for recursive callbacks ... */
1306  atcontext.pstmt = pstmt;
1307  atcontext.queryString = queryString;
1308  atcontext.relid = relid;
1309  atcontext.params = params;
1310  atcontext.queryEnv = queryEnv;
1311 
1312  /* ... ensure we have an event trigger context ... */
1313  EventTriggerAlterTableStart(parsetree);
1314  EventTriggerAlterTableRelid(relid);
1315 
1316  /* ... and do it */
1317  AlterTable(atstmt, lockmode, &atcontext);
1318 
1319  /* done */
1320  EventTriggerAlterTableEnd();
1321  }
1322  else
1323  ereport(NOTICE,
1324  (errmsg("relation \"%s\" does not exist, skipping",
1325  atstmt->relation->relname)));
1326  }
1327 
1328  /* ALTER TABLE stashes commands internally */
1329  commandCollected = true;
1330  break;
1331 
1332  case T_AlterDomainStmt:
1333  {
1334  AlterDomainStmt *stmt = (AlterDomainStmt *) parsetree;
1335 
1336  /*
1337  * Some or all of these functions are recursive to cover
1338  * inherited things, so permission checks are done there.
1339  */
1340  switch (stmt->subtype)
1341  {
1342  case 'T': /* ALTER DOMAIN DEFAULT */
1343 
1344  /*
1345  * Recursively alter column default for table and,
1346  * if requested, for descendants
1347  */
1348  address =
1349  AlterDomainDefault(stmt->typeName,
1350  stmt->def);
1351  break;
1352  case 'N': /* ALTER DOMAIN DROP NOT NULL */
1353  address =
1354  AlterDomainNotNull(stmt->typeName,
1355  false);
1356  break;
1357  case 'O': /* ALTER DOMAIN SET NOT NULL */
1358  address =
1359  AlterDomainNotNull(stmt->typeName,
1360  true);
1361  break;
1362  case 'C': /* ADD CONSTRAINT */
1363  address =
1364  AlterDomainAddConstraint(stmt->typeName,
1365  stmt->def,
1366  &secondaryObject);
1367  break;
1368  case 'X': /* DROP CONSTRAINT */
1369  address =
1370  AlterDomainDropConstraint(stmt->typeName,
1371  stmt->name,
1372  stmt->behavior,
1373  stmt->missing_ok);
1374  break;
1375  case 'V': /* VALIDATE CONSTRAINT */
1376  address =
1377  AlterDomainValidateConstraint(stmt->typeName,
1378  stmt->name);
1379  break;
1380  default: /* oops */
1381  elog(ERROR, "unrecognized alter domain type: %d",
1382  (int) stmt->subtype);
1383  break;
1384  }
1385  }
1386  break;
1387 
1388  /*
1389  * ************* object creation / destruction **************
1390  */
1391  case T_DefineStmt:
1392  {
1393  DefineStmt *stmt = (DefineStmt *) parsetree;
1394 
1395  switch (stmt->kind)
1396  {
1397  case OBJECT_AGGREGATE:
1398  address =
1399  DefineAggregate(pstate, stmt->defnames, stmt->args,
1400  stmt->oldstyle,
1401  stmt->definition,
1402  stmt->replace);
1403  break;
1404  case OBJECT_OPERATOR:
1405  Assert(stmt->args == NIL);
1406  address = DefineOperator(stmt->defnames,
1407  stmt->definition);
1408  break;
1409  case OBJECT_TYPE:
1410  Assert(stmt->args == NIL);
1411  address = DefineType(pstate,
1412  stmt->defnames,
1413  stmt->definition);
1414  break;
1415  case OBJECT_TSPARSER:
1416  Assert(stmt->args == NIL);
1417  address = DefineTSParser(stmt->defnames,
1418  stmt->definition);
1419  break;
1420  case OBJECT_TSDICTIONARY:
1421  Assert(stmt->args == NIL);
1422  address = DefineTSDictionary(stmt->defnames,
1423  stmt->definition);
1424  break;
1425  case OBJECT_TSTEMPLATE:
1426  Assert(stmt->args == NIL);
1427  address = DefineTSTemplate(stmt->defnames,
1428  stmt->definition);
1429  break;
1430  case OBJECT_TSCONFIGURATION:
1431  Assert(stmt->args == NIL);
1432  address = DefineTSConfiguration(stmt->defnames,
1433  stmt->definition,
1434  &secondaryObject);
1435  break;
1436  case OBJECT_COLLATION:
1437  Assert(stmt->args == NIL);
1438  address = DefineCollation(pstate,
1439  stmt->defnames,
1440  stmt->definition,
1441  stmt->if_not_exists);
1442  break;
1443  default:
1444  elog(ERROR, "unrecognized define stmt type: %d",
1445  (int) stmt->kind);
1446  break;
1447  }
1448  }
1449  break;
1450 
1451  case T_IndexStmt: /* CREATE INDEX */
1452  {
1453  IndexStmt *stmt = (IndexStmt *) parsetree;
1454  Oid relid;
1455  LOCKMODE lockmode;
1456  bool is_alter_table;
1457 
1458  if (stmt->concurrent)
1459  PreventInTransactionBlock(isTopLevel,
1460  "CREATE INDEX CONCURRENTLY");
1461 
1462  /*
1463  * Look up the relation OID just once, right here at the
1464  * beginning, so that we don't end up repeating the name
1465  * lookup later and latching onto a different relation
1466  * partway through. To avoid lock upgrade hazards, it's
1467  * important that we take the strongest lock that will
1468  * eventually be needed here, so the lockmode calculation
1469  * needs to match what DefineIndex() does.
1470  */
1471  lockmode = stmt->concurrent ? ShareUpdateExclusiveLock
1472  : ShareLock;
1473  relid =
1474  RangeVarGetRelidExtended(stmt->relation, lockmode,
1475  0,
1476  RangeVarCallbackOwnsRelation,
1477  NULL);
1478 
1479  /*
1480  * CREATE INDEX on partitioned tables (but not regular
1481  * inherited tables) recurses to partitions, so we must
1482  * acquire locks early to avoid deadlocks.
1483  *
1484  * We also take the opportunity to verify that all
1485  * partitions are something we can put an index on, to
1486  * avoid building some indexes only to fail later.
1487  */
1488  if (stmt->relation->inh &&
1489  get_rel_relkind(relid) == RELKIND_PARTITIONED_TABLE)
1490  {
1491  ListCell *lc;
1492  List *inheritors = NIL;
1493 
1494  inheritors = find_all_inheritors(relid, lockmode, NULL);
1495  foreach(lc, inheritors)
1496  {
1497  char relkind = get_rel_relkind(lfirst_oid(lc));
1498 
1499  if (relkind != RELKIND_RELATION &&
1500  relkind != RELKIND_MATVIEW &&
1501  relkind != RELKIND_PARTITIONED_TABLE &&
1502  relkind != RELKIND_FOREIGN_TABLE)
1503  elog(ERROR, "unexpected relkind \"%c\" on partition \"%s\"",
1504  relkind, stmt->relation->relname);
1505 
1506  if (relkind == RELKIND_FOREIGN_TABLE &&
1507  (stmt->unique || stmt->primary))
1508  ereport(ERROR,
1509  (errcode(ERRCODE_WRONG_OBJECT_TYPE),
1510  errmsg("cannot create unique index on partitioned table \"%s\"",
1511  stmt->relation->relname),
1512  errdetail("Table \"%s\" contains partitions that are foreign tables.",
1513  stmt->relation->relname)));
1514  }
1515  list_free(inheritors);
1516  }
1517 
1518  /*
1519  * If the IndexStmt is already transformed, it must have
1520  * come from generateClonedIndexStmt, which in current
1521  * usage means it came from expandTableLikeClause rather
1522  * than from original parse analysis. And that means we
1523  * must treat it like ALTER TABLE ADD INDEX, not CREATE.
1524  * (This is a bit grotty, but currently it doesn't seem
1525  * worth adding a separate bool field for the purpose.)
1526  */
1527  is_alter_table = stmt->transformed;
1528 
1529  /* Run parse analysis ... */
1530  stmt = transformIndexStmt(relid, stmt, queryString);
1531 
1532  /* ... and do it */
1533  EventTriggerAlterTableStart(parsetree);
1534  address =
1535  DefineIndex(relid, /* OID of heap relation */
1536  stmt,
1537  InvalidOid, /* no predefined OID */
1538  InvalidOid, /* no parent index */
1539  InvalidOid, /* no parent constraint */
1540  is_alter_table,
1541  true, /* check_rights */
1542  true, /* check_not_in_use */
1543  false, /* skip_build */
1544  false); /* quiet */
1545 
1546  /*
1547  * Add the CREATE INDEX node itself to stash right away;
1548  * if there were any commands stashed in the ALTER TABLE
1549  * code, we need them to appear after this one.
1550  */
1551  EventTriggerCollectSimpleCommand(address, secondaryObject,
1552  parsetree);
1553  commandCollected = true;
1554  EventTriggerAlterTableEnd();
1555  }
1556  break;
1557 
1558  case T_CreateExtensionStmt:
1559  address = CreateExtension(pstate, (CreateExtensionStmt *) parsetree);
1560  break;
1561 
1562  case T_AlterExtensionStmt:
1563  address = ExecAlterExtensionStmt(pstate, (AlterExtensionStmt *) parsetree);
1564  break;
1565 
1566  case T_AlterExtensionContentsStmt:
1567  address = ExecAlterExtensionContentsStmt((AlterExtensionContentsStmt *) parsetree,
1568  &secondaryObject);
1569  break;
1570 
1571  case T_CreateFdwStmt:
1572  address = CreateForeignDataWrapper(pstate, (CreateFdwStmt *) parsetree);
1573  break;
1574 
1575  case T_AlterFdwStmt:
1576  address = AlterForeignDataWrapper(pstate, (AlterFdwStmt *) parsetree);
1577  break;
1578 
1579  case T_CreateForeignServerStmt:
1580  address = CreateForeignServer((CreateForeignServerStmt *) parsetree);
1581  break;
1582 
1583  case T_AlterForeignServerStmt:
1584  address = AlterForeignServer((AlterForeignServerStmt *) parsetree);
1585  break;
1586 
1587  case T_CreateUserMappingStmt:
1588  address = CreateUserMapping((CreateUserMappingStmt *) parsetree);
1589  break;
1590 
1591  case T_AlterUserMappingStmt:
1592  address = AlterUserMapping((AlterUserMappingStmt *) parsetree);
1593  break;
1594 
1595  case T_DropUserMappingStmt:
1596  RemoveUserMapping((DropUserMappingStmt *) parsetree);
1597  /* no commands stashed for DROP */
1598  commandCollected = true;
1599  break;
1600 
1601  case T_ImportForeignSchemaStmt:
1602  ImportForeignSchema((ImportForeignSchemaStmt *) parsetree);
1603  /* commands are stashed inside ImportForeignSchema */
1604  commandCollected = true;
1605  break;
1606 
1607  case T_CompositeTypeStmt: /* CREATE TYPE (composite) */
1608  {
1609  CompositeTypeStmt *stmt = (CompositeTypeStmt *) parsetree;
1610 
1611  address = DefineCompositeType(stmt->typevar,
1612  stmt->coldeflist);
1613  }
1614  break;
1615 
1616  case T_CreateEnumStmt: /* CREATE TYPE AS ENUM */
1617  address = DefineEnum((CreateEnumStmt *) parsetree);
1618  break;
1619 
1620  case T_CreateRangeStmt: /* CREATE TYPE AS RANGE */
1621  address = DefineRange(pstate, (CreateRangeStmt *) parsetree);
1622  break;
1623 
1624  case T_AlterEnumStmt: /* ALTER TYPE (enum) */
1625  address = AlterEnum((AlterEnumStmt *) parsetree);
1626  break;
1627 
1628  case T_ViewStmt: /* CREATE VIEW */
1629  EventTriggerAlterTableStart(parsetree);
1630  address = DefineView((ViewStmt *) parsetree, queryString,
1631  pstmt->stmt_location, pstmt->stmt_len);
1632  EventTriggerCollectSimpleCommand(address, secondaryObject,
1633  parsetree);
1634  /* stashed internally */
1635  commandCollected = true;
1636  EventTriggerAlterTableEnd();
1637  break;
1638 
1639  case T_CreateFunctionStmt: /* CREATE FUNCTION */
1640  address = CreateFunction(pstate, (CreateFunctionStmt *) parsetree);
1641  break;
1642 
1643  case T_AlterFunctionStmt: /* ALTER FUNCTION */
1644  address = AlterFunction(pstate, (AlterFunctionStmt *) parsetree);
1645  break;
1646 
1647  case T_RuleStmt: /* CREATE RULE */
1648  address = DefineRule((RuleStmt *) parsetree, queryString);
1649  break;
1650 
1651  case T_CreateSeqStmt:
1652  address = DefineSequence(pstate, (CreateSeqStmt *) parsetree);
1653  break;
1654 
1655  case T_AlterSeqStmt:
1656  address = AlterSequence(pstate, (AlterSeqStmt *) parsetree);
1657  break;
1658 
1659  case T_CreateTableAsStmt:
1660  address = ExecCreateTableAs(pstate, (CreateTableAsStmt *) parsetree,
1661  params, queryEnv, qc);
1662  break;
1663 
1664  case T_RefreshMatViewStmt:
1665 
1666  /*
1667  * REFRESH CONCURRENTLY executes some DDL commands internally.
1668  * Inhibit DDL command collection here to avoid those commands
1669  * from showing up in the deparsed command queue. The refresh
1670  * command itself is queued, which is enough.
1671  */
1672  EventTriggerInhibitCommandCollection();
1673  PG_TRY();
1674  {
1675  address = ExecRefreshMatView((RefreshMatViewStmt *) parsetree,
1676  queryString, params, qc);
1677  }
1678  PG_FINALLY();
1679  {
1680  EventTriggerUndoInhibitCommandCollection();
1681  }
1682  PG_END_TRY();
1683  break;
1684 
1685  case T_CreateTrigStmt:
1686  address = CreateTrigger((CreateTrigStmt *) parsetree,
1687  queryString, InvalidOid, InvalidOid,
1688  InvalidOid, InvalidOid, InvalidOid,
1689  InvalidOid, NULL, false, false);
1690  break;
1691 
1692  case T_CreatePLangStmt:
1693  address = CreateProceduralLanguage((CreatePLangStmt *) parsetree);
1694  break;
1695 
1696  case T_CreateDomainStmt:
1697  address = DefineDomain((CreateDomainStmt *) parsetree);
1698  break;
1699 
1700  case T_CreateConversionStmt:
1701  address = CreateConversionCommand((CreateConversionStmt *) parsetree);
1702  break;
1703 
1704  case T_CreateCastStmt:
1705  address = CreateCast((CreateCastStmt *) parsetree);
1706  break;
1707 
1708  case T_CreateOpClassStmt:
1709  DefineOpClass((CreateOpClassStmt *) parsetree);
1710  /* command is stashed in DefineOpClass */
1711  commandCollected = true;
1712  break;
1713 
1714  case T_CreateOpFamilyStmt:
1715  address = DefineOpFamily((CreateOpFamilyStmt *) parsetree);
1716  break;
1717 
1718  case T_CreateTransformStmt:
1719  address = CreateTransform((CreateTransformStmt *) parsetree);
1720  break;
1721 
1722  case T_AlterOpFamilyStmt:
1723  AlterOpFamily((AlterOpFamilyStmt *) parsetree);
1724  /* commands are stashed in AlterOpFamily */
1725  commandCollected = true;
1726  break;
1727 
1728  case T_AlterTSDictionaryStmt:
1729  address = AlterTSDictionary((AlterTSDictionaryStmt *) parsetree);
1730  break;
1731 
1732  case T_AlterTSConfigurationStmt:
1733  AlterTSConfiguration((AlterTSConfigurationStmt *) parsetree);
1734 
1735  /*
1736  * Commands are stashed in MakeConfigurationMapping and
1737  * DropConfigurationMapping, which are called from
1738  * AlterTSConfiguration
1739  */
1740  commandCollected = true;
1741  break;
1742 
1743  case T_AlterTableMoveAllStmt:
1744  AlterTableMoveAll((AlterTableMoveAllStmt *) parsetree);
1745  /* commands are stashed in AlterTableMoveAll */
1746  commandCollected = true;
1747  break;
1748 
1749  case T_DropStmt:
1750  ExecDropStmt((DropStmt *) parsetree, isTopLevel);
1751  /* no commands stashed for DROP */
1752  commandCollected = true;
1753  break;
1754 
1755  case T_RenameStmt:
1756  address = ExecRenameStmt((RenameStmt *) parsetree);
1757  break;
1758 
1759  case T_AlterObjectDependsStmt:
1760  address =
1761  ExecAlterObjectDependsStmt((AlterObjectDependsStmt *) parsetree,
1762  &secondaryObject);
1763  break;
1764 
1765  case T_AlterObjectSchemaStmt:
1766  address =
1767  ExecAlterObjectSchemaStmt((AlterObjectSchemaStmt *) parsetree,
1768  &secondaryObject);
1769  break;
1770 
1771  case T_AlterOwnerStmt:
1772  address = ExecAlterOwnerStmt((AlterOwnerStmt *) parsetree);
1773  break;
1774 
1775  case T_AlterOperatorStmt:
1776  address = AlterOperator((AlterOperatorStmt *) parsetree);
1777  break;
1778 
1779  case T_AlterTypeStmt:
1780  address = AlterType((AlterTypeStmt *) parsetree);
1781  break;
1782 
1783  case T_CommentStmt:
1784  address = CommentObject((CommentStmt *) parsetree);
1785  break;
1786 
1787  case T_GrantStmt:
1788  ExecuteGrantStmt((GrantStmt *) parsetree);
1789  /* commands are stashed in ExecGrantStmt_oids */
1790  commandCollected = true;
1791  break;
1792 
1793  case T_DropOwnedStmt:
1794  DropOwnedObjects((DropOwnedStmt *) parsetree);
1795  /* no commands stashed for DROP */
1796  commandCollected = true;
1797  break;
1798 
1799  case T_AlterDefaultPrivilegesStmt:
1800  ExecAlterDefaultPrivilegesStmt(pstate, (AlterDefaultPrivilegesStmt *) parsetree);
1801  EventTriggerCollectAlterDefPrivs((AlterDefaultPrivilegesStmt *) parsetree);
1802  commandCollected = true;
1803  break;
1804 
1805  case T_CreatePolicyStmt: /* CREATE POLICY */
1806  address = CreatePolicy((CreatePolicyStmt *) parsetree);
1807  break;
1808 
1809  case T_AlterPolicyStmt: /* ALTER POLICY */
1810  address = AlterPolicy((AlterPolicyStmt *) parsetree);
1811  break;
1812 
1813  case T_SecLabelStmt:
1814  address = ExecSecLabelStmt((SecLabelStmt *) parsetree);
1815  break;
1816 
1817  case T_CreateAmStmt:
1818  address = CreateAccessMethod((CreateAmStmt *) parsetree);
1819  break;
1820 
1821  case T_CreatePublicationStmt:
1822  address = CreatePublication(pstate, (CreatePublicationStmt *) parsetree);
1823  break;
1824 
1825  case T_AlterPublicationStmt:
1826  AlterPublication(pstate, (AlterPublicationStmt *) parsetree);
1827 
1828  /*
1829  * AlterPublication calls EventTriggerCollectSimpleCommand
1830  * directly
1831  */
1832  commandCollected = true;
1833  break;
1834 
1835  case T_CreateSubscriptionStmt:
1836  address = CreateSubscription(pstate,
1837  (CreateSubscriptionStmt *) parsetree,
1838  isTopLevel);
1839  break;
1840 
1841  case T_AlterSubscriptionStmt:
1842  address = AlterSubscription(pstate,
1843  (AlterSubscriptionStmt *) parsetree,
1844  isTopLevel);
1845  break;
1846 
1847  case T_DropSubscriptionStmt:
1848  DropSubscription((DropSubscriptionStmt *) parsetree, isTopLevel);
1849  /* no commands stashed for DROP */
1850  commandCollected = true;
1851  break;
1852 
1853  case T_CreateStatsStmt:
1854  {
1855  Oid relid;
1856  CreateStatsStmt *stmt = (CreateStatsStmt *) parsetree;
1857  RangeVar *rel = (RangeVar *) linitial(stmt->relations);
1858 
1859  if (!IsA(rel, RangeVar))
1860  ereport(ERROR,
1861  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1862  errmsg("only a single relation is allowed in CREATE STATISTICS")));
1863 
1864  /*
1865  * CREATE STATISTICS will influence future execution plans
1866  * but does not interfere with currently executing plans.
1867  * So it should be enough to take ShareUpdateExclusiveLock
1868  * on relation, conflicting with ANALYZE and other DDL
1869  * that sets statistical information, but not with normal
1870  * queries.
1871  *
1872  * XXX RangeVarCallbackOwnsRelation not needed here, to
1873  * keep the same behavior as before.
1874  */
1875  relid = RangeVarGetRelid(rel, ShareUpdateExclusiveLock, false);
1876 
1877  /* Run parse analysis ... */
1878  stmt = transformStatsStmt(relid, stmt, queryString);
1879 
1880  address = CreateStatistics(stmt);
1881  }
1882  break;
1883 
1884  case T_AlterStatsStmt:
1885  address = AlterStatistics((AlterStatsStmt *) parsetree);
1886  break;
1887 
1888  case T_AlterCollationStmt:
1889  address = AlterCollation((AlterCollationStmt *) parsetree);
1890  break;
1891 
1892  default:
1893  elog(ERROR, "unrecognized node type: %d",
1894  (int) nodeTag(parsetree));
1895  break;
1896  }
1897 
1898  /*
1899  * Remember the object so that ddl_command_end event triggers have
1900  * access to it.
1901  */
1902  if (!commandCollected)
1903  EventTriggerCollectSimpleCommand(address, secondaryObject,
1904  parsetree);
1905 
1906  if (isCompleteQuery)
1907  {
1908  EventTriggerSQLDrop(parsetree);
1909  EventTriggerDDLCommandEnd(parsetree);
1910  }
1911  }
1912  PG_FINALLY();
1913  {
1914  if (needCleanup)
1915  EventTriggerEndCompleteQuery();
1916  }
1917  PG_END_TRY();
1918 }
CreateStmt::relation
RangeVar * relation
Definition: parsenodes.h:2183
AlterSequence
ObjectAddress AlterSequence(ParseState *pstate, AlterSeqStmt *stmt)
Definition: sequence.c:422
DefineTSParser
ObjectAddress DefineTSParser(List *names, List *parameters)
Definition: tsearchcmds.c:178
heap_reloptions
bytea * heap_reloptions(char relkind, Datum reloptions, bool validate)
Definition: reloptions.c:2013
NIL
#define NIL
Definition: pg_list.h:65
IndexStmt::primary
bool primary
Definition: parsenodes.h:2905
AlterForeignServer
ObjectAddress AlterForeignServer(AlterForeignServerStmt *stmt)
Definition: foreigncmds.c:965
CreateForeignTable
void CreateForeignTable(CreateForeignTableStmt *stmt, Oid relid)
Definition: foreigncmds.c:1391
DropSubscription
void DropSubscription(DropSubscriptionStmt *stmt, bool isTopLevel)
Definition: subscriptioncmds.c:1121
DefineOperator
ObjectAddress DefineOperator(List *names, List *parameters)
Definition: operatorcmds.c:65
IsA
#define IsA(nodeptr, _type_)
Definition: nodes.h:587
DefineTSConfiguration
ObjectAddress DefineTSConfiguration(List *names, List *parameters, ObjectAddress *copied)
Definition: tsearchcmds.c:893
CreateTransform
ObjectAddress CreateTransform(CreateTransformStmt *stmt)
Definition: functioncmds.c:1800
ExecDropStmt
static void ExecDropStmt(DropStmt *stmt, bool isTopLevel)
Definition: utility.c:1971
DefineIndex
ObjectAddress DefineIndex(Oid relationId, IndexStmt *stmt, Oid indexRelationId, Oid parentIndexId, Oid parentConstraintId, bool is_alter_table, bool check_rights, bool check_not_in_use, bool skip_build, bool quiet)
Definition: indexcmds.c:506
CreateForeignDataWrapper
ObjectAddress CreateForeignDataWrapper(ParseState *pstate, CreateFdwStmt *stmt)
Definition: foreigncmds.c:558
AlterDomainAddConstraint
ObjectAddress AlterDomainAddConstraint(List *names, Node *newConstraint, ObjectAddress *constrAddr)
Definition: typecmds.c:2918
transformRelOptions
Datum transformRelOptions(Datum oldOptions, List *defList, const char *namspace, char *validnsps[], bool acceptOidsOff, bool isReset)
Definition: reloptions.c:1149
AlterDomainStmt::behavior
DropBehavior behavior
Definition: parsenodes.h:2007
CommentObject
ObjectAddress CommentObject(CommentStmt *stmt)
Definition: comment.c:40
CreateFunction
ObjectAddress CreateFunction(ParseState *pstate, CreateFunctionStmt *stmt)
Definition: functioncmds.c:1020
LOCKMODE
int LOCKMODE
Definition: lockdefs.h:26
ExecSecLabelStmt
ObjectAddress ExecSecLabelStmt(SecLabelStmt *stmt)
Definition: seclabel.c:113
CreatePublication
ObjectAddress CreatePublication(ParseState *pstate, CreatePublicationStmt *stmt)
Definition: publicationcmds.c:142
AlterTableUtilityContext::pstmt
PlannedStmt * pstmt
Definition: utility.h:32
RangeVarGetRelid
#define RangeVarGetRelid(relation, lockmode, missing_ok)
Definition: namespace.h:79
AlterTableLookupRelation
Oid AlterTableLookupRelation(AlterTableStmt *stmt, LOCKMODE lockmode)
Definition: tablecmds.c:3937
AlterDomainValidateConstraint
ObjectAddress AlterDomainValidateConstraint(List *names, const char *constrName)
Definition: typecmds.c:3034
DefineAggregate
ObjectAddress DefineAggregate(ParseState *pstate, List *name, List *args, bool oldstyle, List *parameters, bool replace)
Definition: aggregatecmds.c:56
get_rel_relkind
char get_rel_relkind(Oid relid)
Definition: lsyscache.c:1974
AlterEnum
ObjectAddress AlterEnum(AlterEnumStmt *stmt)
Definition: typecmds.c:1261
DropOwnedObjects
void DropOwnedObjects(DropOwnedStmt *stmt)
Definition: user.c:1313
CompositeTypeStmt::typevar
RangeVar * typevar
Definition: parsenodes.h:3211
EventTriggerDDLCommandEnd
void EventTriggerDDLCommandEnd(Node *parsetree)
Definition: event_trigger.c:689
Node
Definition: nodes.h:536
ExecAlterExtensionContentsStmt
ObjectAddress ExecAlterExtensionContentsStmt(AlterExtensionContentsStmt *stmt, ObjectAddress *objAddr)
Definition: extension.c:3266
list_concat
List * list_concat(List *list1, const List *list2)
Definition: list.c:530
errcode
int errcode(int sqlerrcode)
Definition: elog.c:698
CreateProceduralLanguage
ObjectAddress CreateProceduralLanguage(CreatePLangStmt *stmt)
Definition: proclang.c:39
AlterTableCmd::subtype
AlterTableType subtype
Definition: parsenodes.h:1962
EventTriggerInhibitCommandCollection
void EventTriggerInhibitCommandCollection(void)
Definition: event_trigger.c:1476
DefineDomain
ObjectAddress DefineDomain(CreateDomainStmt *stmt)
Definition: typecmds.c:693
DefineCompositeType
ObjectAddress DefineCompositeType(RangeVar *typevar, List *coldeflist)
Definition: typecmds.c:2509
Oid
unsigned int Oid
Definition: postgres_ext.h:31
DefineOpClass
ObjectAddress DefineOpClass(CreateOpClassStmt *stmt)
Definition: opclasscmds.c:328
None_Receiver
DestReceiver * None_Receiver
Definition: dest.c:96
NewRelationCreateToastTable
void NewRelationCreateToastTable(Oid relOid, Datum reloptions)
Definition: toasting.c:73
OidIsValid
#define OidIsValid(objectId)
Definition: c.h:710
PlannedStmt::stmt_len
int stmt_len
Definition: plannodes.h:90
EventTriggerAlterTableStart
void EventTriggerAlterTableStart(Node *parsetree)
Definition: event_trigger.c:1548
RangeVar::relname
char * relname
Definition: primnodes.h:68
AlterTable
void AlterTable(AlterTableStmt *stmt, LOCKMODE lockmode, AlterTableUtilityContext *context)
Definition: tablecmds.c:3993
IndexStmt::relation
RangeVar * relation
Definition: parsenodes.h:2889
AlterPolicy
ObjectAddress AlterPolicy(AlterPolicyStmt *stmt)
Definition: policy.c:773
AlterStatistics
ObjectAddress AlterStatistics(AlterStatsStmt *stmt)
Definition: statscmds.c:619
linitial
#define linitial(l)
Definition: pg_list.h:174
RangeVarCallbackOwnsRelation
void RangeVarCallbackOwnsRelation(const RangeVar *relation, Oid relId, Oid oldRelId, void *arg)
Definition: tablecmds.c:16508
DefineStmt::args
List * args
Definition: parsenodes.h:2683
ProcessUtility
void ProcessUtility(PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
Definition: utility.c:503
ERROR
#define ERROR
Definition: elog.h:46
AlterDomainDefault
ObjectAddress AlterDomainDefault(List *names, Node *defaultRaw)
Definition: typecmds.c:2567
AlterOperator
ObjectAddress AlterOperator(AlterOperatorStmt *stmt)
Definition: operatorcmds.c:409
EventTriggerDDLCommandStart
void EventTriggerDDLCommandStart(Node *parsetree)
Definition: event_trigger.c:641
CreatePolicy
ObjectAddress CreatePolicy(CreatePolicyStmt *stmt)
Definition: policy.c:573
EventTriggerSQLDrop
void EventTriggerSQLDrop(Node *parsetree)
Definition: event_trigger.c:737
AlterTSConfiguration
ObjectAddress AlterTSConfiguration(AlterTSConfigurationStmt *stmt)
Definition: tsearchcmds.c:1109
AlterType
ObjectAddress AlterType(AlterTypeStmt *stmt)
Definition: typecmds.c:4098
AlterDomainNotNull
ObjectAddress AlterDomainNotNull(List *names, bool notNull)
Definition: typecmds.c:2699
RemoveUserMapping
Oid RemoveUserMapping(DropUserMappingStmt *stmt)
Definition: foreigncmds.c:1311
CreateUserMapping
ObjectAddress CreateUserMapping(CreateUserMappingStmt *stmt)
Definition: foreigncmds.c:1091
PlannedStmt::stmt_location
int stmt_location
Definition: plannodes.h:89
AlterTSDictionary
ObjectAddress AlterTSDictionary(AlterTSDictionaryStmt *stmt)
Definition: tsearchcmds.c:487
IndexStmt::transformed
bool transformed
Definition: parsenodes.h:2909
errdetail
int errdetail(const char *fmt,...)
Definition: elog.c:1042
PlannedStmt::utilityStmt
Node * utilityStmt
Definition: plannodes.h:86
PreventInTransactionBlock
void PreventInTransactionBlock(bool isTopLevel, const char *stmtType)
Definition: xact.c:3389
AlterTableUtilityContext::queryString
const char * queryString
Definition: utility.h:33
CreateStmt::options
List * options
Definition: parsenodes.h:2191
RangeVarGetRelidExtended
Oid RangeVarGetRelidExtended(const RangeVar *relation, LOCKMODE lockmode, uint32 flags, RangeVarGetRelidCallback callback, void *callback_arg)
Definition: namespace.c:237
DefineEnum
ObjectAddress DefineEnum(CreateEnumStmt *stmt)
Definition: typecmds.c:1137
DefineView
ObjectAddress DefineView(ViewStmt *stmt, const char *queryString, int stmt_location, int stmt_len)
Definition: view.c:407
CreateSchemaCommand
Oid CreateSchemaCommand(CreateSchemaStmt *stmt, const char *queryString, int stmt_location, int stmt_len)
Definition: schemacmds.c:50
HEAP_RELOPT_NAMESPACES
#define HEAP_RELOPT_NAMESPACES
Definition: reloptions.h:61
AlterUserMapping
ObjectAddress AlterUserMapping(AlterUserMappingStmt *stmt)
Definition: foreigncmds.c:1213
ExecRenameStmt
ObjectAddress ExecRenameStmt(RenameStmt *stmt)
Definition: alter.c:331
DefineSequence
ObjectAddress DefineSequence(ParseState *pstate, CreateSeqStmt *seq)
Definition: sequence.c:118
DefineRelation
ObjectAddress DefineRelation(CreateStmt *stmt, char relkind, Oid ownerId, ObjectAddress *typaddress, const char *queryString)
Definition: tablecmds.c:627
AlterTableUtilityContext::queryEnv
QueryEnvironment * queryEnv
Definition: utility.h:36
ExecAlterDefaultPrivilegesStmt
void ExecAlterDefaultPrivilegesStmt(ParseState *pstate, AlterDefaultPrivilegesStmt *stmt)
Definition: aclchk.c:905
DefineType
ObjectAddress DefineType(ParseState *pstate, List *names, List *parameters)
Definition: typecmds.c:148
RangeVar::inh
bool inh
Definition: primnodes.h:69
AlterForeignDataWrapper
ObjectAddress AlterForeignDataWrapper(ParseState *pstate, AlterFdwStmt *stmt)
Definition: foreigncmds.c:674
CreateExtension
ObjectAddress CreateExtension(ParseState *pstate, CreateExtensionStmt *stmt)
Definition: extension.c:1681
EventTriggerEndCompleteQuery
void EventTriggerEndCompleteQuery(void)
Definition: event_trigger.c:1119
AlterSubscription
ObjectAddress AlterSubscription(ParseState *pstate, AlterSubscriptionStmt *stmt, bool isTopLevel)
Definition: subscriptioncmds.c:821
AlterTableGetLockLevel
LOCKMODE AlterTableGetLockLevel(List *cmds)
Definition: tablecmds.c:4067
CreateForeignServer
ObjectAddress CreateForeignServer(CreateForeignServerStmt *stmt)
Definition: foreigncmds.c:838
DefineStmt::replace
bool replace
Definition: parsenodes.h:2686
PG_FINALLY
#define PG_FINALLY()
Definition: elog.h:330
PlannedStmt::canSetTag
bool canSetTag
Definition: plannodes.h:54
EventTriggerUndoInhibitCommandCollection
void EventTriggerUndoInhibitCommandCollection(void)
Definition: event_trigger.c:1488
Datum
uintptr_t Datum
Definition: postgres.h:411
PlannedStmt::commandType
CmdType commandType
Definition: plannodes.h:46
CommandCounterIncrement
void CommandCounterIncrement(void)
Definition: xact.c:1021
DefineRange
ObjectAddress DefineRange(ParseState *pstate, CreateRangeStmt *stmt)
Definition: typecmds.c:1336
IndexStmt::unique
bool unique
Definition: parsenodes.h:2904
DefineStmt::kind
ObjectType kind
Definition: parsenodes.h:2680
ExecAlterObjectDependsStmt
ObjectAddress ExecAlterObjectDependsStmt(AlterObjectDependsStmt *stmt, ObjectAddress *refAddress)
Definition: alter.c:431
EventTriggerCollectAlterDefPrivs
void EventTriggerCollectAlterDefPrivs(AlterDefaultPrivilegesStmt *stmt)
Definition: event_trigger.c:1819
expandTableLikeClause
List * expandTableLikeClause(RangeVar *heapRel, TableLikeClause *table_like_clause)
Definition: parse_utilcmd.c:1186
InvalidOid
#define InvalidOid
Definition: postgres_ext.h:36
DefineCollation
ObjectAddress DefineCollation(ParseState *pstate, List *names, List *parameters, bool if_not_exists)
Definition: collationcmds.c:53
DefineStmt::defnames
List * defnames
Definition: parsenodes.h:2682
ereport
#define ereport(elevel,...)
Definition: elog.h:157
NOTICE
#define NOTICE
Definition: elog.h:37
CreateCast
ObjectAddress CreateCast(CreateCastStmt *stmt)
Definition: functioncmds.c:1526
ExecAlterExtensionStmt
ObjectAddress ExecAlterExtensionStmt(ParseState *pstate, AlterExtensionStmt *stmt)
Definition: extension.c:2961
ExecAlterObjectSchemaStmt
ObjectAddress ExecAlterObjectSchemaStmt(AlterObjectSchemaStmt *stmt, ObjectAddress *oldSchemaAddr)
Definition: alter.c:495
makeNode
#define makeNode(_type_)
Definition: nodes.h:584
ShareUpdateExclusiveLock
#define ShareUpdateExclusiveLock
Definition: lockdefs.h:39
DefineTSDictionary
ObjectAddress DefineTSDictionary(List *names, List *parameters)
Definition: tsearchcmds.c:391
Assert
#define Assert(condition)
Definition: c.h:804
lfirst
#define lfirst(lc)
Definition: pg_list.h:169
CreateSubscription
ObjectAddress CreateSubscription(ParseState *pstate, CreateSubscriptionStmt *stmt, bool isTopLevel)
Definition: subscriptioncmds.c:375
ExecRefreshMatView
ObjectAddress ExecRefreshMatView(RefreshMatViewStmt *stmt, const char *queryString, ParamListInfo params, QueryCompletion *qc)
Definition: matview.c:138
CreateConversionCommand
ObjectAddress CreateConversionCommand(CreateConversionStmt *stmt)
Definition: conversioncmds.c:37
AlterTableMoveAll
Oid AlterTableMoveAll(AlterTableMoveAllStmt *stmt)
Definition: tablecmds.c:14031
transformCreateStmt
List * transformCreateStmt(CreateStmt *stmt, const char *queryString)
Definition: parse_utilcmd.c:165
ExecAlterOwnerStmt
ObjectAddress ExecAlterOwnerStmt(AlterOwnerStmt *stmt)
Definition: alter.c:833
ExecCreateTableAs
ObjectAddress ExecCreateTableAs(ParseState *pstate, CreateTableAsStmt *stmt, ParamListInfo params, QueryEnvironment *queryEnv, QueryCompletion *qc)
Definition: createas.c:226
nodeTag
#define nodeTag(nodeptr)
Definition: nodes.h:541
EventTriggerAlterTableRelid
void EventTriggerAlterTableRelid(Oid objectId)
Definition: event_trigger.c:1582
AlterOpFamily
Oid AlterOpFamily(AlterOpFamilyStmt *stmt)
Definition: opclasscmds.c:808
DefineOpFamily
ObjectAddress DefineOpFamily(CreateOpFamilyStmt *stmt)
Definition: opclasscmds.c:763
AlterDomainDropConstraint
ObjectAddress AlterDomainDropConstraint(List *names, const char *constrName, DropBehavior behavior, bool missing_ok)
Definition: typecmds.c:2819
IndexStmt::concurrent
bool concurrent
Definition: parsenodes.h:2910
DefineRule
ObjectAddress DefineRule(RuleStmt *stmt, const char *queryString)
Definition: rewriteDefine.c:199
find_all_inheritors
List * find_all_inheritors(Oid parentrelId, LOCKMODE lockmode, List **numparents)
Definition: pg_inherits.c:256
transformStatsStmt
CreateStatsStmt * transformStatsStmt(Oid relid, CreateStatsStmt *stmt, const char *queryString)
Definition: parse_utilcmd.c:2900
InvalidObjectAddress
const ObjectAddress InvalidObjectAddress
Definition: objectaddress.c:846
ImportForeignSchema
void ImportForeignSchema(ImportForeignSchemaStmt *stmt)
Definition: foreigncmds.c:1471
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:909
AlterTableStmt::relation
RangeVar * relation
Definition: parsenodes.h:1871
list_free
void list_free(List *list)
Definition: list.c:1391
elog
#define elog(elevel,...)
Definition: elog.h:232
AlterCollation
ObjectAddress AlterCollation(AlterCollationStmt *stmt)
Definition: collationcmds.c:311
ShareLock
#define ShareLock
Definition: lockdefs.h:41
DefineTSTemplate
ObjectAddress DefineTSTemplate(List *names, List *parameters)
Definition: tsearchcmds.c:684
DefineStmt::if_not_exists
bool if_not_exists
Definition: parsenodes.h:2685
CreateTrigger
ObjectAddress CreateTrigger(CreateTrigStmt *stmt, const char *queryString, Oid relOid, Oid refRelOid, Oid constraintOid, Oid indexOid, Oid funcoid, Oid parentTriggerOid, Node *whenClause, bool isInternal, bool in_partition)
Definition: trigger.c:156
CreateAccessMethod
ObjectAddress CreateAccessMethod(CreateAmStmt *stmt)
Definition: amcmds.c:43
DefineStmt::definition
List * definition
Definition: parsenodes.h:2684
EventTriggerCollectSimpleCommand
void EventTriggerCollectSimpleCommand(ObjectAddress address, ObjectAddress secondaryObject, Node *parsetree)
Definition: event_trigger.c:1510
PG_TRY
#define PG_TRY()
Definition: elog.h:313
transformIndexStmt
IndexStmt * transformIndexStmt(Oid relid, IndexStmt *stmt, const char *queryString)
Definition: parse_utilcmd.c:2805
List
Definition: pg_list.h:50
AlterFunction
ObjectAddress AlterFunction(ParseState *pstate, AlterFunctionStmt *stmt)
Definition: functioncmds.c:1353
AlterTableUtilityContext::params
ParamListInfo params
Definition: utility.h:35
AlterPublication
void AlterPublication(ParseState *pstate, AlterPublicationStmt *stmt)
Definition: publicationcmds.c:450
DefineStmt::oldstyle
bool oldstyle
Definition: parsenodes.h:2681
PG_END_TRY
#define PG_END_TRY()
Definition: elog.h:338
lfirst_oid
#define lfirst_oid(lc)
Definition: pg_list.h:171
list_delete_first
List * list_delete_first(List *list)
Definition: list.c:875
EventTriggerBeginCompleteQuery
bool EventTriggerBeginCompleteQuery(void)
Definition: event_trigger.c:1075
ExecuteGrantStmt
void ExecuteGrantStmt(GrantStmt *stmt)
Definition: aclchk.c:360
EventTriggerAlterTableEnd
void EventTriggerAlterTableEnd(void)
Definition: event_trigger.c:1635
CreateStatistics
ObjectAddress CreateStatistics(CreateStatsStmt *stmt)
Definition: statscmds.c:65

◆ standard_ProcessUtility()

void standard_ProcessUtility ( PlannedStmt *  pstmt,
const char *  queryString,
bool  readOnlyTree,
ProcessUtilityContext  context,
ParamListInfo  params,
QueryEnvironment *  queryEnv,
DestReceiver *  dest,
QueryCompletion *  qc 
)

Definition at line 544 of file utility.c.

References AfterTriggerSetState(), AlterDatabase(), AlterDatabaseSet(), AlterEventTrigger(), AlterRole(), AlterRoleSet(), AlterSystemSetConfigFile(), AlterTableSpaceOptions(), DefElem::arg, Async_Listen(), Async_Notify(), Async_Unlisten(), Async_UnlistenAll(), B_BACKEND, BeginTransactionBlock(), castNode, TransactionStmt::chain, check_stack_depth(), CHECKPOINT_FORCE, CHECKPOINT_IMMEDIATE, CHECKPOINT_WAIT, CheckRestrictedOperation(), ClassifyUtilityCommandAsReadOnly(), closeAllVfds(), cluster(), COMMAND_IS_STRICTLY_READ_ONLY, COMMAND_OK_IN_PARALLEL_MODE, COMMAND_OK_IN_READ_ONLY_TXN, COMMAND_OK_IN_RECOVERY, CommandCounterIncrement(), CommentObject(), NotifyStmt::conditionname, ListenStmt::conditionname, UnlistenStmt::conditionname, copyObject, CreateCommandTag(), createdb(), CreateEventTrigger(), CreateRole(), CreateTableSpace(), DeallocateQuery(), DefineSavepoint(), DefElem::defname, DiscardCommand(), DoCopy(), DropDatabase(), DropRole(), DropTableSpace(), EndTransactionBlock(), ereport, errcode(), errmsg(), ERROR, EventTriggerSupportsObjectType(), ExecAlterObjectDependsStmt(), ExecAlterObjectSchemaStmt(), ExecAlterOwnerStmt(), ExecDropStmt(), ExecReindex(), ExecRenameStmt(), ExecSecLabelStmt(), ExecSetVariableStmt(), ExecuteCallStmt(), ExecuteDoStmt(), ExecuteGrantStmt(), ExecuteQuery(), ExecuteTruncate(), ExecVacuum(), ExplainQuery(), LoadStmt::filename, FinishPreparedTransaction(), free_parsestate(), GetCommandTagName(), GetPGVariable(), TransactionStmt::gid, GrantRole(), IsInParallelMode(), IsTransactionBlock(), TransactionStmt::kind, lfirst, list_make1, load_file(), LockTableCommand(), make_parsestate(), MyBackendType, VariableShowStmt::name, nodeTag, AlterObjectDependsStmt::objectType, AlterObjectSchemaStmt::objectType, AlterOwnerStmt::objectType, GrantStmt::objtype, CommentStmt::objtype, SecLabelStmt::objtype, TransactionStmt::options, ParseState::p_queryEnv, ParseState::p_sourcetext, NotifyStmt::payload, PerformCursorOpen(), PerformPortalClose(), PerformPortalFetch(), ClosePortalStmt::portalname, PrepareQuery(), PrepareTransactionBlock(), PreventCommandDuringRecovery(), PreventCommandIfParallelMode(), PreventCommandIfReadOnly(), PreventInTransactionBlock(), PROCESS_UTILITY_QUERY_NONATOMIC, PROCESS_UTILITY_TOPLEVEL, ProcessUtilitySlow(), ReassignOwnedObjects(), RecoveryInProgress(), ReleaseSavepoint(), DropStmt::removeType, RenameStmt::renameType, RequestCheckpoint(), RequireTransactionBlock(), RollbackToSavepoint(), TransactionStmt::savepoint_name, SetPGVariable(), SetQueryCompletion(), PlannedStmt::stmt_len, PlannedStmt::stmt_location, superuser(), T_AlterDatabaseSetStmt, T_AlterDatabaseStmt, T_AlterEventTrigStmt, T_AlterObjectDependsStmt, T_AlterObjectSchemaStmt, T_AlterOwnerStmt, T_AlterRoleSetStmt, T_AlterRoleStmt, T_AlterSystemStmt, T_AlterTableSpaceOptionsStmt, T_CallStmt, T_CheckPointStmt, T_ClosePortalStmt, T_ClusterStmt, T_CommentStmt, T_ConstraintsSetStmt, T_CopyStmt, T_CreatedbStmt, T_CreateEventTrigStmt, T_CreateRoleStmt, T_CreateTableSpaceStmt, T_DeallocateStmt, T_DeclareCursorStmt, T_DiscardStmt, T_DoStmt, T_DropdbStmt, T_DropRoleStmt, T_DropStmt, T_DropTableSpaceStmt, T_ExecuteStmt, T_ExplainStmt, T_FetchStmt, T_GrantRoleStmt, T_GrantStmt, T_ListenStmt, T_LoadStmt, T_LockStmt, T_NotifyStmt, T_PrepareStmt, T_ReassignOwnedStmt, T_ReindexStmt, T_RenameStmt, T_SecLabelStmt, T_TransactionStmt, T_TruncateStmt, T_UnlistenStmt, T_VacuumStmt, T_VariableSetStmt, T_VariableShowStmt, TRANS_STMT_BEGIN, TRANS_STMT_COMMIT, TRANS_STMT_COMMIT_PREPARED, TRANS_STMT_PREPARE, TRANS_STMT_RELEASE, TRANS_STMT_ROLLBACK, TRANS_STMT_ROLLBACK_PREPARED, TRANS_STMT_ROLLBACK_TO, TRANS_STMT_SAVEPOINT, TRANS_STMT_START, UserAbortTransactionBlock(), PlannedStmt::utilityStmt, WarnNoTransactionBlock(), and XactReadOnly.

Referenced by pgss_ProcessUtility(), ProcessUtility(), and sepgsql_utility_command().

552 {
553  Node *parsetree;
554  bool isTopLevel = (context == PROCESS_UTILITY_TOPLEVEL);
555  bool isAtomicContext = (!(context == PROCESS_UTILITY_TOPLEVEL || context == PROCESS_UTILITY_QUERY_NONATOMIC) || IsTransactionBlock());
556  ParseState *pstate;
557  int readonly_flags;
558 
559  /* This can recurse, so check for excessive recursion */
560  check_stack_depth();
561 
562  /*
563  * If the given node tree is read-only, make a copy to ensure that parse
564  * transformations don't damage the original tree. This could be
565  * refactored to avoid making unnecessary copies in more cases, but it's
566  * not clear that it's worth a great deal of trouble over. Statements
567  * that are complex enough to be expensive to copy are exactly the ones
568  * we'd need to copy, so that only marginal savings seem possible.
569  */
570  if (readOnlyTree)
571  pstmt = copyObject(pstmt);
572  parsetree = pstmt->utilityStmt;
573 
574  /* Prohibit read/write commands in read-only states. */
575  readonly_flags = ClassifyUtilityCommandAsReadOnly(parsetree);
576  if (readonly_flags != COMMAND_IS_STRICTLY_READ_ONLY &&
577  (XactReadOnly || IsInParallelMode()))
578  {
579  CommandTag commandtag = CreateCommandTag(parsetree);
580 
581  if ((readonly_flags & COMMAND_OK_IN_READ_ONLY_TXN) == 0)
582  PreventCommandIfReadOnly(GetCommandTagName(commandtag));
583  if ((readonly_flags & COMMAND_OK_IN_PARALLEL_MODE) == 0)
584  PreventCommandIfParallelMode(GetCommandTagName(commandtag));
585  if ((readonly_flags & COMMAND_OK_IN_RECOVERY) == 0)
586  PreventCommandDuringRecovery(GetCommandTagName(commandtag));
587  }
588 
589  pstate = make_parsestate(NULL);
590  pstate->p_sourcetext = queryString;
591  pstate->p_queryEnv = queryEnv;
592 
593  switch (nodeTag(parsetree))
594  {
595  /*
596  * ******************** transactions ********************
597  */
598  case T_TransactionStmt:
599  {
600  TransactionStmt *stmt = (TransactionStmt *) parsetree;
601 
602  switch (stmt->kind)
603  {
604  /*
605  * START TRANSACTION, as defined by SQL99: Identical
606  * to BEGIN. Same code for both.
607  */
608  case TRANS_STMT_BEGIN:
609  case TRANS_STMT_START:
610  {
611  ListCell *lc;
612 
613  BeginTransactionBlock();
614  foreach(lc, stmt->options)
615  {
616  DefElem *item = (DefElem *) lfirst(lc);
617 
618  if (strcmp(item->defname, "transaction_isolation") == 0)
619  SetPGVariable("transaction_isolation",
620  list_make1(item->arg),
621  true);
622  else if (strcmp(item->defname, "transaction_read_only") == 0)
623  SetPGVariable("transaction_read_only",
624  list_make1(item->arg),
625  true);
626  else if (strcmp(item->defname, "transaction_deferrable") == 0)
627  SetPGVariable("transaction_deferrable",
628  list_make1(item->arg),
629  true);
630  }
631  }
632  break;
633 
634  case TRANS_STMT_COMMIT:
635  if (!EndTransactionBlock(stmt->chain))
636  {
637  /* report unsuccessful commit in qc */
638  if (qc)
639  SetQueryCompletion(qc, CMDTAG_ROLLBACK, 0);
640  }
641  break;
642 
643  case TRANS_STMT_PREPARE:
644  if (!PrepareTransactionBlock(stmt->gid))
645  {
646  /* report unsuccessful commit in qc */
647  if (qc)
648  SetQueryCompletion(qc, CMDTAG_ROLLBACK, 0);
649  }
650  break;
651 
652  case TRANS_STMT_COMMIT_PREPARED:
653  PreventInTransactionBlock(isTopLevel, "COMMIT PREPARED");
654  FinishPreparedTransaction(stmt->gid, true);
655  break;
656 
657  case TRANS_STMT_ROLLBACK_PREPARED:
658  PreventInTransactionBlock(isTopLevel, "ROLLBACK PREPARED");
659  FinishPreparedTransaction(stmt->gid, false);
660  break;
661 
662  case TRANS_STMT_ROLLBACK:
663  UserAbortTransactionBlock(stmt->chain);
664  break;
665 
666  case TRANS_STMT_SAVEPOINT:
667  RequireTransactionBlock(isTopLevel, "SAVEPOINT");
668  DefineSavepoint(stmt->savepoint_name);
669  break;
670 
671  case TRANS_STMT_RELEASE:
672  RequireTransactionBlock(isTopLevel, "RELEASE SAVEPOINT");
673  ReleaseSavepoint(stmt->savepoint_name);
674  break;
675 
676  case TRANS_STMT_ROLLBACK_TO:
677  RequireTransactionBlock(isTopLevel, "ROLLBACK TO SAVEPOINT");
678  RollbackToSavepoint(stmt->savepoint_name);
679 
680  /*
681  * CommitTransactionCommand is in charge of
682  * re-defining the savepoint again
683  */
684  break;
685  }
686  }
687  break;
688 
689  /*
690  * Portal (cursor) manipulation
691  */
692  case T_DeclareCursorStmt:
693  PerformCursorOpen(pstate, (DeclareCursorStmt *) parsetree, params,
694  isTopLevel);
695  break;
696 
697  case T_ClosePortalStmt:
698  {
699  ClosePortalStmt *stmt = (ClosePortalStmt *) parsetree;
700 
701  CheckRestrictedOperation("CLOSE");
702  PerformPortalClose(stmt->portalname);
703  }
704  break;
705 
706  case T_FetchStmt:
707  PerformPortalFetch((FetchStmt *) parsetree, dest, qc);
708  break;
709 
710  case T_DoStmt:
711  ExecuteDoStmt(pstate, (DoStmt *) parsetree, isAtomicContext);
712  break;
713 
714  case T_CreateTableSpaceStmt:
715  /* no event triggers for global objects */
716  PreventInTransactionBlock(isTopLevel, "CREATE TABLESPACE");
717  CreateTableSpace((CreateTableSpaceStmt *) parsetree);
718  break;
719 
720  case T_DropTableSpaceStmt:
721  /* no event triggers for global objects */
722  PreventInTransactionBlock(isTopLevel, "DROP TABLESPACE");
723  DropTableSpace((DropTableSpaceStmt *) parsetree);
724  break;
725 
726  case T_AlterTableSpaceOptionsStmt:
727  /* no event triggers for global objects */
728  AlterTableSpaceOptions((AlterTableSpaceOptionsStmt *) parsetree);
729  break;
730 
731  case T_TruncateStmt:
732  ExecuteTruncate((TruncateStmt *) parsetree);
733  break;
734 
735  case T_CopyStmt:
736  {
737  uint64 processed;
738 
739  DoCopy(pstate, (CopyStmt *) parsetree,
740  pstmt->stmt_location, pstmt->stmt_len,
741  &processed);
742  if (qc)
743  SetQueryCompletion(qc, CMDTAG_COPY, processed);
744  }
745  break;
746 
747  case T_PrepareStmt:
748  CheckRestrictedOperation("PREPARE");
749  PrepareQuery(pstate, (PrepareStmt *) parsetree,
750  pstmt->stmt_location, pstmt->stmt_len);
751  break;
752 
753  case T_ExecuteStmt:
754  ExecuteQuery(pstate,
755  (ExecuteStmt *) parsetree, NULL,
756  params,
757  dest, qc);
758  break;
759 
760  case T_DeallocateStmt:
761  CheckRestrictedOperation("DEALLOCATE");
762  DeallocateQuery((DeallocateStmt *) parsetree);
763  break;
764 
765  case T_GrantRoleStmt:
766  /* no event triggers for global objects */
767  GrantRole((GrantRoleStmt *) parsetree);
768  break;
769 
770  case T_CreatedbStmt:
771  /* no event triggers for global objects */
772  PreventInTransactionBlock(isTopLevel, "CREATE DATABASE");
773  createdb(pstate, (CreatedbStmt *) parsetree);
774  break;
775 
776  case T_AlterDatabaseStmt:
777  /* no event triggers for global objects */
778  AlterDatabase(pstate, (AlterDatabaseStmt *) parsetree, isTopLevel);
779  break;
780 
781  case T_AlterDatabaseSetStmt:
782  /* no event triggers for global objects */
783  AlterDatabaseSet((AlterDatabaseSetStmt *) parsetree);
784  break;
785 
786  case T_DropdbStmt:
787  /* no event triggers for global objects */
788  PreventInTransactionBlock(isTopLevel, "DROP DATABASE");
789  DropDatabase(pstate, (DropdbStmt *) parsetree);
790  break;
791 
792  /* Query-level asynchronous notification */
793  case T_NotifyStmt:
794  {
795  NotifyStmt *stmt = (NotifyStmt *) parsetree;
796 
797  Async_Notify(stmt->conditionname, stmt->payload);
798  }
799  break;
800 
801  case T_ListenStmt:
802  {
803  ListenStmt *stmt = (ListenStmt *) parsetree;
804 
805  CheckRestrictedOperation("LISTEN");
806 
807  /*
808  * We don't allow LISTEN in background processes, as there is
809  * no mechanism for them to collect NOTIFY messages, so they'd
810  * just block cleanout of the async SLRU indefinitely.
811  * (Authors of custom background workers could bypass this
812  * restriction by calling Async_Listen directly, but then it's
813  * on them to provide some mechanism to process the message
814  * queue.) Note there seems no reason to forbid UNLISTEN.
815  */
816  if (MyBackendType != B_BACKEND)
817  ereport(ERROR,
818  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
819  /* translator: %s is name of a SQL command, eg LISTEN */
820  errmsg("cannot execute %s within a background process",
821  "LISTEN")));
822 
823  Async_Listen(stmt->conditionname);
824  }
825  break;
826 
827  case T_UnlistenStmt:
828  {
829  UnlistenStmt *stmt = (UnlistenStmt *) parsetree;
830 
831  CheckRestrictedOperation("UNLISTEN");
832  if (stmt->conditionname)
833  Async_Unlisten(stmt->conditionname);
834  else
835  Async_UnlistenAll();
836  }
837  break;
838 
839  case T_LoadStmt:
840  {
841  LoadStmt *stmt = (LoadStmt *) parsetree;
842 
843  closeAllVfds(); /* probably not necessary... */
844  /* Allowed names are restricted if you're not superuser */
845  load_file(stmt->filename, !superuser());
846  }
847  break;
848 
849  case T_CallStmt:
850  ExecuteCallStmt(castNode(CallStmt, parsetree), params, isAtomicContext, dest);
851  break;
852 
853  case T_ClusterStmt:
854  cluster(pstate, (ClusterStmt *) parsetree, isTopLevel);
855  break;
856 
857  case T_VacuumStmt:
858  ExecVacuum(pstate, (VacuumStmt *) parsetree, isTopLevel);
859  break;
860 
861  case T_ExplainStmt:
862  ExplainQuery(pstate, (ExplainStmt *) parsetree, params, dest);
863  break;
864 
865  case T_AlterSystemStmt:
866  PreventInTransactionBlock(isTopLevel, "ALTER SYSTEM");
867  AlterSystemSetConfigFile((AlterSystemStmt *) parsetree);
868  break;
869 
870  case T_VariableSetStmt:
871  ExecSetVariableStmt((VariableSetStmt *) parsetree, isTopLevel);
872  break;
873 
874  case T_VariableShowStmt:
875  {
876  VariableShowStmt *n = (VariableShowStmt *) parsetree;
877 
878  GetPGVariable(n->name, dest);
879  }
880  break;
881 
882  case T_DiscardStmt:
883  /* should we allow DISCARD PLANS? */
884  CheckRestrictedOperation("DISCARD");
885  DiscardCommand((DiscardStmt *) parsetree, isTopLevel);
886  break;
887 
888  case T_CreateEventTrigStmt:
889  /* no event triggers on event triggers */
890  CreateEventTrigger((CreateEventTrigStmt *) parsetree);
891  break;
892 
893  case T_AlterEventTrigStmt:
894  /* no event triggers on event triggers */
895  AlterEventTrigger((AlterEventTrigStmt *) parsetree);
896  break;
897 
898  /*
899  * ******************************** ROLE statements ****
900  */
901  case T_CreateRoleStmt:
902  /* no event triggers for global objects */
903  CreateRole(pstate, (CreateRoleStmt *) parsetree);
904  break;
905 
906  case T_AlterRoleStmt:
907  /* no event triggers for global objects */
908  AlterRole(pstate, (AlterRoleStmt *) parsetree);
909  break;
910 
911  case T_AlterRoleSetStmt:
912  /* no event triggers for global objects */
913  AlterRoleSet((AlterRoleSetStmt *) parsetree);
914  break;
915 
916  case T_DropRoleStmt:
917  /* no event triggers for global objects */
918  DropRole((DropRoleStmt *) parsetree);
919  break;
920 
921  case T_ReassignOwnedStmt:
922  /* no event triggers for global objects */
923  ReassignOwnedObjects((ReassignOwnedStmt *) parsetree);
924  break;
925 
926  case T_LockStmt:
927 
928  /*
929  * Since the lock would just get dropped immediately, LOCK TABLE
930  * outside a transaction block is presumed to be user error.
931  */
932  RequireTransactionBlock(isTopLevel, "LOCK TABLE");
933  LockTableCommand((LockStmt *) parsetree);
934  break;
935 
936  case T_ConstraintsSetStmt:
937  WarnNoTransactionBlock(isTopLevel, "SET CONSTRAINTS");
938  AfterTriggerSetState((ConstraintsSetStmt *) parsetree);
939  break;
940 
941  case T_CheckPointStmt:
942  if (!superuser())
943  ereport(ERROR,
944  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
945  errmsg("must be superuser to do CHECKPOINT")));
946 
947  RequestCheckpoint(CHECKPOINT_IMMEDIATE | CHECKPOINT_WAIT |
948  (RecoveryInProgress() ? 0 : CHECKPOINT_FORCE));
949  break;
950 
951  case T_ReindexStmt:
952  ExecReindex(pstate, (ReindexStmt *) parsetree, isTopLevel);
953  break;
954 
955  /*
956  * The following statements are supported by Event Triggers only
957  * in some cases, so we "fast path" them in the other cases.
958  */
959 
960  case T_GrantStmt:
961  {
962  GrantStmt *stmt = (GrantStmt *) parsetree;
963 
964  if (EventTriggerSupportsObjectType(stmt->objtype))
965  ProcessUtilitySlow(pstate, pstmt, queryString,
966  context, params, queryEnv,
967  dest, qc);
968  else
969  ExecuteGrantStmt(stmt);
970  }
971  break;
972 
973  case T_DropStmt:
974  {
975  DropStmt *stmt = (DropStmt *) parsetree;
976 
977  if (EventTriggerSupportsObjectType(stmt->removeType))
978  ProcessUtilitySlow(pstate, pstmt, queryString,
979  context, params, queryEnv,
980  dest, qc);
981  else
982  ExecDropStmt(stmt, isTopLevel);
983  }
984  break;
985 
986  case T_RenameStmt:
987  {
988  RenameStmt *stmt = (RenameStmt *) parsetree;
989 
990  if (EventTriggerSupportsObjectType(stmt->renameType))
991  ProcessUtilitySlow(pstate, pstmt, queryString,
992  context, params, queryEnv,
993  dest, qc);
994  else
995  ExecRenameStmt(stmt);
996  }
997  break;
998 
999  case T_AlterObjectDependsStmt:
1000  {
1001  AlterObjectDependsStmt *stmt = (AlterObjectDependsStmt *) parsetree;
1002 
1003  if (EventTriggerSupportsObjectType(stmt->objectType))
1004  ProcessUtilitySlow(pstate, pstmt, queryString,
1005  context, params, queryEnv,
1006  dest, qc);
1007  else
1008  ExecAlterObjectDependsStmt(stmt, NULL);
1009  }
1010  break;
1011 
1012  case T_AlterObjectSchemaStmt:
1013  {
1014  AlterObjectSchemaStmt *stmt = (AlterObjectSchemaStmt *) parsetree;
1015 
1016  if (EventTriggerSupportsObjectType(stmt->objectType))
1017  ProcessUtilitySlow(pstate, pstmt, queryString,
1018  context, params, queryEnv,
1019  dest, qc);
1020  else
1021  ExecAlterObjectSchemaStmt(stmt, NULL);
1022  }
1023  break;
1024 
1025  case T_AlterOwnerStmt:
1026  {
1027  AlterOwnerStmt *stmt = (AlterOwnerStmt *) parsetree;
1028 
1029  if (EventTriggerSupportsObjectType(stmt->objectType))
1030  ProcessUtilitySlow(pstate, pstmt, queryString,
1031  context, params, queryEnv,
1032  dest, qc);
1033  else
1034  ExecAlterOwnerStmt(stmt);
1035  }
1036  break;
1037 
1038  case T_CommentStmt:
1039  {
1040  CommentStmt *stmt = (CommentStmt *) parsetree;
1041 
1042  if (EventTriggerSupportsObjectType(stmt->objtype))
1043  ProcessUtilitySlow(pstate, pstmt, queryString,
1044  context, params, queryEnv,
1045  dest, qc);
1046  else
1047  CommentObject(stmt);
1048  break;
1049  }
1050 
1051  case T_SecLabelStmt:
1052  {
1053  SecLabelStmt *stmt = (SecLabelStmt *) parsetree;
1054 
1055  if (EventTriggerSupportsObjectType(stmt->objtype))
1056  ProcessUtilitySlow(pstate, pstmt, queryString,
1057  context, params, queryEnv,
1058  dest, qc);
1059  else
1060  ExecSecLabelStmt(stmt);
1061  break;
1062  }
1063 
1064  default:
1065  /* All other statement types have event trigger support */
1066  ProcessUtilitySlow(pstate, pstmt, queryString,
1067  context, params, queryEnv,