PostgreSQL Source Code  git master
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros
event_trigger.h File Reference
Include dependency graph for event_trigger.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  EventTriggerData
 

Macros

#define AT_REWRITE_ALTER_PERSISTENCE   0x01
 
#define AT_REWRITE_DEFAULT_VAL   0x02
 
#define AT_REWRITE_COLUMN_REWRITE   0x04
 
#define AT_REWRITE_ALTER_OID   0x08
 
#define CALLED_AS_EVENT_TRIGGER(fcinfo)   ((fcinfo)->context != NULL && IsA((fcinfo)->context, EventTriggerData))
 

Typedefs

typedef struct EventTriggerData EventTriggerData
 

Functions

Oid CreateEventTrigger (CreateEventTrigStmt *stmt)
 
void RemoveEventTriggerById (Oid ctrigOid)
 
Oid get_event_trigger_oid (const char *trigname, bool missing_ok)
 
Oid AlterEventTrigger (AlterEventTrigStmt *stmt)
 
ObjectAddress AlterEventTriggerOwner (const char *name, Oid newOwnerId)
 
void AlterEventTriggerOwner_oid (Oid, Oid newOwnerId)
 
bool EventTriggerSupportsObjectType (ObjectType obtype)
 
bool EventTriggerSupportsObjectClass (ObjectClass objclass)
 
bool EventTriggerSupportsGrantObjectType (GrantObjectType objtype)
 
void EventTriggerDDLCommandStart (Node *parsetree)
 
void EventTriggerDDLCommandEnd (Node *parsetree)
 
void EventTriggerSQLDrop (Node *parsetree)
 
void EventTriggerTableRewrite (Node *parsetree, Oid tableOid, int reason)
 
bool EventTriggerBeginCompleteQuery (void)
 
void EventTriggerEndCompleteQuery (void)
 
bool trackDroppedObjectsNeeded (void)
 
void EventTriggerSQLDropAddObject (const ObjectAddress *object, bool original, bool normal)
 
void EventTriggerInhibitCommandCollection (void)
 
void EventTriggerUndoInhibitCommandCollection (void)
 
void EventTriggerCollectSimpleCommand (ObjectAddress address, ObjectAddress secondaryObject, Node *parsetree)
 
void EventTriggerAlterTableStart (Node *parsetree)
 
void EventTriggerAlterTableRelid (Oid objectId)
 
void EventTriggerCollectAlterTableSubcmd (Node *subcmd, ObjectAddress address)
 
void EventTriggerAlterTableEnd (void)
 
void EventTriggerCollectGrant (InternalGrant *istmt)
 
void EventTriggerCollectAlterOpFam (AlterOpFamilyStmt *stmt, Oid opfamoid, List *operators, List *procedures)
 
void EventTriggerCollectCreateOpClass (CreateOpClassStmt *stmt, Oid opcoid, List *operators, List *procedures)
 
void EventTriggerCollectAlterTSConfig (AlterTSConfigurationStmt *stmt, Oid cfgId, Oid *dictIds, int ndicts)
 
void EventTriggerCollectAlterDefPrivs (AlterDefaultPrivilegesStmt *stmt)
 

Macro Definition Documentation

#define AT_REWRITE_ALTER_OID   0x08

Definition at line 34 of file event_trigger.h.

Referenced by ATExecAddColumn(), and ATExecDropColumn().

#define AT_REWRITE_ALTER_PERSISTENCE   0x01

Definition at line 31 of file event_trigger.h.

Referenced by ATPrepCmd().

#define AT_REWRITE_COLUMN_REWRITE   0x04

Definition at line 33 of file event_trigger.h.

Referenced by ATPrepAlterColumnType().

#define AT_REWRITE_DEFAULT_VAL   0x02

Definition at line 32 of file event_trigger.h.

Referenced by ATExecAddColumn().

#define CALLED_AS_EVENT_TRIGGER (   fcinfo)    ((fcinfo)->context != NULL && IsA((fcinfo)->context, EventTriggerData))

Typedef Documentation

Function Documentation

Oid AlterEventTrigger ( AlterEventTrigStmt stmt)

Definition at line 498 of file event_trigger.c.

References ACL_KIND_EVENT_TRIGGER, aclcheck_error(), ACLCHECK_NOT_OWNER, CatalogTupleUpdate(), CStringGetDatum, ereport, errcode(), errmsg(), ERROR, EVENTTRIGGERNAME, EventTriggerRelationId, GETSTRUCT, GetUserId(), heap_close, heap_freetuple(), heap_open(), HeapTupleGetOid, HeapTupleIsValid, InvokeObjectPostAlterHook, pg_event_trigger_ownercheck(), RowExclusiveLock, SearchSysCacheCopy1, HeapTupleData::t_self, AlterEventTrigStmt::tgenabled, and AlterEventTrigStmt::trigname.

Referenced by standard_ProcessUtility().

499 {
500  Relation tgrel;
501  HeapTuple tup;
502  Oid trigoid;
503  Form_pg_event_trigger evtForm;
504  char tgenabled = stmt->tgenabled;
505 
507 
509  CStringGetDatum(stmt->trigname));
510  if (!HeapTupleIsValid(tup))
511  ereport(ERROR,
512  (errcode(ERRCODE_UNDEFINED_OBJECT),
513  errmsg("event trigger \"%s\" does not exist",
514  stmt->trigname)));
515 
516  trigoid = HeapTupleGetOid(tup);
517 
518  if (!pg_event_trigger_ownercheck(trigoid, GetUserId()))
520  stmt->trigname);
521 
522  /* tuple is a copy, so we can modify it below */
523  evtForm = (Form_pg_event_trigger) GETSTRUCT(tup);
524  evtForm->evtenabled = tgenabled;
525 
526  CatalogTupleUpdate(tgrel, &tup->t_self, tup);
527 
529  trigoid, 0);
530 
531  /* clean up */
532  heap_freetuple(tup);
534 
535  return trigoid;
536 }
#define GETSTRUCT(TUP)
Definition: htup_details.h:656
Oid GetUserId(void)
Definition: miscinit.c:283
int errcode(int sqlerrcode)
Definition: elog.c:575
#define heap_close(r, l)
Definition: heapam.h:97
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1374
unsigned int Oid
Definition: postgres_ext.h:31
#define ERROR
Definition: elog.h:43
bool pg_event_trigger_ownercheck(Oid et_oid, Oid roleid)
Definition: aclchk.c:4912
ItemPointerData t_self
Definition: htup.h:65
void aclcheck_error(AclResult aclerr, AclObjectKind objectkind, const char *objectname)
Definition: aclchk.c:3378
#define RowExclusiveLock
Definition: lockdefs.h:38
#define CStringGetDatum(X)
Definition: postgres.h:586
#define ereport(elevel, rest)
Definition: elog.h:122
#define InvokeObjectPostAlterHook(classId, objectId, subId)
Definition: objectaccess.h:163
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1287
FormData_pg_event_trigger * Form_pg_event_trigger
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EventTriggerRelationId
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
Definition: indexing.c:210
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:158
int errmsg(const char *fmt,...)
Definition: elog.c:797
#define HeapTupleGetOid(tuple)
Definition: htup_details.h:695
ObjectAddress AlterEventTriggerOwner ( const char *  name,
Oid  newOwnerId 
)

Definition at line 542 of file event_trigger.c.

References AlterEventTriggerOwner_internal(), CStringGetDatum, ereport, errcode(), errmsg(), ERROR, EVENTTRIGGERNAME, EventTriggerRelationId, heap_close, heap_freetuple(), heap_open(), HeapTupleGetOid, HeapTupleIsValid, ObjectAddressSet, RowExclusiveLock, and SearchSysCacheCopy1.

Referenced by ExecAlterOwnerStmt().

