PostgreSQL Source Code  git master
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 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 trigOid)
 
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)
 
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

◆ AT_REWRITE_ALTER_PERSISTENCE

#define AT_REWRITE_ALTER_PERSISTENCE   0x01

Definition at line 31 of file event_trigger.h.

Referenced by ATPrepCmd().

◆ AT_REWRITE_COLUMN_REWRITE

#define AT_REWRITE_COLUMN_REWRITE   0x04

Definition at line 33 of file event_trigger.h.

Referenced by ATPrepAlterColumnType().

◆ AT_REWRITE_DEFAULT_VAL

#define AT_REWRITE_DEFAULT_VAL   0x02

Definition at line 32 of file event_trigger.h.

Referenced by ATExecAddColumn().

◆ CALLED_AS_EVENT_TRIGGER

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

Typedef Documentation

◆ EventTriggerData

Function Documentation

◆ AlterEventTrigger()

Oid AlterEventTrigger ( AlterEventTrigStmt stmt)

Definition at line 504 of file event_trigger.c.

References aclcheck_error(), ACLCHECK_NOT_OWNER, CatalogTupleUpdate(), CStringGetDatum, ereport, errcode(), errmsg(), ERROR, EVENTTRIGGERNAME, GETSTRUCT, GetUserId(), heap_freetuple(), HeapTupleIsValid, InvokeObjectPostAlterHook, OBJECT_EVENT_TRIGGER, pg_event_trigger_ownercheck(), RowExclusiveLock, SearchSysCacheCopy1, HeapTupleData::t_self, table_close(), table_open(), AlterEventTrigStmt::tgenabled, and AlterEventTrigStmt::trigname.

Referenced by standard_ProcessUtility().

505 {
506  Relation tgrel;
507  HeapTuple tup;
508  Oid trigoid;
509  Form_pg_event_trigger evtForm;
510  char tgenabled = stmt->tgenabled;
511 
512  tgrel = table_open(EventTriggerRelationId, RowExclusiveLock);
513 
515  CStringGetDatum(stmt->trigname));
516  if (!HeapTupleIsValid(tup))
517  ereport(ERROR,
518  (errcode(ERRCODE_UNDEFINED_OBJECT),
519  errmsg("event trigger \"%s\" does not exist",
520  stmt->trigname)));
521 
522  evtForm = (Form_pg_event_trigger) GETSTRUCT(tup);
523  trigoid = evtForm->oid;
524 
525  if (!pg_event_trigger_ownercheck(trigoid, GetUserId()))
527  stmt->trigname);
528 
529  /* tuple is a copy, so we can modify it below */
530  evtForm->evtenabled = tgenabled;
531 
532  CatalogTupleUpdate(tgrel, &tup->t_self, tup);
533 
534  InvokeObjectPostAlterHook(EventTriggerRelationId,
535  trigoid, 0);
536 
537  /* clean up */
538  heap_freetuple(tup);
540 
541  return trigoid;
542 }
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:133
#define GETSTRUCT(TUP)
Definition: htup_details.h:655
Oid GetUserId(void)
Definition: miscinit.c:380
int errcode(int sqlerrcode)
Definition: elog.c:570
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1338
unsigned int Oid
Definition: postgres_ext.h:31
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
Definition: aclchk.c:3353
#define ERROR
Definition: elog.h:43
bool pg_event_trigger_ownercheck(Oid et_oid, Oid roleid)
Definition: aclchk.c:5146
ItemPointerData t_self
Definition: htup.h:65
#define RowExclusiveLock
Definition: lockdefs.h:38
#define CStringGetDatum(X)
Definition: postgres.h:578
#define ereport(elevel, rest)
Definition: elog.h:141
#define InvokeObjectPostAlterHook(classId, objectId, subId)
Definition: objectaccess.h:163
FormData_pg_event_trigger * Form_pg_event_trigger
#define HeapTupleIsValid(tuple)
Definition: htup.h:78
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
Definition: indexing.c:224
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:174
int errmsg(const char *fmt,...)
Definition: elog.c:784
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:39

◆ AlterEventTriggerOwner()

ObjectAddress AlterEventTriggerOwner ( const char *  name,
Oid  newOwnerId 
)

Definition at line 548 of file event_trigger.c.

References AlterEventTriggerOwner_internal(), CStringGetDatum, ereport, errcode(), errmsg(), ERROR, EVENTTRIGGERNAME, GETSTRUCT, heap_freetuple(), HeapTupleIsValid, ObjectAddressSet, RowExclusiveLock, SearchSysCacheCopy1, table_close(), and table_open().

Referenced by ExecAlterOwnerStmt().

549 {
550  Oid evtOid;
551  HeapTuple tup;
552  Form_pg_event_trigger evtForm;
553  Relation rel;
554  ObjectAddress address;
555 
556  rel = table_open(EventTriggerRelationId, RowExclusiveLock);
557 
559 
560  if (!HeapTupleIsValid(tup))
561  ereport(ERROR,
562  (errcode(ERRCODE_UNDEFINED_OBJECT),
563  errmsg("event trigger \"%s\" does not exist", name)));
564 
565  evtForm = (Form_pg_event_trigger) GETSTRUCT(tup);
566  evtOid = evtForm->oid;
567 
568  AlterEventTriggerOwner_internal(rel, tup, newOwnerId);
569 
570  ObjectAddressSet(address, EventTriggerRelationId, evtOid);
571 
572  heap_freetuple(tup);
573 
575 
576  return address;
577 }
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:133
#define GETSTRUCT(TUP)
Definition: htup_details.h:655
int errcode(int sqlerrcode)
Definition: elog.c:570
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1338
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:578
#define ereport(elevel, rest)
Definition: elog.h:141
FormData_pg_event_trigger * Form_pg_event_trigger
#define HeapTupleIsValid(tuple)
Definition: htup.h:78
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:174
int errmsg(const char *fmt,...)
Definition: elog.c:784
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:39

◆ AlterEventTriggerOwner_oid()

void AlterEventTriggerOwner_oid ( Oid  ,
Oid  newOwnerId 
)

