PostgreSQL Source Code  git master
event_trigger.c File Reference
#include "postgres.h"
#include "access/htup_details.h"
#include "access/xact.h"
#include "catalog/dependency.h"
#include "catalog/indexing.h"
#include "catalog/objectaccess.h"
#include "catalog/pg_event_trigger.h"
#include "catalog/pg_namespace.h"
#include "catalog/pg_opclass.h"
#include "catalog/pg_opfamily.h"
#include "catalog/pg_proc.h"
#include "catalog/pg_trigger.h"
#include "catalog/pg_ts_config.h"
#include "catalog/pg_type.h"
#include "commands/dbcommands.h"
#include "commands/event_trigger.h"
#include "commands/extension.h"
#include "commands/trigger.h"
#include "funcapi.h"
#include "parser/parse_func.h"
#include "pgstat.h"
#include "lib/ilist.h"
#include "miscadmin.h"
#include "tcop/deparse_utility.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/evtcache.h"
#include "utils/fmgroids.h"
#include "utils/lsyscache.h"
#include "utils/memutils.h"
#include "utils/rel.h"
#include "utils/tqual.h"
#include "utils/syscache.h"
#include "tcop/utility.h"
Include dependency graph for event_trigger.c:

Go to the source code of this file.

Data Structures

struct  EventTriggerQueryState
 
struct  event_trigger_support_data
 
struct  SQLDropObject
 

Typedefs

typedef struct EventTriggerQueryState EventTriggerQueryState
 
typedef struct SQLDropObject SQLDropObject
 

Enumerations

enum  event_trigger_command_tag_check_result { EVENT_TRIGGER_COMMAND_TAG_OK, EVENT_TRIGGER_COMMAND_TAG_NOT_SUPPORTED, EVENT_TRIGGER_COMMAND_TAG_NOT_RECOGNIZED }
 

Functions

static void AlterEventTriggerOwner_internal (Relation rel, HeapTuple tup, Oid newOwnerId)
 
static event_trigger_command_tag_check_result check_ddl_tag (const char *tag)
 
static event_trigger_command_tag_check_result check_table_rewrite_ddl_tag (const char *tag)
 
static void error_duplicate_filter_variable (const char *defname)
 
static Datum filter_list_to_array (List *filterlist)
 
static Oid insert_event_trigger_tuple (const char *trigname, const char *eventname, Oid evtOwner, Oid funcoid, List *tags)
 
static void validate_ddl_tags (const char *filtervar, List *taglist)
 
static void validate_table_rewrite_tags (const char *filtervar, List *taglist)
 
static void EventTriggerInvoke (List *fn_oid_list, EventTriggerData *trigdata)
 
static const char * stringify_grantobjtype (GrantObjectType objtype)
 
static const char * stringify_adefprivs_objtype (GrantObjectType objtype)
 
Oid CreateEventTrigger (CreateEventTrigStmt *stmt)
 
void RemoveEventTriggerById (Oid trigOid)
 
Oid AlterEventTrigger (AlterEventTrigStmt *stmt)
 
ObjectAddress AlterEventTriggerOwner (const char *name, Oid newOwnerId)
 
void AlterEventTriggerOwner_oid (Oid trigOid, Oid newOwnerId)
 
Oid get_event_trigger_oid (const char *trigname, bool missing_ok)
 
static bool filter_event_trigger (const char **tag, EventTriggerCacheItem *item)
 
static ListEventTriggerCommonSetup (Node *parsetree, EventTriggerEvent event, const char *eventstr, EventTriggerData *trigdata)
 
void EventTriggerDDLCommandStart (Node *parsetree)
 
void EventTriggerDDLCommandEnd (Node *parsetree)
 
void EventTriggerSQLDrop (Node *parsetree)
 
void EventTriggerTableRewrite (Node *parsetree, Oid tableOid, int reason)
 
bool EventTriggerSupportsObjectType (ObjectType obtype)
 
bool EventTriggerSupportsObjectClass (ObjectClass objclass)
 
bool EventTriggerSupportsGrantObjectType (GrantObjectType objtype)
 
bool EventTriggerBeginCompleteQuery (void)
 
void EventTriggerEndCompleteQuery (void)
 
bool trackDroppedObjectsNeeded (void)
 
void EventTriggerSQLDropAddObject (const ObjectAddress *object, bool original, bool normal)
 
Datum pg_event_trigger_dropped_objects (PG_FUNCTION_ARGS)
 
Datum pg_event_trigger_table_rewrite_oid (PG_FUNCTION_ARGS)
 
Datum pg_event_trigger_table_rewrite_reason (PG_FUNCTION_ARGS)
 
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)
 
Datum pg_event_trigger_ddl_commands (PG_FUNCTION_ARGS)
 

Variables

static EventTriggerQueryStatecurrentEventTriggerState = NULL
 
static event_trigger_support_data event_trigger_support []
 

Typedef Documentation

◆ EventTriggerQueryState

◆ SQLDropObject

Enumeration Type Documentation

◆ event_trigger_command_tag_check_result

Enumerator
EVENT_TRIGGER_COMMAND_TAG_OK 
EVENT_TRIGGER_COMMAND_TAG_NOT_SUPPORTED 
EVENT_TRIGGER_COMMAND_TAG_NOT_RECOGNIZED 

Definition at line 80 of file event_trigger.c.

Function Documentation

◆ AlterEventTrigger()

Oid AlterEventTrigger ( AlterEventTrigStmt stmt)

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

502 {
503  Relation tgrel;
504  HeapTuple tup;
505  Oid trigoid;
506  Form_pg_event_trigger evtForm;
507  char tgenabled = stmt->tgenabled;
508 
510 
512  CStringGetDatum(stmt->trigname));
513  if (!HeapTupleIsValid(tup))
514  ereport(ERROR,
515  (errcode(ERRCODE_UNDEFINED_OBJECT),
516  errmsg("event trigger \"%s\" does not exist",
517  stmt->trigname)));
518 
519  trigoid = HeapTupleGetOid(tup);
520 
521  if (!pg_event_trigger_ownercheck(trigoid, GetUserId()))
523  stmt->trigname);
524 
525  /* tuple is a copy, so we can modify it below */
526  evtForm = (Form_pg_event_trigger) GETSTRUCT(tup);
527  evtForm->evtenabled = tgenabled;
528 
529  CatalogTupleUpdate(tgrel, &tup->t_self, tup);
530 
532  trigoid, 0);
533 
534  /* clean up */
535  heap_freetuple(tup);
537 
538  return trigoid;
539 }
#define GETSTRUCT(TUP)
Definition: htup_details.h:661
Oid GetUserId(void)
Definition: miscinit.c:284
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:1373
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:4995
ItemPointerData t_self
Definition: htup.h:65
void aclcheck_error(AclResult aclerr, AclObjectKind objectkind, const char *objectname)
Definition: aclchk.c:3457
#define RowExclusiveLock
Definition: lockdefs.h:38
#define CStringGetDatum(X)
Definition: postgres.h:584
#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:1290
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:173
int errmsg(const char *fmt,...)
Definition: elog.c:797
#define HeapTupleGetOid(tuple)
Definition: htup_details.h:700

◆ AlterEventTriggerOwner()

ObjectAddress AlterEventTriggerOwner ( const char *  name,
Oid  newOwnerId 
)

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

546 {
547  Oid evtOid;
548  HeapTuple tup;
549  Relation rel;
550  ObjectAddress address;
551 
553 
555 
556  if (!HeapTupleIsValid(tup))
557  ereport(ERROR,
558  (errcode(ERRCODE_UNDEFINED_OBJECT),
559  errmsg("event trigger \"%s\" does not exist", name)));
560 
561  evtOid = HeapTupleGetOid(tup);
562 
563  AlterEventTriggerOwner_internal(rel, tup, newOwnerId);
564 
565  ObjectAddressSet(address, EventTriggerRelationId, evtOid);
566 
567  heap_freetuple(tup);
568 
570 
571  return address;
572 }
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:1373
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:584
#define ereport(elevel, rest)
Definition: elog.h:122
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1290
#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:173
int errmsg(const char *fmt,...)
Definition: elog.c:797
#define HeapTupleGetOid(tuple)
Definition: htup_details.h:700

◆ AlterEventTriggerOwner_internal()

static void AlterEventTriggerOwner_internal ( Relation  rel,
HeapTuple  tup,
Oid  newOwnerId 
)
static

Definition at line 603 of file event_trigger.c.

References ACL_KIND_EVENT_TRIGGER, aclcheck_error(), ACLCHECK_NOT_OWNER, CatalogTupleUpdate(), changeDependencyOnOwner(), ereport, errcode(), errhint(), errmsg(), ERROR, EventTriggerRelationId, GETSTRUCT, GetUserId(), HeapTupleGetOid, InvokeObjectPostAlterHook, NameStr, pg_event_trigger_ownercheck(), superuser_arg(), and HeapTupleData::t_self.

Referenced by AlterEventTriggerOwner(), and AlterEventTriggerOwner_oid().

604 {
606 
607  form = (Form_pg_event_trigger) GETSTRUCT(tup);
608 
609  if (form->evtowner == newOwnerId)
610  return;
611 
614  NameStr(form->evtname));
615 
616  /* New owner must be a superuser */
617  if (!superuser_arg(newOwnerId))
618  ereport(ERROR,
619  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
620  errmsg("permission denied to change owner of event trigger \"%s\"",
621  NameStr(form->evtname)),
622  errhint("The owner of an event trigger must be a superuser.")));
623 
624  form->evtowner = newOwnerId;
625  CatalogTupleUpdate(rel, &tup->t_self, tup);
626 
627  /* Update owner dependency reference */
629  HeapTupleGetOid(tup),
630  newOwnerId);
631 
633  HeapTupleGetOid(tup), 0);
634 }
int errhint(const char *fmt,...)
Definition: elog.c:987
#define GETSTRUCT(TUP)
Definition: htup_details.h:661
Oid GetUserId(void)
Definition: miscinit.c:284
int errcode(int sqlerrcode)
Definition: elog.c:575
void changeDependencyOnOwner(Oid classId, Oid objectId, Oid newOwnerId)
Definition: pg_shdepend.c:304
#define ERROR
Definition: elog.h:43
bool pg_event_trigger_ownercheck(Oid et_oid, Oid roleid)
Definition: aclchk.c:4995
ItemPointerData t_self
Definition: htup.h:65
void aclcheck_error(AclResult aclerr, AclObjectKind objectkind, const char *objectname)
Definition: aclchk.c:3457
#define ereport(elevel, rest)
Definition: elog.h:122
#define InvokeObjectPostAlterHook(classId, objectId, subId)
Definition: objectaccess.h:163
bool superuser_arg(Oid roleid)
Definition: superuser.c:57
FormData_pg_event_trigger * Form_pg_event_trigger
#define EventTriggerRelationId
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
Definition: indexing.c:210
int errmsg(const char *fmt,...)
Definition: elog.c:797
#define NameStr(name)
Definition: c.h:557
#define HeapTupleGetOid(tuple)
Definition: htup_details.h:700

◆ AlterEventTriggerOwner_oid()

void AlterEventTriggerOwner_oid ( Oid  trigOid,
Oid  newOwnerId 
)

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

579 {
580  HeapTuple tup;
581  Relation rel;
582 
584 
586 
587  if (!HeapTupleIsValid(tup))
588  ereport(ERROR,
589  (errcode(ERRCODE_UNDEFINED_OBJECT),
590  errmsg("event trigger with OID %u does not exist", trigOid)));
591 
592  AlterEventTriggerOwner_internal(rel, tup, newOwnerId);
593 
594  heap_freetuple(tup);
595 
597 }
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:1373
static void AlterEventTriggerOwner_internal(Relation rel, HeapTuple tup, Oid newOwnerId)
#define ObjectIdGetDatum(X)
Definition: postgres.h:513
#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:1290
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EventTriggerRelationId
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:173
int errmsg(const char *fmt,...)
Definition: elog.c:797