543 {
544  Oid evtOid;
545  HeapTuple tup;
546  Relation rel;
547  ObjectAddress address;
548 
550 
552 
553  if (!HeapTupleIsValid(tup))
554  ereport(ERROR,
555  (errcode(ERRCODE_UNDEFINED_OBJECT),
556  errmsg("event trigger \"%s\" does not exist", name)));
557 
558  evtOid = HeapTupleGetOid(tup);
559 
560  AlterEventTriggerOwner_internal(rel, tup, newOwnerId);
561 
562  ObjectAddressSet(address, EventTriggerRelationId, evtOid);
563 
564  heap_freetuple(tup);
565 
567 
568  return address;
569 }
int errcode(int sqlerrcode)
Definition: elog.c:575
#define heap_close(r, l)
Definition: heapam.h:97
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1374
unsigned int Oid
Definition: postgres_ext.h:31
static void AlterEventTriggerOwner_internal(Relation rel, HeapTuple tup, Oid newOwnerId)
#define ERROR
Definition: elog.h:43
#define RowExclusiveLock
Definition: lockdefs.h:38
#define CStringGetDatum(X)
Definition: postgres.h:586
#define ereport(elevel, rest)
Definition: elog.h:122
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1287
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EventTriggerRelationId
const char * name
Definition: encode.c:521
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:158
int errmsg(const char *fmt,...)
Definition: elog.c:797
#define HeapTupleGetOid(tuple)
Definition: htup_details.h:695
void AlterEventTriggerOwner_oid ( Oid  ,
Oid  newOwnerId 
)

Definition at line 575 of file event_trigger.c.

References AlterEventTriggerOwner_internal(), ereport, errcode(), errmsg(), ERROR, EVENTTRIGGEROID, EventTriggerRelationId, heap_close, heap_freetuple(), heap_open(), HeapTupleIsValid, ObjectIdGetDatum, RowExclusiveLock, and SearchSysCacheCopy1.

Referenced by shdepReassignOwned().

576 {
577  HeapTuple tup;
578  Relation rel;
579 
581 
583 
584  if (!HeapTupleIsValid(tup))
585  ereport(ERROR,
586  (errcode(ERRCODE_UNDEFINED_OBJECT),
587  errmsg("event trigger with OID %u does not exist", trigOid)));
588 
589  AlterEventTriggerOwner_internal(rel, tup, newOwnerId);
590 
591  heap_freetuple(tup);
592 
594 }
int errcode(int sqlerrcode)
Definition: elog.c:575
#define heap_close(r, l)
Definition: heapam.h:97
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1374
static void AlterEventTriggerOwner_internal(Relation rel, HeapTuple tup, Oid newOwnerId)
#define ObjectIdGetDatum(X)
Definition: postgres.h:515
#define ERROR
Definition: elog.h:43
#define RowExclusiveLock
Definition: lockdefs.h:38
#define ereport(elevel, rest)
Definition: elog.h:122
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1287
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EventTriggerRelationId
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:158
int errmsg(const char *fmt,...)
Definition: elog.c:797
Oid CreateEventTrigger ( CreateEventTrigStmt stmt)

Definition at line 166 of file event_trigger.c.

References DefElem::arg, CStringGetDatum, DefElem::defname, ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errhint(), errmsg(), ERROR, error_duplicate_filter_variable(), CreateEventTrigStmt::eventname, EVENTTRIGGERNAME, EVTTRIGGEROID, CreateEventTrigStmt::funcname, get_func_rettype(), GetUserId(), HeapTupleIsValid, insert_event_trigger_tuple(), lfirst, LookupFuncName(), NameListToString(), NULL, SearchSysCache1, superuser(), CreateEventTrigStmt::trigname, validate_ddl_tags(), validate_table_rewrite_tags(), and CreateEventTrigStmt::whenclause.

Referenced by standard_ProcessUtility().

167 {
168  HeapTuple tuple;
169  Oid funcoid;
170  Oid funcrettype;
171  Oid fargtypes[1]; /* dummy */
172  Oid evtowner = GetUserId();
173  ListCell *lc;
174  List *tags = NULL;
175 
176  /*
177  * It would be nice to allow database owners or even regular users to do
178  * this, but there are obvious privilege escalation risks which would have
179  * to somehow be plugged first.
180  */
181  if (!superuser())
182  ereport(ERROR,
183  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
184  errmsg("permission denied to create event trigger \"%s\"",
185  stmt->trigname),
186  errhint("Must be superuser to create an event trigger.")));
187 
188  /* Validate event name. */
189  if (strcmp(stmt->eventname, "ddl_command_start") != 0 &&
190  strcmp(stmt->eventname, "ddl_command_end") != 0 &&
191  strcmp(stmt->eventname, "sql_drop") != 0 &&
192  strcmp(stmt->eventname, "table_rewrite") != 0)
193  ereport(ERROR,
194  (errcode(ERRCODE_SYNTAX_ERROR),
195  errmsg("unrecognized event name \"%s\"",
196  stmt->eventname)));
197 
198  /* Validate filter conditions. */
199  foreach(lc, stmt->whenclause)
200  {
201  DefElem *def = (DefElem *) lfirst(lc);
202 
203  if (strcmp(def->defname, "tag") == 0)
204  {
205  if (tags != NULL)
207  tags = (List *) def->arg;
208  }
209  else
210  ereport(ERROR,
211  (errcode(ERRCODE_SYNTAX_ERROR),
212  errmsg("unrecognized filter variable \"%s\"", def->defname)));
213  }
214 
215  /* Validate tag list, if any. */
216  if ((strcmp(stmt->eventname, "ddl_command_start") == 0 ||
217  strcmp(stmt->eventname, "ddl_command_end") == 0 ||
218  strcmp(stmt->eventname, "sql_drop") == 0)
219  && tags != NULL)
220  validate_ddl_tags("tag", tags);
221  else if (strcmp(stmt->eventname, "table_rewrite") == 0
222  && tags != NULL)
223  validate_table_rewrite_tags("tag", tags);
224 
225  /*
226  * Give user a nice error message if an event trigger of the same name
227  * already exists.
228  */
230  if (HeapTupleIsValid(tuple))
231  ereport(ERROR,
233  errmsg("event trigger \"%s\" already exists",
234  stmt->trigname)));
235 
236  /* Find and validate the trigger function. */
237  funcoid = LookupFuncName(stmt->funcname, 0, fargtypes, false);
238  funcrettype = get_func_rettype(funcoid);
239  if (funcrettype != EVTTRIGGEROID)
240  ereport(ERROR,
241  (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
242  errmsg("function %s must return type %s",
243  NameListToString(stmt->funcname), "event_trigger")));
244 
245  /* Insert catalog entries. */
246  return insert_event_trigger_tuple(stmt->trigname, stmt->eventname,
247  evtowner, funcoid, tags);
248 }
static void validate_ddl_tags(const char *filtervar, List *taglist)
int errhint(const char *fmt,...)
Definition: elog.c:987
Oid GetUserId(void)
Definition: miscinit.c:283
static Oid insert_event_trigger_tuple(char *trigname, char *eventname, Oid evtOwner, Oid funcoid, List *tags)
int errcode(int sqlerrcode)
Definition: elog.c:575
bool superuser(void)
Definition: superuser.c:47
unsigned int Oid
Definition: postgres_ext.h:31
#define SearchSysCache1(cacheId, key1)
Definition: syscache.h:149
Oid get_func_rettype(Oid funcid)
Definition: lsyscache.c:1427
#define ERROR
Definition: elog.h:43
static void validate_table_rewrite_tags(const char *filtervar, List *taglist)
static void error_duplicate_filter_variable(const char *defname)
#define CStringGetDatum(X)
Definition: postgres.h:586
#define ereport(elevel, rest)
Definition: elog.h:122
Node * arg
Definition: parsenodes.h:676
char * NameListToString(List *names)
Definition: namespace.c:2897
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EVTTRIGGEROID
Definition: pg_type.h:682
#define NULL
Definition: c.h:226
#define lfirst(lc)
Definition: pg_list.h:106
Oid LookupFuncName(List *funcname, int nargs, const Oid *argtypes, bool noError)
Definition: parse_func.c:1908
int errmsg(const char *fmt,...)
Definition: elog.c:797
char * defname
Definition: parsenodes.h:675
#define ERRCODE_DUPLICATE_OBJECT
Definition: streamutil.c:34
Definition: pg_list.h:45
void EventTriggerAlterTableEnd ( void  )