Definition at line 583 of file event_trigger.c.

References AlterEventTriggerOwner_internal(), ereport, errcode(), errmsg(), ERROR, EVENTTRIGGEROID, heap_freetuple(), HeapTupleIsValid, ObjectIdGetDatum, RowExclusiveLock, SearchSysCacheCopy1, table_close(), and table_open().

Referenced by shdepReassignOwned().

584 {
585  HeapTuple tup;
586  Relation rel;
587 
588  rel = table_open(EventTriggerRelationId, RowExclusiveLock);
589 
591 
592  if (!HeapTupleIsValid(tup))
593  ereport(ERROR,
594  (errcode(ERRCODE_UNDEFINED_OBJECT),
595  errmsg("event trigger with OID %u does not exist", trigOid)));
596 
597  AlterEventTriggerOwner_internal(rel, tup, newOwnerId);
598 
599  heap_freetuple(tup);
600 
602 }
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:133
int errcode(int sqlerrcode)
Definition: elog.c:570
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1338
static void AlterEventTriggerOwner_internal(Relation rel, HeapTuple tup, Oid newOwnerId)
#define ObjectIdGetDatum(X)
Definition: postgres.h:507
#define ERROR
Definition: elog.h:43
#define RowExclusiveLock
Definition: lockdefs.h:38
#define ereport(elevel, rest)
Definition: elog.h:141
#define HeapTupleIsValid(tuple)
Definition: htup.h:78
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:174
int errmsg(const char *fmt,...)
Definition: elog.c:784
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:39

◆ CreateEventTrigger()

Oid CreateEventTrigger ( CreateEventTrigStmt stmt)

Definition at line 169 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, CreateEventTrigStmt::funcname, get_func_rettype(), GetUserId(), HeapTupleIsValid, insert_event_trigger_tuple(), lfirst, LookupFuncName(), NameListToString(), SearchSysCache1(), superuser(), CreateEventTrigStmt::trigname, validate_ddl_tags(), validate_table_rewrite_tags(), and CreateEventTrigStmt::whenclause.

Referenced by standard_ProcessUtility().

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

◆ EventTriggerAlterTableEnd()

void EventTriggerAlterTableEnd ( void  )

Definition at line 1796 of file event_trigger.c.

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

Referenced by AlterTableMoveAll(), and ProcessUtilitySlow().