◆ check_ddl_tag()

static event_trigger_command_tag_check_result check_ddl_tag ( const char *  tag)
static

Definition at line 282 of file event_trigger.c.

References EVENT_TRIGGER_COMMAND_TAG_NOT_RECOGNIZED, EVENT_TRIGGER_COMMAND_TAG_NOT_SUPPORTED, EVENT_TRIGGER_COMMAND_TAG_OK, event_trigger_support_data::obtypename, pg_strcasecmp(), pg_strncasecmp(), and event_trigger_support_data::supported.

Referenced by EventTriggerCommonSetup(), and validate_ddl_tags().

283 {
284  const char *obtypename;
286 
287  /*
288  * Handle some idiosyncratic special cases.
289  */
290  if (pg_strcasecmp(tag, "CREATE TABLE AS") == 0 ||
291  pg_strcasecmp(tag, "SELECT INTO") == 0 ||
292  pg_strcasecmp(tag, "REFRESH MATERIALIZED VIEW") == 0 ||
293  pg_strcasecmp(tag, "ALTER DEFAULT PRIVILEGES") == 0 ||
294  pg_strcasecmp(tag, "ALTER LARGE OBJECT") == 0 ||
295  pg_strcasecmp(tag, "COMMENT") == 0 ||
296  pg_strcasecmp(tag, "GRANT") == 0 ||
297  pg_strcasecmp(tag, "REVOKE") == 0 ||
298  pg_strcasecmp(tag, "DROP OWNED") == 0 ||
299  pg_strcasecmp(tag, "IMPORT FOREIGN SCHEMA") == 0 ||
300  pg_strcasecmp(tag, "SECURITY LABEL") == 0)
302 
303  /*
304  * Otherwise, command should be CREATE, ALTER, or DROP.
305  */
306  if (pg_strncasecmp(tag, "CREATE ", 7) == 0)
307  obtypename = tag + 7;
308  else if (pg_strncasecmp(tag, "ALTER ", 6) == 0)
309  obtypename = tag + 6;
310  else if (pg_strncasecmp(tag, "DROP ", 5) == 0)
311  obtypename = tag + 5;
312  else
314 
315  /*
316  * ...and the object type should be something recognizable.
317  */
318  for (etsd = event_trigger_support; etsd->obtypename != NULL; etsd++)
319  if (pg_strcasecmp(etsd->obtypename, obtypename) == 0)
320  break;
321  if (etsd->obtypename == NULL)
323  if (!etsd->supported)
326 }
int pg_strcasecmp(const char *s1, const char *s2)
Definition: pgstrcasecmp.c:36
int pg_strncasecmp(const char *s1, const char *s2, size_t n)
Definition: pgstrcasecmp.c:69
static event_trigger_support_data event_trigger_support[]
Definition: event_trigger.c:88

◆ check_table_rewrite_ddl_tag()

static event_trigger_command_tag_check_result check_table_rewrite_ddl_tag ( const char *  tag)
static

Definition at line 352 of file event_trigger.c.

References EVENT_TRIGGER_COMMAND_TAG_NOT_SUPPORTED, EVENT_TRIGGER_COMMAND_TAG_OK, and pg_strcasecmp().

Referenced by EventTriggerCommonSetup(), and validate_table_rewrite_tags().

353 {
354  if (pg_strcasecmp(tag, "ALTER TABLE") == 0 ||
355  pg_strcasecmp(tag, "ALTER TYPE") == 0)
357 
359 }
int pg_strcasecmp(const char *s1, const char *s2)
Definition: pgstrcasecmp.c:36

◆ 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, EVTTRIGGEROID, 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:987
Oid GetUserId(void)
Definition: miscinit.c:284
int errcode(int sqlerrcode)
Definition: elog.c:575
bool superuser(void)
Definition: superuser.c:47
unsigned int Oid
Definition: postgres_ext.h:31
Oid get_func_rettype(Oid funcid)
Definition: lsyscache.c:1459
#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:584
#define ereport(elevel, rest)
Definition: elog.h:122
Node * arg
Definition: parsenodes.h:720
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Definition: syscache.c:1112
char * NameListToString(List *names)
Definition: namespace.c:3063
static Oid insert_event_trigger_tuple(const char *trigname, const char *eventname, Oid evtOwner, Oid funcoid, List *tags)
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EVTTRIGGEROID
Definition: pg_type.h:694
#define lfirst(lc)
Definition: pg_list.h:106
Oid LookupFuncName(List *funcname, int nargs, const Oid *argtypes, bool noError)
Definition: parse_func.c:1961
int errmsg(const char *fmt,...)
Definition: elog.c:797
char * defname
Definition: parsenodes.h:719
#define ERRCODE_DUPLICATE_OBJECT
Definition: streamutil.c:30
Definition: pg_list.h:45

◆ error_duplicate_filter_variable()

static void error_duplicate_filter_variable ( const char *  defname)
static

Definition at line 365 of file event_trigger.c.

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

Referenced by CreateEventTrigger().

366 {
367  ereport(ERROR,
368  (errcode(ERRCODE_SYNTAX_ERROR),
369  errmsg("filter variable \"%s\" specified more than once",
370  defname)));
371 }
int errcode(int sqlerrcode)
Definition: elog.c:575
#define ERROR
Definition: elog.h:43
#define ereport(elevel, rest)
Definition: elog.h:122
int errmsg(const char *fmt,...)
Definition: elog.c:797

◆ EventTriggerAlterTableEnd()

void EventTriggerAlterTableEnd ( void  )

Definition at line 1804 of file event_trigger.c.

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

Referenced by AlterTableMoveAll(), and ProcessUtilitySlow().