Definition at line 1777 of file event_trigger.c.

References CollectedCommand::alterTable, EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, EventTriggerQueryState::currentCommand, CollectedCommand::d, lappend(), list_length(), NULL, and pfree().

Referenced by AlterTableMoveAll(), and ProcessUtilitySlow().

1778 {
1779  /* ignore if event trigger context not set, or collection disabled */
1780  if (!currentEventTriggerState ||
1782  return;
1783 
1784  /* If no subcommands, don't collect */
1786  {
1790  }
1791  else
1793 
1795 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void pfree(void *pointer)
Definition: mcxt.c:992
CollectedCommand * currentCommand
Definition: event_trigger.c:66
List * lappend(List *list, void *datum)
Definition: list.c:128
#define NULL
Definition: c.h:226
static int list_length(const List *l)
Definition: pg_list.h:89
union CollectedCommand::@58 d
struct CollectedCommand::@58::@60 alterTable
void EventTriggerAlterTableRelid ( Oid  objectId)

Definition at line 1725 of file event_trigger.c.

References CollectedCommand::alterTable, EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::currentCommand, and CollectedCommand::d.

Referenced by AlterTableInternal(), and ProcessUtilitySlow().

1726 {
1727  if (!currentEventTriggerState ||
1729  return;
1730 
1731  currentEventTriggerState->currentCommand->d.alterTable.objectId = objectId;
1732 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
CollectedCommand * currentCommand
Definition: event_trigger.c:66
union CollectedCommand::@58 d
struct CollectedCommand::@58::@60 alterTable
void EventTriggerAlterTableStart ( Node parsetree)

Definition at line 1692 of file event_trigger.c.

References CollectedCommand::alterTable, EventTriggerQueryState::commandCollectionInhibited, copyObject(), creating_extension, EventTriggerQueryState::currentCommand, EventTriggerQueryState::cxt, CollectedCommand::d, CollectedCommand::in_extension, InvalidOid, MemoryContextSwitchTo(), NIL, palloc(), CollectedCommand::parsetree, RelationRelationId, SCT_AlterTable, and CollectedCommand::type.

Referenced by AlterTableMoveAll(), and ProcessUtilitySlow().

1693 {
1694  MemoryContext oldcxt;
1695  CollectedCommand *command;
1696 
1697  /* ignore if event trigger context not set, or collection disabled */
1698  if (!currentEventTriggerState ||
1700  return;
1701 
1703 
1704  command = palloc(sizeof(CollectedCommand));
1705 
1706  command->type = SCT_AlterTable;
1707  command->in_extension = creating_extension;
1708 
1709  command->d.alterTable.classId = RelationRelationId;
1710  command->d.alterTable.objectId = InvalidOid;
1711  command->d.alterTable.subcmds = NIL;
1712  command->parsetree = copyObject(parsetree);
1713 
1715 
1716  MemoryContextSwitchTo(oldcxt);
1717 }
#define NIL
Definition: pg_list.h:69
#define RelationRelationId
Definition: pg_class.h:29
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
CollectedCommand * currentCommand
Definition: event_trigger.c:66
#define InvalidOid
Definition: postgres_ext.h:36
bool creating_extension
Definition: extension.c:67
union CollectedCommand::@58 d
void * palloc(Size size)
Definition: mcxt.c:891
struct CollectedCommand::@58::@60 alterTable
bool EventTriggerBeginCompleteQuery ( void  )

Definition at line 1217 of file event_trigger.c.

References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate(), EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, EventTriggerQueryState::currentCommand, currentEventTriggerState, EventTriggerQueryState::cxt, EventTriggerQueryState::in_sql_drop, InvalidOid, MemoryContextAlloc(), NIL, NULL, EventTriggerQueryState::previous, slist_init(), EventTriggerQueryState::SQLDropList, EventTriggerQueryState::table_rewrite_oid, TopMemoryContext, and trackDroppedObjectsNeeded().

Referenced by ProcessUtilitySlow().

1218 {
1220  MemoryContext cxt;
1221 
1222  /*
1223  * Currently, sql_drop, table_rewrite, ddl_command_end events are the only
1224  * reason to have event trigger state at all; so if there are none, don't
1225  * install one.
1226  */
1228  return false;
1229 
1231  "event trigger state",
1233  state = MemoryContextAlloc(cxt, sizeof(EventTriggerQueryState));
1234  state->cxt = cxt;
1235  slist_init(&(state->SQLDropList));
1236  state->in_sql_drop = false;
1237  state->table_rewrite_oid = InvalidOid;
1238 
1241  state->currentCommand = NULL;
1242  state->commandList = NIL;
1244  currentEventTriggerState = state;
1245 
1246  return true;
1247 }
#define NIL
Definition: pg_list.h:69
bool trackDroppedObjectsNeeded(void)
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
static void slist_init(slist_head *head)
Definition: ilist.h:554
#define ALLOCSET_DEFAULT_SIZES
Definition: memutils.h:145
CollectedCommand * currentCommand
Definition: event_trigger.c:66
struct EventTriggerQueryState * previous
Definition: event_trigger.c:69
MemoryContext TopMemoryContext
Definition: mcxt.c:43
MemoryContext AllocSetContextCreate(MemoryContext parent, const char *name, Size minContextSize, Size initBlockSize, Size maxBlockSize)
Definition: aset.c:440
#define InvalidOid
Definition: postgres_ext.h:36
#define NULL
Definition: c.h:226
Definition: regguts.h:298
void * MemoryContextAlloc(MemoryContext context, Size size)
Definition: mcxt.c:749
void EventTriggerCollectAlterDefPrivs ( AlterDefaultPrivilegesStmt stmt)

Definition at line 1951 of file event_trigger.c.

References AlterDefaultPrivilegesStmt::action, EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, copyObject(), creating_extension, EventTriggerQueryState::cxt, CollectedCommand::d, CollectedCommand::defprivs, CollectedCommand::in_extension, lappend(), MemoryContextSwitchTo(), GrantStmt::objtype, palloc0(), CollectedCommand::parsetree, SCT_AlterDefaultPrivileges, and CollectedCommand::type.

Referenced by ProcessUtilitySlow().

1952 {
1953  MemoryContext oldcxt;
1954  CollectedCommand *command;
1955 
1956  /* ignore if event trigger context not set, or collection disabled */
1957  if (!currentEventTriggerState ||
1959  return;
1960 
1962 
1963  command = palloc0(sizeof(CollectedCommand));
1964  command->type = SCT_AlterDefaultPrivileges;
1965  command->d.defprivs.objtype = stmt->action->objtype;
1966  command->in_extension = creating_extension;
1967  command->parsetree = copyObject(stmt);
1968 
1971  MemoryContextSwitchTo(oldcxt);
1972 }
struct CollectedCommand::@58::@65 defprivs
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
List * lappend(List *list, void *datum)
Definition: list.c:128
void * palloc0(Size size)
Definition: mcxt.c:920
bool creating_extension
Definition: extension.c:67
union CollectedCommand::@58 d
GrantObjectType objtype
Definition: parsenodes.h:1755
void EventTriggerCollectAlterOpFam ( AlterOpFamilyStmt stmt,
Oid  opfamoid,
List operators,
List procedures 
)

Definition at line 1849 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, copyObject(), creating_extension, EventTriggerQueryState::cxt, CollectedCommand::d, CollectedCommand::in_extension, lappend(), MemoryContextSwitchTo(), ObjectAddressSet, OperatorFamilyRelationId, CollectedCommand::opfam, palloc(), CollectedCommand::parsetree, SCT_AlterOpFamily, and CollectedCommand::type.

Referenced by AlterOpFamilyAdd(), and AlterOpFamilyDrop().

1851 {
1852  MemoryContext oldcxt;
1853  CollectedCommand *command;
1854 
1855  /* ignore if event trigger context not set, or collection disabled */
1856  if (!currentEventTriggerState ||
1858  return;
1859 
1861 
1862  command = palloc(sizeof(CollectedCommand));
1863  command->type = SCT_AlterOpFamily;
1864  command->in_extension = creating_extension;
1865  ObjectAddressSet(command->d.opfam.address,
1866  OperatorFamilyRelationId, opfamoid);
1867  command->d.opfam.operators = operators;
1868  command->d.opfam.procedures = procedures;
1869  command->parsetree = copyObject(stmt);
1870 
1873 
1874  MemoryContextSwitchTo(oldcxt);
1875 }
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define OperatorFamilyRelationId
Definition: pg_opfamily.h:29
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
struct CollectedCommand::@58::@62 opfam
List * lappend(List *list, void *datum)
Definition: list.c:128
bool creating_extension
Definition: extension.c:67
union CollectedCommand::@58 d
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void * palloc(Size size)
Definition: mcxt.c:891
void EventTriggerCollectAlterTableSubcmd ( Node subcmd,
ObjectAddress  address 
)

Definition at line 1743 of file event_trigger.c.

References CollectedATSubcmd::address, CollectedCommand::alterTable, Assert, EventTriggerQueryState::commandCollectionInhibited, copyObject(), EventTriggerQueryState::currentCommand, EventTriggerQueryState::cxt, CollectedCommand::d, IsA, lappend(), MemoryContextSwitchTo(), newsub(), OidIsValid, palloc(), and CollectedATSubcmd::parsetree.

Referenced by ATExecCmd().

1744 {
1745  MemoryContext oldcxt;
1747 
1748  /* ignore if event trigger context not set, or collection disabled */
1749  if (!currentEventTriggerState ||
1751  return;
1752 
1753  Assert(IsA(subcmd, AlterTableCmd));
1755 
1757 
1758  newsub = palloc(sizeof(CollectedATSubcmd));
1759  newsub->address = address;
1760  newsub->parsetree = copyObject(subcmd);
1761 
1764 
1765  MemoryContextSwitchTo(oldcxt);
1766 }
#define IsA(nodeptr, _type_)
Definition: nodes.h:559
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define OidIsValid(objectId)
Definition: c.h:533
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
CollectedCommand * currentCommand
Definition: event_trigger.c:66
List * lappend(List *list, void *datum)
Definition: list.c:128
#define Assert(condition)
Definition: c.h:670
union CollectedCommand::@58 d
void * palloc(Size size)
Definition: mcxt.c:891
static color newsub(struct colormap *cm, color co)
Definition: regc_color.c:389
struct CollectedCommand::@58::@60 alterTable
ObjectAddress address
void EventTriggerCollectAlterTSConfig ( AlterTSConfigurationStmt stmt,
Oid  cfgId,
Oid dictIds,
int  ndicts 
)

Definition at line 1916 of file event_trigger.c.

References CollectedCommand::atscfg, EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, copyObject(), creating_extension, EventTriggerQueryState::cxt, CollectedCommand::d, CollectedCommand::in_extension, lappend(), MemoryContextSwitchTo(), ObjectAddressSet, palloc(), palloc0(), CollectedCommand::parsetree, SCT_AlterTSConfig, TSConfigRelationId, and CollectedCommand::type.

Referenced by DropConfigurationMapping(), and MakeConfigurationMapping().

1918 {
1919  MemoryContext oldcxt;
1920  CollectedCommand *command;
1921 
1922  /* ignore if event trigger context not set, or collection disabled */
1923  if (!currentEventTriggerState ||
1925  return;
1926 
1928 
1929  command = palloc0(sizeof(CollectedCommand));
1930  command->type = SCT_AlterTSConfig;
1931  command->in_extension = creating_extension;
1932  ObjectAddressSet(command->d.atscfg.address,
1933  TSConfigRelationId, cfgId);
1934  command->d.atscfg.dictIds = palloc(sizeof(Oid) * ndicts);
1935  memcpy(command->d.atscfg.dictIds, dictIds, sizeof(Oid) * ndicts);
1936  command->d.atscfg.ndicts = ndicts;
1937  command->parsetree = copyObject(stmt);
1938 
1941 
1942  MemoryContextSwitchTo(oldcxt);
1943 }
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
CollectedCommandType type
unsigned int Oid
Definition: postgres_ext.h:31
struct CollectedCommand::@58::@64 atscfg
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
#define TSConfigRelationId
Definition: pg_ts_config.h:31
List * lappend(List *list, void *datum)
Definition: list.c:128
void * palloc0(Size size)
Definition: mcxt.c:920
bool creating_extension
Definition: extension.c:67
union CollectedCommand::@58 d
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void * palloc(Size size)
Definition: mcxt.c:891
void EventTriggerCollectCreateOpClass ( CreateOpClassStmt stmt,
Oid  opcoid,
List operators,
List procedures 
)

Definition at line 1882 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, copyObject(), CollectedCommand::createopc, creating_extension, EventTriggerQueryState::cxt, CollectedCommand::d, CollectedCommand::in_extension, lappend(), MemoryContextSwitchTo(), ObjectAddressSet, OperatorClassRelationId, palloc0(), CollectedCommand::parsetree, SCT_CreateOpClass, and CollectedCommand::type.

Referenced by DefineOpClass().

1884 {
1885  MemoryContext oldcxt;
1886  CollectedCommand *command;
1887 
1888  /* ignore if event trigger context not set, or collection disabled */
1889  if (!currentEventTriggerState ||
1891  return;
1892 
1894 
1895  command = palloc0(sizeof(CollectedCommand));
1896  command->type = SCT_CreateOpClass;
1897  command->in_extension = creating_extension;
1898  ObjectAddressSet(command->d.createopc.address,
1899  OperatorClassRelationId, opcoid);
1900  command->d.createopc.operators = operators;
1901  command->d.createopc.procedures = procedures;
1902  command->parsetree = copyObject(stmt);
1903 
1906 
1907  MemoryContextSwitchTo(oldcxt);
1908 }
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define OperatorClassRelationId
Definition: pg_opclass.h:49
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
struct CollectedCommand::@58::@63 createopc
List * lappend(List *list, void *datum)
Definition: list.c:128
void * palloc0(Size size)
Definition: mcxt.c:920
bool creating_extension
Definition: extension.c:67
union CollectedCommand::@58 d
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void EventTriggerCollectGrant ( InternalGrant istmt)

Definition at line 1805 of file event_trigger.c.

References InternalGrant::col_privs, EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, copyObject(), creating_extension, EventTriggerQueryState::cxt, CollectedCommand::d, CollectedCommand::grant, InternalGrant::grantees, CollectedCommand::in_extension, lappend(), lfirst, list_copy(), MemoryContextSwitchTo(), NIL, NULL, InternalGrant::objects, palloc(), CollectedCommand::parsetree, SCT_Grant, and CollectedCommand::type.

Referenced by ExecGrantStmt_oids().

1806 {
1807  MemoryContext oldcxt;
1808  CollectedCommand *command;
1809  InternalGrant *icopy;
1810  ListCell *cell;
1811 
1812  /* ignore if event trigger context not set, or collection disabled */
1813  if (!currentEventTriggerState ||
1815  return;
1816 
1818 
1819  /*
1820  * This is tedious, but necessary.
1821  */
1822  icopy = palloc(sizeof(InternalGrant));
1823  memcpy(icopy, istmt, sizeof(InternalGrant));
1824  icopy->objects = list_copy(istmt->objects);
1825  icopy->grantees = list_copy(istmt->grantees);
1826  icopy->col_privs = NIL;
1827  foreach(cell, istmt->col_privs)
1828  icopy->col_privs = lappend(icopy->col_privs, copyObject(lfirst(cell)));
1829 
1830  /* Now collect it, using the copied InternalGrant */
1831  command = palloc(sizeof(CollectedCommand));
1832  command->type = SCT_Grant;
1833  command->in_extension = creating_extension;
1834  command->d.grant.istmt = icopy;
1835  command->parsetree = NULL;
1836 
1839 
1840  MemoryContextSwitchTo(oldcxt);
1841 }
#define NIL
Definition: pg_list.h:69
struct CollectedCommand::@58::@61 grant
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
List * list_copy(const List *oldlist)
Definition: list.c:1160
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
List * lappend(List *list, void *datum)
Definition: list.c:128
bool creating_extension
Definition: extension.c:67
#define NULL
Definition: c.h:226
#define lfirst(lc)
Definition: pg_list.h:106
union CollectedCommand::@58 d
void * palloc(Size size)
Definition: mcxt.c:891
void EventTriggerCollectSimpleCommand ( ObjectAddress  address,
ObjectAddress  secondaryObject,
Node parsetree 
)

Definition at line 1649 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited, EventTriggerQueryState::commandList, copyObject(), creating_extension, EventTriggerQueryState::cxt, CollectedCommand::d, CollectedCommand::in_extension, lappend(), MemoryContextSwitchTo(), palloc(), CollectedCommand::parsetree, SCT_Simple, CollectedCommand::simple, and CollectedCommand::type.

Referenced by AlterPublicationOptions(), CreateSchemaCommand(), ProcessUtilitySlow(), and PublicationAddTables().

1652 {
1653  MemoryContext oldcxt;
1654  CollectedCommand *command;
1655 
1656  /* ignore if event trigger context not set, or collection disabled */
1657  if (!currentEventTriggerState ||
1659  return;
1660 
1662 
1663  command = palloc(sizeof(CollectedCommand));
1664 
1665  command->type = SCT_Simple;
1666  command->in_extension = creating_extension;
1667 
1668  command->d.simple.address = address;
1669  command->d.simple.secondaryObject = secondaryObject;
1670  command->parsetree = copyObject(parsetree);
1671 
1673  command);
1674 
1675  MemoryContextSwitchTo(oldcxt);
1676 }
struct CollectedCommand::@58::@59 simple
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void * copyObject(const void *from)
Definition: copyfuncs.c:4475
List * lappend(List *list, void *datum)
Definition: list.c:128
bool creating_extension
Definition: extension.c:67
union CollectedCommand::@58 d
void * palloc(Size size)
Definition: mcxt.c:891
void EventTriggerDDLCommandEnd ( Node parsetree)

Definition at line 824 of file event_trigger.c.

References CommandCounterIncrement(), EventTriggerCommonSetup(), EventTriggerInvoke(), EVT_DDLCommandEnd, IsUnderPostmaster, list_free(), and NIL.

Referenced by ProcessUtilitySlow().

825 {
826  List *runlist;
827  EventTriggerData trigdata;
828 
829  /*
830  * See EventTriggerDDLCommandStart for a discussion about why event
831  * triggers are disabled in single user mode.
832  */
833  if (!IsUnderPostmaster)
834  return;
835 
836  runlist = EventTriggerCommonSetup(parsetree,
837  EVT_DDLCommandEnd, "ddl_command_end",
838  &trigdata);
839  if (runlist == NIL)
840  return;
841 
842  /*
843  * Make sure anything the main command did will be visible to the event
844  * triggers.
845  */
847 
848  /* Run the triggers. */
849  EventTriggerInvoke(runlist, &trigdata);
850 
851  /* Cleanup. */
852  list_free(runlist);
853 }
#define NIL
Definition: pg_list.h:69
static void EventTriggerInvoke(List *fn_oid_list, EventTriggerData *trigdata)
static List * EventTriggerCommonSetup(Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
bool IsUnderPostmaster
Definition: globals.c:100
void CommandCounterIncrement(void)
Definition: xact.c:921
void list_free(List *list)
Definition: list.c:1133
Definition: pg_list.h:45
void EventTriggerDDLCommandStart ( Node parsetree)

Definition at line 776 of file event_trigger.c.

References CommandCounterIncrement(), EventTriggerCommonSetup(), EventTriggerInvoke(), EVT_DDLCommandStart, IsUnderPostmaster, list_free(), and NIL.

Referenced by ProcessUtilitySlow().

777 {
778  List *runlist;
779  EventTriggerData trigdata;
780 
781  /*
782  * Event Triggers are completely disabled in standalone mode. There are
783  * (at least) two reasons for this:
784  *
785  * 1. A sufficiently broken event trigger might not only render the
786  * database unusable, but prevent disabling itself to fix the situation.
787  * In this scenario, restarting in standalone mode provides an escape
788  * hatch.
789  *
790  * 2. BuildEventTriggerCache relies on systable_beginscan_ordered, and
791  * therefore will malfunction if pg_event_trigger's indexes are damaged.
792  * To allow recovery from a damaged index, we need some operating mode
793  * wherein event triggers are disabled. (Or we could implement
794  * heapscan-and-sort logic for that case, but having disaster recovery
795  * scenarios depend on code that's otherwise untested isn't appetizing.)
796  */
797  if (!IsUnderPostmaster)
798  return;
799 
800  runlist = EventTriggerCommonSetup(parsetree,
802  "ddl_command_start",
803  &trigdata);
804  if (runlist == NIL)
805  return;
806 
807  /* Run the triggers. */
808  EventTriggerInvoke(runlist, &trigdata);
809 
810  /* Cleanup. */
811  list_free(runlist);
812 
813  /*
814  * Make sure anything the event triggers did will be visible to the main
815  * command.
816  */
818 }
#define NIL
Definition: pg_list.h:69
static void EventTriggerInvoke(List *fn_oid_list, EventTriggerData *trigdata)
static List * EventTriggerCommonSetup(Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
bool IsUnderPostmaster
Definition: globals.c:100
void CommandCounterIncrement(void)
Definition: xact.c:921
void list_free(List *list)
Definition: list.c:1133
Definition: pg_list.h:45
void EventTriggerEndCompleteQuery ( void  )

Definition at line 1261 of file event_trigger.c.

References EventTriggerQueryState::cxt, MemoryContextDelete(), and EventTriggerQueryState::previous.

Referenced by ProcessUtilitySlow().

1262 {
1263  EventTriggerQueryState *prevstate;
1264 
1265  prevstate = currentEventTriggerState->previous;
1266 
1267  /* this avoids the need for retail pfree of SQLDropList items: */
1269 
1270  currentEventTriggerState = prevstate;
1271 }
void MemoryContextDelete(MemoryContext context)
Definition: mcxt.c:200
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
struct EventTriggerQueryState * previous
Definition: event_trigger.c:69
void EventTriggerInhibitCommandCollection ( void  )

Definition at line 1615 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited.

Referenced by ProcessUtilitySlow().

1616 {
1618  return;
1619 
1621 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void EventTriggerSQLDrop ( Node parsetree)

Definition at line 859 of file event_trigger.c.

References CommandCounterIncrement(), EventTriggerCommonSetup(), EventTriggerInvoke(), EVT_SQLDrop, EventTriggerQueryState::in_sql_drop, IsUnderPostmaster, list_free(), NIL, PG_CATCH, PG_END_TRY, PG_RE_THROW, PG_TRY, slist_is_empty(), and EventTriggerQueryState::SQLDropList.

Referenced by ProcessUtilitySlow().

860 {
861  List *runlist;
862  EventTriggerData trigdata;
863 
864  /*
865  * See EventTriggerDDLCommandStart for a discussion about why event
866  * triggers are disabled in single user mode.
867  */
868  if (!IsUnderPostmaster)
869  return;
870 
871  /*
872  * Use current state to determine whether this event fires at all. If
873  * there are no triggers for the sql_drop event, then we don't have
874  * anything to do here. Note that dropped object collection is disabled
875  * if this is the case, so even if we were to try to run, the list would
876  * be empty.
877  */
880  return;
881 
882  runlist = EventTriggerCommonSetup(parsetree,
883  EVT_SQLDrop, "sql_drop",
884  &trigdata);
885 
886  /*
887  * Nothing to do if run list is empty. Note this shouldn't happen,
888  * because if there are no sql_drop events, then objects-to-drop wouldn't
889  * have been collected in the first place and we would have quit above.
890  */
891  if (runlist == NIL)
892  return;
893 
894  /*
895  * Make sure anything the main command did will be visible to the event
896  * triggers.
897  */
899 
900  /*
901  * Make sure pg_event_trigger_dropped_objects only works when running
902  * these triggers. Use PG_TRY to ensure in_sql_drop is reset even when
903  * one trigger fails. (This is perhaps not necessary, as the currentState
904  * variable will be removed shortly by our caller, but it seems better to
905  * play safe.)
906  */
908 
909  /* Run the triggers. */
910  PG_TRY();
911  {
912  EventTriggerInvoke(runlist, &trigdata);
913  }
914  PG_CATCH();
915  {
917  PG_RE_THROW();
918  }
919  PG_END_TRY();
921 
922  /* Cleanup. */
923  list_free(runlist);
924 }
#define NIL
Definition: pg_list.h:69
static void EventTriggerInvoke(List *fn_oid_list, EventTriggerData *trigdata)
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
static List * EventTriggerCommonSetup(Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
bool IsUnderPostmaster
Definition: globals.c:100
static bool slist_is_empty(slist_head *head)
Definition: ilist.h:563
void CommandCounterIncrement(void)
Definition: xact.c:921
#define PG_CATCH()
Definition: elog.h:293
#define PG_RE_THROW()
Definition: elog.h:314
void list_free(List *list)
Definition: list.c:1133
#define PG_TRY()
Definition: elog.h:284
Definition: pg_list.h:45
#define PG_END_TRY()
Definition: elog.h:300
void EventTriggerSQLDropAddObject ( const ObjectAddress object,
bool  original,
bool  normal 
)

Definition at line 1311 of file event_trigger.c.

References AccessShareLock, SQLDropObject::addrargs, SQLDropObject::address, SQLDropObject::addrnames, Assert, ObjectAddress::classId, EventTriggerQueryState::cxt, DatumGetName, DatumGetObjectId, EventTriggerSupportsObjectClass(), get_catalog_object_by_oid(), get_namespace_name(), get_object_attnum_name(), get_object_attnum_namespace(), get_object_namensp_unique(), getObjectClass(), getObjectIdentityParts(), getObjectTypeDescription(), heap_close, heap_getattr, heap_open(), InvalidAttrNumber, is_objectclass_supported(), isAnyTempNamespace(), SQLDropObject::istemp, isTempNamespace(), MemoryContextSwitchTo(), NamespaceRelationId, NameStr, SQLDropObject::next, SQLDropObject::normal, ObjectAddress::objectId, ObjectAddress::objectSubId, SQLDropObject::objecttype, SQLDropObject::objidentity, SQLDropObject::objname, SQLDropObject::original, palloc0(), pfree(), pstrdup(), RelationGetDescr, SQLDropObject::schemaname, slist_push_head(), and EventTriggerQueryState::SQLDropList.

Referenced by deleteObjectsInList(), and DropSubscription().

1312 {
1313  SQLDropObject *obj;
1314  MemoryContext oldcxt;
1315 
1317  return;
1318 
1320 
1321  /* don't report temp schemas except my own */
1322  if (object->classId == NamespaceRelationId &&
1323  (isAnyTempNamespace(object->objectId) &&
1324  !isTempNamespace(object->objectId)))
1325  return;
1326 
1328 
1329  obj = palloc0(sizeof(SQLDropObject));
1330  obj->address = *object;
1331  obj->original = original;
1332  obj->normal = normal;
1333 
1334  /*
1335  * Obtain schema names from the object's catalog tuple, if one exists;
1336  * this lets us skip objects in temp schemas. We trust that
1337  * ObjectProperty contains all object classes that can be
1338  * schema-qualified.
1339  */
1340  if (is_objectclass_supported(object->classId))
1341  {
1342  Relation catalog;
1343  HeapTuple tuple;
1344 
1345  catalog = heap_open(obj->address.classId, AccessShareLock);
1346  tuple = get_catalog_object_by_oid(catalog, obj->address.objectId);
1347 
1348  if (tuple)
1349  {
1350  AttrNumber attnum;
1351  Datum datum;
1352  bool isnull;
1353 
1355  if (attnum != InvalidAttrNumber)
1356  {
1357  datum = heap_getattr(tuple, attnum,
1358  RelationGetDescr(catalog), &isnull);
1359  if (!isnull)
1360  {
1361  Oid namespaceId;
1362 
1363  namespaceId = DatumGetObjectId(datum);
1364  /* temp objects are only reported if they are my own */
1365  if (isTempNamespace(namespaceId))
1366  {
1367  obj->schemaname = "pg_temp";
1368  obj->istemp = true;
1369  }
1370  else if (isAnyTempNamespace(namespaceId))
1371  {
1372  pfree(obj);
1373  heap_close(catalog, AccessShareLock);
1374  MemoryContextSwitchTo(oldcxt);
1375  return;
1376  }
1377  else
1378  {
1379  obj->schemaname = get_namespace_name(namespaceId);
1380  obj->istemp = false;
1381  }
1382  }
1383  }
1384 
1386  obj->address.objectSubId == 0)
1387  {
1388  attnum = get_object_attnum_name(obj->address.classId);
1389  if (attnum != InvalidAttrNumber)
1390  {
1391  datum = heap_getattr(tuple, attnum,
1392  RelationGetDescr(catalog), &isnull);
1393  if (!isnull)
1394  obj->objname = pstrdup(NameStr(*DatumGetName(datum)));
1395  }
1396  }
1397  }
1398 
1399  heap_close(catalog, AccessShareLock);
1400  }
1401  else
1402  {
1403  if (object->classId == NamespaceRelationId &&
1404  isTempNamespace(object->objectId))
1405  obj->istemp = true;
1406  }
1407 
1408  /* object identity, objname and objargs */
1409  obj->objidentity =
1410  getObjectIdentityParts(&obj->address, &obj->addrnames, &obj->addrargs);
1411 
1412  /* object type */
1414 
1416 
1417  MemoryContextSwitchTo(oldcxt);
1418 }
bool get_object_namensp_unique(Oid class_id)
slist_node next
#define NamespaceRelationId
Definition: pg_namespace.h:34
ObjectAddress address
char * getObjectTypeDescription(const ObjectAddress *object)
#define RelationGetDescr(relation)
Definition: rel.h:425
const char * objname
#define DatumGetObjectId(X)
Definition: postgres.h:508
char * pstrdup(const char *in)
Definition: mcxt.c:1165
char * getObjectIdentityParts(const ObjectAddress *object, List **objname, List **objargs)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define AccessShareLock
Definition: lockdefs.h:36
static void slist_push_head(slist_head *head, slist_node *node)
Definition: ilist.h:574
AttrNumber get_object_attnum_namespace(Oid class_id)
#define heap_close(r, l)
Definition: heapam.h:97
const char * objidentity
unsigned int Oid
Definition: postgres_ext.h:31
ObjectClass getObjectClass(const ObjectAddress *object)
Definition: dependency.c:2312
const char * objecttype
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
#define DatumGetName(X)
Definition: postgres.h:593
void pfree(void *pointer)
Definition: mcxt.c:992
char * get_namespace_name(Oid nspid)
Definition: lsyscache.c:3006
bool isTempNamespace(Oid namespaceId)
Definition: namespace.c:2952
bool EventTriggerSupportsObjectClass(ObjectClass objclass)
const char * schemaname
#define heap_getattr(tup, attnum, tupleDesc, isnull)
Definition: htup_details.h:769
AttrNumber get_object_attnum_name(Oid class_id)
void * palloc0(Size size)
Definition: mcxt.c:920
uintptr_t Datum
Definition: postgres.h:374
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1287
#define Assert(condition)
Definition: c.h:670
HeapTuple get_catalog_object_by_oid(Relation catalog, Oid objectId)
#define InvalidAttrNumber
Definition: attnum.h:23
#define NameStr(name)
Definition: c.h:494
bool isAnyTempNamespace(Oid namespaceId)
Definition: namespace.c:2990
bool is_objectclass_supported(Oid class_id)
int16 AttrNumber
Definition: attnum.h:21
bool EventTriggerSupportsGrantObjectType ( GrantObjectType  objtype)

Definition at line 1183 of file event_trigger.c.

References ACL_OBJECT_COLUMN, ACL_OBJECT_DATABASE, ACL_OBJECT_DOMAIN, ACL_OBJECT_FDW, ACL_OBJECT_FOREIGN_SERVER, ACL_OBJECT_FUNCTION, ACL_OBJECT_LANGUAGE, ACL_OBJECT_LARGEOBJECT, ACL_OBJECT_NAMESPACE, ACL_OBJECT_RELATION, ACL_OBJECT_SEQUENCE, ACL_OBJECT_TABLESPACE, ACL_OBJECT_TYPE, and Assert.

Referenced by ExecGrantStmt_oids(), and standard_ProcessUtility().

1184 {
1185  switch (objtype)
1186  {
1187  case ACL_OBJECT_DATABASE:
1188  case ACL_OBJECT_TABLESPACE:
1189  /* no support for global objects */
1190  return false;
1191 
1192  case ACL_OBJECT_COLUMN:
1193  case ACL_OBJECT_RELATION:
1194  case ACL_OBJECT_SEQUENCE:
1195  case ACL_OBJECT_DOMAIN:
1196  case ACL_OBJECT_FDW:
1198  case ACL_OBJECT_FUNCTION:
1199  case ACL_OBJECT_LANGUAGE:
1201  case ACL_OBJECT_NAMESPACE:
1202  case ACL_OBJECT_TYPE:
1203  return true;
1204  default:
1205  Assert(false);
1206  return true;
1207  }
1208 }
#define Assert(condition)
Definition: c.h:670
bool EventTriggerSupportsObjectClass ( ObjectClass  objclass)

Definition at line 1131 of file event_trigger.c.

References OCLASS_AM, OCLASS_AMOP, OCLASS_AMPROC, OCLASS_CAST, OCLASS_CLASS, OCLASS_COLLATION, OCLASS_CONSTRAINT, OCLASS_CONVERSION, OCLASS_DATABASE, OCLASS_DEFACL, OCLASS_DEFAULT, OCLASS_EVENT_TRIGGER, OCLASS_EXTENSION, OCLASS_FDW, OCLASS_FOREIGN_SERVER, OCLASS_LANGUAGE, OCLASS_LARGEOBJECT, OCLASS_OPCLASS, OCLASS_OPERATOR, OCLASS_OPFAMILY, OCLASS_POLICY, OCLASS_PROC, OCLASS_PUBLICATION, OCLASS_PUBLICATION_REL, OCLASS_REWRITE, OCLASS_ROLE, OCLASS_SCHEMA, OCLASS_SUBSCRIPTION, OCLASS_TBLSPACE, OCLASS_TRANSFORM, OCLASS_TRIGGER, OCLASS_TSCONFIG, OCLASS_TSDICT, OCLASS_TSPARSER, OCLASS_TSTEMPLATE, OCLASS_TYPE, and OCLASS_USER_MAPPING.

Referenced by deleteObjectsInList(), and EventTriggerSQLDropAddObject().

1132 {
1133  switch (objclass)
1134  {
1135  case OCLASS_DATABASE:
1136  case OCLASS_TBLSPACE:
1137  case OCLASS_ROLE:
1138  /* no support for global objects */
1139  return false;
1140  case OCLASS_EVENT_TRIGGER:
1141  /* no support for event triggers on event triggers */
1142  return false;
1143  case OCLASS_CLASS:
1144  case OCLASS_PROC:
1145  case OCLASS_TYPE:
1146  case OCLASS_CAST:
1147  case OCLASS_COLLATION:
1148  case OCLASS_CONSTRAINT:
1149  case OCLASS_CONVERSION:
1150  case OCLASS_DEFAULT:
1151  case OCLASS_LANGUAGE:
1152  case OCLASS_LARGEOBJECT:
1153  case OCLASS_OPERATOR:
1154  case OCLASS_OPCLASS:
1155  case OCLASS_OPFAMILY:
1156  case OCLASS_AMOP:
1157  case OCLASS_AMPROC:
1158  case OCLASS_REWRITE:
1159  case OCLASS_TRIGGER:
1160  case OCLASS_SCHEMA:
1161  case OCLASS_TRANSFORM:
1162  case OCLASS_TSPARSER:
1163  case OCLASS_TSDICT:
1164  case OCLASS_TSTEMPLATE:
1165  case OCLASS_TSCONFIG:
1166  case OCLASS_FDW:
1167  case OCLASS_FOREIGN_SERVER:
1168  case OCLASS_USER_MAPPING:
1169  case OCLASS_DEFACL:
1170  case OCLASS_EXTENSION:
1171  case OCLASS_POLICY:
1172  case OCLASS_AM:
1173  case OCLASS_PUBLICATION:
1175  case OCLASS_SUBSCRIPTION:
1176  return true;
1177  }
1178 
1179  return true;
1180 }
bool EventTriggerSupportsObjectType ( ObjectType  obtype)

Definition at line 1067 of file event_trigger.c.

References OBJECT_ACCESS_METHOD, OBJECT_AGGREGATE, OBJECT_AMOP, OBJECT_AMPROC, OBJECT_ATTRIBUTE, OBJECT_CAST, OBJECT_COLLATION, OBJECT_COLUMN, OBJECT_CONVERSION, OBJECT_DATABASE, OBJECT_DEFACL, OBJECT_DEFAULT, 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_PUBLICATION, OBJECT_PUBLICATION_REL, OBJECT_ROLE, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_SEQUENCE, OBJECT_SUBSCRIPTION, OBJECT_TABCONSTRAINT, OBJECT_TABLE, OBJECT_TABLESPACE, OBJECT_TRANSFORM, OBJECT_TRIGGER, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, OBJECT_USER_MAPPING, and OBJECT_VIEW.

Referenced by standard_ProcessUtility().

1068 {
1069  switch (obtype)
1070  {
1071  case OBJECT_DATABASE:
1072  case OBJECT_TABLESPACE:
1073  case OBJECT_ROLE:
1074  /* no support for global objects */
1075  return false;
1076  case OBJECT_EVENT_TRIGGER:
1077  /* no support for event triggers on event triggers */
1078  return false;
1079  case OBJECT_ACCESS_METHOD:
1080  case OBJECT_AGGREGATE:
1081  case OBJECT_AMOP:
1082  case OBJECT_AMPROC:
1083  case OBJECT_ATTRIBUTE:
1084  case OBJECT_CAST:
1085  case OBJECT_COLUMN:
1086  case OBJECT_COLLATION:
1087  case OBJECT_CONVERSION:
1088  case OBJECT_DEFACL:
1089  case OBJECT_DEFAULT:
1090  case OBJECT_DOMAIN:
1091  case OBJECT_DOMCONSTRAINT:
1092  case OBJECT_EXTENSION:
1093  case OBJECT_FDW:
1094  case OBJECT_FOREIGN_SERVER:
1095  case OBJECT_FOREIGN_TABLE:
1096  case OBJECT_FUNCTION:
1097  case OBJECT_INDEX:
1098  case OBJECT_LANGUAGE:
1099  case OBJECT_LARGEOBJECT:
1100  case OBJECT_MATVIEW:
1101  case OBJECT_OPCLASS:
1102  case OBJECT_OPERATOR:
1103  case OBJECT_OPFAMILY:
1104  case OBJECT_POLICY:
1105  case OBJECT_PUBLICATION:
1107  case OBJECT_RULE:
1108  case OBJECT_SCHEMA:
1109  case OBJECT_SEQUENCE:
1110  case OBJECT_SUBSCRIPTION:
1111  case OBJECT_TABCONSTRAINT:
1112  case OBJECT_TABLE:
1113  case OBJECT_TRANSFORM:
1114  case OBJECT_TRIGGER:
1116  case OBJECT_TSDICTIONARY:
1117  case OBJECT_TSPARSER:
1118  case OBJECT_TSTEMPLATE:
1119  case OBJECT_TYPE:
1120  case OBJECT_USER_MAPPING:
1121  case OBJECT_VIEW:
1122  return true;
1123  }
1124  return true;
1125 }
void EventTriggerTableRewrite ( Node parsetree,
Oid  tableOid,
int  reason 
)

Definition at line 931 of file event_trigger.c.

References CommandCounterIncrement(), DEBUG1, elog, EventTriggerCommonSetup(), EventTriggerInvoke(), EVT_TableRewrite, InvalidOid, IsUnderPostmaster, list_free(), NIL, PG_CATCH, PG_END_TRY, PG_RE_THROW, PG_TRY, EventTriggerQueryState::table_rewrite_oid, and EventTriggerQueryState::table_rewrite_reason.

Referenced by ATRewriteTables().

932 {
933  List *runlist;
934  EventTriggerData trigdata;
935 
936  elog(DEBUG1, "EventTriggerTableRewrite(%u)", tableOid);
937 
938  /*
939  * Event Triggers are completely disabled in standalone mode. There are
940  * (at least) two reasons for this:
941  *
942  * 1. A sufficiently broken event trigger might not only render the
943  * database unusable, but prevent disabling itself to fix the situation.
944  * In this scenario, restarting in standalone mode provides an escape
945  * hatch.
946  *
947  * 2. BuildEventTriggerCache relies on systable_beginscan_ordered, and
948  * therefore will malfunction if pg_event_trigger's indexes are damaged.
949  * To allow recovery from a damaged index, we need some operating mode
950  * wherein event triggers are disabled. (Or we could implement
951  * heapscan-and-sort logic for that case, but having disaster recovery
952  * scenarios depend on code that's otherwise untested isn't appetizing.)
953  */
954  if (!IsUnderPostmaster)
955  return;
956 
957  runlist = EventTriggerCommonSetup(parsetree,
959  "table_rewrite",
960  &trigdata);
961  if (runlist == NIL)
962  return;
963 
964  /*
965  * Make sure pg_event_trigger_table_rewrite_oid only works when running
966  * these triggers. Use PG_TRY to ensure table_rewrite_oid is reset even
967  * when one trigger fails. (This is perhaps not necessary, as the
968  * currentState variable will be removed shortly by our caller, but it
969  * seems better to play safe.)
970  */
973 
974  /* Run the triggers. */
975  PG_TRY();
976  {
977  EventTriggerInvoke(runlist, &trigdata);
978  }
979  PG_CATCH();
980  {
983  PG_RE_THROW();
984  }
985  PG_END_TRY();
986 
989 
990  /* Cleanup. */
991  list_free(runlist);
992 
993  /*
994  * Make sure anything the event triggers did will be visible to the main
995  * command.
996  */
998 }
#define NIL
Definition: pg_list.h:69
#define DEBUG1
Definition: elog.h:25
static void EventTriggerInvoke(List *fn_oid_list, EventTriggerData *trigdata)
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
static List * EventTriggerCommonSetup(Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
bool IsUnderPostmaster
Definition: globals.c:100
void CommandCounterIncrement(void)
Definition: xact.c:921
#define InvalidOid
Definition: postgres_ext.h:36
#define PG_CATCH()
Definition: elog.h:293
#define PG_RE_THROW()
Definition: elog.h:314
void list_free(List *list)
Definition: list.c:1133
#define elog
Definition: elog.h:219
#define PG_TRY()
Definition: elog.h:284
Definition: pg_list.h:45
#define PG_END_TRY()
Definition: elog.h:300
void EventTriggerUndoInhibitCommandCollection ( void  )

Definition at line 1627 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited.

Referenced by ProcessUtilitySlow().

1628 {
1630  return;
1631 
1633 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
Oid get_event_trigger_oid ( const char *  trigname,
bool  missing_ok 
)

Definition at line 640 of file event_trigger.c.

References CStringGetDatum, ereport, errcode(), errmsg(), ERROR, EVENTTRIGGERNAME, GetSysCacheOid1, and OidIsValid.

Referenced by get_object_address_unqualified().

641 {
642  Oid oid;
643 
645  if (!OidIsValid(oid) && !missing_ok)
646  ereport(ERROR,
647  (errcode(ERRCODE_UNDEFINED_OBJECT),
648  errmsg("event trigger \"%s\" does not exist", trigname)));
649  return oid;
650 }
int errcode(int sqlerrcode)
Definition: elog.c:575
unsigned int Oid
Definition: postgres_ext.h:31
#define OidIsValid(objectId)
Definition: c.h:533
#define GetSysCacheOid1(cacheId, key1)
Definition: syscache.h:176
#define ERROR
Definition: elog.h:43
#define CStringGetDatum(X)
Definition: postgres.h:586
#define ereport(elevel, rest)
Definition: elog.h:122
int errmsg(const char *fmt,...)
Definition: elog.c:797
void RemoveEventTriggerById ( Oid  ctrigOid)

Definition at line 476 of file event_trigger.c.

References CatalogTupleDelete(), elog, ERROR, EVENTTRIGGEROID, EventTriggerRelationId, heap_close, heap_open(), HeapTupleIsValid, ObjectIdGetDatum, ReleaseSysCache(), RowExclusiveLock, SearchSysCache1, and HeapTupleData::t_self.

Referenced by doDeletion().

477 {
478  Relation tgrel;
479  HeapTuple tup;
480 
482 
484  if (!HeapTupleIsValid(tup))
485  elog(ERROR, "cache lookup failed for event trigger %u", trigOid);
486 
487  CatalogTupleDelete(tgrel, &tup->t_self);
488 
489  ReleaseSysCache(tup);
490 
492 }
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
Definition: indexing.c:255
#define heap_close(r, l)
Definition: heapam.h:97
#define SearchSysCache1(cacheId, key1)
Definition: syscache.h:149
#define ObjectIdGetDatum(X)
Definition: postgres.h:515
#define ERROR
Definition: elog.h:43
ItemPointerData t_self
Definition: htup.h:65
#define RowExclusiveLock
Definition: lockdefs.h:38
void ReleaseSysCache(HeapTuple tuple)
Definition: syscache.c:1083
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1287
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EventTriggerRelationId
#define elog
Definition: elog.h:219
bool trackDroppedObjectsNeeded ( void  )

Definition at line 1279 of file event_trigger.c.

References EventCacheLookup(), EVT_DDLCommandEnd, EVT_SQLDrop, EVT_TableRewrite, and list_length().

Referenced by deleteObjectsInList(), and EventTriggerBeginCompleteQuery().

1280 {
1281  /*
1282  * true if any sql_drop, table_rewrite, ddl_command_end event trigger
1283  * exists
1284  */
1285  return list_length(EventCacheLookup(EVT_SQLDrop)) > 0 ||
1288 }
static int list_length(const List *l)
Definition: pg_list.h:89
List * EventCacheLookup(EventTriggerEvent event)
Definition: evtcache.c:64