1797 {
1798  CollectedCommand *parent;
1799 
1800  /* ignore if event trigger context not set, or collection disabled */
1801  if (!currentEventTriggerState ||
1803  return;
1804 
1806 
1807  /* If no subcommands, don't collect */
1809  {
1813  }
1814  else
1816 
1818 }
union CollectedCommand::@111 d
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
void pfree(void *pointer)
Definition: mcxt.c:1031
CollectedCommand * currentCommand
Definition: event_trigger.c:67
struct CollectedCommand * parent
List * lappend(List *list, void *datum)
Definition: list.c:321
static int list_length(const List *l)
Definition: pg_list.h:169
struct CollectedCommand::@111::@113 alterTable

◆ EventTriggerAlterTableRelid()

void EventTriggerAlterTableRelid ( Oid  objectId)

Definition at line 1743 of file event_trigger.c.

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

Referenced by AlterTableInternal(), and ProcessUtilitySlow().

1744 {
1745  if (!currentEventTriggerState ||
1747  return;
1748 
1749  currentEventTriggerState->currentCommand->d.alterTable.objectId = objectId;
1750 }
union CollectedCommand::@111 d
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
CollectedCommand * currentCommand
Definition: event_trigger.c:67
struct CollectedCommand::@111::@113 alterTable

◆ EventTriggerAlterTableStart()

void EventTriggerAlterTableStart ( Node parsetree)

Definition at line 1709 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::parent, CollectedCommand::parsetree, SCT_AlterTable, and CollectedCommand::type.

Referenced by AlterTableMoveAll(), and ProcessUtilitySlow().

1710 {
1711  MemoryContext oldcxt;
1712  CollectedCommand *command;
1713 
1714  /* ignore if event trigger context not set, or collection disabled */
1715  if (!currentEventTriggerState ||
1717  return;
1718 
1720 
1721  command = palloc(sizeof(CollectedCommand));
1722 
1723  command->type = SCT_AlterTable;
1724  command->in_extension = creating_extension;
1725 
1726  command->d.alterTable.classId = RelationRelationId;
1727  command->d.alterTable.objectId = InvalidOid;
1728  command->d.alterTable.subcmds = NIL;
1729  command->parsetree = copyObject(parsetree);
1730 
1733 
1734  MemoryContextSwitchTo(oldcxt);
1735 }
#define NIL
Definition: pg_list.h:65
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
CollectedCommand * currentCommand
Definition: event_trigger.c:67
struct CollectedCommand * parent
#define InvalidOid
Definition: postgres_ext.h:36
bool creating_extension
Definition: extension.c:70
struct CollectedCommand::@111::@113 alterTable
void * palloc(Size size)
Definition: mcxt.c:924
#define copyObject(obj)
Definition: nodes.h:641

◆ EventTriggerBeginCompleteQuery()

bool EventTriggerBeginCompleteQuery ( void  )

Definition at line 1237 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, EventTriggerQueryState::previous, slist_init(), EventTriggerQueryState::SQLDropList, EventTriggerQueryState::table_rewrite_oid, TopMemoryContext, and trackDroppedObjectsNeeded().

Referenced by ProcessUtilitySlow().

1238 {
1240  MemoryContext cxt;
1241 
1242  /*
1243  * Currently, sql_drop, table_rewrite, ddl_command_end events are the only
1244  * reason to have event trigger state at all; so if there are none, don't
1245  * install one.
1246  */
1248  return false;
1249 
1251  "event trigger state",
1253  state = MemoryContextAlloc(cxt, sizeof(EventTriggerQueryState));
1254  state->cxt = cxt;
1255  slist_init(&(state->SQLDropList));
1256  state->in_sql_drop = false;
1257  state->table_rewrite_oid = InvalidOid;
1258 
1261  state->currentCommand = NULL;
1262  state->commandList = NIL;
1264  currentEventTriggerState = state;
1265 
1266  return true;
1267 }
#define NIL
Definition: pg_list.h:65
#define AllocSetContextCreate
Definition: memutils.h:169
bool trackDroppedObjectsNeeded(void)
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
static void slist_init(slist_head *head)
Definition: ilist.h:554
#define ALLOCSET_DEFAULT_SIZES
Definition: memutils.h:191
CollectedCommand * currentCommand
Definition: event_trigger.c:67
struct EventTriggerQueryState * previous
Definition: event_trigger.c:70
MemoryContext TopMemoryContext
Definition: mcxt.c:44
#define InvalidOid
Definition: postgres_ext.h:36
Definition: regguts.h:298
void * MemoryContextAlloc(MemoryContext context, Size size)
Definition: mcxt.c:771

◆ EventTriggerCollectAlterDefPrivs()

void EventTriggerCollectAlterDefPrivs ( AlterDefaultPrivilegesStmt stmt)

Definition at line 1974 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().

1975 {
1976  MemoryContext oldcxt;
1977  CollectedCommand *command;
1978 
1979  /* ignore if event trigger context not set, or collection disabled */
1980  if (!currentEventTriggerState ||
1982  return;
1983 
1985 
1986  command = palloc0(sizeof(CollectedCommand));
1987  command->type = SCT_AlterDefaultPrivileges;
1988  command->d.defprivs.objtype = stmt->action->objtype;
1989  command->in_extension = creating_extension;
1990  command->parsetree = (Node *) copyObject(stmt);
1991 
1994  MemoryContextSwitchTo(oldcxt);
1995 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:525
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
struct CollectedCommand::@111::@118 defprivs
List * lappend(List *list, void *datum)
Definition: list.c:321
void * palloc0(Size size)
Definition: mcxt.c:955
bool creating_extension
Definition: extension.c:70
ObjectType objtype
Definition: parsenodes.h:1906
#define copyObject(obj)
Definition: nodes.h:641

◆ EventTriggerCollectAlterOpFam()

void EventTriggerCollectAlterOpFam ( AlterOpFamilyStmt stmt,
Oid  opfamoid,
List operators,
List procedures 
)

Definition at line 1872 of file event_trigger.c.

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

Referenced by AlterOpFamilyAdd(), and AlterOpFamilyDrop().

1874 {
1875  MemoryContext oldcxt;
1876  CollectedCommand *command;
1877 
1878  /* ignore if event trigger context not set, or collection disabled */
1879  if (!currentEventTriggerState ||
1881  return;
1882 
1884 
1885  command = palloc(sizeof(CollectedCommand));
1886  command->type = SCT_AlterOpFamily;
1887  command->in_extension = creating_extension;
1888  ObjectAddressSet(command->d.opfam.address,
1889  OperatorFamilyRelationId, opfamoid);
1890  command->d.opfam.operators = operators;
1891  command->d.opfam.procedures = procedures;
1892  command->parsetree = (Node *) copyObject(stmt);
1893 
1896 
1897  MemoryContextSwitchTo(oldcxt);
1898 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:525
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
List * lappend(List *list, void *datum)
Definition: list.c:321
bool creating_extension
Definition: extension.c:70
struct CollectedCommand::@111::@115 opfam
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void * palloc(Size size)
Definition: mcxt.c:924
#define copyObject(obj)
Definition: nodes.h:641

◆ EventTriggerCollectAlterTableSubcmd()

void EventTriggerCollectAlterTableSubcmd ( Node subcmd,
ObjectAddress  address 
)

Definition at line 1761 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().

1762 {
1763  MemoryContext oldcxt;
1765 
1766  /* ignore if event trigger context not set, or collection disabled */
1767  if (!currentEventTriggerState ||
1769  return;
1770 
1771  Assert(IsA(subcmd, AlterTableCmd));
1774 
1776 
1777  newsub = palloc(sizeof(CollectedATSubcmd));
1778  newsub->address = address;
1779  newsub->parsetree = copyObject(subcmd);
1780 
1783 
1784  MemoryContextSwitchTo(oldcxt);
1785 }
union CollectedCommand::@111 d
#define IsA(nodeptr, _type_)
Definition: nodes.h:576
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define OidIsValid(objectId)
Definition: c.h:638
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
CollectedCommand * currentCommand
Definition: event_trigger.c:67
List * lappend(List *list, void *datum)
Definition: list.c:321
#define Assert(condition)
Definition: c.h:732
struct CollectedCommand::@111::@113 alterTable
void * palloc(Size size)
Definition: mcxt.c:924
#define copyObject(obj)
Definition: nodes.h:641
static color newsub(struct colormap *cm, color co)
Definition: regc_color.c:389
ObjectAddress address

◆ EventTriggerCollectAlterTSConfig()

void EventTriggerCollectAlterTSConfig ( AlterTSConfigurationStmt stmt,
Oid  cfgId,
Oid dictIds,
int  ndicts 
)

Definition at line 1939 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, and CollectedCommand::type.

Referenced by DropConfigurationMapping(), and MakeConfigurationMapping().

1941 {
1942  MemoryContext oldcxt;
1943  CollectedCommand *command;
1944 
1945  /* ignore if event trigger context not set, or collection disabled */
1946  if (!currentEventTriggerState ||
1948  return;
1949 
1951 
1952  command = palloc0(sizeof(CollectedCommand));
1953  command->type = SCT_AlterTSConfig;
1954  command->in_extension = creating_extension;
1955  ObjectAddressSet(command->d.atscfg.address,
1956  TSConfigRelationId, cfgId);
1957  command->d.atscfg.dictIds = palloc(sizeof(Oid) * ndicts);
1958  memcpy(command->d.atscfg.dictIds, dictIds, sizeof(Oid) * ndicts);
1959  command->d.atscfg.ndicts = ndicts;
1960  command->parsetree = (Node *) copyObject(stmt);
1961 
1964 
1965  MemoryContextSwitchTo(oldcxt);
1966 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:525
CollectedCommandType type
unsigned int Oid
Definition: postgres_ext.h:31
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
struct CollectedCommand::@111::@117 atscfg
List * lappend(List *list, void *datum)
Definition: list.c:321
void * palloc0(Size size)
Definition: mcxt.c:955
bool creating_extension
Definition: extension.c:70
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void * palloc(Size size)
Definition: mcxt.c:924
#define copyObject(obj)
Definition: nodes.h:641

◆ EventTriggerCollectCreateOpClass()

void EventTriggerCollectCreateOpClass ( CreateOpClassStmt stmt,
Oid  opcoid,
List operators,
List procedures 
)

Definition at line 1905 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, palloc0(), CollectedCommand::parsetree, SCT_CreateOpClass, and CollectedCommand::type.

Referenced by DefineOpClass().

1907 {
1908  MemoryContext oldcxt;
1909  CollectedCommand *command;
1910 
1911  /* ignore if event trigger context not set, or collection disabled */
1912  if (!currentEventTriggerState ||
1914  return;
1915 
1917 
1918  command = palloc0(sizeof(CollectedCommand));
1919  command->type = SCT_CreateOpClass;
1920  command->in_extension = creating_extension;
1921  ObjectAddressSet(command->d.createopc.address,
1922  OperatorClassRelationId, opcoid);
1923  command->d.createopc.operators = operators;
1924  command->d.createopc.procedures = procedures;
1925  command->parsetree = (Node *) copyObject(stmt);
1926 
1929 
1930  MemoryContextSwitchTo(oldcxt);
1931 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:525
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
struct CollectedCommand::@111::@116 createopc
List * lappend(List *list, void *datum)
Definition: list.c:321
void * palloc0(Size size)
Definition: mcxt.c:955
bool creating_extension
Definition: extension.c:70
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
#define copyObject(obj)
Definition: nodes.h:641

◆ EventTriggerCollectGrant()

void EventTriggerCollectGrant ( InternalGrant istmt)

Definition at line 1828 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, InternalGrant::objects, palloc(), CollectedCommand::parsetree, SCT_Grant, and CollectedCommand::type.

Referenced by ExecGrantStmt_oids().

1829 {
1830  MemoryContext oldcxt;
1831  CollectedCommand *command;
1832  InternalGrant *icopy;
1833  ListCell *cell;
1834 
1835  /* ignore if event trigger context not set, or collection disabled */
1836  if (!currentEventTriggerState ||
1838  return;
1839 
1841 
1842  /*
1843  * This is tedious, but necessary.
1844  */
1845  icopy = palloc(sizeof(InternalGrant));
1846  memcpy(icopy, istmt, sizeof(InternalGrant));
1847  icopy->objects = list_copy(istmt->objects);
1848  icopy->grantees = list_copy(istmt->grantees);
1849  icopy->col_privs = NIL;
1850  foreach(cell, istmt->col_privs)
1851  icopy->col_privs = lappend(icopy->col_privs, copyObject(lfirst(cell)));
1852 
1853  /* Now collect it, using the copied InternalGrant */
1854  command = palloc(sizeof(CollectedCommand));
1855  command->type = SCT_Grant;
1856  command->in_extension = creating_extension;
1857  command->d.grant.istmt = icopy;
1858  command->parsetree = NULL;
1859 
1862 
1863  MemoryContextSwitchTo(oldcxt);
1864 }
#define NIL
Definition: pg_list.h:65
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
List * list_copy(const List *oldlist)
Definition: list.c:1400
struct CollectedCommand::@111::@114 grant
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
List * lappend(List *list, void *datum)
Definition: list.c:321
bool creating_extension
Definition: extension.c:70
#define lfirst(lc)
Definition: pg_list.h:190
void * palloc(Size size)
Definition: mcxt.c:924
#define copyObject(obj)
Definition: nodes.h:641

◆ EventTriggerCollectSimpleCommand()

void EventTriggerCollectSimpleCommand ( ObjectAddress  address,
ObjectAddress  secondaryObject,
Node parsetree 
)

Definition at line 1671 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().

1674 {
1675  MemoryContext oldcxt;
1676  CollectedCommand *command;
1677 
1678  /* ignore if event trigger context not set, or collection disabled */
1679  if (!currentEventTriggerState ||
1681  return;
1682 
1684 
1685  command = palloc(sizeof(CollectedCommand));
1686 
1687  command->type = SCT_Simple;
1688  command->in_extension = creating_extension;
1689 
1690  command->d.simple.address = address;
1691  command->d.simple.secondaryObject = secondaryObject;
1692  command->parsetree = copyObject(parsetree);
1693 
1695  command);
1696 
1697  MemoryContextSwitchTo(oldcxt);
1698 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
struct CollectedCommand::@111::@112 simple
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
List * lappend(List *list, void *datum)
Definition: list.c:321
bool creating_extension
Definition: extension.c:70
void * palloc(Size size)
Definition: mcxt.c:924
#define copyObject(obj)
Definition: nodes.h:641

◆ EventTriggerDDLCommandEnd()

void EventTriggerDDLCommandEnd ( Node parsetree)

Definition at line 833 of file event_trigger.c.

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

Referenced by ProcessUtilitySlow().

834 {
835  List *runlist;
836  EventTriggerData trigdata;
837 
838  /*
839  * See EventTriggerDDLCommandStart for a discussion about why event
840  * triggers are disabled in single user mode.
841  */
842  if (!IsUnderPostmaster)
843  return;
844 
845  /*
846  * Also do nothing if our state isn't set up, which it won't be if there
847  * weren't any relevant event triggers at the start of the current DDL
848  * command. This test might therefore seem optional, but it's important
849  * because EventTriggerCommonSetup might find triggers that didn't exist
850  * at the time the command started. Although this function itself
851  * wouldn't crash, the event trigger functions would presumably call
852  * pg_event_trigger_ddl_commands which would fail. Better to do nothing
853  * until the next command.
854  */
856  return;
857 
858  runlist = EventTriggerCommonSetup(parsetree,
859  EVT_DDLCommandEnd, "ddl_command_end",
860  &trigdata);
861  if (runlist == NIL)
862  return;
863 
864  /*
865  * Make sure anything the main command did will be visible to the event
866  * triggers.
867  */
869 
870  /* Run the triggers. */
871  EventTriggerInvoke(runlist, &trigdata);
872 
873  /* Cleanup. */
874  list_free(runlist);
875 }
#define NIL
Definition: pg_list.h:65
static void EventTriggerInvoke(List *fn_oid_list, EventTriggerData *trigdata)
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
static List * EventTriggerCommonSetup(Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
bool IsUnderPostmaster
Definition: globals.c:109
void CommandCounterIncrement(void)
Definition: xact.c:1003
void list_free(List *list)
Definition: list.c:1373
Definition: pg_list.h:50

◆ EventTriggerDDLCommandStart()

void EventTriggerDDLCommandStart ( Node parsetree)

Definition at line 785 of file event_trigger.c.

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

Referenced by ProcessUtilitySlow().

786 {
787  List *runlist;
788  EventTriggerData trigdata;
789 
790  /*
791  * Event Triggers are completely disabled in standalone mode. There are
792  * (at least) two reasons for this:
793  *
794  * 1. A sufficiently broken event trigger might not only render the
795  * database unusable, but prevent disabling itself to fix the situation.
796  * In this scenario, restarting in standalone mode provides an escape
797  * hatch.
798  *
799  * 2. BuildEventTriggerCache relies on systable_beginscan_ordered, and
800  * therefore will malfunction if pg_event_trigger's indexes are damaged.
801  * To allow recovery from a damaged index, we need some operating mode
802  * wherein event triggers are disabled. (Or we could implement
803  * heapscan-and-sort logic for that case, but having disaster recovery
804  * scenarios depend on code that's otherwise untested isn't appetizing.)
805  */
806  if (!IsUnderPostmaster)
807  return;
808 
809  runlist = EventTriggerCommonSetup(parsetree,
811  "ddl_command_start",
812  &trigdata);
813  if (runlist == NIL)
814  return;
815 
816  /* Run the triggers. */
817  EventTriggerInvoke(runlist, &trigdata);
818 
819  /* Cleanup. */
820  list_free(runlist);
821 
822  /*
823  * Make sure anything the event triggers did will be visible to the main
824  * command.
825  */
827 }
#define NIL
Definition: pg_list.h:65
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:109
void CommandCounterIncrement(void)
Definition: xact.c:1003
void list_free(List *list)
Definition: list.c:1373
Definition: pg_list.h:50

◆ EventTriggerEndCompleteQuery()

void EventTriggerEndCompleteQuery ( void  )

Definition at line 1281 of file event_trigger.c.

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

Referenced by ProcessUtilitySlow().

1282 {
1283  EventTriggerQueryState *prevstate;
1284 
1285  prevstate = currentEventTriggerState->previous;
1286 
1287  /* this avoids the need for retail pfree of SQLDropList items: */
1289 
1290  currentEventTriggerState = prevstate;
1291 }
void MemoryContextDelete(MemoryContext context)
Definition: mcxt.c:211
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
struct EventTriggerQueryState * previous
Definition: event_trigger.c:70

◆ EventTriggerInhibitCommandCollection()

void EventTriggerInhibitCommandCollection ( void  )

Definition at line 1637 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited.

Referenced by ProcessUtilitySlow().

1638 {
1640  return;
1641 
1643 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73

◆ EventTriggerSQLDrop()

void EventTriggerSQLDrop ( Node parsetree)

Definition at line 881 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().

882 {
883  List *runlist;
884  EventTriggerData trigdata;
885 
886  /*
887  * See EventTriggerDDLCommandStart for a discussion about why event
888  * triggers are disabled in single user mode.
889  */
890  if (!IsUnderPostmaster)
891  return;
892 
893  /*
894  * Use current state to determine whether this event fires at all. If
895  * there are no triggers for the sql_drop event, then we don't have
896  * anything to do here. Note that dropped object collection is disabled
897  * if this is the case, so even if we were to try to run, the list would
898  * be empty.
899  */
902  return;
903 
904  runlist = EventTriggerCommonSetup(parsetree,
905  EVT_SQLDrop, "sql_drop",
906  &trigdata);
907 
908  /*
909  * Nothing to do if run list is empty. Note this typically can't happen,
910  * because if there are no sql_drop events, then objects-to-drop wouldn't
911  * have been collected in the first place and we would have quit above.
912  * But it could occur if event triggers were dropped partway through.
913  */
914  if (runlist == NIL)
915  return;
916 
917  /*
918  * Make sure anything the main command did will be visible to the event
919  * triggers.
920  */
922 
923  /*
924  * Make sure pg_event_trigger_dropped_objects only works when running
925  * these triggers. Use PG_TRY to ensure in_sql_drop is reset even when
926  * one trigger fails. (This is perhaps not necessary, as the currentState
927  * variable will be removed shortly by our caller, but it seems better to
928  * play safe.)
929  */
931 
932  /* Run the triggers. */
933  PG_TRY();
934  {
935  EventTriggerInvoke(runlist, &trigdata);
936  }
937  PG_CATCH();
938  {
940  PG_RE_THROW();
941  }
942  PG_END_TRY();
944 
945  /* Cleanup. */
946  list_free(runlist);
947 }
#define NIL
Definition: pg_list.h:65
static void EventTriggerInvoke(List *fn_oid_list, EventTriggerData *trigdata)
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
static List * EventTriggerCommonSetup(Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
bool IsUnderPostmaster
Definition: globals.c:109
static bool slist_is_empty(slist_head *head)
Definition: ilist.h:563
void CommandCounterIncrement(void)
Definition: xact.c:1003
#define PG_CATCH()
Definition: elog.h:310
#define PG_RE_THROW()
Definition: elog.h:331
void list_free(List *list)
Definition: list.c:1373
#define PG_TRY()
Definition: elog.h:301
Definition: pg_list.h:50
#define PG_END_TRY()
Definition: elog.h:317

◆ EventTriggerSQLDropAddObject()

void EventTriggerSQLDropAddObject ( const ObjectAddress object,
bool  original,
bool  normal 
)

Definition at line 1331 of file event_trigger.c.

References AccessShareLock, SQLDropObject::addrargs, SQLDropObject::address, SQLDropObject::addrnames, Assert, attnum, 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_attnum_oid(), get_object_namensp_unique(), getObjectClass(), getObjectIdentityParts(), getObjectTypeDescription(), heap_getattr, InvalidAttrNumber, is_objectclass_supported(), isAnyTempNamespace(), SQLDropObject::istemp, isTempNamespace(), MemoryContextSwitchTo(), 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(), EventTriggerQueryState::SQLDropList, table_close(), and table_open().

Referenced by deleteObjectsInList(), and DropSubscription().

1332 {
1333  SQLDropObject *obj;
1334  MemoryContext oldcxt;
1335 
1337  return;
1338 
1340 
1341  /* don't report temp schemas except my own */
1342  if (object->classId == NamespaceRelationId &&
1343  (isAnyTempNamespace(object->objectId) &&
1344  !isTempNamespace(object->objectId)))
1345  return;
1346 
1348 
1349  obj = palloc0(sizeof(SQLDropObject));
1350  obj->address = *object;
1351  obj->original = original;
1352  obj->normal = normal;
1353 
1354  /*
1355  * Obtain schema names from the object's catalog tuple, if one exists;
1356  * this lets us skip objects in temp schemas. We trust that
1357  * ObjectProperty contains all object classes that can be
1358  * schema-qualified.
1359  */
1360  if (is_objectclass_supported(object->classId))
1361  {
1362  Relation catalog;
1363  HeapTuple tuple;
1364 
1365  catalog = table_open(obj->address.classId, AccessShareLock);
1366  tuple = get_catalog_object_by_oid(catalog,
1367  get_object_attnum_oid(object->classId),
1368  obj->address.objectId);
1369 
1370  if (tuple)
1371  {
1373  Datum datum;
1374  bool isnull;
1375 
1377  if (attnum != InvalidAttrNumber)
1378  {
1379  datum = heap_getattr(tuple, attnum,
1380  RelationGetDescr(catalog), &isnull);
1381  if (!isnull)
1382  {
1383  Oid namespaceId;
1384 
1385  namespaceId = DatumGetObjectId(datum);
1386  /* temp objects are only reported if they are my own */
1387  if (isTempNamespace(namespaceId))
1388  {
1389  obj->schemaname = "pg_temp";
1390  obj->istemp = true;
1391  }
1392  else if (isAnyTempNamespace(namespaceId))
1393  {
1394  pfree(obj);
1395  table_close(catalog, AccessShareLock);
1396  MemoryContextSwitchTo(oldcxt);
1397  return;
1398  }
1399  else
1400  {
1401  obj->schemaname = get_namespace_name(namespaceId);
1402  obj->istemp = false;
1403  }
1404  }
1405  }
1406 
1408  obj->address.objectSubId == 0)
1409  {
1410  attnum = get_object_attnum_name(obj->address.classId);
1411  if (attnum != InvalidAttrNumber)
1412  {
1413  datum = heap_getattr(tuple, attnum,
1414  RelationGetDescr(catalog), &isnull);
1415  if (!isnull)
1416  obj->objname = pstrdup(NameStr(*DatumGetName(datum)));
1417  }
1418  }
1419  }
1420 
1421  table_close(catalog, AccessShareLock);
1422  }
1423  else
1424  {
1425  if (object->classId == NamespaceRelationId &&
1426  isTempNamespace(object->objectId))
1427  obj->istemp = true;
1428  }
1429 
1430  /* object identity, objname and objargs */
1431  obj->objidentity =
1432  getObjectIdentityParts(&obj->address, &obj->addrnames, &obj->addrargs);
1433 
1434  /* object type */
1436 
1438 
1439  MemoryContextSwitchTo(oldcxt);
1440 }
bool get_object_namensp_unique(Oid class_id)
slist_node next
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:133
ObjectAddress address
char * getObjectTypeDescription(const ObjectAddress *object)
AttrNumber get_object_attnum_oid(Oid class_id)
#define RelationGetDescr(relation)
Definition: rel.h:442
const char * objname
#define DatumGetObjectId(X)
Definition: postgres.h:500
char * pstrdup(const char *in)
Definition: mcxt.c:1161
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)
const char * objidentity
unsigned int Oid
Definition: postgres_ext.h:31
ObjectClass getObjectClass(const ObjectAddress *object)
Definition: dependency.c:2695
const char * objecttype
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
#define DatumGetName(X)
Definition: postgres.h:585
void pfree(void *pointer)
Definition: mcxt.c:1031
char * get_namespace_name(Oid nspid)
Definition: lsyscache.c:3094
bool isTempNamespace(Oid namespaceId)
Definition: namespace.c:3149
bool EventTriggerSupportsObjectClass(ObjectClass objclass)
const char * schemaname
#define heap_getattr(tup, attnum, tupleDesc, isnull)
Definition: htup_details.h:762
AttrNumber get_object_attnum_name(Oid class_id)
void * palloc0(Size size)
Definition: mcxt.c:955
HeapTuple get_catalog_object_by_oid(Relation catalog, AttrNumber oidcol, Oid objectId)
uintptr_t Datum
Definition: postgres.h:367
int16 attnum
Definition: pg_attribute.h:79
#define Assert(condition)
Definition: c.h:732
#define InvalidAttrNumber
Definition: attnum.h:23
#define NameStr(name)
Definition: c.h:609
bool isAnyTempNamespace(Oid namespaceId)
Definition: namespace.c:3187
bool is_objectclass_supported(Oid class_id)
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:39
int16 AttrNumber
Definition: attnum.h:21

◆ EventTriggerSupportsObjectClass()

bool EventTriggerSupportsObjectClass ( ObjectClass  objclass)

Definition at line 1172 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_STATISTIC_EXT, 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().

1173 {
1174  switch (objclass)
1175  {
1176  case OCLASS_DATABASE:
1177  case OCLASS_TBLSPACE:
1178  case OCLASS_ROLE:
1179  /* no support for global objects */
1180  return false;
1181  case OCLASS_EVENT_TRIGGER:
1182  /* no support for event triggers on event triggers */
1183  return false;
1184  case OCLASS_CLASS:
1185  case OCLASS_PROC:
1186  case OCLASS_TYPE:
1187  case OCLASS_CAST:
1188  case OCLASS_COLLATION:
1189  case OCLASS_CONSTRAINT:
1190  case OCLASS_CONVERSION:
1191  case OCLASS_DEFAULT:
1192  case OCLASS_LANGUAGE:
1193  case OCLASS_LARGEOBJECT:
1194  case OCLASS_OPERATOR:
1195  case OCLASS_OPCLASS:
1196  case OCLASS_OPFAMILY:
1197  case OCLASS_AM:
1198  case OCLASS_AMOP:
1199  case OCLASS_AMPROC:
1200  case OCLASS_REWRITE:
1201  case OCLASS_TRIGGER:
1202  case OCLASS_SCHEMA:
1203  case OCLASS_STATISTIC_EXT:
1204  case OCLASS_TSPARSER:
1205  case OCLASS_TSDICT:
1206  case OCLASS_TSTEMPLATE:
1207  case OCLASS_TSCONFIG:
1208  case OCLASS_FDW:
1209  case OCLASS_FOREIGN_SERVER:
1210  case OCLASS_USER_MAPPING:
1211  case OCLASS_DEFACL:
1212  case OCLASS_EXTENSION:
1213  case OCLASS_POLICY:
1214  case OCLASS_PUBLICATION:
1216  case OCLASS_SUBSCRIPTION:
1217  case OCLASS_TRANSFORM:
1218  return true;
1219 
1220  /*
1221  * There's intentionally no default: case here; we want the
1222  * compiler to warn if a new OCLASS hasn't been handled above.
1223  */
1224  }
1225 
1226  /* Shouldn't get here, but if we do, say "no support" */
1227  return false;
1228 }

◆ EventTriggerSupportsObjectType()

bool EventTriggerSupportsObjectType ( ObjectType  obtype)

Definition at line 1098 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_PROCEDURE, OBJECT_PUBLICATION, OBJECT_PUBLICATION_REL, OBJECT_ROLE, OBJECT_ROUTINE, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_SEQUENCE, OBJECT_STATISTIC_EXT, 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 ExecGrantStmt_oids(), and standard_ProcessUtility().

1099 {
1100  switch (obtype)
1101  {
1102  case OBJECT_DATABASE:
1103  case OBJECT_TABLESPACE:
1104  case OBJECT_ROLE:
1105  /* no support for global objects */
1106  return false;
1107  case OBJECT_EVENT_TRIGGER:
1108  /* no support for event triggers on event triggers */
1109  return false;
1110  case OBJECT_ACCESS_METHOD:
1111  case OBJECT_AGGREGATE:
1112  case OBJECT_AMOP:
1113  case OBJECT_AMPROC:
1114  case OBJECT_ATTRIBUTE:
1115  case OBJECT_CAST:
1116  case OBJECT_COLUMN:
1117  case OBJECT_COLLATION:
1118  case OBJECT_CONVERSION:
1119  case OBJECT_DEFACL:
1120  case OBJECT_DEFAULT:
1121  case OBJECT_DOMAIN:
1122  case OBJECT_DOMCONSTRAINT:
1123  case OBJECT_EXTENSION:
1124  case OBJECT_FDW:
1125  case OBJECT_FOREIGN_SERVER:
1126  case OBJECT_FOREIGN_TABLE:
1127  case OBJECT_FUNCTION:
1128  case OBJECT_INDEX:
1129  case OBJECT_LANGUAGE:
1130  case OBJECT_LARGEOBJECT:
1131  case OBJECT_MATVIEW:
1132  case OBJECT_OPCLASS:
1133  case OBJECT_OPERATOR:
1134  case OBJECT_OPFAMILY:
1135  case OBJECT_POLICY:
1136  case OBJECT_PROCEDURE:
1137  case OBJECT_PUBLICATION:
1139  case OBJECT_ROUTINE:
1140  case OBJECT_RULE:
1141  case OBJECT_SCHEMA:
1142  case OBJECT_SEQUENCE:
1143  case OBJECT_SUBSCRIPTION:
1144  case OBJECT_STATISTIC_EXT:
1145  case OBJECT_TABCONSTRAINT:
1146  case OBJECT_TABLE:
1147  case OBJECT_TRANSFORM:
1148  case OBJECT_TRIGGER:
1150  case OBJECT_TSDICTIONARY:
1151  case OBJECT_TSPARSER:
1152  case OBJECT_TSTEMPLATE:
1153  case OBJECT_TYPE:
1154  case OBJECT_USER_MAPPING:
1155  case OBJECT_VIEW:
1156  return true;
1157 
1158  /*
1159  * There's intentionally no default: case here; we want the
1160  * compiler to warn if a new ObjectType hasn't been handled above.
1161  */
1162  }
1163 
1164  /* Shouldn't get here, but if we do, say "no support" */
1165  return false;
1166 }

◆ EventTriggerTableRewrite()

void EventTriggerTableRewrite ( Node parsetree,
Oid  tableOid,
int  reason 
)

Definition at line 954 of file event_trigger.c.

References CommandCounterIncrement(), 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().

955 {
956  List *runlist;
957  EventTriggerData trigdata;
958 
959  /*
960  * Event Triggers are completely disabled in standalone mode. There are
961  * (at least) two reasons for this:
962  *
963  * 1. A sufficiently broken event trigger might not only render the
964  * database unusable, but prevent disabling itself to fix the situation.
965  * In this scenario, restarting in standalone mode provides an escape
966  * hatch.
967  *
968  * 2. BuildEventTriggerCache relies on systable_beginscan_ordered, and
969  * therefore will malfunction if pg_event_trigger's indexes are damaged.
970  * To allow recovery from a damaged index, we need some operating mode
971  * wherein event triggers are disabled. (Or we could implement
972  * heapscan-and-sort logic for that case, but having disaster recovery
973  * scenarios depend on code that's otherwise untested isn't appetizing.)
974  */
975  if (!IsUnderPostmaster)
976  return;
977 
978  /*
979  * Also do nothing if our state isn't set up, which it won't be if there
980  * weren't any relevant event triggers at the start of the current DDL
981  * command. This test might therefore seem optional, but it's
982  * *necessary*, because EventTriggerCommonSetup might find triggers that
983  * didn't exist at the time the command started.
984  */
986  return;
987 
988  runlist = EventTriggerCommonSetup(parsetree,
990  "table_rewrite",
991  &trigdata);
992  if (runlist == NIL)
993  return;
994 
995  /*
996  * Make sure pg_event_trigger_table_rewrite_oid only works when running
997  * these triggers. Use PG_TRY to ensure table_rewrite_oid is reset even
998  * when one trigger fails. (This is perhaps not necessary, as the
999  * currentState variable will be removed shortly by our caller, but it
1000  * seems better to play safe.)
1001  */
1004 
1005  /* Run the triggers. */
1006  PG_TRY();
1007  {
1008  EventTriggerInvoke(runlist, &trigdata);
1009  }
1010  PG_CATCH();
1011  {
1014  PG_RE_THROW();
1015  }
1016  PG_END_TRY();
1017 
1020 
1021  /* Cleanup. */
1022  list_free(runlist);
1023 
1024  /*
1025  * Make sure anything the event triggers did will be visible to the main
1026  * command.
1027  */
1029 }
#define NIL
Definition: pg_list.h:65
static void EventTriggerInvoke(List *fn_oid_list, EventTriggerData *trigdata)
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73
static List * EventTriggerCommonSetup(Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
bool IsUnderPostmaster
Definition: globals.c:109
void CommandCounterIncrement(void)
Definition: xact.c:1003
#define InvalidOid
Definition: postgres_ext.h:36
#define PG_CATCH()
Definition: elog.h:310
#define PG_RE_THROW()
Definition: elog.h:331
void list_free(List *list)
Definition: list.c:1373
#define PG_TRY()
Definition: elog.h:301
Definition: pg_list.h:50
#define PG_END_TRY()
Definition: elog.h:317

◆ EventTriggerUndoInhibitCommandCollection()

void EventTriggerUndoInhibitCommandCollection ( void  )

Definition at line 1649 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited.

Referenced by ProcessUtilitySlow().

1650 {
1652  return;
1653 
1655 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:73

◆ get_event_trigger_oid()

Oid get_event_trigger_oid ( const char *  trigname,
bool  missing_ok 
)

Definition at line 648 of file event_trigger.c.

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

Referenced by get_object_address_unqualified().

649 {
650  Oid oid;
651 
652  oid = GetSysCacheOid1(EVENTTRIGGERNAME, Anum_pg_event_trigger_oid,
653  CStringGetDatum(trigname));
654  if (!OidIsValid(oid) && !missing_ok)
655  ereport(ERROR,
656  (errcode(ERRCODE_UNDEFINED_OBJECT),
657  errmsg("event trigger \"%s\" does not exist", trigname)));
658  return oid;
659 }
#define GetSysCacheOid1(cacheId, oidcol, key1)
Definition: syscache.h:192
int errcode(int sqlerrcode)
Definition: elog.c:570
unsigned int Oid
Definition: postgres_ext.h:31
#define OidIsValid(objectId)
Definition: c.h:638
#define ERROR
Definition: elog.h:43
#define CStringGetDatum(X)
Definition: postgres.h:578
#define ereport(elevel, rest)
Definition: elog.h:141
int errmsg(const char *fmt,...)
Definition: elog.c:784

◆ RemoveEventTriggerById()

void RemoveEventTriggerById ( Oid  trigOid)

Definition at line 482 of file event_trigger.c.

References CatalogTupleDelete(), elog, ERROR, EVENTTRIGGEROID, HeapTupleIsValid, ObjectIdGetDatum, ReleaseSysCache(), RowExclusiveLock, SearchSysCache1(), HeapTupleData::t_self, table_close(), and table_open().

Referenced by doDeletion().

483 {
484  Relation tgrel;
485  HeapTuple tup;
486 
487  tgrel = table_open(EventTriggerRelationId, RowExclusiveLock);
488 
490  if (!HeapTupleIsValid(tup))
491  elog(ERROR, "cache lookup failed for event trigger %u", trigOid);
492 
493  CatalogTupleDelete(tgrel, &tup->t_self);
494 
495  ReleaseSysCache(tup);
496 
498 }
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:133
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
Definition: indexing.c:269
#define ObjectIdGetDatum(X)
Definition: postgres.h:507
#define ERROR
Definition: elog.h:43
ItemPointerData t_self
Definition: htup.h:65
#define RowExclusiveLock
Definition: lockdefs.h:38
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Definition: syscache.c:1124
void ReleaseSysCache(HeapTuple tuple)
Definition: syscache.c:1172
#define HeapTupleIsValid(tuple)
Definition: htup.h:78
#define elog(elevel,...)
Definition: elog.h:226
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:39

◆ trackDroppedObjectsNeeded()

bool trackDroppedObjectsNeeded ( void  )

Definition at line 1299 of file event_trigger.c.

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

Referenced by deleteObjectsInList(), and EventTriggerBeginCompleteQuery().

1300 {
1301  /*
1302  * true if any sql_drop, table_rewrite, ddl_command_end event trigger
1303  * exists
1304  */
1305  return list_length(EventCacheLookup(EVT_SQLDrop)) > 0 ||
1308 }
static int list_length(const List *l)
Definition: pg_list.h:169
List * EventCacheLookup(EventTriggerEvent event)
Definition: evtcache.c:64