1805 {
1806  /* ignore if event trigger context not set, or collection disabled */
1807  if (!currentEventTriggerState ||
1809  return;
1810 
1811  /* If no subcommands, don't collect */
1813  {
1817  }
1818  else
1820 
1822 }
union CollectedCommand::@111 d
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
void pfree(void *pointer)
Definition: mcxt.c:936
CollectedCommand * currentCommand
Definition: event_trigger.c:66
List * lappend(List *list, void *datum)
Definition: list.c:128
static int list_length(const List *l)
Definition: pg_list.h:89
struct CollectedCommand::@111::@113 alterTable

◆ EventTriggerAlterTableRelid()

void EventTriggerAlterTableRelid ( Oid  objectId)

Definition at line 1752 of file event_trigger.c.

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

Referenced by AlterTableInternal(), and ProcessUtilitySlow().

1753 {
1754  if (!currentEventTriggerState ||
1756  return;
1757 
1758  currentEventTriggerState->currentCommand->d.alterTable.objectId = objectId;
1759 }
union CollectedCommand::@111 d
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
CollectedCommand * currentCommand
Definition: event_trigger.c:66
struct CollectedCommand::@111::@113 alterTable

◆ EventTriggerAlterTableStart()

void EventTriggerAlterTableStart ( Node parsetree)

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

1720 {
1721  MemoryContext oldcxt;
1722  CollectedCommand *command;
1723 
1724  /* ignore if event trigger context not set, or collection disabled */
1725  if (!currentEventTriggerState ||
1727  return;
1728 
1730 
1731  command = palloc(sizeof(CollectedCommand));
1732 
1733  command->type = SCT_AlterTable;
1734  command->in_extension = creating_extension;
1735 
1736  command->d.alterTable.classId = RelationRelationId;
1737  command->d.alterTable.objectId = InvalidOid;
1738  command->d.alterTable.subcmds = NIL;
1739  command->parsetree = copyObject(parsetree);
1740 
1742 
1743  MemoryContextSwitchTo(oldcxt);
1744 }
#define NIL
Definition: pg_list.h:69
union CollectedCommand::@111 d
#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
CollectedCommand * currentCommand
Definition: event_trigger.c:66
#define InvalidOid
Definition: postgres_ext.h:36
bool creating_extension
Definition: extension.c:67
struct CollectedCommand::@111::@113 alterTable
void * palloc(Size size)
Definition: mcxt.c:835
#define copyObject(obj)
Definition: nodes.h:625

◆ EventTriggerBeginCompleteQuery()

bool EventTriggerBeginCompleteQuery ( void  )

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

1245 {
1247  MemoryContext cxt;
1248 
1249  /*
1250  * Currently, sql_drop, table_rewrite, ddl_command_end events are the only
1251  * reason to have event trigger state at all; so if there are none, don't
1252  * install one.
1253  */
1255  return false;
1256 
1258  "event trigger state",
1260  state = MemoryContextAlloc(cxt, sizeof(EventTriggerQueryState));
1261  state->cxt = cxt;
1262  slist_init(&(state->SQLDropList));
1263  state->in_sql_drop = false;
1264  state->table_rewrite_oid = InvalidOid;
1265 
1268  state->currentCommand = NULL;
1269  state->commandList = NIL;
1271  currentEventTriggerState = state;
1272 
1273  return true;
1274 }
#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:197
CollectedCommand * currentCommand
Definition: event_trigger.c:66
struct EventTriggerQueryState * previous
Definition: event_trigger.c:69
MemoryContext TopMemoryContext
Definition: mcxt.c:43
#define AllocSetContextCreate(parent, name, allocparams)
Definition: memutils.h:165
#define InvalidOid
Definition: postgres_ext.h:36
Definition: regguts.h:298
void * MemoryContextAlloc(MemoryContext context, Size size)
Definition: mcxt.c:693

◆ EventTriggerCollectAlterDefPrivs()

void EventTriggerCollectAlterDefPrivs ( AlterDefaultPrivilegesStmt stmt)

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

1979 {
1980  MemoryContext oldcxt;
1981  CollectedCommand *command;
1982 
1983  /* ignore if event trigger context not set, or collection disabled */
1984  if (!currentEventTriggerState ||
1986  return;
1987 
1989 
1990  command = palloc0(sizeof(CollectedCommand));
1991  command->type = SCT_AlterDefaultPrivileges;
1992  command->d.defprivs.objtype = stmt->action->objtype;
1993  command->in_extension = creating_extension;
1994  command->parsetree = (Node *) copyObject(stmt);
1995 
1998  MemoryContextSwitchTo(oldcxt);
1999 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:512
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
struct CollectedCommand::@111::@118 defprivs
List * lappend(List *list, void *datum)
Definition: list.c:128
void * palloc0(Size size)
Definition: mcxt.c:864
bool creating_extension
Definition: extension.c:67
GrantObjectType objtype
Definition: parsenodes.h:1872
#define copyObject(obj)
Definition: nodes.h:625

◆ EventTriggerCollectAlterOpFam()

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

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

1878 {
1879  MemoryContext oldcxt;
1880  CollectedCommand *command;
1881 
1882  /* ignore if event trigger context not set, or collection disabled */
1883  if (!currentEventTriggerState ||
1885  return;
1886 
1888 
1889  command = palloc(sizeof(CollectedCommand));
1890  command->type = SCT_AlterOpFamily;
1891  command->in_extension = creating_extension;
1892  ObjectAddressSet(command->d.opfam.address,
1893  OperatorFamilyRelationId, opfamoid);
1894  command->d.opfam.operators = operators;
1895  command->d.opfam.procedures = procedures;
1896  command->parsetree = (Node *) copyObject(stmt);
1897 
1900 
1901  MemoryContextSwitchTo(oldcxt);
1902 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:512
#define OperatorFamilyRelationId
Definition: pg_opfamily.h:29
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
List * lappend(List *list, void *datum)
Definition: list.c:128
bool creating_extension
Definition: extension.c:67
struct CollectedCommand::@111::@115 opfam
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void * palloc(Size size)
Definition: mcxt.c:835
#define copyObject(obj)
Definition: nodes.h:625

◆ EventTriggerCollectAlterTableSubcmd()

void EventTriggerCollectAlterTableSubcmd ( Node subcmd,
ObjectAddress  address 
)

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

1771 {
1772  MemoryContext oldcxt;
1774 
1775  /* ignore if event trigger context not set, or collection disabled */
1776  if (!currentEventTriggerState ||
1778  return;
1779 
1780  Assert(IsA(subcmd, AlterTableCmd));
1782 
1784 
1785  newsub = palloc(sizeof(CollectedATSubcmd));
1786  newsub->address = address;
1787  newsub->parsetree = copyObject(subcmd);
1788 
1791 
1792  MemoryContextSwitchTo(oldcxt);
1793 }
union CollectedCommand::@111 d
#define IsA(nodeptr, _type_)
Definition: nodes.h:563
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define OidIsValid(objectId)
Definition: c.h:586
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
CollectedCommand * currentCommand
Definition: event_trigger.c:66
List * lappend(List *list, void *datum)
Definition: list.c:128
#define Assert(condition)
Definition: c.h:680
struct CollectedCommand::@111::@113 alterTable
void * palloc(Size size)
Definition: mcxt.c:835
#define copyObject(obj)
Definition: nodes.h:625
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 1943 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().

1945 {
1946  MemoryContext oldcxt;
1947  CollectedCommand *command;
1948 
1949  /* ignore if event trigger context not set, or collection disabled */
1950  if (!currentEventTriggerState ||
1952  return;
1953 
1955 
1956  command = palloc0(sizeof(CollectedCommand));
1957  command->type = SCT_AlterTSConfig;
1958  command->in_extension = creating_extension;
1959  ObjectAddressSet(command->d.atscfg.address,
1960  TSConfigRelationId, cfgId);
1961  command->d.atscfg.dictIds = palloc(sizeof(Oid) * ndicts);
1962  memcpy(command->d.atscfg.dictIds, dictIds, sizeof(Oid) * ndicts);
1963  command->d.atscfg.ndicts = ndicts;
1964  command->parsetree = (Node *) copyObject(stmt);
1965 
1968 
1969  MemoryContextSwitchTo(oldcxt);
1970 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:512
CollectedCommandType type
unsigned int Oid
Definition: postgres_ext.h:31
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
#define TSConfigRelationId
Definition: pg_ts_config.h:31
struct CollectedCommand::@111::@117 atscfg
List * lappend(List *list, void *datum)
Definition: list.c:128
void * palloc0(Size size)
Definition: mcxt.c:864
bool creating_extension
Definition: extension.c:67
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void * palloc(Size size)
Definition: mcxt.c:835
#define copyObject(obj)
Definition: nodes.h:625

◆ EventTriggerCollectCreateOpClass()

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

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

1911 {
1912  MemoryContext oldcxt;
1913  CollectedCommand *command;
1914 
1915  /* ignore if event trigger context not set, or collection disabled */
1916  if (!currentEventTriggerState ||
1918  return;
1919 
1921 
1922  command = palloc0(sizeof(CollectedCommand));
1923  command->type = SCT_CreateOpClass;
1924  command->in_extension = creating_extension;
1925  ObjectAddressSet(command->d.createopc.address,
1926  OperatorClassRelationId, opcoid);
1927  command->d.createopc.operators = operators;
1928  command->d.createopc.procedures = procedures;
1929  command->parsetree = (Node *) copyObject(stmt);
1930 
1933 
1934  MemoryContextSwitchTo(oldcxt);
1935 }
union CollectedCommand::@111 d
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define OperatorClassRelationId
Definition: pg_opclass.h:49
Definition: nodes.h:512
CollectedCommandType type
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
struct CollectedCommand::@111::@116 createopc
List * lappend(List *list, void *datum)
Definition: list.c:128
void * palloc0(Size size)
Definition: mcxt.c:864
bool creating_extension
Definition: extension.c:67
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
#define copyObject(obj)
Definition: nodes.h:625

◆ EventTriggerCollectGrant()

void EventTriggerCollectGrant ( InternalGrant istmt)

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

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

◆ EventTriggerCollectSimpleCommand()

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

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

1679 {
1680  MemoryContext oldcxt;
1681  CollectedCommand *command;
1682 
1683  /* ignore if event trigger context not set, or collection disabled */
1684  if (!currentEventTriggerState ||
1686  return;
1687 
1689 
1690  command = palloc(sizeof(CollectedCommand));
1691 
1692  command->type = SCT_Simple;
1693  command->in_extension = creating_extension;
1694 
1695  command->d.simple.address = address;
1696  command->d.simple.secondaryObject = secondaryObject;
1697  command->parsetree = copyObject(parsetree);
1698 
1700  command);
1701 
1702  MemoryContextSwitchTo(oldcxt);
1703 }
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:72
List * lappend(List *list, void *datum)
Definition: list.c:128
bool creating_extension
Definition: extension.c:67
void * palloc(Size size)
Definition: mcxt.c:835
#define copyObject(obj)
Definition: nodes.h:625

◆ EventTriggerCommonSetup()

static List* EventTriggerCommonSetup ( Node parsetree,
EventTriggerEvent  event,
const char *  eventstr,
EventTriggerData trigdata 
)
static

Definition at line 694 of file event_trigger.c.

References check_ddl_tag(), check_table_rewrite_ddl_tag(), CreateCommandTag(), elog, ERROR, EventTriggerData::event, EVENT_TRIGGER_COMMAND_TAG_OK, EventCacheLookup(), EVT_DDLCommandEnd, EVT_DDLCommandStart, EVT_SQLDrop, EVT_TableRewrite, filter_event_trigger(), EventTriggerCacheItem::fnoid, lappend_oid(), lfirst, NIL, EventTriggerData::parsetree, T_EventTriggerData, EventTriggerData::tag, and EventTriggerData::type.

Referenced by EventTriggerDDLCommandEnd(), EventTriggerDDLCommandStart(), EventTriggerSQLDrop(), and EventTriggerTableRewrite().

697 {
698  const char *tag;
699  List *cachelist;
700  ListCell *lc;
701  List *runlist = NIL;
702 
703  /*
704  * We want the list of command tags for which this procedure is actually
705  * invoked to match up exactly with the list that CREATE EVENT TRIGGER
706  * accepts. This debugging cross-check will throw an error if this
707  * function is invoked for a command tag that CREATE EVENT TRIGGER won't
708  * accept. (Unfortunately, there doesn't seem to be any simple, automated
709  * way to verify that CREATE EVENT TRIGGER doesn't accept extra stuff that
710  * never reaches this control point.)
711  *
712  * If this cross-check fails for you, you probably need to either adjust
713  * standard_ProcessUtility() not to invoke event triggers for the command
714  * type in question, or you need to adjust check_ddl_tag to accept the
715  * relevant command tag.
716  */
717 #ifdef USE_ASSERT_CHECKING
718  {
719  const char *dbgtag;
720 
721  dbgtag = CreateCommandTag(parsetree);
722  if (event == EVT_DDLCommandStart ||
723  event == EVT_DDLCommandEnd ||
724  event == EVT_SQLDrop)
725  {
727  elog(ERROR, "unexpected command tag \"%s\"", dbgtag);
728  }
729  else if (event == EVT_TableRewrite)
730  {
732  elog(ERROR, "unexpected command tag \"%s\"", dbgtag);
733  }
734  }
735 #endif
736 
737  /* Use cache to find triggers for this event; fast exit if none. */
738  cachelist = EventCacheLookup(event);
739  if (cachelist == NIL)
740  return NIL;
741 
742  /* Get the command tag. */
743  tag = CreateCommandTag(parsetree);
744 
745  /*
746  * Filter list of event triggers by command tag, and copy them into our
747  * memory context. Once we start running the command triggers, or indeed
748  * once we do anything at all that touches the catalogs, an invalidation
749  * might leave cachelist pointing at garbage, so we must do this before we
750  * can do much else.
751  */
752  foreach(lc, cachelist)
753  {
754  EventTriggerCacheItem *item = lfirst(lc);
755 
756  if (filter_event_trigger(&tag, item))
757  {
758  /* We must plan to fire this trigger. */
759  runlist = lappend_oid(runlist, item->fnoid);
760  }
761  }
762 
763  /* don't spend any more time on this if no functions to run */
764  if (runlist == NIL)
765  return NIL;
766 
767  trigdata->type = T_EventTriggerData;
768  trigdata->event = eventstr;
769  trigdata->parsetree = parsetree;
770  trigdata->tag = tag;
771 
772  return runlist;
773 }
#define NIL
Definition: pg_list.h:69
const char * tag
Definition: event_trigger.h:28
List * lappend_oid(List *list, Oid datum)
Definition: list.c:164
static event_trigger_command_tag_check_result check_ddl_tag(const char *tag)
static bool filter_event_trigger(const char **tag, EventTriggerCacheItem *item)
#define ERROR
Definition: elog.h:43
static event_trigger_command_tag_check_result check_table_rewrite_ddl_tag(const char *tag)
const char * event
Definition: event_trigger.h:26
const char * CreateCommandTag(Node *parsetree)
Definition: utility.c:2046
#define lfirst(lc)
Definition: pg_list.h:106
List * EventCacheLookup(EventTriggerEvent event)
Definition: evtcache.c:64
#define elog
Definition: elog.h:219
Definition: pg_list.h:45

◆ EventTriggerDDLCommandEnd()

void EventTriggerDDLCommandEnd ( Node parsetree)

Definition at line 827 of file event_trigger.c.

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

Referenced by ProcessUtilitySlow().

828 {
829  List *runlist;
830  EventTriggerData trigdata;
831 
832  /*
833  * See EventTriggerDDLCommandStart for a discussion about why event
834  * triggers are disabled in single user mode.
835  */
836  if (!IsUnderPostmaster)
837  return;
838 
839  runlist = EventTriggerCommonSetup(parsetree,
840  EVT_DDLCommandEnd, "ddl_command_end",
841  &trigdata);
842  if (runlist == NIL)
843  return;
844 
845  /*
846  * Make sure anything the main command did will be visible to the event
847  * triggers.
848  */
850 
851  /* Run the triggers. */
852  EventTriggerInvoke(runlist, &trigdata);
853 
854  /* Cleanup. */
855  list_free(runlist);
856 }
#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:101
void CommandCounterIncrement(void)
Definition: xact.c:915
void list_free(List *list)
Definition: list.c:1133
Definition: pg_list.h:45

◆ EventTriggerDDLCommandStart()

void EventTriggerDDLCommandStart ( Node parsetree)

Definition at line 779 of file event_trigger.c.

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

Referenced by ProcessUtilitySlow().

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

◆ EventTriggerEndCompleteQuery()

void EventTriggerEndCompleteQuery ( void  )

Definition at line 1288 of file event_trigger.c.

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

Referenced by ProcessUtilitySlow().

1289 {
1290  EventTriggerQueryState *prevstate;
1291 
1292  prevstate = currentEventTriggerState->previous;
1293 
1294  /* this avoids the need for retail pfree of SQLDropList items: */
1296 
1297  currentEventTriggerState = prevstate;
1298 }
void MemoryContextDelete(MemoryContext context)
Definition: mcxt.c:198
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
struct EventTriggerQueryState * previous
Definition: event_trigger.c:69

◆ EventTriggerInhibitCommandCollection()

void EventTriggerInhibitCommandCollection ( void  )

Definition at line 1642 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited.

Referenced by ProcessUtilitySlow().

1643 {
1645  return;
1646 
1648 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72

◆ EventTriggerInvoke()

static void EventTriggerInvoke ( List fn_oid_list,
EventTriggerData trigdata 
)
static

Definition at line 1007 of file event_trigger.c.

References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, check_stack_depth(), CommandCounterIncrement(), CurrentMemoryContext, DEBUG1, elog, fmgr_info(), FunctionCallInvoke, InitFunctionCallInfoData, InvalidOid, lfirst_oid, MemoryContextDelete(), MemoryContextReset(), MemoryContextSwitchTo(), pgstat_end_function_usage(), and pgstat_init_function_usage().

Referenced by EventTriggerDDLCommandEnd(), EventTriggerDDLCommandStart(), EventTriggerSQLDrop(), and EventTriggerTableRewrite().

1008 {
1009  MemoryContext context;
1010  MemoryContext oldcontext;
1011  ListCell *lc;
1012  bool first = true;
1013 
1014  /* Guard against stack overflow due to recursive event trigger */
1016 
1017  /*
1018  * Let's evaluate event triggers in their own memory context, so that any
1019  * leaks get cleaned up promptly.
1020  */
1022  "event trigger context",
1024  oldcontext = MemoryContextSwitchTo(context);
1025 
1026  /* Call each event trigger. */
1027  foreach(lc, fn_oid_list)
1028  {
1029  Oid fnoid = lfirst_oid(lc);
1030  FmgrInfo flinfo;
1031  FunctionCallInfoData fcinfo;
1032  PgStat_FunctionCallUsage fcusage;
1033 
1034  elog(DEBUG1, "EventTriggerInvoke %u", fnoid);
1035 
1036  /*
1037  * We want each event trigger to be able to see the results of the
1038  * previous event trigger's action. Caller is responsible for any
1039  * command-counter increment that is needed between the event trigger
1040  * and anything else in the transaction.
1041  */
1042  if (first)
1043  first = false;
1044  else
1046 
1047  /* Look up the function */
1048  fmgr_info(fnoid, &flinfo);
1049 
1050  /* Call the function, passing no arguments but setting a context. */
1051  InitFunctionCallInfoData(fcinfo, &flinfo, 0,
1052  InvalidOid, (Node *) trigdata, NULL);
1053  pgstat_init_function_usage(&fcinfo, &fcusage);
1054  FunctionCallInvoke(&fcinfo);
1055  pgstat_end_function_usage(&fcusage, true);
1056 
1057  /* Reclaim memory. */
1058  MemoryContextReset(context);
1059  }
1060 
1061  /* Restore old memory context and delete the temporary one. */
1062  MemoryContextSwitchTo(oldcontext);
1063  MemoryContextDelete(context);
1064 }
Definition: fmgr.h:56
void MemoryContextDelete(MemoryContext context)
Definition: mcxt.c:198
#define DEBUG1
Definition: elog.h:25
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
Definition: nodes.h:512
void MemoryContextReset(MemoryContext context)
Definition: mcxt.c:134
unsigned int Oid
Definition: postgres_ext.h:31
void fmgr_info(Oid functionId, FmgrInfo *finfo)
Definition: fmgr.c:122
#define ALLOCSET_DEFAULT_SIZES
Definition: memutils.h:197
#define FunctionCallInvoke(fcinfo)
Definition: fmgr.h:137
void check_stack_depth(void)
Definition: postgres.c:3154
MemoryContext CurrentMemoryContext
Definition: mcxt.c:37
#define AllocSetContextCreate(parent, name, allocparams)
Definition: memutils.h:165
void CommandCounterIncrement(void)
Definition: xact.c:915
#define InvalidOid
Definition: postgres_ext.h:36
#define InitFunctionCallInfoData(Fcinfo, Flinfo, Nargs, Collation, Context, Resultinfo)
Definition: fmgr.h:120
void pgstat_end_function_usage(PgStat_FunctionCallUsage *fcu, bool finalize)
Definition: pgstat.c:1653
void pgstat_init_function_usage(FunctionCallInfoData *fcinfo, PgStat_FunctionCallUsage *fcu)
Definition: pgstat.c:1581
#define elog
Definition: elog.h:219
#define lfirst_oid(lc)
Definition: pg_list.h:108

◆ EventTriggerSQLDrop()

void EventTriggerSQLDrop ( Node parsetree)

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

863 {
864  List *runlist;
865  EventTriggerData trigdata;
866 
867  /*
868  * See EventTriggerDDLCommandStart for a discussion about why event
869  * triggers are disabled in single user mode.
870  */
871  if (!IsUnderPostmaster)
872  return;
873 
874  /*
875  * Use current state to determine whether this event fires at all. If
876  * there are no triggers for the sql_drop event, then we don't have
877  * anything to do here. Note that dropped object collection is disabled
878  * if this is the case, so even if we were to try to run, the list would
879  * be empty.
880  */
883  return;
884 
885  runlist = EventTriggerCommonSetup(parsetree,
886  EVT_SQLDrop, "sql_drop",
887  &trigdata);
888 
889  /*
890  * Nothing to do if run list is empty. Note this shouldn't happen,
891  * because if there are no sql_drop events, then objects-to-drop wouldn't
892  * have been collected in the first place and we would have quit above.
893  */
894  if (runlist == NIL)
895  return;
896 
897  /*
898  * Make sure anything the main command did will be visible to the event
899  * triggers.
900  */
902 
903  /*
904  * Make sure pg_event_trigger_dropped_objects only works when running
905  * these triggers. Use PG_TRY to ensure in_sql_drop is reset even when
906  * one trigger fails. (This is perhaps not necessary, as the currentState
907  * variable will be removed shortly by our caller, but it seems better to
908  * play safe.)
909  */
911 
912  /* Run the triggers. */
913  PG_TRY();
914  {
915  EventTriggerInvoke(runlist, &trigdata);
916  }
917  PG_CATCH();
918  {
920  PG_RE_THROW();
921  }
922  PG_END_TRY();
924 
925  /* Cleanup. */
926  list_free(runlist);
927 }
#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:101
static bool slist_is_empty(slist_head *head)
Definition: ilist.h:563
void CommandCounterIncrement(void)
Definition: xact.c:915
#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

◆ EventTriggerSQLDropAddObject()

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

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

1339 {
1340  SQLDropObject *obj;
1341  MemoryContext oldcxt;
1342 
1344  return;
1345 
1347 
1348  /* don't report temp schemas except my own */
1349  if (object->classId == NamespaceRelationId &&
1350  (isAnyTempNamespace(object->objectId) &&
1351  !isTempNamespace(object->objectId)))
1352  return;
1353 
1355 
1356  obj = palloc0(sizeof(SQLDropObject));
1357  obj->address = *object;
1358  obj->original = original;
1359  obj->normal = normal;
1360 
1361  /*
1362  * Obtain schema names from the object's catalog tuple, if one exists;
1363  * this lets us skip objects in temp schemas. We trust that
1364  * ObjectProperty contains all object classes that can be
1365  * schema-qualified.
1366  */
1367  if (is_objectclass_supported(object->classId))
1368  {
1369  Relation catalog;
1370  HeapTuple tuple;
1371 
1372  catalog = heap_open(obj->address.classId, AccessShareLock);
1373  tuple = get_catalog_object_by_oid(catalog, obj->address.objectId);
1374 
1375  if (tuple)
1376  {
1377  AttrNumber attnum;
1378  Datum datum;
1379  bool isnull;
1380 
1382  if (attnum != InvalidAttrNumber)
1383  {
1384  datum = heap_getattr(tuple, attnum,
1385  RelationGetDescr(catalog), &isnull);
1386  if (!isnull)
1387  {
1388  Oid namespaceId;
1389 
1390  namespaceId = DatumGetObjectId(datum);
1391  /* temp objects are only reported if they are my own */
1392  if (isTempNamespace(namespaceId))
1393  {
1394  obj->schemaname = "pg_temp";
1395  obj->istemp = true;
1396  }
1397  else if (isAnyTempNamespace(namespaceId))
1398  {
1399  pfree(obj);
1400  heap_close(catalog, AccessShareLock);
1401  MemoryContextSwitchTo(oldcxt);
1402  return;
1403  }
1404  else
1405  {
1406  obj->schemaname = get_namespace_name(namespaceId);
1407  obj->istemp = false;
1408  }
1409  }
1410  }
1411 
1413  obj->address.objectSubId == 0)
1414  {
1415  attnum = get_object_attnum_name(obj->address.classId);
1416  if (attnum != InvalidAttrNumber)
1417  {
1418  datum = heap_getattr(tuple, attnum,
1419  RelationGetDescr(catalog), &isnull);
1420  if (!isnull)
1421  obj->objname = pstrdup(NameStr(*DatumGetName(datum)));
1422  }
1423  }
1424  }
1425 
1426  heap_close(catalog, AccessShareLock);
1427  }
1428  else
1429  {
1430  if (object->classId == NamespaceRelationId &&
1431  isTempNamespace(object->objectId))
1432  obj->istemp = true;
1433  }
1434 
1435  /* object identity, objname and objargs */
1436  obj->objidentity =
1437  getObjectIdentityParts(&obj->address, &obj->addrnames, &obj->addrargs);
1438 
1439  /* object type */
1441 
1443 
1444  MemoryContextSwitchTo(oldcxt);
1445 }
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:437
const char * objname
#define DatumGetObjectId(X)
Definition: postgres.h:506
char * pstrdup(const char *in)
Definition: mcxt.c:1063
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:2391
const char * objecttype
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
#define DatumGetName(X)
Definition: postgres.h:591
void pfree(void *pointer)
Definition: mcxt.c:936
char * get_namespace_name(Oid nspid)
Definition: lsyscache.c:3066
bool isTempNamespace(Oid namespaceId)
Definition: namespace.c:3118
bool EventTriggerSupportsObjectClass(ObjectClass objclass)
const char * schemaname
#define heap_getattr(tup, attnum, tupleDesc, isnull)
Definition: htup_details.h:774
AttrNumber get_object_attnum_name(Oid class_id)
void * palloc0(Size size)
Definition: mcxt.c:864
uintptr_t Datum
Definition: postgres.h:372
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1290
#define Assert(condition)
Definition: c.h:680
HeapTuple get_catalog_object_by_oid(Relation catalog, Oid objectId)
#define InvalidAttrNumber
Definition: attnum.h:23
#define NameStr(name)
Definition: c.h:557
bool isAnyTempNamespace(Oid namespaceId)
Definition: namespace.c:3156
bool is_objectclass_supported(Oid class_id)
int16 AttrNumber
Definition: attnum.h:21

◆ EventTriggerSupportsGrantObjectType()

bool EventTriggerSupportsGrantObjectType ( GrantObjectType  objtype)

Definition at line 1203 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_PROCEDURE, ACL_OBJECT_RELATION, ACL_OBJECT_ROUTINE, ACL_OBJECT_SEQUENCE, ACL_OBJECT_TABLESPACE, and ACL_OBJECT_TYPE.

Referenced by ExecGrantStmt_oids(), and standard_ProcessUtility().

1204 {
1205  switch (objtype)
1206  {
1207  case ACL_OBJECT_DATABASE:
1208  case ACL_OBJECT_TABLESPACE:
1209  /* no support for global objects */
1210  return false;
1211 
1212  case ACL_OBJECT_COLUMN:
1213  case ACL_OBJECT_RELATION:
1214  case ACL_OBJECT_SEQUENCE:
1215  case ACL_OBJECT_DOMAIN:
1216  case ACL_OBJECT_FDW:
1218  case ACL_OBJECT_FUNCTION:
1219  case ACL_OBJECT_LANGUAGE:
1221  case ACL_OBJECT_NAMESPACE:
1222  case ACL_OBJECT_PROCEDURE:
1223  case ACL_OBJECT_ROUTINE:
1224  case ACL_OBJECT_TYPE:
1225  return true;
1226 
1227  /*
1228  * There's intentionally no default: case here; we want the
1229  * compiler to warn if a new ACL class hasn't been handled above.
1230  */
1231  }
1232 
1233  /* Shouldn't get here, but if we do, say "no support" */
1234  return false;
1235 }

◆ EventTriggerSupportsObjectClass()

bool EventTriggerSupportsObjectClass ( ObjectClass  objclass)

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

1145 {
1146  switch (objclass)
1147  {
1148  case OCLASS_DATABASE:
1149  case OCLASS_TBLSPACE:
1150  case OCLASS_ROLE:
1151  /* no support for global objects */
1152  return false;
1153  case OCLASS_EVENT_TRIGGER:
1154  /* no support for event triggers on event triggers */
1155  return false;
1156  case OCLASS_CLASS:
1157  case OCLASS_PROC:
1158  case OCLASS_TYPE:
1159  case OCLASS_CAST:
1160  case OCLASS_COLLATION:
1161  case OCLASS_CONSTRAINT:
1162  case OCLASS_CONVERSION:
1163  case OCLASS_DEFAULT:
1164  case OCLASS_LANGUAGE:
1165  case OCLASS_LARGEOBJECT:
1166  case OCLASS_OPERATOR:
1167  case OCLASS_OPCLASS:
1168  case OCLASS_OPFAMILY:
1169  case OCLASS_AM:
1170  case OCLASS_AMOP:
1171  case OCLASS_AMPROC:
1172  case OCLASS_REWRITE:
1173  case OCLASS_TRIGGER:
1174  case OCLASS_SCHEMA:
1175  case OCLASS_STATISTIC_EXT:
1176  case OCLASS_TSPARSER:
1177  case OCLASS_TSDICT:
1178  case OCLASS_TSTEMPLATE:
1179  case OCLASS_TSCONFIG:
1180  case OCLASS_FDW:
1181  case OCLASS_FOREIGN_SERVER:
1182  case OCLASS_USER_MAPPING:
1183  case OCLASS_DEFACL:
1184  case OCLASS_EXTENSION:
1185  case OCLASS_POLICY:
1186  case OCLASS_PUBLICATION:
1188  case OCLASS_SUBSCRIPTION:
1189  case OCLASS_TRANSFORM:
1190  return true;
1191 
1192  /*
1193  * There's intentionally no default: case here; we want the
1194  * compiler to warn if a new OCLASS hasn't been handled above.
1195  */
1196  }
1197 
1198  /* Shouldn't get here, but if we do, say "no support" */
1199  return false;
1200 }

◆ EventTriggerSupportsObjectType()

bool EventTriggerSupportsObjectType ( ObjectType  obtype)

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

1071 {
1072  switch (obtype)
1073  {
1074  case OBJECT_DATABASE:
1075  case OBJECT_TABLESPACE:
1076  case OBJECT_ROLE:
1077  /* no support for global objects */
1078  return false;
1079  case OBJECT_EVENT_TRIGGER:
1080  /* no support for event triggers on event triggers */
1081  return false;
1082  case OBJECT_ACCESS_METHOD:
1083  case OBJECT_AGGREGATE:
1084  case OBJECT_AMOP:
1085  case OBJECT_AMPROC:
1086  case OBJECT_ATTRIBUTE:
1087  case OBJECT_CAST:
1088  case OBJECT_COLUMN:
1089  case OBJECT_COLLATION:
1090  case OBJECT_CONVERSION:
1091  case OBJECT_DEFACL:
1092  case OBJECT_DEFAULT:
1093  case OBJECT_DOMAIN:
1094  case OBJECT_DOMCONSTRAINT:
1095  case OBJECT_EXTENSION:
1096  case OBJECT_FDW:
1097  case OBJECT_FOREIGN_SERVER:
1098  case OBJECT_FOREIGN_TABLE:
1099  case OBJECT_FUNCTION:
1100  case OBJECT_INDEX:
1101  case OBJECT_LANGUAGE:
1102  case OBJECT_LARGEOBJECT:
1103  case OBJECT_MATVIEW:
1104  case OBJECT_OPCLASS:
1105  case OBJECT_OPERATOR:
1106  case OBJECT_OPFAMILY:
1107  case OBJECT_POLICY:
1108  case OBJECT_PROCEDURE:
1109  case OBJECT_PUBLICATION:
1111  case OBJECT_ROUTINE:
1112  case OBJECT_RULE:
1113  case OBJECT_SCHEMA:
1114  case OBJECT_SEQUENCE:
1115  case OBJECT_SUBSCRIPTION:
1116  case OBJECT_STATISTIC_EXT:
1117  case OBJECT_TABCONSTRAINT:
1118  case OBJECT_TABLE:
1119  case OBJECT_TRANSFORM:
1120  case OBJECT_TRIGGER:
1122  case OBJECT_TSDICTIONARY:
1123  case OBJECT_TSPARSER:
1124  case OBJECT_TSTEMPLATE:
1125  case OBJECT_TYPE:
1126  case OBJECT_USER_MAPPING:
1127  case OBJECT_VIEW:
1128  return true;
1129 
1130  /*
1131  * There's intentionally no default: case here; we want the
1132  * compiler to warn if a new ObjectType hasn't been handled above.
1133  */
1134  }
1135 
1136  /* Shouldn't get here, but if we do, say "no support" */
1137  return false;
1138 }

◆ EventTriggerTableRewrite()

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

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

935 {
936  List *runlist;
937  EventTriggerData trigdata;
938 
939  elog(DEBUG1, "EventTriggerTableRewrite(%u)", tableOid);
940 
941  /*
942  * Event Triggers are completely disabled in standalone mode. There are
943  * (at least) two reasons for this:
944  *
945  * 1. A sufficiently broken event trigger might not only render the
946  * database unusable, but prevent disabling itself to fix the situation.
947  * In this scenario, restarting in standalone mode provides an escape
948  * hatch.
949  *
950  * 2. BuildEventTriggerCache relies on systable_beginscan_ordered, and
951  * therefore will malfunction if pg_event_trigger's indexes are damaged.
952  * To allow recovery from a damaged index, we need some operating mode
953  * wherein event triggers are disabled. (Or we could implement
954  * heapscan-and-sort logic for that case, but having disaster recovery
955  * scenarios depend on code that's otherwise untested isn't appetizing.)
956  */
957  if (!IsUnderPostmaster)
958  return;
959 
960  runlist = EventTriggerCommonSetup(parsetree,
962  "table_rewrite",
963  &trigdata);
964  if (runlist == NIL)
965  return;
966 
967  /*
968  * Make sure pg_event_trigger_table_rewrite_oid only works when running
969  * these triggers. Use PG_TRY to ensure table_rewrite_oid is reset even
970  * when one trigger fails. (This is perhaps not necessary, as the
971  * currentState variable will be removed shortly by our caller, but it
972  * seems better to play safe.)
973  */
976 
977  /* Run the triggers. */
978  PG_TRY();
979  {
980  EventTriggerInvoke(runlist, &trigdata);
981  }
982  PG_CATCH();
983  {
986  PG_RE_THROW();
987  }
988  PG_END_TRY();
989 
992 
993  /* Cleanup. */
994  list_free(runlist);
995 
996  /*
997  * Make sure anything the event triggers did will be visible to the main
998  * command.
999  */
1001 }
#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:101
void CommandCounterIncrement(void)
Definition: xact.c:915
#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

◆ EventTriggerUndoInhibitCommandCollection()

void EventTriggerUndoInhibitCommandCollection ( void  )

Definition at line 1654 of file event_trigger.c.

References EventTriggerQueryState::commandCollectionInhibited.

Referenced by ProcessUtilitySlow().

1655 {
1657  return;
1658 
1660 }
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72

◆ filter_event_trigger()

static bool filter_event_trigger ( const char **  tag,
EventTriggerCacheItem item 
)
static

Definition at line 661 of file event_trigger.c.

References EventTriggerCacheItem::enabled, EventTriggerCacheItem::ntags, pg_qsort_strcmp(), SESSION_REPLICATION_ROLE_REPLICA, SessionReplicationRole, EventTriggerCacheItem::tag, TRIGGER_FIRES_ON_ORIGIN, and TRIGGER_FIRES_ON_REPLICA.

Referenced by EventTriggerCommonSetup().

662 {
663  /*
664  * Filter by session replication role, knowing that we never see disabled
665  * items down here.
666  */
668  {
669  if (item->enabled == TRIGGER_FIRES_ON_ORIGIN)
670  return false;
671  }
672  else
673  {
674  if (item->enabled == TRIGGER_FIRES_ON_REPLICA)
675  return false;
676  }
677 
678  /* Filter by tags, if any were specified. */
679  if (item->ntags != 0 && bsearch(tag, item->tag,
680  item->ntags, sizeof(char *),
681  pg_qsort_strcmp) == NULL)
682  return false;
683 
684  /* if we reach that point, we're not filtering out this item */
685  return true;
686 }
#define TRIGGER_FIRES_ON_ORIGIN
Definition: trigger.h:155
int SessionReplicationRole
Definition: trigger.c:65
#define SESSION_REPLICATION_ROLE_REPLICA
Definition: trigger.h:147
int pg_qsort_strcmp(const void *a, const void *b)
Definition: qsort.c:232
#define TRIGGER_FIRES_ON_REPLICA
Definition: trigger.h:157

◆ filter_list_to_array()

static Datum filter_list_to_array ( List filterlist)
static

Definition at line 450 of file event_trigger.c.

References construct_array(), cstring_to_text(), i, lfirst, list_length(), palloc(), pfree(), pg_ascii_toupper(), PointerGetDatum, pstrdup(), strVal, TEXTOID, and value.

Referenced by insert_event_trigger_tuple().

451 {
452  ListCell *lc;
453  Datum *data;
454  int i = 0,
455  l = list_length(filterlist);
456 
457  data = (Datum *) palloc(l * sizeof(Datum));
458 
459  foreach(lc, filterlist)
460  {
461  const char *value = strVal(lfirst(lc));
462  char *result,
463  *p;
464 
465  result = pstrdup(value);
466  for (p = result; *p; p++)
467  *p = pg_ascii_toupper((unsigned char) *p);
468  data[i++] = PointerGetDatum(cstring_to_text(result));
469  pfree(result);
470  }
471 
472  return PointerGetDatum(construct_array(data, l, TEXTOID, -1, false, 'i'));
473 }
static struct @130 value
#define TEXTOID
Definition: pg_type.h:324
#define PointerGetDatum(X)
Definition: postgres.h:562
char * pstrdup(const char *in)
Definition: mcxt.c:1063
ArrayType * construct_array(Datum *elems, int nelems, Oid elmtype, int elmlen, bool elmbyval, char elmalign)
Definition: arrayfuncs.c:3279
#define strVal(v)
Definition: value.h:54
unsigned char pg_ascii_toupper(unsigned char ch)
Definition: pgstrcasecmp.c:135
void pfree(void *pointer)
Definition: mcxt.c:936
uintptr_t Datum
Definition: postgres.h:372
text * cstring_to_text(const char *s)
Definition: varlena.c:150
#define lfirst(lc)
Definition: pg_list.h:106
static int list_length(const List *l)
Definition: pg_list.h:89
void * palloc(Size size)
Definition: mcxt.c:835
int i

◆ get_event_trigger_oid()

Oid get_event_trigger_oid ( const char *  trigname,
bool  missing_ok 
)

Definition at line 643 of file event_trigger.c.

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

Referenced by get_object_address_unqualified().

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

◆ insert_event_trigger_tuple()

static Oid insert_event_trigger_tuple ( const char *  trigname,
const char *  eventname,
Oid  evtOwner,
Oid  funcoid,
List tags 
)
static

Definition at line 377 of file event_trigger.c.

References Anum_pg_event_trigger_evtenabled, Anum_pg_event_trigger_evtevent, Anum_pg_event_trigger_evtfoid, Anum_pg_event_trigger_evtname, Anum_pg_event_trigger_evtowner, Anum_pg_event_trigger_evttags, CatalogTupleInsert(), CharGetDatum, ObjectAddress::classId, DEPENDENCY_NORMAL, EventTriggerRelationId, filter_list_to_array(), heap_close, heap_form_tuple(), heap_freetuple(), heap_open(), InvokeObjectPostCreateHook, NameGetDatum, namestrcpy(), Natts_pg_trigger, NIL, ObjectAddress::objectId, ObjectIdGetDatum, ObjectAddress::objectSubId, ProcedureRelationId, RelationData::rd_att, recordDependencyOn(), recordDependencyOnCurrentExtension(), recordDependencyOnOwner(), RowExclusiveLock, TRIGGER_FIRES_ON_ORIGIN, and values.

Referenced by CreateEventTrigger().

379 {
380  Relation tgrel;
381  Oid trigoid;
382  HeapTuple tuple;
384  bool nulls[Natts_pg_trigger];
385  NameData evtnamedata,
386  evteventdata;
387  ObjectAddress myself,
388  referenced;
389 
390  /* Open pg_event_trigger. */
392 
393  /* Build the new pg_trigger tuple. */
394  memset(nulls, false, sizeof(nulls));
395  namestrcpy(&evtnamedata, trigname);
396  values[Anum_pg_event_trigger_evtname - 1] = NameGetDatum(&evtnamedata);
397  namestrcpy(&evteventdata, eventname);
398  values[Anum_pg_event_trigger_evtevent - 1] = NameGetDatum(&evteventdata);
399  values[Anum_pg_event_trigger_evtowner - 1] = ObjectIdGetDatum(evtOwner);
400  values[Anum_pg_event_trigger_evtfoid - 1] = ObjectIdGetDatum(funcoid);
403  if (taglist == NIL)
404  nulls[Anum_pg_event_trigger_evttags - 1] = true;
405  else
406  values[Anum_pg_event_trigger_evttags - 1] =
407  filter_list_to_array(taglist);
408 
409  /* Insert heap tuple. */
410  tuple = heap_form_tuple(tgrel->rd_att, values, nulls);
411  trigoid = CatalogTupleInsert(tgrel, tuple);
412  heap_freetuple(tuple);
413 
414  /* Depend on owner. */
416 
417  /* Depend on event trigger function. */
419  myself.objectId = trigoid;
420  myself.objectSubId = 0;
421  referenced.classId = ProcedureRelationId;
422  referenced.objectId = funcoid;
423  referenced.objectSubId = 0;
424  recordDependencyOn(&myself, &referenced, DEPENDENCY_NORMAL);
425 
426  /* Depend on extension, if any. */
427  recordDependencyOnCurrentExtension(&myself, false);
428 
429  /* Post creation hook for new event trigger */
431 
432  /* Close pg_event_trigger. */
434 
435  return trigoid;
436 }
#define Anum_pg_event_trigger_evtname
#define NIL
Definition: pg_list.h:69
#define Anum_pg_event_trigger_evtevent
#define NameGetDatum(X)
Definition: postgres.h:601
#define InvokeObjectPostCreateHook(classId, objectId, subId)
Definition: objectaccess.h:145
#define ProcedureRelationId
Definition: pg_proc.h:33
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
Definition: pg_depend.c:44
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, Datum *values, bool *isnull)
Definition: heaptuple.c:695
#define heap_close(r, l)
Definition: heapam.h:97
void recordDependencyOnOwner(Oid classId, Oid objectId, Oid owner)
Definition: pg_shdepend.c:159
#define Anum_pg_event_trigger_evtfoid
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1373
unsigned int Oid
Definition: postgres_ext.h:31
int namestrcpy(Name name, const char *str)
Definition: name.c:216
#define TRIGGER_FIRES_ON_ORIGIN
Definition: trigger.h:155
#define ObjectIdGetDatum(X)
Definition: postgres.h:513
Oid CatalogTupleInsert(Relation heapRel, HeapTuple tup)
Definition: indexing.c:162
static Datum filter_list_to_array(List *filterlist)
Definition: c.h:551
#define RowExclusiveLock
Definition: lockdefs.h:38
uintptr_t Datum
Definition: postgres.h:372
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1290
TupleDesc rd_att
Definition: rel.h:115
#define EventTriggerRelationId
void recordDependencyOnCurrentExtension(const ObjectAddress *object, bool isReplace)
Definition: pg_depend.c:139
#define Anum_pg_event_trigger_evttags
#define Anum_pg_event_trigger_evtenabled
#define CharGetDatum(X)
Definition: postgres.h:422
static Datum values[MAXATTR]
Definition: bootstrap.c:164
#define Anum_pg_event_trigger_evtowner
#define Natts_pg_trigger
Definition: pg_trigger.h:78

◆ pg_event_trigger_ddl_commands()

Datum pg_event_trigger_ddl_commands ( PG_FUNCTION_ARGS  )

Definition at line 2006 of file event_trigger.c.

References AccessShareLock, ReturnSetInfo::allowedModes, CollectedCommand::alterTable, CollectedCommand::atscfg, BoolGetDatum, ObjectAddress::classId, EventTriggerQueryState::commandList, CreateCommandTag(), CollectedCommand::createopc, CStringGetTextDatum, CollectedCommand::d, CollectedCommand::defprivs, ReturnSetInfo::econtext, ExprContext::ecxt_per_query_memory, elog, ereport, errcode(), errmsg(), ERROR, get_call_result_type(), get_catalog_object_by_oid(), get_namespace_name(), get_object_attnum_namespace(), getObjectIdentity(), getObjectTypeDescription(), CollectedCommand::grant, heap_close, heap_getattr, heap_open(), HeapTupleIsValid, i, CollectedCommand::in_extension, Int32GetDatum, InvalidAttrNumber, is_objectclass_supported(), IsA, isAnyTempNamespace(), lfirst, MemoryContextSwitchTo(), MemSet, ObjectAddressSet, ObjectAddress::objectId, ObjectIdGetDatum, ObjectAddress::objectSubId, OidIsValid, CollectedCommand::opfam, CollectedCommand::parsetree, PG_RETURN_VOID, PointerGetDatum, pstrdup(), RelationGetDescr, ReturnSetInfo::returnMode, SCT_AlterDefaultPrivileges, SCT_AlterOpFamily, SCT_AlterTable, SCT_AlterTSConfig, SCT_CreateOpClass, SCT_Grant, SCT_Simple, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, SFRM_Materialize, CollectedCommand::simple, stringify_adefprivs_objtype(), stringify_grantobjtype(), tuplestore_begin_heap(), tuplestore_donestoring, tuplestore_putvalues(), CollectedCommand::type, generate_unaccent_rules::type, TYPEFUNC_COMPOSITE, values, and work_mem.

2007 {
2008  ReturnSetInfo *rsinfo = (ReturnSetInfo *) fcinfo->resultinfo;
2009  TupleDesc tupdesc;
2010  Tuplestorestate *tupstore;
2011  MemoryContext per_query_ctx;
2012  MemoryContext oldcontext;
2013  ListCell *lc;
2014 
2015  /*
2016  * Protect this function from being called out of context
2017  */
2019  ereport(ERROR,
2020  (errcode(ERRCODE_E_R_I_E_EVENT_TRIGGER_PROTOCOL_VIOLATED),
2021  errmsg("%s can only be called in an event trigger function",
2022  "pg_event_trigger_ddl_commands()")));
2023 
2024  /* check to see if caller supports us returning a tuplestore */
2025  if (rsinfo == NULL || !IsA(rsinfo, ReturnSetInfo))
2026  ereport(ERROR,
2027  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2028  errmsg("set-valued function called in context that cannot accept a set")));
2029  if (!(rsinfo->allowedModes & SFRM_Materialize))
2030  ereport(ERROR,
2031  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2032  errmsg("materialize mode required, but it is not allowed in this context")));
2033 
2034  /* Build a tuple descriptor for our result type */
2035  if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
2036  elog(ERROR, "return type must be a row type");
2037 
2038  /* Build tuplestore to hold the result rows */
2039  per_query_ctx = rsinfo->econtext->ecxt_per_query_memory;
2040  oldcontext = MemoryContextSwitchTo(per_query_ctx);
2041 
2042  tupstore = tuplestore_begin_heap(true, false, work_mem);
2043  rsinfo->returnMode = SFRM_Materialize;
2044  rsinfo->setResult = tupstore;
2045  rsinfo->setDesc = tupdesc;
2046 
2047  MemoryContextSwitchTo(oldcontext);
2048 
2050  {
2051  CollectedCommand *cmd = lfirst(lc);
2052  Datum values[9];
2053  bool nulls[9];
2054  ObjectAddress addr;
2055  int i = 0;
2056 
2057  /*
2058  * For IF NOT EXISTS commands that attempt to create an existing
2059  * object, the returned OID is Invalid. Don't return anything.
2060  *
2061  * One might think that a viable alternative would be to look up the
2062  * Oid of the existing object and run the deparse with that. But
2063  * since the parse tree might be different from the one that created
2064  * the object in the first place, we might not end up in a consistent
2065  * state anyway.
2066  */
2067  if (cmd->type == SCT_Simple &&
2068  !OidIsValid(cmd->d.simple.address.objectId))
2069  continue;
2070 
2071  MemSet(nulls, 0, sizeof(nulls));
2072 
2073  switch (cmd->type)
2074  {
2075  case SCT_Simple:
2076  case SCT_AlterTable:
2077  case SCT_AlterOpFamily:
2078  case SCT_CreateOpClass:
2079  case SCT_AlterTSConfig:
2080  {
2081  char *identity;
2082  char *type;
2083  char *schema = NULL;
2084 
2085  if (cmd->type == SCT_Simple)
2086  addr = cmd->d.simple.address;
2087  else if (cmd->type == SCT_AlterTable)
2088  ObjectAddressSet(addr,
2089  cmd->d.alterTable.classId,
2090  cmd->d.alterTable.objectId);
2091  else if (cmd->type == SCT_AlterOpFamily)
2092  addr = cmd->d.opfam.address;
2093  else if (cmd->type == SCT_CreateOpClass)
2094  addr = cmd->d.createopc.address;
2095  else if (cmd->type == SCT_AlterTSConfig)
2096  addr = cmd->d.atscfg.address;
2097 
2098  type = getObjectTypeDescription(&addr);
2099  identity = getObjectIdentity(&addr);
2100 
2101  /*
2102  * Obtain schema name, if any ("pg_temp" if a temp
2103  * object). If the object class is not in the supported
2104  * list here, we assume it's a schema-less object type,
2105  * and thus "schema" remains set to NULL.
2106  */
2108  {
2109  AttrNumber nspAttnum;
2110 
2111  nspAttnum = get_object_attnum_namespace(addr.classId);
2112  if (nspAttnum != InvalidAttrNumber)
2113  {
2114  Relation catalog;
2115  HeapTuple objtup;
2116  Oid schema_oid;
2117  bool isnull;
2118 
2119  catalog = heap_open(addr.classId, AccessShareLock);
2120  objtup = get_catalog_object_by_oid(catalog,
2121  addr.objectId);
2122  if (!HeapTupleIsValid(objtup))
2123  elog(ERROR, "cache lookup failed for object %u/%u",
2124  addr.classId, addr.objectId);
2125  schema_oid =
2126  heap_getattr(objtup, nspAttnum,
2127  RelationGetDescr(catalog), &isnull);
2128  if (isnull)
2129  elog(ERROR,
2130  "invalid null namespace in object %u/%u/%d",
2131  addr.classId, addr.objectId, addr.objectSubId);
2132  /* XXX not quite get_namespace_name_or_temp */
2133  if (isAnyTempNamespace(schema_oid))
2134  schema = pstrdup("pg_temp");
2135  else
2136  schema = get_namespace_name(schema_oid);
2137 
2138  heap_close(catalog, AccessShareLock);
2139  }
2140  }
2141 
2142  /* classid */
2143  values[i++] = ObjectIdGetDatum(addr.classId);
2144  /* objid */
2145  values[i++] = ObjectIdGetDatum(addr.objectId);
2146  /* objsubid */
2147  values[i++] = Int32GetDatum(addr.objectSubId);
2148  /* command tag */
2149  values[i++] = CStringGetTextDatum(CreateCommandTag(cmd->parsetree));
2150  /* object_type */
2151  values[i++] = CStringGetTextDatum(type);
2152  /* schema */
2153  if (schema == NULL)
2154  nulls[i++] = true;
2155  else
2156  values[i++] = CStringGetTextDatum(schema);
2157  /* identity */
2158  values[i++] = CStringGetTextDatum(identity);
2159  /* in_extension */
2160  values[i++] = BoolGetDatum(cmd->in_extension);
2161  /* command */
2162  values[i++] = PointerGetDatum(cmd);
2163  }
2164  break;
2165 
2167  /* classid */
2168  nulls[i++] = true;
2169  /* objid */
2170  nulls[i++] = true;
2171  /* objsubid */
2172  nulls[i++] = true;
2173  /* command tag */
2174  values[i++] = CStringGetTextDatum(CreateCommandTag(cmd->parsetree));
2175  /* object_type */
2177  cmd->d.defprivs.objtype));
2178  /* schema */
2179  nulls[i++] = true;
2180  /* identity */
2181  nulls[i++] = true;
2182  /* in_extension */
2183  values[i++] = BoolGetDatum(cmd->in_extension);
2184  /* command */
2185  values[i++] = PointerGetDatum(cmd);
2186  break;
2187 
2188  case SCT_Grant:
2189  /* classid */
2190  nulls[i++] = true;
2191  /* objid */
2192  nulls[i++] = true;
2193  /* objsubid */
2194  nulls[i++] = true;
2195  /* command tag */
2196  values[i++] = CStringGetTextDatum(cmd->d.grant.istmt->is_grant ?
2197  "GRANT" : "REVOKE");
2198  /* object_type */
2200  cmd->d.grant.istmt->objtype));
2201  /* schema */
2202  nulls[i++] = true;
2203  /* identity */
2204  nulls[i++] = true;
2205  /* in_extension */
2206  values[i++] = BoolGetDatum(cmd->in_extension);
2207  /* command */
2208  values[i++] = PointerGetDatum(cmd);
2209  break;
2210  }
2211 
2212  tuplestore_putvalues(tupstore, tupdesc, values, nulls);
2213  }
2214 
2215  /* clean up and return the tuplestore */
2216  tuplestore_donestoring(tupstore);
2217 
2218  PG_RETURN_VOID();
2219 }
void tuplestore_putvalues(Tuplestorestate *state, TupleDesc tdesc, Datum *values, bool *isnull)
Definition: tuplestore.c:750
union CollectedCommand::@111 d
#define IsA(nodeptr, _type_)
Definition: nodes.h:563
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
Definition: funcapi.c:211
char * getObjectTypeDescription(const ObjectAddress *object)
#define RelationGetDescr(relation)
Definition: rel.h:437
#define PointerGetDatum(X)
Definition: postgres.h:562
char * pstrdup(const char *in)
Definition: mcxt.c:1063
#define tuplestore_donestoring(state)
Definition: tuplestore.h:60
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
#define AccessShareLock
Definition: lockdefs.h:36
static const char * stringify_adefprivs_objtype(GrantObjectType objtype)
int errcode(int sqlerrcode)
Definition: elog.c:575
#define MemSet(start, val, len)
Definition: c.h:877
struct CollectedCommand::@111::@114 grant
AttrNumber get_object_attnum_namespace(Oid class_id)
#define heap_close(r, l)
Definition: heapam.h:97
struct CollectedCommand::@111::@112 simple
CollectedCommandType type
unsigned int Oid
Definition: postgres_ext.h:31
#define OidIsValid(objectId)
Definition: c.h:586
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
static const char * stringify_grantobjtype(GrantObjectType objtype)
struct CollectedCommand::@111::@116 createopc
struct CollectedCommand::@111::@118 defprivs
struct CollectedCommand::@111::@117 atscfg
#define ObjectIdGetDatum(X)
Definition: postgres.h:513
#define ERROR
Definition: elog.h:43
char * getObjectIdentity(const ObjectAddress *object)
char * get_namespace_name(Oid nspid)
Definition: lsyscache.c:3066
#define ereport(elevel, rest)
Definition: elog.h:122
const char * CreateCommandTag(Node *parsetree)
Definition: utility.c:2046
#define heap_getattr(tup, attnum, tupleDesc, isnull)
Definition: htup_details.h:774
Tuplestorestate * tuplestore_begin_heap(bool randomAccess, bool interXact, int maxKBytes)
Definition: tuplestore.c:318
uintptr_t Datum
Definition: postgres.h:372
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1290
int work_mem
Definition: globals.c:113
#define BoolGetDatum(X)
Definition: postgres.h:408
int allowedModes
Definition: execnodes.h:279
#define PG_RETURN_VOID()
Definition: fmgr.h:309
SetFunctionReturnMode returnMode
Definition: execnodes.h:281
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define lfirst(lc)
Definition: pg_list.h:106
struct CollectedCommand::@111::@115 opfam
struct CollectedCommand::@111::@113 alterTable
MemoryContext ecxt_per_query_memory
Definition: execnodes.h:213
HeapTuple get_catalog_object_by_oid(Relation catalog, Oid objectId)
#define InvalidAttrNumber
Definition: attnum.h:23
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
Tuplestorestate * setResult
Definition: execnodes.h:284
static Datum values[MAXATTR]
Definition: bootstrap.c:164
ExprContext * econtext
Definition: execnodes.h:277
#define Int32GetDatum(X)
Definition: postgres.h:485
TupleDesc setDesc
Definition: execnodes.h:285
int errmsg(const char *fmt,...)
Definition: elog.c:797
int i
#define CStringGetTextDatum(s)
Definition: builtins.h:91
bool isAnyTempNamespace(Oid namespaceId)
Definition: namespace.c:3156
#define elog
Definition: elog.h:219
bool is_objectclass_supported(Oid class_id)
int16 AttrNumber
Definition: attnum.h:21

◆ pg_event_trigger_dropped_objects()

Datum pg_event_trigger_dropped_objects ( PG_FUNCTION_ARGS  )

Definition at line 1454 of file event_trigger.c.

References SQLDropObject::addrargs, SQLDropObject::address, SQLDropObject::addrnames, ReturnSetInfo::allowedModes, BoolGetDatum, ObjectAddress::classId, construct_empty_array(), CStringGetTextDatum, ReturnSetInfo::econtext, ExprContext::ecxt_per_query_memory, elog, ereport, errcode(), errmsg(), ERROR, get_call_result_type(), i, EventTriggerQueryState::in_sql_drop, Int32GetDatum, IsA, SQLDropObject::istemp, MemoryContextSwitchTo(), MemSet, next, SQLDropObject::normal, ObjectAddress::objectId, ObjectIdGetDatum, ObjectAddress::objectSubId, SQLDropObject::objecttype, SQLDropObject::objidentity, SQLDropObject::objname, SQLDropObject::original, PointerGetDatum, ReturnSetInfo::returnMode, SQLDropObject::schemaname, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, SFRM_Materialize, slist_container, slist_foreach, EventTriggerQueryState::SQLDropList, strlist_to_textarray(), TEXTOID, tuplestore_begin_heap(), tuplestore_donestoring, tuplestore_putvalues(), TYPEFUNC_COMPOSITE, values, and work_mem.

1455 {
1456  ReturnSetInfo *rsinfo = (ReturnSetInfo *) fcinfo->resultinfo;
1457  TupleDesc tupdesc;
1458  Tuplestorestate *tupstore;
1459  MemoryContext per_query_ctx;
1460  MemoryContext oldcontext;
1461  slist_iter iter;
1462 
1463  /*
1464  * Protect this function from being called out of context
1465  */
1466  if (!currentEventTriggerState ||
1468  ereport(ERROR,
1469  (errcode(ERRCODE_E_R_I_E_EVENT_TRIGGER_PROTOCOL_VIOLATED),
1470  errmsg("%s can only be called in a sql_drop event trigger function",
1471  "pg_event_trigger_dropped_objects()")));
1472 
1473  /* check to see if caller supports us returning a tuplestore */
1474  if (rsinfo == NULL || !IsA(rsinfo, ReturnSetInfo))
1475  ereport(ERROR,
1476  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1477  errmsg("set-valued function called in context that cannot accept a set")));
1478  if (!(rsinfo->allowedModes & SFRM_Materialize))
1479  ereport(ERROR,
1480  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1481  errmsg("materialize mode required, but it is not allowed in this context")));
1482 
1483  /* Build a tuple descriptor for our result type */
1484  if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
1485  elog(ERROR, "return type must be a row type");
1486 
1487  /* Build tuplestore to hold the result rows */
1488  per_query_ctx = rsinfo->econtext->ecxt_per_query_memory;
1489  oldcontext = MemoryContextSwitchTo(per_query_ctx);
1490 
1491  tupstore = tuplestore_begin_heap(true, false, work_mem);
1492  rsinfo->returnMode = SFRM_Materialize;
1493  rsinfo->setResult = tupstore;
1494  rsinfo->setDesc = tupdesc;
1495 
1496  MemoryContextSwitchTo(oldcontext);
1497 
1499  {
1500  SQLDropObject *obj;
1501  int i = 0;
1502  Datum values[12];
1503  bool nulls[12];
1504 
1505  obj = slist_container(SQLDropObject, next, iter.cur);
1506 
1507  MemSet(values, 0, sizeof(values));
1508  MemSet(nulls, 0, sizeof(nulls));
1509 
1510  /* classid */
1511  values[i++] = ObjectIdGetDatum(obj->address.classId);
1512 
1513  /* objid */
1514  values[i++] = ObjectIdGetDatum(obj->address.objectId);
1515 
1516  /* objsubid */
1517  values[i++] = Int32GetDatum(obj->address.objectSubId);
1518 
1519  /* original */
1520  values[i++] = BoolGetDatum(obj->original);
1521 
1522  /* normal */
1523  values[i++] = BoolGetDatum(obj->normal);
1524 
1525  /* is_temporary */
1526  values[i++] = BoolGetDatum(obj->istemp);
1527 
1528  /* object_type */
1529  values[i++] = CStringGetTextDatum(obj->objecttype);
1530 
1531  /* schema_name */
1532  if (obj->schemaname)
1533  values[i++] = CStringGetTextDatum(obj->schemaname);
1534  else
1535  nulls[i++] = true;
1536 
1537  /* object_name */
1538  if (obj->objname)
1539  values[i++] = CStringGetTextDatum(obj->objname);
1540  else
1541  nulls[i++] = true;
1542 
1543  /* object_identity */
1544  if (obj->objidentity)
1545  values[i++] = CStringGetTextDatum(obj->objidentity);
1546  else
1547  nulls[i++] = true;
1548 
1549  /* address_names and address_args */
1550  if (obj->addrnames)
1551  {
1552  values[i++] = PointerGetDatum(strlist_to_textarray(obj->addrnames));
1553 
1554  if (obj->addrargs)
1555  values[i++] = PointerGetDatum(strlist_to_textarray(obj->addrargs));
1556  else
1558  }
1559  else
1560  {
1561  nulls[i++] = true;
1562  nulls[i++] = true;
1563  }
1564 
1565  tuplestore_putvalues(tupstore, tupdesc, values, nulls);
1566  }
1567 
1568  /* clean up and return the tuplestore */
1569  tuplestore_donestoring(tupstore);
1570 
1571  return (Datum) 0;
1572 }
void tuplestore_putvalues(Tuplestorestate *state, TupleDesc tdesc, Datum *values, bool *isnull)
Definition: tuplestore.c:750
#define IsA(nodeptr, _type_)
Definition: nodes.h:563
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
Definition: funcapi.c:211
static int32 next
Definition: blutils.c:210
ObjectAddress address
#define TEXTOID
Definition: pg_type.h:324
#define PointerGetDatum(X)
Definition: postgres.h:562
const char * objname
#define tuplestore_donestoring(state)
Definition: tuplestore.h:60
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:109
int errcode(int sqlerrcode)
Definition: elog.c:575
#define MemSet(start, val, len)
Definition: c.h:877
const char * objidentity
ArrayType * construct_empty_array(Oid elmtype)
Definition: arrayfuncs.c:3398
const char * objecttype
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
#define ObjectIdGetDatum(X)
Definition: postgres.h:513
#define ERROR
Definition: elog.h:43
#define ereport(elevel, rest)
Definition: elog.h:122
const char * schemaname
Tuplestorestate * tuplestore_begin_heap(bool randomAccess, bool interXact, int maxKBytes)
Definition: tuplestore.c:318
#define slist_container(type, membername, ptr)
Definition: ilist.h:674
uintptr_t Datum
Definition: postgres.h:372
int work_mem
Definition: globals.c:113
#define BoolGetDatum(X)
Definition: postgres.h:408
int allowedModes
Definition: execnodes.h:279
SetFunctionReturnMode returnMode
Definition: execnodes.h:281
MemoryContext ecxt_per_query_memory
Definition: execnodes.h:213
Tuplestorestate * setResult
Definition: execnodes.h:284
static Datum values[MAXATTR]
Definition: bootstrap.c:164
ExprContext * econtext
Definition: execnodes.h:277
#define slist_foreach(iter, lhead)
Definition: ilist.h:700
#define Int32GetDatum(X)
Definition: postgres.h:485
TupleDesc setDesc
Definition: execnodes.h:285
int errmsg(const char *fmt,...)
Definition: elog.c:797
int i
#define CStringGetTextDatum(s)
Definition: builtins.h:91
ArrayType * strlist_to_textarray(List *list)
#define elog
Definition: elog.h:219

◆ pg_event_trigger_table_rewrite_oid()

Datum pg_event_trigger_table_rewrite_oid ( PG_FUNCTION_ARGS  )

Definition at line 1581 of file event_trigger.c.

References ereport, errcode(), errmsg(), ERROR, InvalidOid, PG_RETURN_OID, and EventTriggerQueryState::table_rewrite_oid.

1582 {
1583  /*
1584  * Protect this function from being called out of context
1585  */
1586  if (!currentEventTriggerState ||
1588  ereport(ERROR,
1589  (errcode(ERRCODE_E_R_I_E_EVENT_TRIGGER_PROTOCOL_VIOLATED),
1590  errmsg("%s can only be called in a table_rewrite event trigger function",
1591  "pg_event_trigger_table_rewrite_oid()")));
1592 
1594 }
int errcode(int sqlerrcode)
Definition: elog.c:575
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
#define ERROR
Definition: elog.h:43
#define ereport(elevel, rest)
Definition: elog.h:122
#define InvalidOid
Definition: postgres_ext.h:36
int errmsg(const char *fmt,...)
Definition: elog.c:797
#define PG_RETURN_OID(x)
Definition: fmgr.h:320

◆ pg_event_trigger_table_rewrite_reason()

Datum pg_event_trigger_table_rewrite_reason ( PG_FUNCTION_ARGS  )

Definition at line 1602 of file event_trigger.c.

References ereport, errcode(), errmsg(), ERROR, PG_RETURN_INT32, and EventTriggerQueryState::table_rewrite_reason.

1603 {
1604  /*
1605  * Protect this function from being called out of context
1606  */
1607  if (!currentEventTriggerState ||
1609  ereport(ERROR,
1610  (errcode(ERRCODE_E_R_I_E_EVENT_TRIGGER_PROTOCOL_VIOLATED),
1611  errmsg("%s can only be called in a table_rewrite event trigger function",
1612  "pg_event_trigger_table_rewrite_reason()")));
1613 
1615 }
#define PG_RETURN_INT32(x)
Definition: fmgr.h:314
int errcode(int sqlerrcode)
Definition: elog.c:575
static EventTriggerQueryState * currentEventTriggerState
Definition: event_trigger.c:72
#define ERROR
Definition: elog.h:43
#define ereport(elevel, rest)
Definition: elog.h:122
int errmsg(const char *fmt,...)
Definition: elog.c:797

◆ RemoveEventTriggerById()

void RemoveEventTriggerById ( Oid  trigOid)

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

480 {
481  Relation tgrel;
482  HeapTuple tup;
483 
485 
487  if (!HeapTupleIsValid(tup))
488  elog(ERROR, "cache lookup failed for event trigger %u", trigOid);
489 
490  CatalogTupleDelete(tgrel, &tup->t_self);
491 
492  ReleaseSysCache(tup);
493 
495 }
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
Definition: indexing.c:255
#define heap_close(r, l)
Definition: heapam.h:97
#define ObjectIdGetDatum(X)
Definition: postgres.h:513
#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:1112
void ReleaseSysCache(HeapTuple tuple)
Definition: syscache.c:1160
Relation heap_open(Oid relationId, LOCKMODE lockmode)
Definition: heapam.c:1290
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define EventTriggerRelationId
#define elog
Definition: elog.h:219

◆ stringify_adefprivs_objtype()

static const char * stringify_adefprivs_objtype ( GrantObjectType  objtype)
static

Definition at line 2272 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_PROCEDURE, ACL_OBJECT_RELATION, ACL_OBJECT_ROUTINE, ACL_OBJECT_SEQUENCE, ACL_OBJECT_TABLESPACE, ACL_OBJECT_TYPE, elog, and ERROR.

Referenced by pg_event_trigger_ddl_commands().

2273 {
2274  switch (objtype)
2275  {
2276  case ACL_OBJECT_COLUMN:
2277  return "COLUMNS";
2278  case ACL_OBJECT_RELATION:
2279  return "TABLES";
2280  case ACL_OBJECT_SEQUENCE:
2281  return "SEQUENCES";
2282  case ACL_OBJECT_DATABASE:
2283  return "DATABASES";
2284  case ACL_OBJECT_DOMAIN:
2285  return "DOMAINS";
2286  case ACL_OBJECT_FDW:
2287  return "FOREIGN DATA WRAPPERS";
2289  return "FOREIGN SERVERS";
2290  case ACL_OBJECT_FUNCTION:
2291  return "FUNCTIONS";
2292  case ACL_OBJECT_LANGUAGE:
2293  return "LANGUAGES";
2295  return "LARGE OBJECTS";
2296  case ACL_OBJECT_NAMESPACE:
2297  return "SCHEMAS";
2298  case ACL_OBJECT_PROCEDURE:
2299  return "PROCEDURES";
2300  case ACL_OBJECT_ROUTINE:
2301  return "ROUTINES";
2302  case ACL_OBJECT_TABLESPACE:
2303  return "TABLESPACES";
2304  case ACL_OBJECT_TYPE:
2305  return "TYPES";
2306  }
2307 
2308  elog(ERROR, "unrecognized grant object type: %d", (int) objtype);
2309  return "???"; /* keep compiler quiet */
2310 }
#define ERROR
Definition: elog.h:43
#define elog
Definition: elog.h:219

◆ stringify_grantobjtype()

static const char * stringify_grantobjtype ( GrantObjectType  objtype)
static

Definition at line 2226 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_PROCEDURE, ACL_OBJECT_RELATION, ACL_OBJECT_ROUTINE, ACL_OBJECT_SEQUENCE, ACL_OBJECT_TABLESPACE, ACL_OBJECT_TYPE, elog, and ERROR.

Referenced by pg_event_trigger_ddl_commands().

2227 {
2228  switch (objtype)
2229  {
2230  case ACL_OBJECT_COLUMN:
2231  return "COLUMN";
2232  case ACL_OBJECT_RELATION:
2233  return "TABLE";
2234  case ACL_OBJECT_SEQUENCE:
2235  return "SEQUENCE";
2236  case ACL_OBJECT_DATABASE:
2237  return "DATABASE";
2238  case ACL_OBJECT_DOMAIN:
2239  return "DOMAIN";
2240  case ACL_OBJECT_FDW:
2241  return "FOREIGN DATA WRAPPER";
2243  return "FOREIGN SERVER";
2244  case ACL_OBJECT_FUNCTION:
2245  return "FUNCTION";
2246  case ACL_OBJECT_LANGUAGE:
2247  return "LANGUAGE";
2249  return "LARGE OBJECT";
2250  case ACL_OBJECT_NAMESPACE:
2251  return "SCHEMA";
2252  case ACL_OBJECT_PROCEDURE:
2253  return "PROCEDURE";
2254  case ACL_OBJECT_ROUTINE:
2255  return "ROUTINE";
2256  case ACL_OBJECT_TABLESPACE:
2257  return "TABLESPACE";
2258  case ACL_OBJECT_TYPE:
2259  return "TYPE";
2260  }
2261 
2262  elog(ERROR, "unrecognized grant object type: %d", (int) objtype);
2263  return "???"; /* keep compiler quiet */
2264 }
#define ERROR
Definition: elog.h:43
#define elog
Definition: elog.h:219

◆ trackDroppedObjectsNeeded()

bool trackDroppedObjectsNeeded ( void  )

Definition at line 1306 of file event_trigger.c.

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

Referenced by deleteObjectsInList(), and EventTriggerBeginCompleteQuery().

1307 {
1308  /*
1309  * true if any sql_drop, table_rewrite, ddl_command_end event trigger
1310  * exists
1311  */
1312  return list_length(EventCacheLookup(EVT_SQLDrop)) > 0 ||
1315 }
static int list_length(const List *l)
Definition: pg_list.h:89
List * EventCacheLookup(EventTriggerEvent event)
Definition: evtcache.c:64

◆ validate_ddl_tags()

static void validate_ddl_tags ( const char *  filtervar,
List taglist 
)
static

Definition at line 257 of file event_trigger.c.

References check_ddl_tag(), ereport, errcode(), errmsg(), ERROR, EVENT_TRIGGER_COMMAND_TAG_NOT_RECOGNIZED, EVENT_TRIGGER_COMMAND_TAG_NOT_SUPPORTED, lfirst, and strVal.

Referenced by CreateEventTrigger().

258 {
259  ListCell *lc;
260 
261  foreach(lc, taglist)
262  {
263  const char *tag = strVal(lfirst(lc));
265 
266  result = check_ddl_tag(tag);
268  ereport(ERROR,
269  (errcode(ERRCODE_SYNTAX_ERROR),
270  errmsg("filter value \"%s\" not recognized for filter variable \"%s\"",
271  tag, filtervar)));
273  ereport(ERROR,
274  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
275  /* translator: %s represents an SQL statement name */
276  errmsg("event triggers are not supported for %s",
277  tag)));
278  }
279 }
#define strVal(v)
Definition: value.h:54
int errcode(int sqlerrcode)
Definition: elog.c:575
static event_trigger_command_tag_check_result check_ddl_tag(const char *tag)
#define ERROR
Definition: elog.h:43
#define ereport(elevel, rest)
Definition: elog.h:122
event_trigger_command_tag_check_result
Definition: event_trigger.c:80
#define lfirst(lc)
Definition: pg_list.h:106
int errmsg(const char *fmt,...)
Definition: elog.c:797

◆ validate_table_rewrite_tags()

static void validate_table_rewrite_tags ( const char *  filtervar,
List taglist 
)
static

Definition at line 332 of file event_trigger.c.

References check_table_rewrite_ddl_tag(), ereport, errcode(), errmsg(), ERROR, EVENT_TRIGGER_COMMAND_TAG_NOT_SUPPORTED, lfirst, and strVal.

Referenced by CreateEventTrigger().

333 {
334  ListCell *lc;
335 
336  foreach(lc, taglist)
337  {
338  const char *tag = strVal(lfirst(lc));
340 
341  result = check_table_rewrite_ddl_tag(tag);
343  ereport(ERROR,
344  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
345  /* translator: %s represents an SQL statement name */
346  errmsg("event triggers are not supported for %s",
347  tag)));
348  }
349 }
#define strVal(v)
Definition: value.h:54
int errcode(int sqlerrcode)
Definition: elog.c:575
#define ERROR
Definition: elog.h:43
static event_trigger_command_tag_check_result check_table_rewrite_ddl_tag(const char *tag)
#define ereport(elevel, rest)
Definition: elog.h:122
event_trigger_command_tag_check_result
Definition: event_trigger.c:80
#define lfirst(lc)
Definition: pg_list.h:106
int errmsg(const char *fmt,...)
Definition: elog.c:797

Variable Documentation

◆ currentEventTriggerState

EventTriggerQueryState* currentEventTriggerState = NULL
static

Definition at line 72 of file event_trigger.c.

Referenced by EventTriggerBeginCompleteQuery().

◆ event_trigger_support

event_trigger_support_data event_trigger_support[]
static

Definition at line 88 of file event_trigger.c.