Loading...
Searching...
No Matches
trigger.c File Reference
#include "postgres.h"#include "access/genam.h"#include "access/htup_details.h"#include "access/relation.h"#include "access/sysattr.h"#include "access/table.h"#include "access/tableam.h"#include "access/xact.h"#include "catalog/catalog.h"#include "catalog/dependency.h"#include "catalog/indexing.h"#include "catalog/objectaccess.h"#include "catalog/partition.h"#include "catalog/pg_constraint.h"#include "catalog/pg_inherits.h"#include "catalog/pg_proc.h"#include "catalog/pg_trigger.h"#include "catalog/pg_type.h"#include "commands/trigger.h"#include "executor/executor.h"#include "miscadmin.h"#include "nodes/bitmapset.h"#include "nodes/makefuncs.h"#include "optimizer/optimizer.h"#include "parser/parse_clause.h"#include "parser/parse_collate.h"#include "parser/parse_func.h"#include "parser/parse_relation.h"#include "partitioning/partdesc.h"#include "pgstat.h"#include "rewrite/rewriteHandler.h"#include "rewrite/rewriteManip.h"#include "storage/lmgr.h"#include "utils/acl.h"#include "utils/builtins.h"#include "utils/fmgroids.h"#include "utils/guc_hooks.h"#include "utils/inval.h"#include "utils/lsyscache.h"#include "utils/memutils.h"#include "utils/plancache.h"#include "utils/rel.h"#include "utils/snapmgr.h"#include "utils/syscache.h"#include "utils/tuplestore.h"
Include dependency graph for trigger.c:
Go to the source code of this file.
Data Structures | |
| struct | SetConstraintTriggerData |
| struct | SetConstraintStateData |
| struct | AfterTriggerSharedData |
| struct | AfterTriggerEventData |
| struct | AfterTriggerEventDataNoOids |
| struct | AfterTriggerEventDataOneCtid |
| struct | AfterTriggerEventDataZeroCtids |
| struct | AfterTriggerEventChunk |
| struct | AfterTriggerEventList |
| struct | AfterTriggersData |
| struct | AfterTriggersQueryData |
| struct | AfterTriggersTransData |
| struct | AfterTriggersTableData |
Variables | |
| int | SessionReplicationRole = SESSION_REPLICATION_ROLE_ORIGIN |
| static int | MyTriggerDepth = 0 |
| static AfterTriggersData | afterTriggers |
Macro Definition Documentation
◆ AFTER_TRIGGER_1CTID
◆ AFTER_TRIGGER_2CTID
◆ AFTER_TRIGGER_CP_UPDATE
◆ AFTER_TRIGGER_DONE
◆ AFTER_TRIGGER_FDW_FETCH
◆ AFTER_TRIGGER_FDW_REUSE
◆ AFTER_TRIGGER_IN_PROGRESS
◆ AFTER_TRIGGER_OFFSET
◆ AFTER_TRIGGER_TUP_BITS
◆ CHUNK_DATA_START
| #define CHUNK_DATA_START | ( | cptr | ) | ((char *) (cptr) + MAXALIGN(sizeof(AfterTriggerEventChunk))) |
◆ for_each_chunk
| #define for_each_chunk | ( | cptr, | |
| evtlist | |||
| ) | for (cptr = (evtlist).head; cptr != NULL; cptr = cptr->next) |
Definition at line 3781 of file trigger.c.
3880{
3885
3886 /* per-query-level data: */
3888 int query_depth; /* current index in above array */
3889 int maxquerydepth; /* allocated len of above array */
3890
3891 /* per-subtransaction-level data: */
3893 int maxtransdepth; /* allocated len of above array */
3894} AfterTriggersData;
3895
3897{
3901};
3902
3904{
3905 /* these fields are just for resetting at subtrans abort: */
3910};
3911
3913{
3914 /* relid + cmdType form the lookup key for these structs: */
3921
3922 /* "old" transition table for UPDATE/DELETE, if any */
3924 /* "new" transition table for INSERT/UPDATE, if any */
3926
3928};
3929
3931
3933 AfterTriggerEvent event,
3937 TriggerDesc *trigdesc,
3938 FmgrInfo *finfo,
3939 Instrumentation *instr,
3944 CmdType cmdType);
3946 TupleDesc tupdesc);
3950 TransitionCaptureState *transition_capture);
3952 int event,
3953 TransitionCaptureState *transition_capture,
3955 TupleTableSlot *slot,
3957 Tuplestorestate *tuplestore);
3964
3965
3966/*
3967 * Get the FDW tuplestore for the current trigger query level, creating it
3968 * if necessary.
3969 */
3972{
3973 Tuplestorestate *ret;
3974
3977 {
3980
3981 /*
3982 * Make the tuplestore valid until end of subtransaction. We really
3983 * only need it until AfterTriggerEndQuery().
3984 */
3988
3990
3993
3995 }
3996
3997 return ret;
3998}
3999
4000/* ----------
4001 * afterTriggerCheckState()
4002 *
4003 * Returns true if the trigger event is actually in state DEFERRED.
4004 * ----------
4005 */
4006static bool
4008{
4012
4013 /*
4014 * For not-deferrable triggers (i.e. normal AFTER ROW triggers and
4015 * constraints declared NOT DEFERRABLE), the state is always false.
4016 */
4018 return false;
4019
4020 /*
4021 * If constraint state exists, SET CONSTRAINTS might have been executed
4022 * either for this trigger or for all triggers.
4023 */
4025 {
4026 /* Check for SET CONSTRAINTS for this specific trigger. */
4028 {
4031 }
4032
4033 /* Check for SET CONSTRAINTS ALL. */
4036 }
4037
4038 /*
4039 * Otherwise return the default state for the trigger.
4040 */
4042}
4043
4044/* ----------
4045 * afterTriggerCopyBitmap()
4046 *
4047 * Copy bitmap into AfterTriggerEvents memory context, which is where the after
4048 * trigger events are kept.
4049 * ----------
4050 */
4053{
4056
4059
4061
4063
4065
4067}
4068
4069/* ----------
4070 * afterTriggerAddEvent()
4071 *
4072 * Add a new trigger event to the specified queue.
4073 * The passed-in event data is copied.
4074 * ----------
4075 */
4076static void
4079{
4085
4086 /*
4087 * If empty list or not enough room in the tail chunk, make a new chunk.
4088 * We assume here that a new shared record will always be needed.
4089 */
4093 {
4095
4096 /* Create event context if we didn't already */
4100 "AfterTriggerEvents",
4101 ALLOCSET_DEFAULT_SIZES);
4102
4103 /*
4104 * Chunk size starts at 1KB and is allowed to increase up to 1MB.
4105 * These numbers are fairly arbitrary, though there is a hard limit at
4106 * AFTER_TRIGGER_OFFSET; else we couldn't link event records to their
4107 * shared records using the available space in ate_flags. Another
4108 * constraint is that if the chunk size gets too huge, the search loop
4109 * below would get slow given a (not too common) usage pattern with
4110 * many distinct event types in a chunk. Therefore, we double the
4111 * preceding chunk size only if there weren't too many shared records
4112 * in the preceding chunk; otherwise we halve it. This gives us some
4113 * ability to adapt to the actual usage pattern of the current query
4114 * while still having large chunk sizes in typical usage. All chunk
4115 * sizes used should be MAXALIGN multiples, to ensure that the shared
4116 * records will be aligned safely.
4117 */
4118#define MIN_CHUNK_SIZE 1024
4119#define MAX_CHUNK_SIZE (1024*1024)
4120
4121#if MAX_CHUNK_SIZE > (AFTER_TRIGGER_OFFSET+1)
4122#error MAX_CHUNK_SIZE must not exceed AFTER_TRIGGER_OFFSET
4123#endif
4124
4127 else
4128 {
4129 /* preceding chunk size... */
4131 /* check number of shared records in preceding chunk */
4135 else
4138 }
4144
4146 {
4149 }
4150 else
4153 /* events->tailfree is now out of sync, but we'll fix it below */
4154 }
4155
4156 /*
4157 * Try to locate a matching shared-data record already in the chunk. If
4158 * none, make a new one. The search begins with the most recently added
4159 * record, since newer ones are most likely to match.
4160 */
4163 newshared++)
4164 {
4165 /* compare fields roughly by probability of them being different */
4168 newshared->ats_firing_id == 0 &&
4173 evtshared->ats_modifiedcols))
4174 break;
4175 }
4177 {
4180 /* now we must make a suitably-long-lived copy of the bitmap */
4184 }
4185
4186 /* Insert the data */
4189 /* ... and link the new event to its shared record */
4192
4195}
4196
4197/* ----------
4198 * afterTriggerFreeEventList()
4199 *
4200 * Free all the event storage in the given list.
4201 * ----------
4202 */
4203static void
4205{
4207
4209 {
4212 }
4215}
4216
4217/* ----------
4218 * afterTriggerRestoreEventList()
4219 *
4220 * Restore an event list to its prior length, removing all the events
4221 * added since it had the value old_events.
4222 * ----------
4223 */
4224static void
4227{
4230
4232 {
4233 /* restoring to a completely empty state, so free everything */
4234 afterTriggerFreeEventList(events);
4235 }
4236 else
4237 {
4238 *events = *old_events;
4239 /* free any chunks after the last one we want to keep */
4241 {
4244 }
4245 /* and clean up the tail chunk to be the right length */
4248
4249 /*
4250 * We don't make any effort to remove now-unused shared data records.
4251 * They might still be useful, anyway.
4252 */
4253 }
4254}
4255
4256/* ----------
4257 * afterTriggerDeleteHeadEventChunk()
4258 *
4259 * Remove the first chunk of events from the query level's event list.
4260 * Keep any event list pointers elsewhere in the query level's data
4261 * structures in sync.
4262 * ----------
4263 */
4264static void
4266{
4269
4271
4272 /*
4273 * First, update any pointers in the per-table data, so that they won't be
4274 * dangling. Resetting obsoleted pointers to NULL will make
4275 * cancel_prior_stmt_triggers start from the list head, which is fine.
4276 */
4278 {
4280
4282 table->after_trig_events.tail == target)
4283 {
4287 }
4288 }
4289
4290 /* Now we can flush the head chunk */
4292 pfree(target);
4293}
4294
4295
4296/* ----------
4297 * AfterTriggerExecute()
4298 *
4299 * Fetch the required tuples back from the heap and fire one
4300 * single trigger function.
4301 *
4302 * Frequently, this will be fired many times in a row for triggers of
4303 * a single relation. Therefore, we cache the open relation and provide
4304 * fmgr lookup cache space at the caller level. (For triggers fired at
4305 * the end of a query, we can even piggyback on the executor's state.)
4306 *
4307 * When fired for a cross-partition update of a partitioned table, the old
4308 * tuple is fetched using 'src_relInfo' (the source leaf partition) and
4309 * the new tuple using 'dst_relInfo' (the destination leaf partition), though
4310 * both are converted into the root partitioned table's format before passing
4311 * to the trigger function.
4312 *
4313 * event: event currently being fired.
4314 * relInfo: result relation for event.
4315 * src_relInfo: source partition of a cross-partition update
4316 * dst_relInfo: its destination partition
4317 * trigdesc: working copy of rel's trigger info.
4318 * finfo: array of fmgr lookup cache entries (one per trigger in trigdesc).
4319 * instr: array of EXPLAIN ANALYZE instrumentation nodes (one per trigger),
4320 * or NULL if no instrumentation is wanted.
4321 * per_tuple_context: memory context to call trigger function in.
4322 * trig_tuple_slot1: scratch slot for tg_trigtuple (foreign tables only)
4323 * trig_tuple_slot2: scratch slot for tg_newtuple (foreign tables only)
4324 * ----------
4325 */
4326static void
4328 AfterTriggerEvent event,
4332 TriggerDesc *trigdesc,
4337{
4345 int save_sec_context;
4350
4351 /*
4352 * Locate trigger in trigdesc. It might not be present, and in fact the
4353 * trigdesc could be NULL, if the trigger was dropped since the event was
4354 * queued. In that case, silently do nothing.
4355 */
4357 return;
4359 {
4361 {
4363 break;
4364 }
4365 }
4367 return;
4368
4369 /*
4370 * If doing EXPLAIN ANALYZE, start charging time to this trigger. We want
4371 * to include time spent re-fetching tuples in the trigger cost.
4372 */
4373 if (instr)
4375
4376 /*
4377 * Fetch the required tuple(s).
4378 */
4380 {
4382 {
4384
4386 trig_tuple_slot1))
4388
4390 TRIGGER_EVENT_UPDATE &&
4392 trig_tuple_slot2))
4394 }
4395 /* fall through */
4397
4398 /*
4399 * Store tuple in the slot so that tg_trigtuple does not reference
4400 * tuplestore memory. (It is formally possible for the trigger
4401 * function to queue trigger events that add to the same
4402 * tuplestore, which can push other tuples out of memory.) The
4403 * distinction is academic, because we start with a minimal tuple
4404 * that is stored as a heap tuple, constructed in different memory
4405 * context, in the slot anyway.
4406 */
4408 LocTriggerData.tg_trigtuple =
4410
4412 TRIGGER_EVENT_UPDATE)
4413 {
4415 LocTriggerData.tg_newtuple =
4417 }
4418 else
4419 {
4421 }
4422 break;
4423
4424 default:
4426 {
4428 src_relInfo);
4429
4431 &(event->ate_ctid1),
4432 SnapshotAny,
4433 src_slot))
4435
4436 /*
4437 * Store the tuple fetched from the source partition into the
4438 * target (root partitioned) table slot, converting if needed.
4439 */
4441 {
4443
4445 if (map)
4446 {
4448 src_slot,
4449 LocTriggerData.tg_trigslot);
4450 }
4451 else
4453 }
4454 else
4456 LocTriggerData.tg_trigtuple =
4458 }
4459 else
4460 {
4462 }
4463
4464 /* don't touch ctid2 if not there */
4468 {
4470 dst_relInfo);
4471
4473 &(event->ate_ctid2),
4474 SnapshotAny,
4475 dst_slot))
4477
4478 /*
4479 * Store the tuple fetched from the destination partition into
4480 * the target (root partitioned) table slot, converting if
4481 * needed.
4482 */
4484 {
4486
4488 if (map)
4489 {
4491 dst_slot,
4492 LocTriggerData.tg_newslot);
4493 }
4494 else
4496 }
4497 else
4499 LocTriggerData.tg_newtuple =
4501 }
4502 else
4503 {
4505 }
4506 }
4507
4508 /*
4509 * Set up the tuplestore information to let the trigger have access to
4510 * transition tables. When we first make a transition table available to
4511 * a trigger, mark it "closed" so that it cannot change anymore. If any
4512 * additional events of the same type get queued in the current trigger
4513 * query level, they'll go into new transition tables.
4514 */
4517 {
4519 {
4522 }
4523
4525 {
4528 }
4529 }
4530
4531 /*
4532 * Setup the remaining trigger information
4533 */
4535 LocTriggerData.tg_event =
4537 LocTriggerData.tg_relation = rel;
4540
4542
4543 /*
4544 * If necessary, become the role that was active when the trigger got
4545 * queued. Note that the role might have been dropped since the trigger
4546 * was queued, but if that is a problem, we will get an error later.
4547 * Checking here would still leave a race condition.
4548 */
4552 save_sec_context | SECURITY_LOCAL_USERID_CHANGE);
4553
4554 /*
4555 * Call the trigger and throw away any possibly returned updated tuple.
4556 * (Don't let ExecCallTriggerFunc measure EXPLAIN time.)
4557 */
4559 tgindx,
4560 finfo,
4561 NULL,
4562 per_tuple_context);
4567
4568 /* Restore the current role if necessary */
4571
4572 /*
4573 * Release resources
4574 */
4579
4580 /* don't clear slots' contents if foreign table */
4582 {
4587 }
4588
4589 /*
4590 * If doing EXPLAIN ANALYZE, stop charging time to this trigger, and count
4591 * one "tuple returned" (really the number of firings).
4592 */
4593 if (instr)
4595}
4596
4597
4598/*
4599 * afterTriggerMarkEvents()
4600 *
4601 * Scan the given event list for not yet invoked events. Mark the ones
4602 * that can be invoked now with the current firing ID.
4603 *
4604 * If move_list isn't NULL, events that are not to be invoked now are
4605 * transferred to move_list.
4606 *
4607 * When immediate_only is true, do not invoke currently-deferred triggers.
4608 * (This will be false only at main transaction exit.)
4609 *
4610 * Returns true if any invokable events were found.
4611 */
4612static bool
4616{
4617 bool found = false;
4619 AfterTriggerEvent event;
4621
4623 {
4626
4629 {
4630 /*
4631 * This trigger hasn't been called or scheduled yet. Check if we
4632 * should call it now.
4633 */
4635 {
4637 }
4638 else
4639 {
4640 /*
4641 * Mark it as to be fired in this firing cycle.
4642 */
4645 found = true;
4646 }
4647 }
4648
4649 /*
4650 * If it's deferred, move it to move_list, if requested.
4651 */
4653 {
4655 /* add it to move_list */
4657 /* mark original copy "done" so we don't do it again */
4659 }
4660 }
4661
4662 /*
4663 * We could allow deferred triggers if, before the end of the
4664 * security-restricted operation, we were to verify that a SET CONSTRAINTS
4665 * ... IMMEDIATE has fired all such triggers. For now, don't bother.
4666 */
4671
4672 return found;
4673}
4674
4675/*
4676 * afterTriggerInvokeEvents()
4677 *
4678 * Scan the given event list for events that are marked as to be fired
4679 * in the current firing cycle, and fire them.
4680 *
4681 * If estate isn't NULL, we use its result relation info to avoid repeated
4682 * openings and closing of trigger target relations. If it is NULL, we
4683 * make one locally to cache the info in case there are multiple trigger
4684 * events per rel.
4685 *
4686 * When delete_ok is true, it's safe to delete fully-processed events.
4687 * (We are not very tense about that: we simply reset a chunk to be empty
4688 * if all its events got fired. The objective here is just to avoid useless
4689 * rescanning of events when a trigger queues new events during transaction
4690 * end, so it's not necessary to worry much about the case where only
4691 * some events are fired.)
4692 *
4693 * Returns true if no unfired events remain in the list (this allows us
4694 * to avoid repeating afterTriggerMarkEvents).
4695 */
4696static bool
4699 EState *estate,
4701{
4713
4714 /* Make a local EState if need be */
4716 {
4717 estate = CreateExecutorState();
4719 }
4720
4721 /* Make a per-tuple memory context for trigger function calls */
4722 per_tuple_context =
4724 "AfterTriggerTupleContext",
4725 ALLOCSET_DEFAULT_SIZES);
4726
4728 {
4729 AfterTriggerEvent event;
4731
4733 {
4735
4736 /*
4737 * Is it one for me to fire?
4738 */
4741 {
4743 *dst_rInfo;
4744
4745 /*
4746 * So let's fire it... but first, find the correct relation if
4747 * this is not the same relation as before.
4748 */
4750 {
4752 NULL);
4753 rel = rInfo->ri_RelationDesc;
4754 /* Catch calls with insufficient relcache refcounting */
4756 trigdesc = rInfo->ri_TrigDesc;
4757 /* caution: trigdesc could be NULL here */
4758 finfo = rInfo->ri_TrigFunctions;
4759 instr = rInfo->ri_TrigInstrument;
4761 {
4765 }
4767 {
4769 &TTSOpsMinimalTuple);
4771 &TTSOpsMinimalTuple);
4772 }
4773 }
4774
4775 /*
4776 * Look up source and destination partition result rels of a
4777 * cross-partition update event.
4778 */
4780 AFTER_TRIGGER_CP_UPDATE)
4781 {
4785 event->ate_src_part,
4786 rInfo);
4788 event->ate_dst_part,
4789 rInfo);
4790 }
4791 else
4793
4794 /*
4795 * Fire it. Note that the AFTER_TRIGGER_IN_PROGRESS flag is
4796 * still set, so recursive examinations of the event list
4797 * won't try to re-fire it.
4798 */
4801 trigdesc, finfo, instr,
4803
4804 /*
4805 * Mark the event as done.
4806 */
4809 }
4811 {
4812 /* something remains to be done */
4814 }
4815 }
4816
4817 /* Clear the chunk if delete_ok and nothing left of interest */
4819 {
4822
4823 /*
4824 * If it's last chunk, must sync event list's tailfree too. Note
4825 * that delete_ok must NOT be passed as true if there could be
4826 * additional AfterTriggerEventList values pointing at this event
4827 * list, since we'd fail to fix their copies of tailfree.
4828 */
4831 }
4832 }
4834 {
4837 }
4838
4839 /* Release working resources */
4841
4843 {
4844 ExecCloseResultRelations(estate);
4846 FreeExecutorState(estate);
4847 }
4848
4850}
4851
4852
4853/*
4854 * GetAfterTriggersTableData
4855 *
4856 * Find or create an AfterTriggersTableData struct for the specified
4857 * trigger event (relation + operation type). Ignore existing structs
4858 * marked "closed"; we don't want to put any additional tuples into them,
4859 * nor change their stmt-triggers-fired state.
4860 *
4861 * Note: the AfterTriggersTableData list is allocated in the current
4862 * (sub)transaction's CurTransactionContext. This is OK because
4863 * we don't need it to live past AfterTriggerEndQuery.
4864 */
4867{
4872
4873 /* At this level, cmdType should not be, eg, CMD_MERGE */
4875 cmdType == CMD_UPDATE ||
4876 cmdType == CMD_DELETE);
4877
4878 /* Caller should have ensured query_depth is OK. */
4882
4884 {
4887 !table->closed)
4889 }
4890
4892
4894 table->relid = relid;
4895 table->cmdType = cmdType;
4897
4899
4901}
4902
4903/*
4904 * Returns a TupleTableSlot suitable for holding the tuples to be put
4905 * into AfterTriggersTableData's transition table tuplestores.
4906 */
4909 TupleDesc tupdesc)
4910{
4911 /* Create it if not already done. */
4913 {
4915
4916 /*
4917 * We need this slot only until AfterTriggerEndQuery, but making it
4918 * last till end-of-subxact is good enough. It'll be freed by
4919 * AfterTriggerFreeQuery(). However, the passed-in tupdesc might have
4920 * a different lifespan, so we'd better make a copy of that.
4921 */
4923 tupdesc = CreateTupleDescCopy(tupdesc);
4926 }
4927
4929}
4930
4931/*
4932 * MakeTransitionCaptureState
4933 *
4934 * Make a TransitionCaptureState object for the given TriggerDesc, target
4935 * relation, and operation type. The TCS object holds all the state needed
4936 * to decide whether to capture tuples in transition tables.
4937 *
4938 * If there are no triggers in 'trigdesc' that request relevant transition
4939 * tables, then return NULL.
4940 *
4941 * The resulting object can be passed to the ExecAR* functions. When
4942 * dealing with child tables, the caller can set tcs_original_insert_tuple
4943 * to avoid having to reconstruct the original tuple in the root table's
4944 * format.
4945 *
4946 * Note that we copy the flags from a parent table into this struct (rather
4947 * than subsequently using the relation's TriggerDesc directly) so that we can
4948 * use it to control collection of transition tuples from child tables.
4949 *
4950 * Per SQL spec, all operations of the same kind (INSERT/UPDATE/DELETE)
4951 * on the same table during one query should share one transition table.
4952 * Therefore, the Tuplestores are owned by an AfterTriggersTableData struct
4953 * looked up using the table OID + CmdType, and are merely referenced by
4954 * the TransitionCaptureState objects we hand out to callers.
4955 */
4956TransitionCaptureState *
4958{
4961 need_new_upd,
4962 need_old_del,
4963 need_new_ins;
4969
4972
4973 /* Detect which table(s) we need. */
4974 switch (cmdType)
4975 {
4979 break;
4984 break;
4988 break;
4994 break;
4995 default:
4997 /* keep compiler quiet */
4999 break;
5000 }
5003
5004 /* Check state, like AfterTriggerSaveEvent. */
5007
5008 /* Be sure we have enough space to record events at this query depth. */
5010 AfterTriggerEnlargeQueryState();
5011
5012 /*
5013 * Find or create AfterTriggersTableData struct(s) to hold the
5014 * tuplestore(s). If there's a matching struct but it's marked closed,
5015 * ignore it; we need a newer one.
5016 *
5017 * Note: MERGE must use the same AfterTriggersTableData structs as INSERT,
5018 * UPDATE, and DELETE, so that any MERGE'd tuples are added to the same
5019 * tuplestores as tuples from any INSERT, UPDATE, or DELETE commands
5020 * running in the same top-level command (e.g., in a writable CTE).
5021 *
5022 * Note: the AfterTriggersTableData list, as well as the tuplestores, are
5023 * allocated in the current (sub)transaction's CurTransactionContext, and
5024 * the tuplestores are managed by the (sub)transaction's resource owner.
5025 * This is sufficient lifespan because we do not allow triggers using
5026 * transition tables to be deferrable; they will be fired during
5027 * AfterTriggerEndQuery, after which it's okay to delete the data.
5028 */
5031 else
5033
5036 else
5038
5041 else
5043
5044 /* Now create required tuplestore(s), if we don't have them already. */
5048
5057
5060
5061 /* Now build the TransitionCaptureState struct, in caller's context */
5070
5072}
5073
5074
5075/* ----------
5076 * AfterTriggerBeginXact()
5077 *
5078 * Called at transaction start (either BEGIN or implicit for single
5079 * statement outside of transaction block).
5080 * ----------
5081 */
5082void
5084{
5085 /*
5086 * Initialize after-trigger state structure to empty
5087 */
5090
5091 /*
5092 * Verify that there is no leftover state remaining. If these assertions
5093 * trip, it means that AfterTriggerEndXact wasn't called or didn't clean
5094 * up properly.
5095 */
5103}
5104
5105
5106/* ----------
5107 * AfterTriggerBeginQuery()
5108 *
5109 * Called just before we start processing a single query within a
5110 * transaction (or subtransaction). Most of the real work gets deferred
5111 * until somebody actually tries to queue a trigger event.
5112 * ----------
5113 */
5114void
5116{
5117 /* Increase the query stack depth */
5119}
5120
5121
5122/* ----------
5123 * AfterTriggerEndQuery()
5124 *
5125 * Called after one query has been completely processed. At this time
5126 * we invoke all AFTER IMMEDIATE trigger events queued by the query, and
5127 * transfer deferred trigger events to the global deferred-trigger list.
5128 *
5129 * Note that this must be called BEFORE closing down the executor
5130 * with ExecutorEnd, because we make use of the EState's info about
5131 * target relations. Normally it is called from ExecutorFinish.
5132 * ----------
5133 */
5134void
5136{
5138
5139 /* Must be inside a query, too */
5141
5142 /*
5143 * If we never even got as far as initializing the event stack, there
5144 * certainly won't be any events, so exit quickly.
5145 */
5147 {
5149 return;
5150 }
5151
5152 /*
5153 * Process all immediate-mode triggers queued by the query, and move the
5154 * deferred ones to the main list of deferred events.
5155 *
5156 * Notice that we decide which ones will be fired, and put the deferred
5157 * ones on the main list, before anything is actually fired. This ensures
5158 * reasonably sane behavior if a trigger function does SET CONSTRAINTS ...
5159 * IMMEDIATE: all events we have decided to defer will be available for it
5160 * to fire.
5161 *
5162 * We loop in case a trigger queues more events at the same query level.
5163 * Ordinary trigger functions, including all PL/pgSQL trigger functions,
5164 * will instead fire any triggers in a dedicated query level. Foreign key
5165 * enforcement triggers do add to the current query level, thanks to their
5166 * passing fire_triggers = false to SPI_execute_snapshot(). Other
5167 * C-language triggers might do likewise.
5168 *
5169 * If we find no firable events, we don't have to increment
5170 * firing_counter.
5171 */
5173
5174 for (;;)
5175 {
5177 {
5180
5182 break; /* all fired */
5183
5184 /*
5185 * Firing a trigger could result in query_stack being repalloc'd,
5186 * so we must recalculate qs after each afterTriggerInvokeEvents
5187 * call. Furthermore, it's unsafe to pass delete_ok = true here,
5188 * because that could cause afterTriggerInvokeEvents to try to
5189 * access qs->events after the stack has been repalloc'd.
5190 */
5192
5193 /*
5194 * We'll need to scan the events list again. To reduce the cost
5195 * of doing so, get rid of completely-fired chunks. We know that
5196 * all events were marked IN_PROGRESS or DONE at the conclusion of
5197 * afterTriggerMarkEvents, so any still-interesting events must
5198 * have been added after that, and so must be in the chunk that
5199 * was then the tail chunk, or in later chunks. So, zap all
5200 * chunks before oldtail. This is approximately the same set of
5201 * events we would have gotten rid of by passing delete_ok = true.
5202 */
5206 }
5207 else
5208 break;
5209 }
5210
5211 /* Release query-level-local storage, including tuplestores if any */
5213
5215}
5216
5217
5218/*
5219 * AfterTriggerFreeQuery
5220 * Release subsidiary storage for a trigger query level.
5221 * This includes closing down tuplestores.
5222 * Note: it's important for this to be safe if interrupted by an error
5223 * and then called again for the same query level.
5224 */
5225static void
5227{
5228 Tuplestorestate *ts;
5229 List *tables;
5231
5232 /* Drop the trigger events */
5234
5235 /* Drop FDW tuplestore if any */
5236 ts = qs->fdw_tuplestore;
5238 if (ts)
5239 tuplestore_end(ts);
5240
5241 /* Release per-table subsidiary storage */
5242 tables = qs->tables;
5244 {
5246
5247 ts = table->old_tuplestore;
5249 if (ts)
5250 tuplestore_end(ts);
5251 ts = table->new_tuplestore;
5253 if (ts)
5254 tuplestore_end(ts);
5256 {
5258
5260 ExecDropSingleTupleTableSlot(slot);
5261 }
5262 }
5263
5264 /*
5265 * Now free the AfterTriggersTableData structs and list cells. Reset list
5266 * pointer first; if list_free_deep somehow gets an error, better to leak
5267 * that storage than have an infinite loop.
5268 */
5270 list_free_deep(tables);
5271}
5272
5273
5274/* ----------
5275 * AfterTriggerFireDeferred()
5276 *
5277 * Called just before the current transaction is committed. At this
5278 * time we invoke all pending DEFERRED triggers.
5279 *
5280 * It is possible for other modules to queue additional deferred triggers
5281 * during pre-commit processing; therefore xact.c may have to call this
5282 * multiple times.
5283 * ----------
5284 */
5285void
5287{
5288 AfterTriggerEventList *events;
5290
5291 /* Must not be inside a query */
5293
5294 /*
5295 * If there are any triggers to fire, make sure we have set a snapshot for
5296 * them to use. (Since PortalRunUtility doesn't set a snap for COMMIT, we
5297 * can't assume ActiveSnapshot is valid on entry.)
5298 */
5301 {
5304 }
5305
5306 /*
5307 * Run all the remaining triggers. Loop until they are all gone, in case
5308 * some trigger queues more for us to do.
5309 */
5311 {
5313
5315 break; /* all fired */
5316 }
5317
5318 /*
5319 * We don't bother freeing the event list, since it will go away anyway
5320 * (and more efficiently than via pfree) in AfterTriggerEndXact.
5321 */
5322
5324 PopActiveSnapshot();
5325}
5326
5327
5328/* ----------
5329 * AfterTriggerEndXact()
5330 *
5331 * The current transaction is finishing.
5332 *
5333 * Any unfired triggers are canceled so we simply throw
5334 * away anything we know.
5335 *
5336 * Note: it is possible for this to be called repeatedly in case of
5337 * error during transaction abort; therefore, do not complain if
5338 * already closed down.
5339 * ----------
5340 */
5341void
5343{
5344 /*
5345 * Forget the pending-events list.
5346 *
5347 * Since all the info is in TopTransactionContext or children thereof, we
5348 * don't really need to do anything to reclaim memory. However, the
5349 * pending-events list could be large, and so it's useful to discard it as
5350 * soon as possible --- especially if we are aborting because we ran out
5351 * of memory for the list!
5352 */
5354 {
5360 }
5361
5362 /*
5363 * Forget any subtransaction state as well. Since this can't be very
5364 * large, we let the eventual reset of TopTransactionContext free the
5365 * memory instead of doing it here.
5366 */
5369
5370
5371 /*
5372 * Forget the query stack and constraint-related state information. As
5373 * with the subtransaction state information, we don't bother freeing the
5374 * memory here.
5375 */
5379
5380 /* No more afterTriggers manipulation until next transaction starts. */
5382}
5383
5384/*
5385 * AfterTriggerBeginSubXact()
5386 *
5387 * Start a subtransaction.
5388 */
5389void
5391{
5393
5394 /*
5395 * Allocate more space in the trans_stack if needed. (Note: because the
5396 * minimum nest level of a subtransaction is 2, we waste the first couple
5397 * entries of the array; not worth the notational effort to avoid it.)
5398 */
5400 {
5402 {
5403 /* Arbitrarily initialize for max of 8 subtransaction levels */
5408 }
5409 else
5410 {
5411 /* repalloc will keep the stack in the same context */
5413
5418 }
5419 }
5420
5421 /*
5422 * Push the current information into the stack. The SET CONSTRAINTS state
5423 * is not saved until/unless changed. Likewise, we don't make a
5424 * per-subtransaction event context until needed.
5425 */
5430}
5431
5432/*
5433 * AfterTriggerEndSubXact()
5434 *
5435 * The current subtransaction is ending.
5436 */
5437void
5439{
5442 AfterTriggerEvent event;
5445
5446 /*
5447 * Pop the prior state if needed.
5448 */
5450 {
5452 /* If we saved a prior state, we don't need it anymore */
5456 /* this avoids double pfree if error later: */
5460 }
5461 else
5462 {
5463 /*
5464 * Aborting. It is possible subxact start failed before calling
5465 * AfterTriggerBeginSubXact, in which case we mustn't risk touching
5466 * trans_stack levels that aren't there.
5467 */
5469 return;
5470
5471 /*
5472 * Release query-level storage for queries being aborted, and restore
5473 * query_depth to its pre-subxact value. This assumes that a
5474 * subtransaction will not add events to query levels started in a
5475 * earlier transaction state.
5476 */
5478 {
5482 }
5485
5486 /*
5487 * Restore the global deferred-event list to its former length,
5488 * discarding any events queued by the subxact.
5489 */
5492
5493 /*
5494 * Restore the trigger state. If the saved state is NULL, then this
5495 * subxact didn't save it, so it doesn't need restoring.
5496 */
5499 {
5502 }
5503 /* this avoids double pfree if error later: */
5505
5506 /*
5507 * Scan for any remaining deferred events that were marked DONE or IN
5508 * PROGRESS by this subxact or a child, and un-mark them. We can
5509 * recognize such events because they have a firing ID greater than or
5510 * equal to the firing_counter value we saved at subtransaction start.
5511 * (This essentially assumes that the current subxact includes all
5512 * subxacts started after it.)
5513 */
5516 {
5518
5521 {
5523 event->ate_flags &=
5525 }
5526 }
5527 }
5528}
5529
5530/*
5531 * Get the transition table for the given event and depending on whether we are
5532 * processing the old or the new tuple.
5533 */
5538 TransitionCaptureState *transition_capture)
5539{
5545
5546 /*
5547 * For INSERT events NEW should be non-NULL, for DELETE events OLD should
5548 * be non-NULL, whereas for UPDATE events normally both OLD and NEW are
5549 * non-NULL. But for UPDATE events fired for capturing transition tuples
5550 * during UPDATE partition-key row movement, OLD is NULL when the event is
5551 * for a row being inserted, whereas NEW is NULL when the event is for a
5552 * row being deleted.
5553 */
5558
5560 {
5566 }
5568 {
5574 }
5575
5576 return tuplestore;
5577}
5578
5579/*
5580 * Add the given heap tuple to the given tuplestore, applying the conversion
5581 * map if necessary.
5582 *
5583 * If original_insert_tuple is given, we can add that tuple without conversion.
5584 */
5585static void
5587 int event,
5588 TransitionCaptureState *transition_capture,
5590 TupleTableSlot *slot,
5592 Tuplestorestate *tuplestore)
5593{
5594 TupleConversionMap *map;
5595
5596 /*
5597 * Nothing needs to be done if we don't have a tuplestore.
5598 */
5600 return;
5601
5605 {
5607 TupleTableSlot *storeslot;
5608
5609 switch (event)
5610 {
5613 break;
5616 break;
5619 break;
5620 default:
5623 break;
5624 }
5625
5628 tuplestore_puttupleslot(tuplestore, storeslot);
5629 }
5630 else
5631 tuplestore_puttupleslot(tuplestore, slot);
5632}
5633
5634/* ----------
5635 * AfterTriggerEnlargeQueryState()
5636 *
5637 * Prepare the necessary state so that we can record AFTER trigger events
5638 * queued by a query. It is allowed to have nested queries within a
5639 * (sub)transaction, so we need to have separate state for each query
5640 * nesting level.
5641 * ----------
5642 */
5643static void
5645{
5647
5649
5651 {
5653
5658 }
5659 else
5660 {
5661 /* repalloc will keep the stack in the same context */
5664 old_alloc * 2);
5665
5670 }
5671
5672 /* Initialize new array entries to empty */
5674 {
5676
5682
5683 ++init_depth;
5684 }
5685}
5686
5687/*
5688 * Create an empty SetConstraintState with room for numalloc trigstates
5689 */
5692{
5694
5695 /* Behave sanely with numalloc == 0 */
5696 if (numalloc <= 0)
5697 numalloc = 1;
5698
5699 /*
5700 * We assume that zeroing will correctly initialize the state values.
5701 */
5706
5707 state->numalloc = numalloc;
5708
5710}
5711
5712/*
5713 * Copy a SetConstraintState
5714 */
5717{
5719
5721
5727
5729}
5730
5731/*
5732 * Add a per-trigger item to a SetConstraintState. Returns possibly-changed
5733 * pointer to the state object (it will change if we have to repalloc).
5734 */
5738{
5740 {
5742
5750 }
5751
5754 state->numstates++;
5755
5757}
5758
5759/* ----------
5760 * AfterTriggerSetState()
5761 *
5762 * Execute the SET CONSTRAINTS ... utility command.
5763 * ----------
5764 */
5765void
5767{
5769
5770 /* If we haven't already done so, initialize our state. */
5773
5774 /*
5775 * If in a subtransaction, and we didn't save the current state already,
5776 * save it so it can be restored if the subtransaction aborts.
5777 */
5778 if (my_level > 1 &&
5780 {
5783 }
5784
5785 /*
5786 * Handle SET CONSTRAINTS ALL ...
5787 */
5789 {
5790 /*
5791 * Forget any previous SET CONSTRAINTS commands in this transaction.
5792 */
5794
5795 /*
5796 * Set the per-transaction ALL state to known.
5797 */
5800 }
5801 else
5802 {
5808
5809 /*
5810 * Handle SET CONSTRAINTS constraint-name [, ...]
5811 *
5812 * First, identify all the named constraints and make a list of their
5813 * OIDs. Since, unlike the SQL spec, we allow multiple constraints of
5814 * the same name within a schema, the specifications are not
5815 * necessarily unique. Our strategy is to target all matching
5816 * constraints within the first search-path schema that has any
5817 * matches, but disregard matches in schemas beyond the first match.
5818 * (This is a bit odd but it's the historical behavior.)
5819 *
5820 * A constraint in a partitioned table may have corresponding
5821 * constraints in the partitions. Grab those too.
5822 */
5824
5826 {
5828 bool found;
5831
5833 {
5839 constraint->relname)));
5840 }
5841
5842 /*
5843 * If we're given the schema name with the constraint, look only
5844 * in that schema. If given a bare constraint name, use the
5845 * search path to find the first matching constraint.
5846 */
5848 {
5850 false);
5851
5853 }
5854 else
5855 {
5857 }
5858
5859 found = false;
5861 {
5866
5875
5878
5880 {
5882
5883 if (con->condeferrable)
5889 constraint->relname)));
5890 found = true;
5891 }
5892
5894
5895 /*
5896 * Once we've found a matching constraint we do not search
5897 * later parts of the search path.
5898 */
5899 if (found)
5900 break;
5901 }
5902
5904
5905 /*
5906 * Not found ?
5907 */
5908 if (!found)
5912 constraint->relname)));
5913 }
5914
5915 /*
5916 * Scan for any possible descendants of the constraints. We append
5917 * whatever we find to the same list that we're scanning; this has the
5918 * effect that we create new scans for those, too, so if there are
5919 * further descendents, we'll also catch them.
5920 */
5922 {
5925 SysScanDesc scan;
5926 HeapTuple tuple;
5927
5928 ScanKeyInit(&key,
5931 ObjectIdGetDatum(parent));
5932
5934
5936 {
5938
5940 }
5941
5942 systable_endscan(scan);
5943 }
5944
5946
5947 /*
5948 * Now, locate the trigger(s) implementing each of these constraints,
5949 * and make a list of their OIDs.
5950 */
5952
5954 {
5958 HeapTuple htup;
5959
5963 ObjectIdGetDatum(conoid));
5964
5967
5969 {
5971
5972 /*
5973 * Silently skip triggers that are marked as non-deferrable in
5974 * pg_trigger. This is not an error condition, since a
5975 * deferrable RI constraint may have some non-deferrable
5976 * actions.
5977 */
5980 }
5981
5983 }
5984
5986
5987 /*
5988 * Now we can set the trigger states of individual triggers for this
5989 * xact.
5990 */
5992 {
5995 bool found = false;
5997
5999 {
6001 {
6003 found = true;
6004 break;
6005 }
6006 }
6007 if (!found)
6008 {
6011 }
6012 }
6013 }
6014
6015 /*
6016 * SQL99 requires that when a constraint is set to IMMEDIATE, any deferred
6017 * checks against that constraint must be made when the SET CONSTRAINTS
6018 * command is executed -- i.e. the effects of the SET CONSTRAINTS command
6019 * apply retroactively. We've updated the constraints state, so scan the
6020 * list of previously deferred events to fire any that have now become
6021 * immediate.
6022 *
6023 * Obviously, if this was SET ... DEFERRED then it can't have converted
6024 * any unfired events to immediate, so we need do nothing in that case.
6025 */
6027 {
6030
6032 {
6034
6035 /*
6036 * Make sure a snapshot has been established in case trigger
6037 * functions need one. Note that we avoid setting a snapshot if
6038 * we don't find at least one trigger that has to be fired now.
6039 * This is so that BEGIN; SET CONSTRAINTS ...; SET TRANSACTION
6040 * ISOLATION LEVEL SERIALIZABLE; ... works properly. (If we are
6041 * at the start of a transaction it's not possible for any trigger
6042 * events to be queued yet.)
6043 */
6045 {
6048 }
6049
6050 /*
6051 * We can delete fired events if we are at top transaction level,
6052 * but we'd better not if inside a subtransaction, since the
6053 * subtransaction could later get rolled back.
6054 */
6056 !IsSubTransaction()))
6057 break; /* all fired */
6058 }
6059
6061 PopActiveSnapshot();
6062 }
6063}
6064
6065/* ----------
6066 * AfterTriggerPendingOnRel()
6067 * Test to see if there are any pending after-trigger events for rel.
6068 *
6069 * This is used by TRUNCATE, CLUSTER, ALTER TABLE, etc to detect whether
6070 * it is unsafe to perform major surgery on a relation. Note that only
6071 * local pending events are examined. We assume that having exclusive lock
6072 * on a rel guarantees there are no unserviced events in other backends ---
6073 * but having a lock does not prevent there being such events in our own.
6074 *
6075 * In some scenarios it'd be reasonable to remove pending events (more
6076 * specifically, mark them DONE by the current subxact) but without a lot
6077 * of knowledge of the trigger semantics we can't do this in general.
6078 * ----------
6079 */
6080bool
6082{
6083 AfterTriggerEvent event;
6085 int depth;
6086
6087 /* Scan queued events */
6089 {
6091
6092 /*
6093 * We can ignore completed events. (Even if a DONE flag is rolled
6094 * back by subxact abort, it's OK because the effects of the TRUNCATE
6095 * or whatever must get rolled back too.)
6096 */
6098 continue;
6099
6101 return true;
6102 }
6103
6104 /*
6105 * Also scan events queued by incomplete queries. This could only matter
6106 * if TRUNCATE/etc is executed by a function or trigger within an updating
6107 * query on the same relation, which is pretty perverse, but let's check.
6108 */
6109 for (depth = 0; depth <= afterTriggers.query_depth && depth < afterTriggers.maxquerydepth; depth++)
6110 {
6112 {
6114
6116 continue;
6117
6119 return true;
6120 }
6121 }
6122
6123 return false;
6124}
6125
6126/* ----------
6127 * AfterTriggerSaveEvent()
6128 *
6129 * Called by ExecA[RS]...Triggers() to queue up the triggers that should
6130 * be fired for an event.
6131 *
6132 * NOTE: this is called whenever there are any triggers associated with
6133 * the event (even if they are disabled). This function decides which
6134 * triggers actually need to be queued. It is also called after each row,
6135 * even if there are no triggers for that event, if there are any AFTER
6136 * STATEMENT triggers for the statement which use transition tables, so that
6137 * the transition tuplestores can be built. Furthermore, if the transition
6138 * capture is happening for UPDATEd rows being moved to another partition due
6139 * to the partition-key being changed, then this function is called once when
6140 * the row is deleted (to capture OLD row), and once when the row is inserted
6141 * into another partition (to capture NEW row). This is done separately because
6142 * DELETE and INSERT happen on different tables.
6143 *
6144 * Transition tuplestores are built now, rather than when events are pulled
6145 * off of the queue because AFTER ROW triggers are allowed to select from the
6146 * transition tables for the statement.
6147 *
6148 * This contains special support to queue the update events for the case where
6149 * a partitioned table undergoing a cross-partition update may have foreign
6150 * keys pointing into it. Normally, a partitioned table's row triggers are
6151 * not fired because the leaf partition(s) which are modified as a result of
6152 * the operation on the partitioned table contain the same triggers which are
6153 * fired instead. But that general scheme can cause problematic behavior with
6154 * foreign key triggers during cross-partition updates, which are implemented
6155 * as DELETE on the source partition followed by INSERT into the destination
6156 * partition. Specifically, firing DELETE triggers would lead to the wrong
6157 * foreign key action to be enforced considering that the original command is
6158 * UPDATE; in this case, this function is called with relinfo as the
6159 * partitioned table, and src_partinfo and dst_partinfo referring to the
6160 * source and target leaf partitions, respectively.
6161 *
6162 * is_crosspart_update is true either when a DELETE event is fired on the
6163 * source partition (which is to be ignored) or an UPDATE event is fired on
6164 * the root partitioned table.
6165 * ----------
6166 */
6167static void
6174 TransitionCaptureState *transition_capture,
6176{
6186
6187 /*
6188 * Check state. We use a normal test not Assert because it is possible to
6189 * reach here in the wrong state given misconfigured RI triggers, in
6190 * particular deferring a cascade action trigger.
6191 */
6194
6195 /* Be sure we have enough space to record events at this query depth. */
6197 AfterTriggerEnlargeQueryState();
6198
6199 /*
6200 * If the directly named relation has any triggers with transition tables,
6201 * then we need to capture transition tuples.
6202 */
6204 {
6206
6207 /*
6208 * Capture the old tuple in the appropriate transition table based on
6209 * the event.
6210 */
6212 {
6213 Tuplestorestate *old_tuplestore;
6214
6215 old_tuplestore = GetAfterTriggersTransitionTable(event,
6216 oldslot,
6217 NULL,
6218 transition_capture);
6221 }
6222
6223 /*
6224 * Capture the new tuple in the appropriate transition table based on
6225 * the event.
6226 */
6228 {
6229 Tuplestorestate *new_tuplestore;
6230
6231 new_tuplestore = GetAfterTriggersTransitionTable(event,
6232 NULL,
6233 newslot,
6234 transition_capture);
6237 }
6238
6239 /*
6240 * If transition tables are the only reason we're here, return. As
6241 * mentioned above, we can also be here during update tuple routing in
6242 * presence of transition tables, in which case this function is
6243 * called separately for OLD and NEW, so we expect exactly one of them
6244 * to be NULL.
6245 */
6251 return;
6252 }
6253
6254 /*
6255 * We normally don't see partitioned tables here for row level triggers
6256 * except in the special case of a cross-partition update. In that case,
6257 * nodeModifyTable.c:ExecCrossPartitionUpdateForeignKey() calls here to
6258 * queue an update event on the root target partitioned table, also
6259 * passing the source and destination partitions and their tuples.
6260 */
6263 (is_crosspart_update &&
6264 TRIGGER_FIRED_BY_UPDATE(event) &&
6266
6267 /*
6268 * Validate the event code and collect the associated tuple CTIDs.
6269 *
6270 * The event code will be used both as a bitmask and an array offset, so
6271 * validation is important to make sure we don't walk off the edge of our
6272 * arrays.
6273 *
6274 * Also, if we're considering statement-level triggers, check whether we
6275 * already queued a set of them for this event, and cancel the prior set
6276 * if so. This preserves the behavior that statement-level triggers fire
6277 * just once per statement and fire after row-level triggers.
6278 */
6279 switch (event)
6280 {
6284 {
6289 }
6290 else
6291 {
6297 CMD_INSERT, event);
6298 }
6299 break;
6303 {
6308 }
6309 else
6310 {
6316 CMD_DELETE, event);
6317 }
6318 break;
6322 {
6327
6328 /*
6329 * Also remember the OIDs of partitions to fetch these tuples
6330 * out of later in AfterTriggerExecute().
6331 */
6333 {
6335 new_event.ate_src_part =
6337 new_event.ate_dst_part =
6339 }
6340 }
6341 else
6342 {
6348 CMD_UPDATE, event);
6349 }
6350 break;
6357 break;
6358 default:
6361 break;
6362 }
6363
6364 /* Determine flags */
6366 {
6368 {
6371 else
6373 }
6374 else
6376 }
6377
6378 /* else, we'll initialize ate_flags for each trigger */
6379
6381
6382 /*
6383 * Must convert/copy the source and destination partition tuples into the
6384 * root partitioned table's format/slot, because the processing in the
6385 * loop below expects both oldslot and newslot tuples to be in that form.
6386 */
6388 {
6390 TupleConversionMap *map;
6391
6394 if (map)
6396 oldslot,
6397 rootslot);
6398 else
6400
6403 if (map)
6405 newslot,
6406 rootslot);
6407 else
6409 }
6410
6412 {
6414
6416 tgtype_level,
6417 TRIGGER_TYPE_AFTER,
6418 tgtype_event))
6419 continue;
6422 continue;
6423
6425 {
6427 {
6428 fdw_tuplestore = GetCurrentFDWTuplestore();
6430 }
6431 else
6432 /* subsequent event for the same tuple */
6434 }
6435
6436 /*
6437 * If the trigger is a foreign key enforcement trigger, there are
6438 * certain cases where we can skip queueing the event because we can
6439 * tell by inspection that the FK constraint will still pass. There
6440 * are also some cases during cross-partition updates of a partitioned
6441 * table where queuing the event can be skipped.
6442 */
6444 {
6446 {
6448
6449 /*
6450 * For cross-partitioned updates of partitioned PK table,
6451 * skip the event fired by the component delete on the
6452 * source leaf partition unless the constraint originates
6453 * in the partition itself (!tgisclone), because the
6454 * update event that will be fired on the root
6455 * (partitioned) target table will be used to perform the
6456 * necessary foreign key enforcement action.
6457 */
6459 TRIGGER_FIRED_BY_DELETE(event) &&
6460 trigger->tgisclone)
6461 continue;
6462
6463 /* Update or delete on trigger's PK table */
6466 {
6467 /* skip queuing this event */
6468 continue;
6469 }
6470 break;
6471
6473
6474 /*
6475 * Update on trigger's FK table. We can skip the update
6476 * event fired on a partitioned table during a
6477 * cross-partition of that table, because the insert event
6478 * that is fired on the destination leaf partition would
6479 * suffice to perform the necessary foreign key check.
6480 * Moreover, RI_FKey_fk_upd_check_required() expects to be
6481 * passed a tuple that contains system attributes, most of
6482 * which are not present in the virtual slot belonging to
6483 * a partitioned table.
6484 */
6488 {
6489 /* skip queuing this event */
6490 continue;
6491 }
6492 break;
6493
6495
6496 /*
6497 * Not an FK trigger. No need to queue the update event
6498 * fired during a cross-partitioned update of a
6499 * partitioned table, because the same row trigger must be
6500 * present in the leaf partition(s) that are affected as
6501 * part of this update and the events fired on them are
6502 * queued instead.
6503 */
6506 continue;
6507 break;
6508 }
6509 }
6510
6511 /*
6512 * If the trigger is a deferred unique constraint check trigger, only
6513 * queue it if the unique constraint was potentially violated, which
6514 * we know from index insertion time.
6515 */
6517 {
6519 continue; /* Uniqueness definitely not violated */
6520 }
6521
6522 /*
6523 * Fill in event structure and add it to the current query's queue.
6524 * Note we set ats_table to NULL whenever this trigger doesn't use
6525 * transition tables, to improve sharability of the shared event data.
6526 */
6527 new_shared.ats_event =
6535 new_shared.ats_firing_id = 0;
6537 transition_capture != NULL)
6538 {
6539 switch (event)
6540 {
6543 break;
6546 break;
6549 break;
6550 default:
6551 /* Must be TRUNCATE, see switch above */
6553 break;
6554 }
6555 }
6556 else
6559
6562 }
6563
6564 /*
6565 * Finally, spool any foreign tuple(s). The tuplestore squashes them to
6566 * minimal tuples, so this loses any system columns. The executor lost
6567 * those columns before us, for an unrelated reason, so this is fine.
6568 */
6569 if (fdw_tuplestore)
6570 {
6575 }
6576}
6577
6578/*
6579 * Detect whether we already queued BEFORE STATEMENT triggers for the given
6580 * relation + operation, and set the flag so the next call will report "true".
6581 */
6582static bool
6584{
6585 bool result;
6587
6588 /* Check state, like AfterTriggerSaveEvent. */
6591
6592 /* Be sure we have enough space to record events at this query depth. */
6594 AfterTriggerEnlargeQueryState();
6595
6596 /*
6597 * We keep this state in the AfterTriggersTableData that also holds
6598 * transition tables for the relation + operation. In this way, if we are
6599 * forced to make a new set of transition tables because more tuples get
6600 * entered after we've already fired triggers, we will allow a new set of
6601 * statement triggers to get queued.
6602 */
6604 result = table->before_trig_done;
6606 return result;
6607}
6608
6609/*
6610 * If we previously queued a set of AFTER STATEMENT triggers for the given
6611 * relation + operation, and they've not been fired yet, cancel them. The
6612 * caller will queue a fresh set that's after any row-level triggers that may
6613 * have been queued by the current sub-statement, preserving (as much as
6614 * possible) the property that AFTER ROW triggers fire before AFTER STATEMENT
6615 * triggers, and that the latter only fire once. This deals with the
6616 * situation where several FK enforcement triggers sequentially queue triggers
6617 * for the same table into the same trigger query level. We can't fully
6618 * prevent odd behavior though: if there are AFTER ROW triggers taking
6619 * transition tables, we don't want to change the transition tables once the
6620 * first such trigger has seen them. In such a case, any additional events
6621 * will result in creating new transition tables and allowing new firings of
6622 * statement triggers.
6623 *
6624 * This also saves the current event list location so that a later invocation
6625 * of this function can cheaply find the triggers we're about to queue and
6626 * cancel them.
6627 */
6628static void
6630{
6633
6634 /*
6635 * We keep this state in the AfterTriggersTableData that also holds
6636 * transition tables for the relation + operation. In this way, if we are
6637 * forced to make a new set of transition tables because more tuples get
6638 * entered after we've already fired triggers, we will allow a new set of
6639 * statement triggers to get queued without canceling the old ones.
6640 */
6642
6644 {
6645 /*
6646 * We want to start scanning from the tail location that existed just
6647 * before we inserted any statement triggers. But the events list
6648 * might've been entirely empty then, in which case scan from the
6649 * current head.
6650 */
6651 AfterTriggerEvent event;
6653
6655 {
6658 }
6659 else
6660 {
6663 }
6664
6666 {
6670 {
6672
6673 /*
6674 * Exit loop when we reach events that aren't AS triggers for
6675 * the target relation.
6676 */
6678 goto done;
6680 goto done;
6682 goto done;
6684 goto done;
6685 /* OK, mark it DONE */
6688 }
6689 /* signal we must reinitialize event ptr for next chunk */
6691 }
6692 }
6693done:
6694
6695 /* In any case, save current insertion point for next time */
6698}
6699
6700/*
6701 * GUC assign_hook for session_replication_role
6702 */
6703void
6705{
6706 /*
6707 * Must flush the plan cache when changing replication role; but don't
6708 * flush unnecessarily.
6709 */
6711 ResetPlanCache();
6712}
6713
6714/*
6715 * SQL function pg_trigger_depth()
6716 */
6717Datum
6719{
6721}
6722
6723/*
6724 * Check whether a trigger modified a virtual generated column and replace the
6725 * value with null if so.
6726 *
6727 * We need to check this so that we don't end up storing a non-null value in a
6728 * virtual generated column.
6729 *
6730 * We don't need to check for stored generated columns, since those will be
6731 * overwritten later anyway.
6732 */
6735{
6737 return tuple;
6738
6740 {
6742 {
6744 {
6748
6750 }
6751 }
6752 }
6753
6754 return tuple;
6755}
ResultRelInfo * ExecGetTriggerResultRel(EState *estate, Oid relid, ResultRelInfo *rootRelInfo)
Definition execMain.c:1347
void ExecResetTupleTable(List *tupleTable, bool shouldFree)
Definition execTuples.c:1380
TupleTableSlot * MakeSingleTupleTableSlot(TupleDesc tupdesc, const TupleTableSlotOps *tts_ops)
Definition execTuples.c:1427
void ExecDropSingleTupleTableSlot(TupleTableSlot *slot)
Definition execTuples.c:1443
HeapTuple ExecFetchSlotHeapTuple(TupleTableSlot *slot, bool materialize, bool *shouldFree)
Definition execTuples.c:1833
TupleTableSlot * ExecGetTriggerNewSlot(EState *estate, ResultRelInfo *relInfo)
Definition execUtils.c:1226
TupleConversionMap * ExecGetChildToRootMap(ResultRelInfo *resultRelInfo)
Definition execUtils.c:1300
TupleTableSlot * ExecGetTriggerOldSlot(EState *estate, ResultRelInfo *relInfo)
Definition execUtils.c:1204
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
Definition genam.c:388
#define newval
HeapTuple heap_modify_tuple_by_cols(HeapTuple tuple, TupleDesc tupleDesc, int nCols, const int *replCols, const Datum *replValues, const bool *replIsnull)
Definition heaptuple.c:1278
bool heap_attisnull(HeapTuple tup, int attnum, TupleDesc tupleDesc)
Definition heaptuple.c:456
static void ItemPointerSetInvalid(ItemPointerData *pointer)
Definition itemptr.h:184
static void ItemPointerCopy(const ItemPointerData *fromPointer, ItemPointerData *toPointer)
Definition itemptr.h:172
static bool ItemPointerIsValid(const ItemPointerData *pointer)
Definition itemptr.h:83
void * MemoryContextAllocZero(MemoryContext context, Size size)
Definition mcxt.c:1266
void GetUserIdAndSecContext(Oid *userid, int *sec_context)
Definition miscinit.c:612
void SetUserIdAndSecContext(Oid userid, int sec_context)
Definition miscinit.c:619
Oid LookupExplicitNamespace(const char *nspname, bool missing_ok)
Definition namespace.c:3455
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition palloc.h:124
bool RI_FKey_pk_upd_check_required(Trigger *trigger, Relation pk_rel, TupleTableSlot *oldslot, TupleTableSlot *newslot)
Definition ri_triggers.c:1386
bool RI_FKey_fk_upd_check_required(Trigger *trigger, Relation fk_rel, TupleTableSlot *oldslot, TupleTableSlot *newslot)
Definition ri_triggers.c:1418
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
Definition scankey.c:76
Definition trigger.c:3762
Definition trigger.c:3707
Definition trigger.c:3774
Definition trigger.c:3880
Definition trigger.c:3897
Definition trigger.c:3913
AfterTriggerEventList after_trig_events
Definition trigger.c:3920
Definition trigger.c:3904
Definition bitmapset.h:50
Definition parsenodes.h:4121
Definition execnodes.h:657
Definition htup.h:63
Definition instrument.h:71
Definition pg_list.h:54
Definition memnodes.h:118
Definition primnodes.h:73
Definition rel.h:56
Definition resowner.c:113
Definition execnodes.h:475
Definition skey.h:65
Definition trigger.c:3626
Definition trigger.c:3608
Definition relscan.h:209
Definition trigger.h:57
TupleTableSlot * tcs_original_insert_tuple
Definition trigger.h:76
struct AfterTriggersTableData * tcs_insert_private
Definition trigger.h:81
struct AfterTriggersTableData * tcs_update_private
Definition trigger.h:82
struct AfterTriggersTableData * tcs_delete_private
Definition trigger.h:83
Definition trigger.h:32
Definition reltrigger.h:48
Definition reltrigger.h:24
Definition tupconvert.h:25
Definition tupdesc.h:136
Definition tuptable.h:114
Definition tuplestore.c:104
Definition regguts.h:323
static bool table_tuple_fetch_row_version(Relation rel, ItemPointer tid, Snapshot snapshot, TupleTableSlot *slot)
Definition tableam.h:1263
static SetConstraintState SetConstraintStateCopy(SetConstraintState origstate)
Definition trigger.c:5716
static void cancel_prior_stmt_triggers(Oid relid, CmdType cmdType, int tgevent)
Definition trigger.c:6629
static SetConstraintState SetConstraintStateAddItem(SetConstraintState state, Oid tgoid, bool tgisdeferred)
Definition trigger.c:5736
TransitionCaptureState * MakeTransitionCaptureState(TriggerDesc *trigdesc, Oid relid, CmdType cmdType)
Definition trigger.c:4957
static void afterTriggerDeleteHeadEventChunk(AfterTriggersQueryData *qs)
Definition trigger.c:4265
static AfterTriggersTableData * GetAfterTriggersTableData(Oid relid, CmdType cmdType)
Definition trigger.c:4866
static Bitmapset * afterTriggerCopyBitmap(Bitmapset *src)
Definition trigger.c:4052
static bool TriggerEnabled(EState *estate, ResultRelInfo *relinfo, Trigger *trigger, TriggerEvent event, Bitmapset *modifiedCols, TupleTableSlot *oldslot, TupleTableSlot *newslot)
Definition trigger.c:3482
#define MAX_CHUNK_SIZE
static void AfterTriggerFreeQuery(AfterTriggersQueryData *qs)
Definition trigger.c:5226
static HeapTuple ExecCallTriggerFunc(TriggerData *trigdata, int tgindx, FmgrInfo *finfo, Instrumentation *instr, MemoryContext per_tuple_context)
Definition trigger.c:2309
static void afterTriggerFreeEventList(AfterTriggerEventList *events)
Definition trigger.c:4204
static bool afterTriggerMarkEvents(AfterTriggerEventList *events, AfterTriggerEventList *move_list, bool immediate_only)
Definition trigger.c:4613
static Tuplestorestate * GetAfterTriggersTransitionTable(int event, TupleTableSlot *oldslot, TupleTableSlot *newslot, TransitionCaptureState *transition_capture)
Definition trigger.c:5535
static bool afterTriggerInvokeEvents(AfterTriggerEventList *events, CommandId firing_id, EState *estate, bool delete_ok)
Definition trigger.c:4697
static bool before_stmt_triggers_fired(Oid relid, CmdType cmdType)
Definition trigger.c:6583
static void afterTriggerAddEvent(AfterTriggerEventList *events, AfterTriggerEvent event, AfterTriggerShared evtshared)
Definition trigger.c:4077
static bool afterTriggerCheckState(AfterTriggerShared evtshared)
Definition trigger.c:4007
static void AfterTriggerExecute(EState *estate, AfterTriggerEvent event, ResultRelInfo *relInfo, ResultRelInfo *src_relInfo, ResultRelInfo *dst_relInfo, TriggerDesc *trigdesc, FmgrInfo *finfo, Instrumentation *instr, MemoryContext per_tuple_context, TupleTableSlot *trig_tuple_slot1, TupleTableSlot *trig_tuple_slot2)
Definition trigger.c:4327
static SetConstraintState SetConstraintStateCreate(int numalloc)
Definition trigger.c:5691
static void TransitionTableAddTuple(EState *estate, int event, TransitionCaptureState *transition_capture, ResultRelInfo *relinfo, TupleTableSlot *slot, TupleTableSlot *original_insert_tuple, Tuplestorestate *tuplestore)
Definition trigger.c:5586
static void afterTriggerRestoreEventList(AfterTriggerEventList *events, const AfterTriggerEventList *old_events)
Definition trigger.c:4225
#define MIN_CHUNK_SIZE
static Tuplestorestate * GetCurrentFDWTuplestore(void)
Definition trigger.c:3971
void assign_session_replication_role(int newval, void *extra)
Definition trigger.c:6704
static void AfterTriggerSaveEvent(EState *estate, ResultRelInfo *relinfo, ResultRelInfo *src_partinfo, ResultRelInfo *dst_partinfo, int event, bool row_trigger, TupleTableSlot *oldslot, TupleTableSlot *newslot, List *recheckIndexes, Bitmapset *modifiedCols, TransitionCaptureState *transition_capture, bool is_crosspart_update)
Definition trigger.c:6168
static HeapTuple check_modified_virtual_generated(TupleDesc tupdesc, HeapTuple tuple)
Definition trigger.c:6734
static TupleTableSlot * GetAfterTriggersStoreSlot(AfterTriggersTableData *table, TupleDesc tupdesc)
Definition trigger.c:4908
static void AfterTriggerEnlargeQueryState(void)
Definition trigger.c:5644
TupleTableSlot * execute_attr_map_slot(AttrMap *attrMap, TupleTableSlot *in_slot, TupleTableSlot *out_slot)
Definition tupconvert.c:193
static FormData_pg_attribute * TupleDescAttr(TupleDesc tupdesc, int i)
Definition tupdesc.h:160
bool tuplestore_gettupleslot(Tuplestorestate *state, bool forward, bool copy, TupleTableSlot *slot)
Definition tuplestore.c:1130
void tuplestore_puttupleslot(Tuplestorestate *state, TupleTableSlot *slot)
Definition tuplestore.c:742
Tuplestorestate * tuplestore_begin_heap(bool randomAccess, bool interXact, int maxKBytes)
Definition tuplestore.c:330
static TupleTableSlot * ExecCopySlot(TupleTableSlot *dstslot, TupleTableSlot *srcslot)
Definition tuptable.h:524
Definition pg_list.h:46
◆ for_each_chunk_from
◆ for_each_event
Value:
(char *) eptr < (cptr)->freeptr; \
◆ for_each_event_chunk
| #define for_each_event_chunk | ( | eptr, | |
| cptr, | |||
| evtlist | |||
| ) | for_each_chunk(cptr, evtlist) for_each_event(eptr, cptr) |
◆ for_each_event_from
Value:
for (; \
(char *) eptr < (cptr)->freeptr; \
◆ GetTriggerSharedData
| #define GetTriggerSharedData | ( | evt | ) | ((AfterTriggerShared) ((char *) (evt) + ((evt)->ate_flags & AFTER_TRIGGER_OFFSET))) |
◆ MAX_CHUNK_SIZE
| #define MAX_CHUNK_SIZE (1024*1024) |
◆ MIN_CHUNK_SIZE
| #define MIN_CHUNK_SIZE 1024 |
◆ SizeofTriggerEvent
Value:
Definition at line 3742 of file trigger.c.
3744 : \
Typedef Documentation
◆ AfterTriggerEvent
◆ AfterTriggerEventChunk
◆ AfterTriggerEventData
◆ AfterTriggerEventDataNoOids
◆ AfterTriggerEventDataOneCtid
◆ AfterTriggerEventDataZeroCtids
◆ AfterTriggerEventList
◆ AfterTriggersData
◆ AfterTriggerShared
◆ AfterTriggerSharedData
◆ AfterTriggersQueryData
◆ AfterTriggersTableData
◆ AfterTriggersTransData
◆ SetConstraintState
◆ SetConstraintStateData
◆ SetConstraintTrigger
◆ SetConstraintTriggerData
◆ TriggerFlags
Function Documentation
◆ afterTriggerAddEvent()
|
static |
Definition at line 4077 of file trigger.c.
4079{
4085
4086 /*
4087 * If empty list or not enough room in the tail chunk, make a new chunk.
4088 * We assume here that a new shared record will always be needed.
4089 */
4093 {
4095
4096 /* Create event context if we didn't already */
4100 "AfterTriggerEvents",
4101 ALLOCSET_DEFAULT_SIZES);
4102
4103 /*
4104 * Chunk size starts at 1KB and is allowed to increase up to 1MB.
4105 * These numbers are fairly arbitrary, though there is a hard limit at
4106 * AFTER_TRIGGER_OFFSET; else we couldn't link event records to their
4107 * shared records using the available space in ate_flags. Another
4108 * constraint is that if the chunk size gets too huge, the search loop
4109 * below would get slow given a (not too common) usage pattern with
4110 * many distinct event types in a chunk. Therefore, we double the
4111 * preceding chunk size only if there weren't too many shared records
4112 * in the preceding chunk; otherwise we halve it. This gives us some
4113 * ability to adapt to the actual usage pattern of the current query
4114 * while still having large chunk sizes in typical usage. All chunk
4115 * sizes used should be MAXALIGN multiples, to ensure that the shared
4116 * records will be aligned safely.
4117 */
4118#define MIN_CHUNK_SIZE 1024
4119#define MAX_CHUNK_SIZE (1024*1024)
4120
4121#if MAX_CHUNK_SIZE > (AFTER_TRIGGER_OFFSET+1)
4122#error MAX_CHUNK_SIZE must not exceed AFTER_TRIGGER_OFFSET
4123#endif
4124
4127 else
4128 {
4129 /* preceding chunk size... */
4131 /* check number of shared records in preceding chunk */
4135 else
4138 }
4144
4146 {
4149 }
4150 else
4153 /* events->tailfree is now out of sync, but we'll fix it below */
4154 }
4155
4156 /*
4157 * Try to locate a matching shared-data record already in the chunk. If
4158 * none, make a new one. The search begins with the most recently added
4159 * record, since newer ones are most likely to match.
4160 */
4163 newshared++)
4164 {
4165 /* compare fields roughly by probability of them being different */
4168 newshared->ats_firing_id == 0 &&
4173 evtshared->ats_modifiedcols))
4174 break;
4175 }
4177 {
4180 /* now we must make a suitably-long-lived copy of the bitmap */
4184 }
4185
4186 /* Insert the data */
4189 /* ... and link the new event to its shared record */
4192
4195}
References afterTriggerCopyBitmap(), afterTriggers, ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, Assert, bms_equal(), CHUNK_DATA_START, AfterTriggersData::event_cxt, fb(), AfterTriggerEventList::head, MAX_CHUNK_SIZE, MemoryContextAlloc(), Min, MIN_CHUNK_SIZE, AfterTriggerEventChunk::next, SizeofTriggerEvent, AfterTriggerEventList::tail, AfterTriggerEventList::tailfree, and TopTransactionContext.
Referenced by afterTriggerMarkEvents(), and AfterTriggerSaveEvent().
◆ AfterTriggerBeginQuery()
Definition at line 5115 of file trigger.c.
References afterTriggers, and AfterTriggersData::query_depth.
Referenced by CopyFrom(), create_edata_for_relation(), ExecuteTruncateGuts(), and standard_ExecutorStart().
◆ AfterTriggerBeginSubXact()
Definition at line 5390 of file trigger.c.
5391{
5393
5394 /*
5395 * Allocate more space in the trans_stack if needed. (Note: because the
5396 * minimum nest level of a subtransaction is 2, we waste the first couple
5397 * entries of the array; not worth the notational effort to avoid it.)
5398 */
5400 {
5402 {
5403 /* Arbitrarily initialize for max of 8 subtransaction levels */
5408 }
5409 else
5410 {
5411 /* repalloc will keep the stack in the same context */
5413
5418 }
5419 }
5420
5421 /*
5422 * Push the current information into the stack. The SET CONSTRAINTS state
5423 * is not saved until/unless changed. Likewise, we don't make a
5424 * per-subtransaction event context until needed.
5425 */
5430}
References afterTriggers, AfterTriggersData::events, AfterTriggersTransData::events, fb(), AfterTriggersData::firing_counter, AfterTriggersTransData::firing_counter, GetCurrentTransactionNestLevel(), AfterTriggersData::maxtransdepth, MemoryContextAlloc(), AfterTriggersData::query_depth, AfterTriggersTransData::query_depth, repalloc(), AfterTriggersTransData::state, TopTransactionContext, and AfterTriggersData::trans_stack.
Referenced by StartSubTransaction().
◆ AfterTriggerBeginXact()
Definition at line 5083 of file trigger.c.
5084{
5085 /*
5086 * Initialize after-trigger state structure to empty
5087 */
5090
5091 /*
5092 * Verify that there is no leftover state remaining. If these assertions
5093 * trip, it means that AfterTriggerEndXact wasn't called or didn't clean
5094 * up properly.
5095 */
5103}
References afterTriggers, Assert, AfterTriggersData::event_cxt, AfterTriggersData::events, fb(), AfterTriggersData::firing_counter, AfterTriggerEventList::head, AfterTriggersData::maxquerydepth, AfterTriggersData::maxtransdepth, AfterTriggersData::query_depth, AfterTriggersData::query_stack, AfterTriggersData::state, and AfterTriggersData::trans_stack.
Referenced by StartTransaction().
◆ afterTriggerCheckState()
|
static |
Definition at line 4007 of file trigger.c.
4008{
4012
4013 /*
4014 * For not-deferrable triggers (i.e. normal AFTER ROW triggers and
4015 * constraints declared NOT DEFERRABLE), the state is always false.
4016 */
4018 return false;
4019
4020 /*
4021 * If constraint state exists, SET CONSTRAINTS might have been executed
4022 * either for this trigger or for all triggers.
4023 */
4025 {
4026 /* Check for SET CONSTRAINTS for this specific trigger. */
4028 {
4031 }
4032
4033 /* Check for SET CONSTRAINTS ALL. */
4036 }
4037
4038 /*
4039 * Otherwise return the default state for the trigger.
4040 */
4042}
References AFTER_TRIGGER_DEFERRABLE, AFTER_TRIGGER_INITDEFERRED, afterTriggers, fb(), i, and AfterTriggersData::state.
Referenced by afterTriggerMarkEvents().
◆ afterTriggerCopyBitmap()
Definition at line 4052 of file trigger.c.
4053{
4056
4059
4061
4063
4065
4067}
References afterTriggers, bms_copy(), AfterTriggersData::event_cxt, fb(), and MemoryContextSwitchTo().
Referenced by afterTriggerAddEvent().
◆ afterTriggerDeleteHeadEventChunk()
|
static |
Definition at line 4265 of file trigger.c.
4266{
4269
4271
4272 /*
4273 * First, update any pointers in the per-table data, so that they won't be
4274 * dangling. Resetting obsoleted pointers to NULL will make
4275 * cancel_prior_stmt_triggers start from the list head, which is fine.
4276 */
4278 {
4280
4282 table->after_trig_events.tail == target)
4283 {
4287 }
4288 }
4289
4290 /* Now we can flush the head chunk */
4292 pfree(target);
4293}
References Assert, fb(), lfirst, AfterTriggerEventChunk::next, pfree(), and table.
Referenced by AfterTriggerEndQuery().
◆ AfterTriggerEndQuery()
Definition at line 5135 of file trigger.c.
5136{
5138
5139 /* Must be inside a query, too */
5141
5142 /*
5143 * If we never even got as far as initializing the event stack, there
5144 * certainly won't be any events, so exit quickly.
5145 */
5147 {
5149 return;
5150 }
5151
5152 /*
5153 * Process all immediate-mode triggers queued by the query, and move the
5154 * deferred ones to the main list of deferred events.
5155 *
5156 * Notice that we decide which ones will be fired, and put the deferred
5157 * ones on the main list, before anything is actually fired. This ensures
5158 * reasonably sane behavior if a trigger function does SET CONSTRAINTS ...
5159 * IMMEDIATE: all events we have decided to defer will be available for it
5160 * to fire.
5161 *
5162 * We loop in case a trigger queues more events at the same query level.
5163 * Ordinary trigger functions, including all PL/pgSQL trigger functions,
5164 * will instead fire any triggers in a dedicated query level. Foreign key
5165 * enforcement triggers do add to the current query level, thanks to their
5166 * passing fire_triggers = false to SPI_execute_snapshot(). Other
5167 * C-language triggers might do likewise.
5168 *
5169 * If we find no firable events, we don't have to increment
5170 * firing_counter.
5171 */
5173
5174 for (;;)
5175 {
5177 {
5180
5182 break; /* all fired */
5183
5184 /*
5185 * Firing a trigger could result in query_stack being repalloc'd,
5186 * so we must recalculate qs after each afterTriggerInvokeEvents
5187 * call. Furthermore, it's unsafe to pass delete_ok = true here,
5188 * because that could cause afterTriggerInvokeEvents to try to
5189 * access qs->events after the stack has been repalloc'd.
5190 */
5192
5193 /*
5194 * We'll need to scan the events list again. To reduce the cost
5195 * of doing so, get rid of completely-fired chunks. We know that
5196 * all events were marked IN_PROGRESS or DONE at the conclusion of
5197 * afterTriggerMarkEvents, so any still-interesting events must
5198 * have been added after that, and so must be in the chunk that
5199 * was then the tail chunk, or in later chunks. So, zap all
5200 * chunks before oldtail. This is approximately the same set of
5201 * events we would have gotten rid of by passing delete_ok = true.
5202 */
5206 }
5207 else
5208 break;
5209 }
5210
5211 /* Release query-level-local storage, including tuplestores if any */
5213
5215}
References afterTriggerDeleteHeadEventChunk(), AfterTriggerFreeQuery(), afterTriggerInvokeEvents(), afterTriggerMarkEvents(), afterTriggers, Assert, AfterTriggersData::events, fb(), AfterTriggersData::firing_counter, AfterTriggersData::maxquerydepth, AfterTriggersData::query_depth, and AfterTriggersData::query_stack.
Referenced by CopyFrom(), ExecuteTruncateGuts(), finish_edata(), and standard_ExecutorFinish().
◆ AfterTriggerEndSubXact()
Definition at line 5438 of file trigger.c.
5439{
5442 AfterTriggerEvent event;
5445
5446 /*
5447 * Pop the prior state if needed.
5448 */
5450 {
5452 /* If we saved a prior state, we don't need it anymore */
5456 /* this avoids double pfree if error later: */
5460 }
5461 else
5462 {
5463 /*
5464 * Aborting. It is possible subxact start failed before calling
5465 * AfterTriggerBeginSubXact, in which case we mustn't risk touching
5466 * trans_stack levels that aren't there.
5467 */
5469 return;
5470
5471 /*
5472 * Release query-level storage for queries being aborted, and restore
5473 * query_depth to its pre-subxact value. This assumes that a
5474 * subtransaction will not add events to query levels started in a
5475 * earlier transaction state.
5476 */
5478 {
5482 }
5485
5486 /*
5487 * Restore the global deferred-event list to its former length,
5488 * discarding any events queued by the subxact.
5489 */
5492
5493 /*
5494 * Restore the trigger state. If the saved state is NULL, then this
5495 * subxact didn't save it, so it doesn't need restoring.
5496 */
5499 {
5502 }
5503 /* this avoids double pfree if error later: */
5505
5506 /*
5507 * Scan for any remaining deferred events that were marked DONE or IN
5508 * PROGRESS by this subxact or a child, and un-mark them. We can
5509 * recognize such events because they have a firing ID greater than or
5510 * equal to the firing_counter value we saved at subtransaction start.
5511 * (This essentially assumes that the current subxact includes all
5512 * subxacts started after it.)
5513 */
5516 {
5518
5521 {
5523 event->ate_flags &=
5525 }
5526 }
5527 }
5528}
References AFTER_TRIGGER_DONE, AFTER_TRIGGER_IN_PROGRESS, AfterTriggerFreeQuery(), afterTriggerRestoreEventList(), afterTriggers, Assert, AfterTriggerEventData::ate_flags, AfterTriggersData::events, AfterTriggersTransData::events, fb(), AfterTriggersTransData::firing_counter, for_each_event_chunk, GetCurrentTransactionNestLevel(), GetTriggerSharedData, AfterTriggersData::maxquerydepth, AfterTriggersData::maxtransdepth, pfree(), AfterTriggersData::query_depth, AfterTriggersTransData::query_depth, AfterTriggersData::query_stack, AfterTriggersData::state, AfterTriggersTransData::state, and AfterTriggersData::trans_stack.
Referenced by AbortSubTransaction(), and CommitSubTransaction().
◆ AfterTriggerEndXact()
Definition at line 5342 of file trigger.c.
5343{
5344 /*
5345 * Forget the pending-events list.
5346 *
5347 * Since all the info is in TopTransactionContext or children thereof, we
5348 * don't really need to do anything to reclaim memory. However, the
5349 * pending-events list could be large, and so it's useful to discard it as
5350 * soon as possible --- especially if we are aborting because we ran out
5351 * of memory for the list!
5352 */
5354 {
5360 }
5361
5362 /*
5363 * Forget any subtransaction state as well. Since this can't be very
5364 * large, we let the eventual reset of TopTransactionContext free the
5365 * memory instead of doing it here.
5366 */
5369
5370
5371 /*
5372 * Forget the query stack and constraint-related state information. As
5373 * with the subtransaction state information, we don't bother freeing the
5374 * memory here.
5375 */
5379
5380 /* No more afterTriggers manipulation until next transaction starts. */
5382}
References afterTriggers, AfterTriggersData::event_cxt, AfterTriggersData::events, fb(), AfterTriggerEventList::head, AfterTriggersData::maxquerydepth, AfterTriggersData::maxtransdepth, MemoryContextDelete(), AfterTriggersData::query_depth, AfterTriggersData::query_stack, AfterTriggersData::state, AfterTriggerEventList::tail, AfterTriggerEventList::tailfree, and AfterTriggersData::trans_stack.
Referenced by AbortTransaction(), CommitTransaction(), and PrepareTransaction().
◆ AfterTriggerEnlargeQueryState()
Definition at line 5644 of file trigger.c.
5645{
5647
5649
5651 {
5653
5658 }
5659 else
5660 {
5661 /* repalloc will keep the stack in the same context */
5664 old_alloc * 2);
5665
5670 }
5671
5672 /* Initialize new array entries to empty */
5674 {
5676
5682
5683 ++init_depth;
5684 }
5685}
References afterTriggers, Assert, AfterTriggersQueryData::events, fb(), AfterTriggerEventList::head, Max, AfterTriggersData::maxquerydepth, MemoryContextAlloc(), NIL, AfterTriggersData::query_depth, AfterTriggersData::query_stack, repalloc(), and TopTransactionContext.
Referenced by AfterTriggerSaveEvent(), before_stmt_triggers_fired(), and MakeTransitionCaptureState().
◆ AfterTriggerExecute()
|
static |
Definition at line 4327 of file trigger.c.
4337{
4345 int save_sec_context;
4350
4351 /*
4352 * Locate trigger in trigdesc. It might not be present, and in fact the
4353 * trigdesc could be NULL, if the trigger was dropped since the event was
4354 * queued. In that case, silently do nothing.
4355 */
4357 return;
4359 {
4361 {
4363 break;
4364 }
4365 }
4367 return;
4368
4369 /*
4370 * If doing EXPLAIN ANALYZE, start charging time to this trigger. We want
4371 * to include time spent re-fetching tuples in the trigger cost.
4372 */
4373 if (instr)
4375
4376 /*
4377 * Fetch the required tuple(s).
4378 */
4380 {
4382 {
4384
4386 trig_tuple_slot1))
4388
4390 TRIGGER_EVENT_UPDATE &&
4392 trig_tuple_slot2))
4394 }
4395 /* fall through */
4397
4398 /*
4399 * Store tuple in the slot so that tg_trigtuple does not reference
4400 * tuplestore memory. (It is formally possible for the trigger
4401 * function to queue trigger events that add to the same
4402 * tuplestore, which can push other tuples out of memory.) The
4403 * distinction is academic, because we start with a minimal tuple
4404 * that is stored as a heap tuple, constructed in different memory
4405 * context, in the slot anyway.
4406 */
4408 LocTriggerData.tg_trigtuple =
4410
4412 TRIGGER_EVENT_UPDATE)
4413 {
4415 LocTriggerData.tg_newtuple =
4417 }
4418 else
4419 {
4421 }
4422 break;
4423
4424 default:
4426 {
4428 src_relInfo);
4429
4431 &(event->ate_ctid1),
4432 SnapshotAny,
4433 src_slot))
4435
4436 /*
4437 * Store the tuple fetched from the source partition into the
4438 * target (root partitioned) table slot, converting if needed.
4439 */
4441 {
4443
4445 if (map)
4446 {
4448 src_slot,
4449 LocTriggerData.tg_trigslot);
4450 }
4451 else
4453 }
4454 else
4456 LocTriggerData.tg_trigtuple =
4458 }
4459 else
4460 {
4462 }
4463
4464 /* don't touch ctid2 if not there */
4468 {
4470 dst_relInfo);
4471
4473 &(event->ate_ctid2),
4474 SnapshotAny,
4475 dst_slot))
4477
4478 /*
4479 * Store the tuple fetched from the destination partition into
4480 * the target (root partitioned) table slot, converting if
4481 * needed.
4482 */
4484 {
4486
4488 if (map)
4489 {
4491 dst_slot,
4492 LocTriggerData.tg_newslot);
4493 }
4494 else
4496 }
4497 else
4499 LocTriggerData.tg_newtuple =
4501 }
4502 else
4503 {
4505 }
4506 }
4507
4508 /*
4509 * Set up the tuplestore information to let the trigger have access to
4510 * transition tables. When we first make a transition table available to
4511 * a trigger, mark it "closed" so that it cannot change anymore. If any
4512 * additional events of the same type get queued in the current trigger
4513 * query level, they'll go into new transition tables.
4514 */
4517 {
4519 {
4522 }
4523
4525 {
4528 }
4529 }
4530
4531 /*
4532 * Setup the remaining trigger information
4533 */
4535 LocTriggerData.tg_event =
4537 LocTriggerData.tg_relation = rel;
4540
4542
4543 /*
4544 * If necessary, become the role that was active when the trigger got
4545 * queued. Note that the role might have been dropped since the trigger
4546 * was queued, but if that is a problem, we will get an error later.
4547 * Checking here would still leave a race condition.
4548 */
4552 save_sec_context | SECURITY_LOCAL_USERID_CHANGE);
4553
4554 /*
4555 * Call the trigger and throw away any possibly returned updated tuple.
4556 * (Don't let ExecCallTriggerFunc measure EXPLAIN time.)
4557 */
4559 tgindx,
4560 finfo,
4561 NULL,
4562 per_tuple_context);
4567
4568 /* Restore the current role if necessary */
4571
4572 /*
4573 * Release resources
4574 */
4579
4580 /* don't clear slots' contents if foreign table */
4582 {
4587 }
4588
4589 /*
4590 * If doing EXPLAIN ANALYZE, stop charging time to this trigger, and count
4591 * one "tuple returned" (really the number of firings).
4592 */
4593 if (instr)
4595}
References AFTER_TRIGGER_2CTID, AFTER_TRIGGER_CP_UPDATE, AFTER_TRIGGER_FDW_FETCH, AFTER_TRIGGER_FDW_REUSE, AFTER_TRIGGER_TUP_BITS, AfterTriggerEventData::ate_ctid1, AfterTriggerEventData::ate_ctid2, AfterTriggerEventData::ate_flags, TupleConversionMap::attrMap, elog, ERROR, ExecCallTriggerFunc(), ExecClearTuple(), ExecCopySlot(), ExecFetchSlotHeapTuple(), ExecGetChildToRootMap(), ExecGetTriggerNewSlot(), ExecGetTriggerOldSlot(), execute_attr_map_slot(), fb(), GetCurrentFDWTuplestore(), GetTriggerSharedData, GetUserIdAndSecContext(), heap_freetuple(), InstrStartNode(), InstrStopNode(), ItemPointerIsValid(), MemoryContextReset(), TriggerDesc::numtriggers, SECURITY_LOCAL_USERID_CHANGE, SetUserIdAndSecContext(), SnapshotAny, table_tuple_fetch_row_version(), Trigger::tgoid, TRIGGER_EVENT_OPMASK, TRIGGER_EVENT_ROW, TRIGGER_EVENT_UPDATE, TriggerDesc::triggers, and tuplestore_gettupleslot().
Referenced by afterTriggerInvokeEvents().
◆ AfterTriggerFireDeferred()
Definition at line 5286 of file trigger.c.
5287{
5288 AfterTriggerEventList *events;
5290
5291 /* Must not be inside a query */
5293
5294 /*
5295 * If there are any triggers to fire, make sure we have set a snapshot for
5296 * them to use. (Since PortalRunUtility doesn't set a snap for COMMIT, we
5297 * can't assume ActiveSnapshot is valid on entry.)
5298 */
5301 {
5304 }
5305
5306 /*
5307 * Run all the remaining triggers. Loop until they are all gone, in case
5308 * some trigger queues more for us to do.
5309 */
5311 {
5313
5315 break; /* all fired */
5316 }
5317
5318 /*
5319 * We don't bother freeing the event list, since it will go away anyway
5320 * (and more efficiently than via pfree) in AfterTriggerEndXact.
5321 */
5322
5324 PopActiveSnapshot();
5325}
References afterTriggerInvokeEvents(), afterTriggerMarkEvents(), afterTriggers, Assert, AfterTriggersData::events, fb(), AfterTriggersData::firing_counter, GetTransactionSnapshot(), AfterTriggerEventList::head, PopActiveSnapshot(), PushActiveSnapshot(), and AfterTriggersData::query_depth.
Referenced by CommitTransaction(), and PrepareTransaction().
◆ afterTriggerFreeEventList()
|
static |
Definition at line 4204 of file trigger.c.
4205{
4207
4209 {
4212 }
4215}
References fb(), AfterTriggerEventList::head, AfterTriggerEventChunk::next, pfree(), AfterTriggerEventList::tail, and AfterTriggerEventList::tailfree.
Referenced by AfterTriggerFreeQuery(), and afterTriggerRestoreEventList().
◆ AfterTriggerFreeQuery()
|
static |
Definition at line 5226 of file trigger.c.
5227{
5228 Tuplestorestate *ts;
5229 List *tables;
5231
5232 /* Drop the trigger events */
5234
5235 /* Drop FDW tuplestore if any */
5236 ts = qs->fdw_tuplestore;
5238 if (ts)
5239 tuplestore_end(ts);
5240
5241 /* Release per-table subsidiary storage */
5242 tables = qs->tables;
5244 {
5246
5247 ts = table->old_tuplestore;
5249 if (ts)
5250 tuplestore_end(ts);
5251 ts = table->new_tuplestore;
5253 if (ts)
5254 tuplestore_end(ts);
5256 {
5258
5260 ExecDropSingleTupleTableSlot(slot);
5261 }
5262 }
5263
5264 /*
5265 * Now free the AfterTriggersTableData structs and list cells. Reset list
5266 * pointer first; if list_free_deep somehow gets an error, better to leak
5267 * that storage than have an infinite loop.
5268 */
5270 list_free_deep(tables);
5271}
References afterTriggerFreeEventList(), ExecDropSingleTupleTableSlot(), fb(), lfirst, list_free_deep(), NIL, table, and tuplestore_end().
Referenced by AfterTriggerEndQuery(), and AfterTriggerEndSubXact().
◆ afterTriggerInvokeEvents()
|
static |
Definition at line 4697 of file trigger.c.
4701{
4713
4714 /* Make a local EState if need be */
4716 {
4717 estate = CreateExecutorState();
4719 }
4720
4721 /* Make a per-tuple memory context for trigger function calls */
4722 per_tuple_context =
4724 "AfterTriggerTupleContext",
4725 ALLOCSET_DEFAULT_SIZES);
4726
4728 {
4729 AfterTriggerEvent event;
4731
4733 {
4735
4736 /*
4737 * Is it one for me to fire?
4738 */
4741 {
4743 *dst_rInfo;
4744
4745 /*
4746 * So let's fire it... but first, find the correct relation if
4747 * this is not the same relation as before.
4748 */
4750 {
4752 NULL);
4753 rel = rInfo->ri_RelationDesc;
4754 /* Catch calls with insufficient relcache refcounting */
4756 trigdesc = rInfo->ri_TrigDesc;
4757 /* caution: trigdesc could be NULL here */
4758 finfo = rInfo->ri_TrigFunctions;
4759 instr = rInfo->ri_TrigInstrument;
4761 {
4765 }
4767 {
4769 &TTSOpsMinimalTuple);
4771 &TTSOpsMinimalTuple);
4772 }
4773 }
4774
4775 /*
4776 * Look up source and destination partition result rels of a
4777 * cross-partition update event.
4778 */
4780 AFTER_TRIGGER_CP_UPDATE)
4781 {
4785 event->ate_src_part,
4786 rInfo);
4788 event->ate_dst_part,
4789 rInfo);
4790 }
4791 else
4793
4794 /*
4795 * Fire it. Note that the AFTER_TRIGGER_IN_PROGRESS flag is
4796 * still set, so recursive examinations of the event list
4797 * won't try to re-fire it.
4798 */
4801 trigdesc, finfo, instr,
4803
4804 /*
4805 * Mark the event as done.
4806 */
4809 }
4811 {
4812 /* something remains to be done */
4814 }
4815 }
4816
4817 /* Clear the chunk if delete_ok and nothing left of interest */
4819 {
4822
4823 /*
4824 * If it's last chunk, must sync event list's tailfree too. Note
4825 * that delete_ok must NOT be passed as true if there could be
4826 * additional AfterTriggerEventList values pointing at this event
4827 * list, since we'd fail to fix their copies of tailfree.
4828 */
4831 }
4832 }
4834 {
4837 }
4838
4839 /* Release working resources */
4841
4843 {
4844 ExecCloseResultRelations(estate);
4846 FreeExecutorState(estate);
4847 }
4848
4850}
References AFTER_TRIGGER_CP_UPDATE, AFTER_TRIGGER_DONE, AFTER_TRIGGER_IN_PROGRESS, AFTER_TRIGGER_TUP_BITS, AfterTriggerExecute(), ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, Assert, AfterTriggerEventData::ate_dst_part, AfterTriggerEventData::ate_flags, AfterTriggerEventData::ate_src_part, CHUNK_DATA_START, CreateExecutorState(), CurrentMemoryContext, EState::es_tupleTable, ExecCloseResultRelations(), ExecDropSingleTupleTableSlot(), ExecGetTriggerResultRel(), ExecResetTupleTable(), fb(), for_each_chunk, for_each_event, FreeExecutorState(), GetTriggerSharedData, MakeSingleTupleTableSlot(), MemoryContextDelete(), OidIsValid, RelationData::rd_att, RelationData::rd_rel, RelationGetRelid, RelationHasReferenceCountZero, AfterTriggerEventList::tail, AfterTriggerEventList::tailfree, and TTSOpsMinimalTuple.
Referenced by AfterTriggerEndQuery(), AfterTriggerFireDeferred(), and AfterTriggerSetState().
◆ afterTriggerMarkEvents()
|
static |
Definition at line 4613 of file trigger.c.
4616{
4617 bool found = false;
4619 AfterTriggerEvent event;
4621
4623 {
4626
4629 {
4630 /*
4631 * This trigger hasn't been called or scheduled yet. Check if we
4632 * should call it now.
4633 */
4635 {
4637 }
4638 else
4639 {
4640 /*
4641 * Mark it as to be fired in this firing cycle.
4642 */
4645 found = true;
4646 }
4647 }
4648
4649 /*
4650 * If it's deferred, move it to move_list, if requested.
4651 */
4653 {
4655 /* add it to move_list */
4657 /* mark original copy "done" so we don't do it again */
4659 }
4660 }
4661
4662 /*
4663 * We could allow deferred triggers if, before the end of the
4664 * security-restricted operation, we were to verify that a SET CONSTRAINTS
4665 * ... IMMEDIATE has fired all such triggers. For now, don't bother.
4666 */
4671
4672 return found;
4673}
References AFTER_TRIGGER_DONE, AFTER_TRIGGER_IN_PROGRESS, afterTriggerAddEvent(), afterTriggerCheckState(), afterTriggers, AfterTriggerEventData::ate_flags, ereport, errcode(), errmsg(), ERROR, fb(), AfterTriggersData::firing_counter, for_each_event_chunk, GetTriggerSharedData, and InSecurityRestrictedOperation().
Referenced by AfterTriggerEndQuery(), AfterTriggerFireDeferred(), and AfterTriggerSetState().
◆ AfterTriggerPendingOnRel()
Definition at line 6081 of file trigger.c.
6082{
6083 AfterTriggerEvent event;
6085 int depth;
6086
6087 /* Scan queued events */
6089 {
6091
6092 /*
6093 * We can ignore completed events. (Even if a DONE flag is rolled
6094 * back by subxact abort, it's OK because the effects of the TRUNCATE
6095 * or whatever must get rolled back too.)
6096 */
6098 continue;
6099
6101 return true;
6102 }
6103
6104 /*
6105 * Also scan events queued by incomplete queries. This could only matter
6106 * if TRUNCATE/etc is executed by a function or trigger within an updating
6107 * query on the same relation, which is pretty perverse, but let's check.
6108 */
6109 for (depth = 0; depth <= afterTriggers.query_depth && depth < afterTriggers.maxquerydepth; depth++)
6110 {
6112 {
6114
6116 continue;
6117
6119 return true;
6120 }
6121 }
6122
6123 return false;
6124}
References AFTER_TRIGGER_DONE, afterTriggers, AfterTriggerEventData::ate_flags, AfterTriggersData::events, AfterTriggersQueryData::events, fb(), for_each_event_chunk, GetTriggerSharedData, AfterTriggersData::maxquerydepth, AfterTriggersData::query_depth, and AfterTriggersData::query_stack.
Referenced by CheckTableNotInUse().
◆ afterTriggerRestoreEventList()
|
static |
Definition at line 4225 of file trigger.c.
4227{
4230
4232 {
4233 /* restoring to a completely empty state, so free everything */
4234 afterTriggerFreeEventList(events);
4235 }
4236 else
4237 {
4238 *events = *old_events;
4239 /* free any chunks after the last one we want to keep */
4241 {
4244 }
4245 /* and clean up the tail chunk to be the right length */
4248
4249 /*
4250 * We don't make any effort to remove now-unused shared data records.
4251 * They might still be useful, anyway.
4252 */
4253 }
4254}
References afterTriggerFreeEventList(), fb(), AfterTriggerEventChunk::freeptr, AfterTriggerEventChunk::next, pfree(), AfterTriggerEventList::tail, and AfterTriggerEventList::tailfree.
Referenced by AfterTriggerEndSubXact().
◆ AfterTriggerSaveEvent()
|
static |
Definition at line 6168 of file trigger.c.
6176{
6186
6187 /*
6188 * Check state. We use a normal test not Assert because it is possible to
6189 * reach here in the wrong state given misconfigured RI triggers, in
6190 * particular deferring a cascade action trigger.
6191 */
6194
6195 /* Be sure we have enough space to record events at this query depth. */
6197 AfterTriggerEnlargeQueryState();
6198
6199 /*
6200 * If the directly named relation has any triggers with transition tables,
6201 * then we need to capture transition tuples.
6202 */
6204 {
6206
6207 /*
6208 * Capture the old tuple in the appropriate transition table based on
6209 * the event.
6210 */
6212 {
6213 Tuplestorestate *old_tuplestore;
6214
6215 old_tuplestore = GetAfterTriggersTransitionTable(event,
6216 oldslot,
6217 NULL,
6218 transition_capture);
6221 }
6222
6223 /*
6224 * Capture the new tuple in the appropriate transition table based on
6225 * the event.
6226 */
6228 {
6229 Tuplestorestate *new_tuplestore;
6230
6231 new_tuplestore = GetAfterTriggersTransitionTable(event,
6232 NULL,
6233 newslot,
6234 transition_capture);
6237 }
6238
6239 /*
6240 * If transition tables are the only reason we're here, return. As
6241 * mentioned above, we can also be here during update tuple routing in
6242 * presence of transition tables, in which case this function is
6243 * called separately for OLD and NEW, so we expect exactly one of them
6244 * to be NULL.
6245 */
6251 return;
6252 }
6253
6254 /*
6255 * We normally don't see partitioned tables here for row level triggers
6256 * except in the special case of a cross-partition update. In that case,
6257 * nodeModifyTable.c:ExecCrossPartitionUpdateForeignKey() calls here to
6258 * queue an update event on the root target partitioned table, also
6259 * passing the source and destination partitions and their tuples.
6260 */
6263 (is_crosspart_update &&
6264 TRIGGER_FIRED_BY_UPDATE(event) &&
6266
6267 /*
6268 * Validate the event code and collect the associated tuple CTIDs.
6269 *
6270 * The event code will be used both as a bitmask and an array offset, so
6271 * validation is important to make sure we don't walk off the edge of our
6272 * arrays.
6273 *
6274 * Also, if we're considering statement-level triggers, check whether we
6275 * already queued a set of them for this event, and cancel the prior set
6276 * if so. This preserves the behavior that statement-level triggers fire
6277 * just once per statement and fire after row-level triggers.
6278 */
6279 switch (event)
6280 {
6284 {
6289 }
6290 else
6291 {
6297 CMD_INSERT, event);
6298 }
6299 break;
6303 {
6308 }
6309 else
6310 {
6316 CMD_DELETE, event);
6317 }
6318 break;
6322 {
6327
6328 /*
6329 * Also remember the OIDs of partitions to fetch these tuples
6330 * out of later in AfterTriggerExecute().
6331 */
6333 {
6335 new_event.ate_src_part =
6337 new_event.ate_dst_part =
6339 }
6340 }
6341 else
6342 {
6348 CMD_UPDATE, event);
6349 }
6350 break;
6357 break;
6358 default:
6361 break;
6362 }
6363
6364 /* Determine flags */
6366 {
6368 {
6371 else
6373 }
6374 else
6376 }
6377
6378 /* else, we'll initialize ate_flags for each trigger */
6379
6381
6382 /*
6383 * Must convert/copy the source and destination partition tuples into the
6384 * root partitioned table's format/slot, because the processing in the
6385 * loop below expects both oldslot and newslot tuples to be in that form.
6386 */
6388 {
6390 TupleConversionMap *map;
6391
6394 if (map)
6396 oldslot,
6397 rootslot);
6398 else
6400
6403 if (map)
6405 newslot,
6406 rootslot);
6407 else
6409 }
6410
6412 {
6414
6416 tgtype_level,
6417 TRIGGER_TYPE_AFTER,
6418 tgtype_event))
6419 continue;
6422 continue;
6423
6425 {
6427 {
6428 fdw_tuplestore = GetCurrentFDWTuplestore();
6430 }
6431 else
6432 /* subsequent event for the same tuple */
6434 }
6435
6436 /*
6437 * If the trigger is a foreign key enforcement trigger, there are
6438 * certain cases where we can skip queueing the event because we can
6439 * tell by inspection that the FK constraint will still pass. There
6440 * are also some cases during cross-partition updates of a partitioned
6441 * table where queuing the event can be skipped.
6442 */
6444 {
6446 {
6448
6449 /*
6450 * For cross-partitioned updates of partitioned PK table,
6451 * skip the event fired by the component delete on the
6452 * source leaf partition unless the constraint originates
6453 * in the partition itself (!tgisclone), because the
6454 * update event that will be fired on the root
6455 * (partitioned) target table will be used to perform the
6456 * necessary foreign key enforcement action.
6457 */
6459 TRIGGER_FIRED_BY_DELETE(event) &&
6460 trigger->tgisclone)
6461 continue;
6462
6463 /* Update or delete on trigger's PK table */
6466 {
6467 /* skip queuing this event */
6468 continue;
6469 }
6470 break;
6471
6473
6474 /*
6475 * Update on trigger's FK table. We can skip the update
6476 * event fired on a partitioned table during a
6477 * cross-partition of that table, because the insert event
6478 * that is fired on the destination leaf partition would
6479 * suffice to perform the necessary foreign key check.
6480 * Moreover, RI_FKey_fk_upd_check_required() expects to be
6481 * passed a tuple that contains system attributes, most of
6482 * which are not present in the virtual slot belonging to
6483 * a partitioned table.
6484 */
6488 {
6489 /* skip queuing this event */
6490 continue;
6491 }
6492 break;
6493
6495
6496 /*
6497 * Not an FK trigger. No need to queue the update event
6498 * fired during a cross-partitioned update of a
6499 * partitioned table, because the same row trigger must be
6500 * present in the leaf partition(s) that are affected as
6501 * part of this update and the events fired on them are
6502 * queued instead.
6503 */
6506 continue;
6507 break;
6508 }
6509 }
6510
6511 /*
6512 * If the trigger is a deferred unique constraint check trigger, only
6513 * queue it if the unique constraint was potentially violated, which
6514 * we know from index insertion time.
6515 */
6517 {
6519 continue; /* Uniqueness definitely not violated */
6520 }
6521
6522 /*
6523 * Fill in event structure and add it to the current query's queue.
6524 * Note we set ats_table to NULL whenever this trigger doesn't use
6525 * transition tables, to improve sharability of the shared event data.
6526 */
6527 new_shared.ats_event =
6535 new_shared.ats_firing_id = 0;
6537 transition_capture != NULL)
6538 {
6539 switch (event)
6540 {
6543 break;
6546 break;
6549 break;
6550 default:
6551 /* Must be TRUNCATE, see switch above */
6553 break;
6554 }
6555 }
6556 else
6559
6562 }
6563
6564 /*
6565 * Finally, spool any foreign tuple(s). The tuplestore squashes them to
6566 * minimal tuples, so this loses any system columns. The executor lost
6567 * those columns before us, for an unrelated reason, so this is fine.
6568 */
6569 if (fdw_tuplestore)
6570 {
6575 }
6576}
References AFTER_TRIGGER_1CTID, AFTER_TRIGGER_2CTID, AFTER_TRIGGER_CP_UPDATE, AFTER_TRIGGER_DEFERRABLE, AFTER_TRIGGER_FDW_FETCH, AFTER_TRIGGER_FDW_REUSE, AFTER_TRIGGER_INITDEFERRED, afterTriggerAddEvent(), AfterTriggerEnlargeQueryState(), afterTriggers, Assert, TupleConversionMap::attrMap, cancel_prior_stmt_triggers(), CMD_DELETE, CMD_INSERT, CMD_UPDATE, elog, ERROR, AfterTriggersQueryData::events, ExecCopySlot(), ExecGetChildToRootMap(), ExecGetTriggerNewSlot(), ExecGetTriggerOldSlot(), execute_attr_map_slot(), fb(), GetAfterTriggersTransitionTable(), GetCurrentFDWTuplestore(), GetUserId(), i, ItemPointerCopy(), ItemPointerSetInvalid(), list_member_oid(), AfterTriggersData::maxquerydepth, TriggerDesc::numtriggers, AfterTriggersData::query_depth, AfterTriggersData::query_stack, RelationData::rd_rel, RelationGetRelid, RI_FKey_fk_upd_check_required(), RI_FKey_pk_upd_check_required(), RI_FKey_trigger_type(), RI_TRIGGER_FK, RI_TRIGGER_NONE, RI_TRIGGER_PK, TransitionCaptureState::tcs_delete_private, TransitionCaptureState::tcs_insert_private, TransitionCaptureState::tcs_original_insert_tuple, TransitionCaptureState::tcs_update_private, TransitionTableAddTuple(), TriggerDesc::trig_delete_after_row, TriggerDesc::trig_insert_after_row, TriggerDesc::trig_update_after_row, TRIGGER_EVENT_DELETE, TRIGGER_EVENT_INSERT, TRIGGER_EVENT_OPMASK, TRIGGER_EVENT_ROW, TRIGGER_EVENT_TRUNCATE, TRIGGER_EVENT_UPDATE, TRIGGER_FIRED_BY_DELETE, TRIGGER_FIRED_BY_UPDATE, TriggerEnabled(), TriggerDesc::triggers, TupIsNull, and tuplestore_puttupleslot().
Referenced by ExecARDeleteTriggers(), ExecARInsertTriggers(), ExecARUpdateTriggers(), ExecASDeleteTriggers(), ExecASInsertTriggers(), ExecASTruncateTriggers(), and ExecASUpdateTriggers().
◆ AfterTriggerSetState()
| void AfterTriggerSetState | ( | ConstraintsSetStmt * | stmt | ) |
Definition at line 5766 of file trigger.c.
5767{
5769
5770 /* If we haven't already done so, initialize our state. */
5773
5774 /*
5775 * If in a subtransaction, and we didn't save the current state already,
5776 * save it so it can be restored if the subtransaction aborts.
5777 */
5778 if (my_level > 1 &&
5780 {
5783 }
5784
5785 /*
5786 * Handle SET CONSTRAINTS ALL ...
5787 */
5789 {
5790 /*
5791 * Forget any previous SET CONSTRAINTS commands in this transaction.
5792 */
5794
5795 /*
5796 * Set the per-transaction ALL state to known.
5797 */
5800 }
5801 else
5802 {
5808
5809 /*
5810 * Handle SET CONSTRAINTS constraint-name [, ...]
5811 *
5812 * First, identify all the named constraints and make a list of their
5813 * OIDs. Since, unlike the SQL spec, we allow multiple constraints of
5814 * the same name within a schema, the specifications are not
5815 * necessarily unique. Our strategy is to target all matching
5816 * constraints within the first search-path schema that has any
5817 * matches, but disregard matches in schemas beyond the first match.
5818 * (This is a bit odd but it's the historical behavior.)
5819 *
5820 * A constraint in a partitioned table may have corresponding
5821 * constraints in the partitions. Grab those too.
5822 */
5824
5826 {
5828 bool found;
5831
5833 {
5839 constraint->relname)));
5840 }
5841
5842 /*
5843 * If we're given the schema name with the constraint, look only
5844 * in that schema. If given a bare constraint name, use the
5845 * search path to find the first matching constraint.
5846 */
5848 {
5850 false);
5851
5853 }
5854 else
5855 {
5857 }
5858
5859 found = false;
5861 {
5866
5875
5878
5880 {
5882
5883 if (con->condeferrable)
5889 constraint->relname)));
5890 found = true;
5891 }
5892
5894
5895 /*
5896 * Once we've found a matching constraint we do not search
5897 * later parts of the search path.
5898 */
5899 if (found)
5900 break;
5901 }
5902
5904
5905 /*
5906 * Not found ?
5907 */
5908 if (!found)
5912 constraint->relname)));
5913 }
5914
5915 /*
5916 * Scan for any possible descendants of the constraints. We append
5917 * whatever we find to the same list that we're scanning; this has the
5918 * effect that we create new scans for those, too, so if there are
5919 * further descendents, we'll also catch them.
5920 */
5922 {
5925 SysScanDesc scan;
5926 HeapTuple tuple;
5927
5928 ScanKeyInit(&key,
5931 ObjectIdGetDatum(parent));
5932
5934
5936 {
5938
5940 }
5941
5942 systable_endscan(scan);
5943 }
5944
5946
5947 /*
5948 * Now, locate the trigger(s) implementing each of these constraints,
5949 * and make a list of their OIDs.
5950 */
5952
5954 {
5958 HeapTuple htup;
5959
5963 ObjectIdGetDatum(conoid));
5964
5967
5969 {
5971
5972 /*
5973 * Silently skip triggers that are marked as non-deferrable in
5974 * pg_trigger. This is not an error condition, since a
5975 * deferrable RI constraint may have some non-deferrable
5976 * actions.
5977 */
5980 }
5981
5983 }
5984
5986
5987 /*
5988 * Now we can set the trigger states of individual triggers for this
5989 * xact.
5990 */
5992 {
5995 bool found = false;
5997
5999 {
6001 {
6003 found = true;
6004 break;
6005 }
6006 }
6007 if (!found)
6008 {
6011 }
6012 }
6013 }
6014
6015 /*
6016 * SQL99 requires that when a constraint is set to IMMEDIATE, any deferred
6017 * checks against that constraint must be made when the SET CONSTRAINTS
6018 * command is executed -- i.e. the effects of the SET CONSTRAINTS command
6019 * apply retroactively. We've updated the constraints state, so scan the
6020 * list of previously deferred events to fire any that have now become
6021 * immediate.
6022 *
6023 * Obviously, if this was SET ... DEFERRED then it can't have converted
6024 * any unfired events to immediate, so we need do nothing in that case.
6025 */
6027 {
6030
6032 {
6034
6035 /*
6036 * Make sure a snapshot has been established in case trigger
6037 * functions need one. Note that we avoid setting a snapshot if
6038 * we don't find at least one trigger that has to be fired now.
6039 * This is so that BEGIN; SET CONSTRAINTS ...; SET TRANSACTION
6040 * ISOLATION LEVEL SERIALIZABLE; ... works properly. (If we are
6041 * at the start of a transaction it's not possible for any trigger
6042 * events to be queued yet.)
6043 */
6045 {
6048 }
6049
6050 /*
6051 * We can delete fired events if we are at top transaction level,
6052 * but we'd better not if inside a subtransaction, since the
6053 * subtransaction could later get rolled back.
6054 */
6056 !IsSubTransaction()))
6057 break; /* all fired */
6058 }
6059
6061 PopActiveSnapshot();
6062 }
6063}
References AccessShareLock, afterTriggerInvokeEvents(), afterTriggerMarkEvents(), afterTriggers, SetConstraintStateData::all_isdeferred, SetConstraintStateData::all_isset, BTEqualStrategyNumber, RangeVar::catalogname, CStringGetDatum(), ereport, errcode(), errmsg(), ERROR, AfterTriggersData::events, fb(), fetch_search_path(), AfterTriggersData::firing_counter, get_database_name(), GetCurrentTransactionNestLevel(), GETSTRUCT(), GetTransactionSnapshot(), HeapTupleIsValid, i, IsSubTransaction(), lappend_oid(), lfirst, lfirst_oid, list_free(), list_make1_oid, LookupExplicitNamespace(), MyDatabaseId, NIL, SetConstraintStateData::numstates, ObjectIdGetDatum(), PopActiveSnapshot(), PushActiveSnapshot(), RangeVar::relname, ScanKeyInit(), RangeVar::schemaname, SetConstraintStateAddItem(), SetConstraintStateCopy(), SetConstraintStateCreate(), AfterTriggersData::state, AfterTriggersTransData::state, stmt, systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), and AfterTriggersData::trans_stack.
Referenced by standard_ProcessUtility().
◆ assign_session_replication_role()
Definition at line 6704 of file trigger.c.
6705{
6706 /*
6707 * Must flush the plan cache when changing replication role; but don't
6708 * flush unnecessarily.
6709 */
6711 ResetPlanCache();
6712}
References newval, ResetPlanCache(), and SessionReplicationRole.
◆ before_stmt_triggers_fired()
Definition at line 6583 of file trigger.c.
6584{
6585 bool result;
6587
6588 /* Check state, like AfterTriggerSaveEvent. */
6591
6592 /* Be sure we have enough space to record events at this query depth. */
6594 AfterTriggerEnlargeQueryState();
6595
6596 /*
6597 * We keep this state in the AfterTriggersTableData that also holds
6598 * transition tables for the relation + operation. In this way, if we are
6599 * forced to make a new set of transition tables because more tuples get
6600 * entered after we've already fired triggers, we will allow a new set of
6601 * statement triggers to get queued.
6602 */
6604 result = table->before_trig_done;
6606 return result;
6607}
References AfterTriggerEnlargeQueryState(), afterTriggers, elog, ERROR, GetAfterTriggersTableData(), AfterTriggersData::maxquerydepth, AfterTriggersData::query_depth, and table.
Referenced by ExecBSDeleteTriggers(), ExecBSInsertTriggers(), and ExecBSUpdateTriggers().
◆ cancel_prior_stmt_triggers()
Definition at line 6629 of file trigger.c.
6630{
6633
6634 /*
6635 * We keep this state in the AfterTriggersTableData that also holds
6636 * transition tables for the relation + operation. In this way, if we are
6637 * forced to make a new set of transition tables because more tuples get
6638 * entered after we've already fired triggers, we will allow a new set of
6639 * statement triggers to get queued without canceling the old ones.
6640 */
6642
6644 {
6645 /*
6646 * We want to start scanning from the tail location that existed just
6647 * before we inserted any statement triggers. But the events list
6648 * might've been entirely empty then, in which case scan from the
6649 * current head.
6650 */
6651 AfterTriggerEvent event;
6653
6655 {
6658 }
6659 else
6660 {
6663 }
6664
6666 {
6670 {
6672
6673 /*
6674 * Exit loop when we reach events that aren't AS triggers for
6675 * the target relation.
6676 */
6678 goto done;
6680 goto done;
6682 goto done;
6684 goto done;
6685 /* OK, mark it DONE */
6688 }
6689 /* signal we must reinitialize event ptr for next chunk */
6691 }
6692 }
6693done:
6694
6695 /* In any case, save current insertion point for next time */
6698}
References AFTER_TRIGGER_DONE, afterTriggers, CHUNK_DATA_START, fb(), for_each_chunk_from, for_each_event_from, GetAfterTriggersTableData(), GetTriggerSharedData, AfterTriggersData::query_depth, AfterTriggersData::query_stack, table, TRIGGER_EVENT_OPMASK, TRIGGER_FIRED_AFTER, and TRIGGER_FIRED_FOR_STATEMENT.
Referenced by AfterTriggerSaveEvent().
◆ check_modified_virtual_generated()
Definition at line 6734 of file trigger.c.
6735{
6737 return tuple;
6738
6740 {
6742 {
6744 {
6748
6750 }
6751 }
6752 }
6753
6754 return tuple;
6755}
References TupleDescData::constr, fb(), TupleConstr::has_generated_virtual, heap_attisnull(), heap_modify_tuple_by_cols(), i, TupleDescData::natts, and TupleDescAttr().
Referenced by ExecBRInsertTriggers(), and ExecBRUpdateTriggers().
◆ CopyTriggerDesc()
| TriggerDesc * CopyTriggerDesc | ( | TriggerDesc * | trigdesc | ) |
Definition at line 2090 of file trigger.c.
2091{
2095
2098
2101
2106
2108 {
2111 {
2113
2118 }
2120 {
2123
2128 }
2135 trigger++;
2136 }
2137
2139}
References fb(), i, j, TriggerDesc::numtriggers, palloc(), palloc_object, pstrdup(), and TriggerDesc::triggers.
Referenced by InitResultRelInfo(), and RelationBuildTriggers().
◆ CreateTrigger()
| ObjectAddress CreateTrigger | ( | CreateTrigStmt * | stmt, |
| const char * | queryString, | ||
| Oid | relOid, | ||
| Oid | refRelOid, | ||
| Oid | constraintOid, | ||
| Oid | indexOid, | ||
| Oid | funcoid, | ||
| Oid | parentTriggerOid, | ||
| Node * | whenClause, | ||
| bool | isInternal, | ||
| bool | in_partition | ||
| ) |
Definition at line 160 of file trigger.c.
164{
165 return
170}
ObjectAddress CreateTriggerFiringOn(CreateTrigStmt *stmt, const char *queryString, Oid relOid, Oid refRelOid, Oid constraintOid, Oid indexOid, Oid funcoid, Oid parentTriggerOid, Node *whenClause, bool isInternal, bool in_partition, char trigger_fires_when)
Definition trigger.c:177
References CreateTriggerFiringOn(), fb(), stmt, and TRIGGER_FIRES_ON_ORIGIN.
Referenced by CreateFKCheckTrigger(), createForeignKeyActionTriggers(), index_constraint_create(), and ProcessUtilitySlow().
◆ CreateTriggerFiringOn()
| ObjectAddress CreateTriggerFiringOn | ( | CreateTrigStmt * | stmt, |
| const char * | queryString, | ||
| Oid | relOid, | ||
| Oid | refRelOid, | ||
| Oid | constraintOid, | ||
| Oid | indexOid, | ||
| Oid | funcoid, | ||
| Oid | parentTriggerOid, | ||
| Node * | whenClause, | ||
| bool | isInternal, | ||
| bool | in_partition, | ||
| char | trigger_fires_when | ||
| ) |
Definition at line 177 of file trigger.c.
182{
183 int16 tgtype;
184 int ncolumns;
185 int16 *columns;
186 int2vector *tgattr;
188 char *qual;
191 Relation rel;
199 char *trigname;
202 referenced;
210
213 else
215
216 /*
217 * Triggers must be on tables or views, and there are additional
218 * relation-type-specific restrictions.
219 */
221 {
222 /* Tables can't have INSTEAD OF triggers */
228 RelationGetRelationName(rel)),
230 }
232 {
233 /* Partitioned tables can't have INSTEAD OF triggers */
239 RelationGetRelationName(rel)),
241
242 /*
243 * FOR EACH ROW triggers have further restrictions
244 */
246 {
247 /*
248 * Disallow use of transition tables.
249 *
250 * Note that we have another restriction about transition tables
251 * in partitions; search for 'has_superclass' below for an
252 * explanation. The check here is just to protect from the fact
253 * that if we allowed it here, the creation would succeed for a
254 * partitioned table with no partitions, but would be blocked by
255 * the other restriction when the first partition was created,
256 * which is very unfriendly behavior.
257 */
262 RelationGetRelationName(rel)),
264 }
265 }
267 {
268 /*
269 * Views can have INSTEAD OF triggers (which we check below are
270 * row-level), or statement-level BEFORE/AFTER triggers.
271 */
276 RelationGetRelationName(rel)),
278 /* Disallow TRUNCATE triggers on VIEWs */
283 RelationGetRelationName(rel)),
285 }
287 {
293 RelationGetRelationName(rel)),
295
296 /*
297 * We disallow constraint triggers to protect the assumption that
298 * triggers on FKs can't be deferred. See notes with AfterTriggers
299 * data structures, below.
300 */
305 RelationGetRelationName(rel)),
307 }
308 else
312 RelationGetRelationName(rel)),
314
319 RelationGetRelationName(rel))));
320
322 {
323 /*
324 * We must take a lock on the target relation to protect against
325 * concurrent drop. It's not clear that AccessShareLock is strong
326 * enough, but we certainly need at least that much... otherwise, we
327 * might end up creating a pg_constraint entry referencing a
328 * nonexistent table.
329 */
331 {
334 }
337 false);
338 }
339
340 /* permission checks */
342 {
344 ACL_TRIGGER);
347 RelationGetRelationName(rel));
348
350 {
352 ACL_TRIGGER);
356 }
357 }
358
359 /*
360 * When called on a partitioned table to create a FOR EACH ROW trigger
361 * that's not internal, we create one trigger for each partition, too.
362 *
363 * For that, we'd better hold lock on all of them ahead of time.
364 */
370
371 /* Compute tgtype */
372 TRIGGER_CLEAR_TYPE(tgtype);
374 TRIGGER_SETT_ROW(tgtype);
375 tgtype |= stmt->timing;
376 tgtype |= stmt->events;
377
378 /* Disallow ROW-level TRUNCATE triggers */
383
384 /* INSTEAD triggers must be row-level, and can't have WHEN or columns */
386 {
399 }
400
401 /*
402 * We don't yet support naming ROW transition variables, but the parser
403 * recognizes the syntax so we can give a nicer message here.
404 *
405 * Per standard, REFERENCING TABLE names are only allowed on AFTER
406 * triggers. Per standard, REFERENCING ROW names are not allowed with FOR
407 * EACH STATEMENT. Per standard, each OLD/NEW, ROW/TABLE permutation is
408 * only allowed once. Per standard, OLD may not be specified when
409 * creating a trigger only for INSERT, and NEW may not be specified when
410 * creating a trigger only for DELETE.
411 *
412 * Notice that the standard allows an AFTER ... FOR EACH ROW trigger to
413 * reference both ROW and TABLE transition data.
414 */
416 {
419
421 {
423
429
430 /*
431 * Because of the above test, we omit further ROW-related testing
432 * below. If we later allow naming OLD and NEW ROW variables,
433 * adjustments will be needed below.
434 */
435
440 RelationGetRelationName(rel)),
442
447 RelationGetRelationName(rel)),
449
450 /*
451 * We currently don't allow row-level triggers with transition
452 * tables on partition or inheritance children. Such triggers
453 * would somehow need to see tuples converted to the format of the
454 * table they're attached to, and it's not clear which subset of
455 * tuples each child should see. See also the prohibitions in
456 * ATExecAttachPartition() and ATExecAddInherit().
457 */
459 {
460 /* Use appropriate error message. */
465 else
469 }
470
475
480
481 /*
482 * We currently don't allow multi-event triggers ("INSERT OR
483 * UPDATE") with transition tables, because it's not clear how to
484 * handle INSERT ... ON CONFLICT statements which can fire both
485 * INSERT and UPDATE triggers. We show the inserted tuples to
486 * INSERT triggers and the updated tuples to UPDATE triggers, but
487 * it's not yet clear what INSERT OR UPDATE trigger should see.
488 * This restriction could be lifted if we can decide on the right
489 * semantics in a later release.
490 */
492 (TRIGGER_FOR_UPDATE(tgtype) ? 1 : 0) +
493 (TRIGGER_FOR_DELETE(tgtype) ? 1 : 0)) != 1)
497
498 /*
499 * We currently don't allow column-specific triggers with
500 * transition tables. Per spec, that seems to require
501 * accumulating separate transition tables for each combination of
502 * columns, which is a lot of work for a rather marginal feature.
503 */
508
509 /*
510 * We disallow constraint triggers with transition tables, to
511 * protect the assumption that such triggers can't be deferred.
512 * See notes with AfterTriggers data structures, below.
513 *
514 * Currently this is enforced by the grammar, so just Assert here.
515 */
517
519 {
521 TRIGGER_FOR_UPDATE(tgtype)))
525
530
532 }
533 else
534 {
536 TRIGGER_FOR_UPDATE(tgtype)))
540
545
547 }
548 }
549
555 }
556
557 /*
558 * Parse the WHEN clause, if any and we weren't passed an already
559 * transformed one.
560 *
561 * Note that as a side effect, we fill whenRtable when parsing. If we got
562 * an already parsed clause, this does not occur, which is what we want --
563 * no point in adding redundant dependencies below.
564 */
566 {
567 ParseState *pstate;
571
572 /* Set up a pstate to parse with */
574 pstate->p_sourcetext = queryString;
575
576 /*
577 * Set up nsitems for OLD and NEW references.
578 *
579 * 'OLD' must always have varno equal to 1 and 'NEW' equal to 2.
580 */
582 AccessShareLock,
584 false, false);
587 AccessShareLock,
589 false, false);
591
592 /* Transform expression. Copy to be sure we don't modify original */
593 whenClause = transformWhereClause(pstate,
596 "WHEN");
597 /* we have to fix its collations too */
598 assign_expr_collations(pstate, whenClause);
599
600 /*
601 * Check for disallowed references to OLD/NEW.
602 *
603 * NB: pull_var_clause is okay here only because we don't allow
604 * subselects in WHEN clauses; it would fail to examine the contents
605 * of subselects.
606 */
609 {
611
613 {
625 /* system columns are okay here */
626 break;
644 var->varattno == 0 &&
645 RelationGetDescr(rel)->constr &&
646 (RelationGetDescr(rel)->constr->has_generated_stored ||
647 RelationGetDescr(rel)->constr->has_generated_virtual))
654 var->varattno > 0 &&
662 break;
663 default:
664 /* can't happen without add_missing_from, so just elog */
666 break;
667 }
668 }
669
670 /* we'll need the rtable for recordDependencyOnExpr */
672
673 qual = nodeToString(whenClause);
674
675 free_parsestate(pstate);
676 }
677 else if (!whenClause)
678 {
679 whenClause = NULL;
681 qual = NULL;
682 }
683 else
684 {
685 qual = nodeToString(whenClause);
687 }
688
689 /*
690 * Find and validate the trigger function.
691 */
695 {
700 }
707
708 /*
709 * Scan pg_trigger to see if there is already a trigger of the same name.
710 * Skip this for internally generated triggers, since we'll modify the
711 * name to be unique below.
712 *
713 * NOTE that this is cool only because we have ShareRowExclusiveLock on
714 * the relation, so the trigger set won't be changing underneath us.
715 */
718 {
721
726
731
734
735 /* There should be at most one matching tuple */
737 {
739
745 /* copy the tuple to use in CatalogTupleUpdate() */
746 tuple = heap_copytuple(tuple);
747 }
749 }
750
752 {
753 /* Generate the OID for the new trigger. */
755 Anum_pg_trigger_oid);
756 }
757 else
758 {
759 /*
760 * If OR REPLACE was specified, we'll replace the old trigger;
761 * otherwise complain about the duplicate name.
762 */
768
769 /*
770 * An internal trigger or a child trigger (isClone) cannot be replaced
771 * by a user-defined trigger. However, skip this test when
772 * in_partition, because then we're recursing from a partitioned table
773 * and the check was made at the parent level.
774 */
781
782 /*
783 * It is not allowed to replace with a constraint trigger; gram.y
784 * should have enforced this already.
785 */
787
788 /*
789 * It is not allowed to replace an existing constraint trigger,
790 * either. (The reason for these restrictions is partly that it seems
791 * difficult to deal with pending trigger events in such cases, and
792 * partly that the command might imply changing the constraint's
793 * properties as well, which doesn't seem nice.)
794 */
800 }
801
802 /*
803 * If it's a user-entered CREATE CONSTRAINT TRIGGER command, make a
804 * corresponding pg_constraint entry.
805 */
807 {
808 /* Internal callers should have made their own constraints */
811 RelationGetNamespace(rel),
812 CONSTRAINT_TRIGGER,
813 stmt->deferrable,
814 stmt->initdeferred,
815 true, /* Is Enforced */
816 true,
818 RelationGetRelid(rel),
820 0,
821 0,
825 NULL,
826 NULL,
827 NULL,
828 NULL,
829 0,
830 ' ',
831 ' ',
832 NULL,
833 0,
834 ' ',
837 NULL,
838 true, /* islocal */
839 0, /* inhcount */
840 true, /* noinherit */
841 false, /* conperiod */
843 }
844
845 /*
846 * If trigger is internally generated, modify the provided trigger name to
847 * ensure uniqueness by appending the trigger OID. (Callers will usually
848 * supply a simple constant trigger name in these cases.)
849 */
851 {
854 trigname = internaltrigname;
855 }
856 else
857 {
858 /* user-defined trigger; use the specified trigger name as-is */
859 trigname = stmt->trigname;
860 }
861
862 /*
863 * Build the new pg_trigger tuple.
864 */
866
871 CStringGetDatum(trigname));
881
883 {
888
890 {
892
895 {
897 len++;
898 }
899 }
903 {
906
907 while (*s)
908 {
909 if (*s == '\\')
910 *d++ = '\\';
911 *d++ = *s++;
912 }
914 }
917 CStringGetDatum(args));
918 }
919 else
920 {
924 }
925
926 /* build column number array if it's a column-specific trigger */
928 if (ncolumns == 0)
929 columns = NULL;
930 else
931 {
932 ListCell *cell;
934
937 {
941
942 /* Lookup column name. System columns are not allowed */
949
950 /* Check for duplicates */
952 {
957 name)));
958 }
959
961 }
962 }
963 tgattr = buildint2vector(columns, ncolumns);
965
966 /* set tgqual if trigger has WHEN clause */
967 if (qual)
969 else
971
975 else
980 else
982
983 /*
984 * Insert or replace tuple in pg_trigger.
985 */
987 {
990 }
991 else
992 {
994
998 }
999
1002
1010
1011 /*
1012 * Update relation's pg_class entry; if necessary; and if not, send an SI
1013 * message to make other backends (and this one) rebuild relcache entries.
1014 */
1020 RelationGetRelid(rel));
1022 {
1024
1026
1027 CommandCounterIncrement();
1028 }
1029 else
1030 CacheInvalidateRelcacheByTuple(tuple);
1031
1032 heap_freetuple(tuple);
1034
1035 /*
1036 * If we're replacing a trigger, flush all the old dependencies before
1037 * recording new ones.
1038 */
1041
1042 /*
1043 * Record dependencies for trigger. Always place a normal dependency on
1044 * the function.
1045 */
1048 myself.objectSubId = 0;
1049
1052 referenced.objectSubId = 0;
1054
1056 {
1057 /*
1058 * Internally-generated trigger for a constraint, so make it an
1059 * internal dependency of the constraint. We can skip depending on
1060 * the relation(s), as there'll be an indirect dependency via the
1061 * constraint.
1062 */
1065 referenced.objectSubId = 0;
1067 }
1068 else
1069 {
1070 /*
1071 * User CREATE TRIGGER, so place dependencies. We make trigger be
1072 * auto-dropped if its relation is dropped or if the FK relation is
1073 * dropped. (Auto drop is compatible with our pre-7.3 behavior.)
1074 */
1077 referenced.objectSubId = 0;
1079
1081 {
1084 referenced.objectSubId = 0;
1086 }
1087 /* Not possible to have an index dependency in this case */
1089
1090 /*
1091 * If it's a user-specified constraint trigger, make the constraint
1092 * internally dependent on the trigger instead of vice versa.
1093 */
1095 {
1098 referenced.objectSubId = 0;
1100 }
1101
1102 /*
1103 * If it's a partition trigger, create the partition dependencies.
1104 */
1106 {
1111 }
1112 }
1113
1114 /* If column-specific trigger, add normal dependencies on columns */
1116 {
1118
1122 {
1125 }
1126 }
1127
1128 /*
1129 * If it has a WHEN clause, add dependencies on objects mentioned in the
1130 * expression (eg, functions, as well as any columns used).
1131 */
1134 DEPENDENCY_NORMAL);
1135
1136 /* Post creation hook for new trigger */
1138 isInternal);
1139
1140 /*
1141 * Lastly, create the trigger on child relations, if needed.
1142 */
1144 {
1148 perChildCxt;
1149
1151 "part trig clone",
1152 ALLOCSET_SMALL_SIZES);
1153
1154 /*
1155 * We don't currently expect to be called with a valid indexOid. If
1156 * that ever changes then we'll need to write code here to find the
1157 * corresponding child index.
1158 */
1160
1162
1163 /* Iterate to create the trigger on each existing partition */
1165 {
1168 Node *qual;
1169
1171
1172 /*
1173 * Initialize our fabricated parse node by copying the original
1174 * one, then resetting fields that we pass separately.
1175 */
1179
1180 /* If there is a WHEN clause, create a modified copy of it */
1181 qual = copyObject(whenClause);
1182 qual = (Node *)
1184 childTbl, rel);
1185 qual = (Node *)
1187 childTbl, rel);
1188
1194
1196
1198 }
1199
1202 }
1203
1204 /* Keep lock on target rel until end of xact */
1206
1208}
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
Definition aclchk.c:2654
AclResult object_aclcheck(Oid classid, Oid objectid, Oid roleid, AclMode mode)
Definition aclchk.c:3836
AclResult pg_class_aclcheck(Oid table_oid, Oid roleid, AclMode mode)
Definition aclchk.c:4039
Oid GetNewOidWithIndex(Relation relation, Oid indexId, AttrNumber oidcolumn)
Definition catalog.c:448
void recordDependencyOnExpr(const ObjectAddress *depender, Node *expr, List *rtable, DependencyType behavior)
Definition dependency.c:1603
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
Definition heaptuple.c:1117
void CatalogTupleUpdate(Relation heapRel, const ItemPointerData *otid, HeapTuple tup)
Definition indexing.c:313
void CacheInvalidateRelcacheByTuple(HeapTuple classTuple)
Definition inval.c:1669
#define InvokeObjectPostCreateHookArg(classId, objectId, subId, is_internal)
Definition objectaccess.h:175
Node * transformWhereClause(ParseState *pstate, Node *clause, ParseExprKind exprKind, const char *constructName)
Definition parse_clause.c:1854
void assign_expr_collations(ParseState *pstate, Node *expr)
Definition parse_collate.c:177
Oid LookupFuncName(List *funcname, int nargs, const Oid *argtypes, bool missing_ok)
Definition parse_func.c:2269
int parser_errposition(ParseState *pstate, int location)
Definition parse_node.c:106
ParseNamespaceItem * addRangeTableEntryForRelation(ParseState *pstate, Relation rel, int lockmode, Alias *alias, bool inh, bool inFromCl)
Definition parse_relation.c:1580
void addNSItemToQuery(ParseState *pstate, ParseNamespaceItem *nsitem, bool addToJoinList, bool addToRelNameSpace, bool addToVarNameSpace)
Definition parse_relation.c:2706
int attnameAttNum(Relation rd, const char *attname, bool sysColOK)
Definition parse_relation.c:3585
PartitionDesc RelationGetPartitionDesc(Relation rel, bool omit_detached)
Definition partdesc.c:71
List * map_partition_varattnos(List *expr, int fromrel_varno, Relation to_rel, Relation from_rel)
Definition partition.c:222
int errdetail_relkind_not_supported(char relkind)
Definition pg_class.c:24
Oid CreateConstraintEntry(const char *constraintName, Oid constraintNamespace, char constraintType, bool isDeferrable, bool isDeferred, bool isEnforced, bool isValidated, Oid parentConstrId, Oid relId, const int16 *constraintKey, int constraintNKeys, int constraintNTotalKeys, Oid domainId, Oid indexRelId, Oid foreignRelId, const int16 *foreignKey, const Oid *pfEqOp, const Oid *ppEqOp, const Oid *ffEqOp, int foreignNKeys, char foreignUpdateType, char foreignDeleteType, const int16 *fkDeleteSetCols, int numFkDeleteSetCols, char foreignMatchType, const Oid *exclOp, Node *conExpr, const char *conBin, bool conIsLocal, int16 conInhCount, bool conNoInherit, bool conPeriod, bool is_internal)
Definition pg_constraint.c:51
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
Definition pg_depend.c:45
long deleteDependencyRecordsFor(Oid classId, Oid objectId, bool skipExtensionDeps)
Definition pg_depend.c:301
List * find_all_inheritors(Oid parentrelId, LOCKMODE lockmode, List **numparents)
Definition pg_inherits.c:255
Definition parsenodes.h:3136
Definition nodes.h:135
Definition objectaddress.h:25
Definition parse_node.h:293
Definition parse_node.h:193
Definition partdesc.h:30
Definition parsenodes.h:1831
Definition primnodes.h:262
Definition c.h:734
References AccessShareLock, ACL_EXECUTE, ACL_TRIGGER, aclcheck_error(), ACLCHECK_OK, addNSItemToQuery(), addRangeTableEntryForRelation(), ALLOCSET_SMALL_SIZES, AllocSetContextCreate, allowSystemTableMods, Assert, assign_expr_collations(), attnameAttNum(), attnum, BoolGetDatum(), BTEqualStrategyNumber, buildint2vector(), byteain(), CacheInvalidateRelcacheByTuple(), CatalogTupleInsert(), CatalogTupleUpdate(), CharGetDatum(), CommandCounterIncrement(), copyObject, CreateConstraintEntry(), CreateTriggerFiringOn(), CStringGetDatum(), CStringGetTextDatum, CurrentMemoryContext, DatumGetPointer(), deleteDependencyRecordsFor(), DEPENDENCY_AUTO, DEPENDENCY_INTERNAL, DEPENDENCY_NORMAL, DEPENDENCY_PARTITION_PRI, DEPENDENCY_PARTITION_SEC, DirectFunctionCall1, elog, ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errdetail(), errdetail_relkind_not_supported(), errhint(), errmsg(), ERROR, EXPR_KIND_TRIGGER_WHEN, fb(), find_all_inheritors(), free_parsestate(), get_func_rettype(), get_rel_name(), get_rel_relkind(), get_relkind_objtype(), GetNewOidWithIndex(), GETSTRUCT(), GetUserId(), has_superclass(), heap_copytuple(), heap_form_tuple(), heap_freetuple(), HeapTupleIsValid, i, Int16GetDatum(), InvalidAttrNumber, InvalidOid, InvokeObjectPostCreateHookArg, IsSystemRelation(), j, len, lfirst, lfirst_node, list_free(), list_length(), Var::location, LockRelationOid(), LookupFuncName(), make_parsestate(), makeAlias(), map_partition_varattnos(), MemoryContextDelete(), MemoryContextReset(), MemoryContextSwitchTo(), name, NAMEDATALEN, namein(), NameListToString(), NameStr, NIL, nodeToString(), NoLock, PartitionDescData::nparts, object_aclcheck(), OBJECT_FUNCTION, ObjectAddressSet, ObjectIdGetDatum(), OidIsValid, PartitionDescData::oids, ParseState::p_rtable, ParseState::p_sourcetext, palloc(), parser_errposition(), pfree(), pg_class_aclcheck(), PointerGetDatum(), PRS2_NEW_VARNO, PRS2_OLD_VARNO, pull_var_clause(), RangeVarGetRelid, RelationData::rd_id, RelationData::rd_rel, recordDependencyOn(), recordDependencyOnExpr(), RelationGetDescr, RelationGetNamespace, RelationGetPartitionDesc(), RelationGetRelationName, RelationGetRelid, RowExclusiveLock, ScanKeyInit(), SearchSysCacheCopy1, ShareRowExclusiveLock, snprintf, stmt, strVal, systable_beginscan(), systable_endscan(), systable_getnext(), HeapTupleData::t_self, table_close(), table_open(), table_openrv(), transformWhereClause(), TupleDescAttr(), values, Var::varattno, and Var::varno.
Referenced by CloneRowTriggersToPartition(), CreateTrigger(), and CreateTriggerFiringOn().
◆ EnableDisableTrigger()
| void EnableDisableTrigger | ( | Relation | rel, |
| const char * | tgname, | ||
| Oid | tgparent, | ||
| char | fires_when, | ||
| bool | skip_system, | ||
| bool | recurse, | ||
| LOCKMODE | lockmode | ||
| ) |
Definition at line 1726 of file trigger.c.
1729{
1731 int nkeys;
1732 ScanKeyData keys[2];
1734 HeapTuple tuple;
1735 bool found;
1737
1738 /* Scan the relevant entries in pg_triggers */
1740
1741 ScanKeyInit(&keys[0],
1742 Anum_pg_trigger_tgrelid,
1745 if (tgname)
1746 {
1747 ScanKeyInit(&keys[1],
1748 Anum_pg_trigger_tgname,
1750 CStringGetDatum(tgname));
1751 nkeys = 2;
1752 }
1753 else
1754 nkeys = 1;
1755
1757 NULL, nkeys, keys);
1758
1760
1762 {
1764
1766 continue;
1767
1769 {
1770 /* system trigger ... ok to process? */
1772 continue;
1778 }
1779
1780 found = true;
1781
1783 {
1784 /* need to change this one ... make a copy to scribble on */
1787
1789
1791
1793
1795 }
1796
1797 /*
1798 * When altering FOR EACH ROW triggers on a partitioned table, do the
1799 * same on the partitions as well, unless ONLY is specified.
1800 *
1801 * Note that we recurse even if we didn't change the trigger above,
1802 * because the partitions' copy of the trigger may have a different
1803 * value of tgenabled than the parent's trigger and thus might need to
1804 * be changed.
1805 */
1806 if (recurse &&
1809 {
1812
1814 {
1816
1818 /* Match on child triggers' tgparentid, not their name */
1821 lockmode);
1823 }
1824 }
1825
1827 oldtrig->oid, 0);
1828 }
1829
1831
1833
1834 if (tgname && !found)
1838 tgname, RelationGetRelationName(rel))));
1839
1840 /*
1841 * If we changed anything, broadcast a SI inval message to force each
1842 * backend (including our own!) to rebuild relation's relcache entry.
1843 * Otherwise they will fail to apply the change promptly.
1844 */
1846 CacheInvalidateRelcache(rel);
1847}
#define InvokeObjectPostAlterHook(classId, objectId, subId)
Definition objectaccess.h:197
void EnableDisableTrigger(Relation rel, const char *tgname, Oid tgparent, char fires_when, bool skip_system, bool recurse, LOCKMODE lockmode)
Definition trigger.c:1726
References BTEqualStrategyNumber, CacheInvalidateRelcache(), CatalogTupleUpdate(), CStringGetDatum(), EnableDisableTrigger(), ereport, errcode(), errmsg(), ERROR, fb(), GETSTRUCT(), heap_copytuple(), heap_freetuple(), HeapTupleIsValid, i, InvokeObjectPostAlterHook, NameStr, NoLock, PartitionDescData::nparts, ObjectIdGetDatum(), OidIsValid, PartitionDescData::oids, RelationData::rd_rel, relation_open(), RelationGetPartitionDesc(), RelationGetRelationName, RelationGetRelid, RowExclusiveLock, ScanKeyInit(), superuser(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().
Referenced by ATExecEnableDisableTrigger(), and EnableDisableTrigger().
◆ ExecARDeleteTriggers()
| void ExecARDeleteTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| ItemPointer | tupleid, | ||
| HeapTuple | fdw_trigtuple, | ||
| TransitionCaptureState * | transition_capture, | ||
| bool | is_crosspart_update | ||
| ) |
Definition at line 2801 of file trigger.c.
2807{
2809
2811 transition_capture->tcs_delete_old_table)
2812 {
2817 }
2818
2820 (transition_capture && transition_capture->tcs_delete_old_table))
2821 {
2823
2826 GetTupleForTrigger(estate,
2827 NULL,
2828 relinfo,
2829 tupleid,
2830 LockTupleExclusive,
2831 slot,
2832 false,
2833 NULL,
2834 NULL,
2835 NULL);
2836 else
2838
2840 TRIGGER_EVENT_DELETE,
2842 transition_capture,
2843 is_crosspart_update);
2844 }
2845}
void ExecForceStoreHeapTuple(HeapTuple tuple, TupleTableSlot *slot, bool shouldFree)
Definition execTuples.c:1658
static bool GetTupleForTrigger(EState *estate, EPQState *epqstate, ResultRelInfo *relinfo, ItemPointer tid, LockTupleMode lockmode, TupleTableSlot *oldslot, bool do_epq_recheck, TupleTableSlot **epqslot, TM_Result *tmresultp, TM_FailureData *tmfdp)
Definition trigger.c:3344
References AfterTriggerSaveEvent(), Assert, ereport, errcode(), errmsg(), ERROR, ExecForceStoreHeapTuple(), ExecGetTriggerOldSlot(), fb(), GetTupleForTrigger(), HeapTupleIsValid, ItemPointerIsValid(), LockTupleExclusive, NIL, TransitionCaptureState::tcs_delete_old_table, TriggerDesc::trig_delete_after_row, and TRIGGER_EVENT_DELETE.
Referenced by ExecDeleteEpilogue(), and ExecSimpleRelationDelete().
◆ ExecARInsertTriggers()
| void ExecARInsertTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| TupleTableSlot * | slot, | ||
| List * | recheckIndexes, | ||
| TransitionCaptureState * | transition_capture | ||
| ) |
Definition at line 2543 of file trigger.c.
2546{
2548
2550 transition_capture->tcs_insert_new_table)
2551 {
2556 }
2557
2559 (transition_capture && transition_capture->tcs_insert_new_table))
2561 TRIGGER_EVENT_INSERT,
2564 transition_capture,
2565 false);
2566}
References AfterTriggerSaveEvent(), Assert, ereport, errcode(), errmsg(), ERROR, fb(), TransitionCaptureState::tcs_insert_new_table, TriggerDesc::trig_insert_after_row, and TRIGGER_EVENT_INSERT.
Referenced by CopyFrom(), CopyMultiInsertBufferFlush(), ExecBatchInsert(), ExecInsert(), and ExecSimpleRelationInsert().
◆ ExecARUpdateTriggers()
| void ExecARUpdateTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| ResultRelInfo * | src_partinfo, | ||
| ResultRelInfo * | dst_partinfo, | ||
| ItemPointer | tupleid, | ||
| HeapTuple | fdw_trigtuple, | ||
| TupleTableSlot * | newslot, | ||
| List * | recheckIndexes, | ||
| TransitionCaptureState * | transition_capture, | ||
| bool | is_crosspart_update | ||
| ) |
Definition at line 3144 of file trigger.c.
3153{
3155
3157 (transition_capture->tcs_update_old_table ||
3158 transition_capture->tcs_update_new_table))
3159 {
3164 }
3165
3167 (transition_capture &&
3168 (transition_capture->tcs_update_old_table ||
3169 transition_capture->tcs_update_new_table)))
3170 {
3171 /*
3172 * Note: if the UPDATE is converted into a DELETE+INSERT as part of
3173 * update-partition-key operation, then this function is also called
3174 * separately for DELETE and INSERT to capture transition table rows.
3175 * In such case, either old tuple or new tuple can be NULL.
3176 */
3179
3181 !is_crosspart_update);
3182
3185
3187 GetTupleForTrigger(estate,
3188 NULL,
3189 tupsrc,
3190 tupleid,
3191 LockTupleExclusive,
3192 oldslot,
3193 false,
3194 NULL,
3195 NULL,
3196 NULL);
3199 else
3201
3204 TRIGGER_EVENT_UPDATE,
3205 true,
3208 transition_capture,
3209 is_crosspart_update);
3210 }
3211}
Bitmapset * ExecGetAllUpdatedCols(ResultRelInfo *relinfo, EState *estate)
Definition execUtils.c:1418
References AfterTriggerSaveEvent(), Assert, ereport, errcode(), errmsg(), ERROR, ExecClearTuple(), ExecForceStoreHeapTuple(), ExecGetAllUpdatedCols(), ExecGetTriggerOldSlot(), fb(), GetTupleForTrigger(), ItemPointerIsValid(), LockTupleExclusive, TransitionCaptureState::tcs_update_new_table, TransitionCaptureState::tcs_update_old_table, TriggerDesc::trig_update_after_row, and TRIGGER_EVENT_UPDATE.
Referenced by ExecCrossPartitionUpdateForeignKey(), ExecDeleteEpilogue(), ExecInsert(), ExecSimpleRelationUpdate(), and ExecUpdateEpilogue().
◆ ExecASDeleteTriggers()
| void ExecASDeleteTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| TransitionCaptureState * | transition_capture | ||
| ) |
Definition at line 2681 of file trigger.c.
References AfterTriggerSaveEvent(), fb(), NIL, TriggerDesc::trig_delete_after_statement, and TRIGGER_EVENT_DELETE.
Referenced by fireASTriggers().
◆ ExecASInsertTriggers()
| void ExecASInsertTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| TransitionCaptureState * | transition_capture | ||
| ) |
Definition at line 2452 of file trigger.c.
References AfterTriggerSaveEvent(), fb(), NIL, TriggerDesc::trig_insert_after_statement, and TRIGGER_EVENT_INSERT.
Referenced by CopyFrom(), and fireASTriggers().
◆ ExecASTruncateTriggers()
| void ExecASTruncateTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo | ||
| ) |
Definition at line 3327 of file trigger.c.
3328{
3330
3334 TRIGGER_EVENT_TRUNCATE,
3336 false);
3337}
bool trig_truncate_after_statement
Definition reltrigger.h:73
References AfterTriggerSaveEvent(), fb(), NIL, TriggerDesc::trig_truncate_after_statement, and TRIGGER_EVENT_TRUNCATE.
Referenced by ExecuteTruncateGuts().
◆ ExecASUpdateTriggers()
| void ExecASUpdateTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| TransitionCaptureState * | transition_capture | ||
| ) |
Definition at line 2953 of file trigger.c.
2955{
2957
2958 /* statement-level triggers operate on the parent table */
2960
2963 TRIGGER_EVENT_UPDATE,
2966 transition_capture,
2967 false);
2968}
References AfterTriggerSaveEvent(), Assert, ExecGetAllUpdatedCols(), fb(), NIL, TriggerDesc::trig_update_after_statement, and TRIGGER_EVENT_UPDATE.
Referenced by fireASTriggers().
◆ ExecBRDeleteTriggers()
| bool ExecBRDeleteTriggers | ( | EState * | estate, |
| EPQState * | epqstate, | ||
| ResultRelInfo * | relinfo, | ||
| ItemPointer | tupleid, | ||
| HeapTuple | fdw_trigtuple, | ||
| TupleTableSlot ** | epqslot, | ||
| TM_Result * | tmresult, | ||
| TM_FailureData * | tmfd, | ||
| bool | is_merge_delete | ||
| ) |
Definition at line 2701 of file trigger.c.
2709{
2712 bool result = true;
2717
2720 {
2722
2723 /*
2724 * Get a copy of the on-disk tuple we are planning to delete. In
2725 * general, if the tuple has been concurrently updated, we should
2726 * recheck it using EPQ. However, if this is a MERGE DELETE action,
2727 * we skip this EPQ recheck and leave it to the caller (it must do
2728 * additional rechecking, and might end up executing a different
2729 * action entirely).
2730 */
2734 return false;
2735
2736 /*
2737 * If the tuple was concurrently updated and the caller of this
2738 * function requested for the updated tuple, skip the trigger
2739 * execution.
2740 */
2742 {
2744 return false;
2745 }
2746
2748 }
2749 else
2750 {
2753 }
2754
2757 TRIGGER_EVENT_ROW |
2758 TRIGGER_EVENT_BEFORE;
2761 {
2762 HeapTuple newtuple;
2764
2766 TRIGGER_TYPE_ROW,
2767 TRIGGER_TYPE_BEFORE,
2768 TRIGGER_TYPE_DELETE))
2769 continue;
2772 continue;
2773
2774 LocTriggerData.tg_trigslot = slot;
2778 i,
2779 relinfo->ri_TrigFunctions,
2780 relinfo->ri_TrigInstrument,
2781 GetPerTupleMemoryContext(estate));
2783 {
2784 result = false; /* tell caller to suppress delete */
2785 break;
2786 }
2788 heap_freetuple(newtuple);
2789 }
2792
2793 return result;
2794}
References Assert, ExecCallTriggerFunc(), ExecFetchSlotHeapTuple(), ExecForceStoreHeapTuple(), ExecGetTriggerOldSlot(), fb(), GetPerTupleMemoryContext, GetTupleForTrigger(), heap_freetuple(), HeapTupleIsValid, i, ItemPointerIsValid(), LockTupleExclusive, TriggerDesc::numtriggers, TRIGGER_EVENT_BEFORE, TRIGGER_EVENT_DELETE, TRIGGER_EVENT_ROW, TriggerEnabled(), and TriggerDesc::triggers.
Referenced by ExecDeletePrologue(), and ExecSimpleRelationDelete().
◆ ExecBRInsertTriggers()
| bool ExecBRInsertTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| TupleTableSlot * | slot | ||
| ) |
Definition at line 2465 of file trigger.c.
2467{
2473
2476 TRIGGER_EVENT_ROW |
2477 TRIGGER_EVENT_BEFORE;
2480 {
2482 HeapTuple oldtuple;
2483
2485 TRIGGER_TYPE_ROW,
2486 TRIGGER_TYPE_BEFORE,
2487 TRIGGER_TYPE_INSERT))
2488 continue;
2491 continue;
2492
2493 if (!newtuple)
2495
2496 LocTriggerData.tg_trigslot = slot;
2497 LocTriggerData.tg_trigtuple = oldtuple = newtuple;
2500 i,
2501 relinfo->ri_TrigFunctions,
2502 relinfo->ri_TrigInstrument,
2503 GetPerTupleMemoryContext(estate));
2505 {
2507 heap_freetuple(oldtuple);
2508 return false; /* "do nothing" */
2509 }
2510 else if (newtuple != oldtuple)
2511 {
2512 newtuple = check_modified_virtual_generated(RelationGetDescr(relinfo->ri_RelationDesc), newtuple);
2513
2515
2516 /*
2517 * After a tuple in a partition goes through a trigger, the user
2518 * could have changed the partition key enough that the tuple no
2519 * longer fits the partition. Verify that.
2520 */
2525 errmsg("moving row to another partition during a BEFORE FOR EACH ROW trigger is not supported"),
2527 trigger->tgname,
2530
2532 heap_freetuple(oldtuple);
2533
2534 /* signal tuple should be re-fetched if used */
2535 newtuple = NULL;
2536 }
2537 }
2538
2539 return true;
2540}
bool ExecPartitionCheck(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate, bool emitError)
Definition execMain.c:1860
References check_modified_virtual_generated(), ereport, errcode(), errdetail(), errmsg(), ERROR, ExecCallTriggerFunc(), ExecFetchSlotHeapTuple(), ExecForceStoreHeapTuple(), ExecPartitionCheck(), fb(), get_namespace_name(), GetPerTupleMemoryContext, heap_freetuple(), i, TriggerDesc::numtriggers, RelationGetDescr, RelationGetNamespace, RelationGetRelationName, TRIGGER_EVENT_BEFORE, TRIGGER_EVENT_INSERT, TRIGGER_EVENT_ROW, TriggerEnabled(), TriggerDesc::triggers, and TriggerData::type.
Referenced by CopyFrom(), ExecInsert(), and ExecSimpleRelationInsert().
◆ ExecBRUpdateTriggers()
| bool ExecBRUpdateTriggers | ( | EState * | estate, |
| EPQState * | epqstate, | ||
| ResultRelInfo * | relinfo, | ||
| ItemPointer | tupleid, | ||
| HeapTuple | fdw_trigtuple, | ||
| TupleTableSlot * | newslot, | ||
| TM_Result * | tmresult, | ||
| TM_FailureData * | tmfd, | ||
| bool | is_merge_update | ||
| ) |
Definition at line 2971 of file trigger.c.
2979{
2988 Bitmapset *updatedCols;
2989 LockTupleMode lockmode;
2990
2991 /* Determine lock mode to use */
2993
2996 {
2998
2999 /*
3000 * Get a copy of the on-disk tuple we are planning to update. In
3001 * general, if the tuple has been concurrently updated, we should
3002 * recheck it using EPQ. However, if this is a MERGE UPDATE action,
3003 * we skip this EPQ recheck and leave it to the caller (it must do
3004 * additional rechecking, and might end up executing a different
3005 * action entirely).
3006 */
3010 return false; /* cancel the update action */
3011
3012 /*
3013 * In READ COMMITTED isolation level it's possible that target tuple
3014 * was changed due to concurrent update. In that case we have a raw
3015 * subplan output tuple in epqslot_candidate, and need to form a new
3016 * insertable tuple using ExecGetUpdateNewTuple to replace the one we
3017 * received in newslot. Neither we nor our callers have any further
3018 * interest in the passed-in tuple, so it's okay to overwrite newslot
3019 * with the newer data.
3020 */
3022 {
3024
3026 oldslot);
3027
3028 /*
3029 * Typically, the caller's newslot was also generated by
3030 * ExecGetUpdateNewTuple, so that epqslot_clean will be the same
3031 * slot and copying is not needed. But do the right thing if it
3032 * isn't.
3033 */
3036
3037 /*
3038 * At this point newslot contains a virtual tuple that may
3039 * reference some fields of oldslot's tuple in some disk buffer.
3040 * If that tuple is in a different page than the original target
3041 * tuple, then our only pin on that buffer is oldslot's, and we're
3042 * about to release it. Hence we'd better materialize newslot to
3043 * ensure it doesn't contain references into an unpinned buffer.
3044 * (We'd materialize it below anyway, but too late for safety.)
3045 */
3047 }
3048
3049 /*
3050 * Here we convert oldslot to a materialized slot holding trigtuple.
3051 * Neither slot passed to the triggers will hold any buffer pin.
3052 */
3054 }
3055 else
3056 {
3057 /* Put the FDW-supplied tuple into oldslot to unify the cases */
3060 }
3061
3064 TRIGGER_EVENT_ROW |
3065 TRIGGER_EVENT_BEFORE;
3068 LocTriggerData.tg_updatedcols = updatedCols;
3070 {
3072 HeapTuple oldtuple;
3073
3075 TRIGGER_TYPE_ROW,
3076 TRIGGER_TYPE_BEFORE,
3077 TRIGGER_TYPE_UPDATE))
3078 continue;
3081 continue;
3082
3083 if (!newtuple)
3085
3088 LocTriggerData.tg_newtuple = oldtuple = newtuple;
3092 i,
3093 relinfo->ri_TrigFunctions,
3094 relinfo->ri_TrigInstrument,
3095 GetPerTupleMemoryContext(estate));
3096
3098 {
3102 heap_freetuple(oldtuple);
3103 return false; /* "do nothing" */
3104 }
3105 else if (newtuple != oldtuple)
3106 {
3107 newtuple = check_modified_virtual_generated(RelationGetDescr(relinfo->ri_RelationDesc), newtuple);
3108
3110
3111 /*
3112 * If the tuple returned by the trigger / being stored, is the old
3113 * row version, and the heap tuple passed to the trigger was
3114 * allocated locally, materialize the slot. Otherwise we might
3115 * free it while still referenced by the slot.
3116 */
3119
3121 heap_freetuple(oldtuple);
3122
3123 /* signal tuple should be re-fetched if used */
3124 newtuple = NULL;
3125 }
3126 }
3129
3130 return true;
3131}
LockTupleMode ExecUpdateLockMode(EState *estate, ResultRelInfo *relinfo)
Definition execMain.c:2534
TupleTableSlot * ExecGetUpdateNewTuple(ResultRelInfo *relinfo, TupleTableSlot *planSlot, TupleTableSlot *oldSlot)
Definition nodeModifyTable.c:813
References Assert, check_modified_virtual_generated(), ExecCallTriggerFunc(), ExecCopySlot(), ExecFetchSlotHeapTuple(), ExecForceStoreHeapTuple(), ExecGetAllUpdatedCols(), ExecGetTriggerOldSlot(), ExecGetUpdateNewTuple(), ExecMaterializeSlot(), ExecUpdateLockMode(), fb(), GetPerTupleMemoryContext, GetTupleForTrigger(), heap_freetuple(), HeapTupleIsValid, i, ItemPointerIsValid(), TriggerDesc::numtriggers, RelationGetDescr, TRIGGER_EVENT_BEFORE, TRIGGER_EVENT_ROW, TRIGGER_EVENT_UPDATE, TriggerEnabled(), TriggerDesc::triggers, and unlikely.
Referenced by ExecSimpleRelationUpdate(), and ExecUpdatePrologue().
◆ ExecBSDeleteTriggers()
| void ExecBSDeleteTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo | ||
| ) |
Definition at line 2630 of file trigger.c.
2631{
2632 TriggerDesc *trigdesc;
2635
2636 trigdesc = relinfo->ri_TrigDesc;
2637
2639 return;
2641 return;
2642
2643 /* no-op if we already fired BS triggers in this context */
2645 CMD_DELETE))
2646 return;
2647
2650 TRIGGER_EVENT_BEFORE;
2653 {
2655 HeapTuple newtuple;
2656
2658 TRIGGER_TYPE_STATEMENT,
2659 TRIGGER_TYPE_BEFORE,
2660 TRIGGER_TYPE_DELETE))
2661 continue;
2664 continue;
2665
2668 i,
2669 relinfo->ri_TrigFunctions,
2670 relinfo->ri_TrigInstrument,
2671 GetPerTupleMemoryContext(estate));
2672
2673 if (newtuple)
2677 }
2678}
bool trig_delete_before_statement
Definition reltrigger.h:69
References before_stmt_triggers_fired(), CMD_DELETE, ereport, errcode(), errmsg(), ERROR, ExecCallTriggerFunc(), fb(), GetPerTupleMemoryContext, i, TriggerDesc::numtriggers, RelationGetRelid, TriggerDesc::trig_delete_before_statement, TRIGGER_EVENT_BEFORE, TRIGGER_EVENT_DELETE, TriggerEnabled(), and TriggerDesc::triggers.
Referenced by fireBSTriggers().
◆ ExecBSInsertTriggers()
| void ExecBSInsertTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo | ||
| ) |
Definition at line 2401 of file trigger.c.
2402{
2403 TriggerDesc *trigdesc;
2406
2407 trigdesc = relinfo->ri_TrigDesc;
2408
2410 return;
2412 return;
2413
2414 /* no-op if we already fired BS triggers in this context */
2416 CMD_INSERT))
2417 return;
2418
2421 TRIGGER_EVENT_BEFORE;
2424 {
2426 HeapTuple newtuple;
2427
2429 TRIGGER_TYPE_STATEMENT,
2430 TRIGGER_TYPE_BEFORE,
2431 TRIGGER_TYPE_INSERT))
2432 continue;
2435 continue;
2436
2439 i,
2440 relinfo->ri_TrigFunctions,
2441 relinfo->ri_TrigInstrument,
2442 GetPerTupleMemoryContext(estate));
2443
2444 if (newtuple)
2448 }
2449}
bool trig_insert_before_statement
Definition reltrigger.h:59
References before_stmt_triggers_fired(), CMD_INSERT, ereport, errcode(), errmsg(), ERROR, ExecCallTriggerFunc(), fb(), GetPerTupleMemoryContext, i, TriggerDesc::numtriggers, RelationGetRelid, TriggerDesc::trig_insert_before_statement, TRIGGER_EVENT_BEFORE, TRIGGER_EVENT_INSERT, TriggerEnabled(), and TriggerDesc::triggers.
Referenced by CopyFrom(), and fireBSTriggers().
◆ ExecBSTruncateTriggers()
| void ExecBSTruncateTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo | ||
| ) |
Definition at line 3280 of file trigger.c.
3281{
3282 TriggerDesc *trigdesc;
3285
3286 trigdesc = relinfo->ri_TrigDesc;
3287
3289 return;
3291 return;
3292
3295 TRIGGER_EVENT_BEFORE;
3297
3299 {
3301 HeapTuple newtuple;
3302
3304 TRIGGER_TYPE_STATEMENT,
3305 TRIGGER_TYPE_BEFORE,
3306 TRIGGER_TYPE_TRUNCATE))
3307 continue;
3310 continue;
3311
3314 i,
3315 relinfo->ri_TrigFunctions,
3316 relinfo->ri_TrigInstrument,
3317 GetPerTupleMemoryContext(estate));
3318
3319 if (newtuple)
3323 }
3324}
bool trig_truncate_before_statement
Definition reltrigger.h:72
References ereport, errcode(), errmsg(), ERROR, ExecCallTriggerFunc(), fb(), GetPerTupleMemoryContext, i, TriggerDesc::numtriggers, TriggerDesc::trig_truncate_before_statement, TRIGGER_EVENT_BEFORE, TRIGGER_EVENT_TRUNCATE, TriggerEnabled(), and TriggerDesc::triggers.
Referenced by ExecuteTruncateGuts().
◆ ExecBSUpdateTriggers()
| void ExecBSUpdateTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo | ||
| ) |
Definition at line 2895 of file trigger.c.
2896{
2897 TriggerDesc *trigdesc;
2900 Bitmapset *updatedCols;
2901
2902 trigdesc = relinfo->ri_TrigDesc;
2903
2905 return;
2907 return;
2908
2909 /* no-op if we already fired BS triggers in this context */
2911 CMD_UPDATE))
2912 return;
2913
2914 /* statement-level triggers operate on the parent table */
2916
2918
2921 TRIGGER_EVENT_BEFORE;
2923 LocTriggerData.tg_updatedcols = updatedCols;
2925 {
2927 HeapTuple newtuple;
2928
2930 TRIGGER_TYPE_STATEMENT,
2931 TRIGGER_TYPE_BEFORE,
2932 TRIGGER_TYPE_UPDATE))
2933 continue;
2936 continue;
2937
2940 i,
2941 relinfo->ri_TrigFunctions,
2942 relinfo->ri_TrigInstrument,
2943 GetPerTupleMemoryContext(estate));
2944
2945 if (newtuple)
2949 }
2950}
bool trig_update_before_statement
Definition reltrigger.h:64
References Assert, before_stmt_triggers_fired(), CMD_UPDATE, ereport, errcode(), errmsg(), ERROR, ExecCallTriggerFunc(), ExecGetAllUpdatedCols(), fb(), GetPerTupleMemoryContext, i, TriggerDesc::numtriggers, RelationGetRelid, TriggerDesc::trig_update_before_statement, TRIGGER_EVENT_BEFORE, TRIGGER_EVENT_UPDATE, TriggerEnabled(), and TriggerDesc::triggers.
Referenced by fireBSTriggers().
◆ ExecCallTriggerFunc()
|
static |
Definition at line 2309 of file trigger.c.
2314{
2315 LOCAL_FCINFO(fcinfo, 0);
2317 Datum result;
2319
2320 /*
2321 * Protect against code paths that may fail to initialize transition table
2322 * info.
2323 */
2331
2332 finfo += tgindx;
2333
2334 /*
2335 * We cache fmgr lookup info, to avoid making the lookup again on each
2336 * call.
2337 */
2340
2342
2343 /*
2344 * If doing EXPLAIN ANALYZE, start charging time to this trigger.
2345 */
2346 if (instr)
2348
2349 /*
2350 * Do the function evaluation in the per-tuple memory context, so that
2351 * leaked memory will be reclaimed once per tuple. Note in particular that
2352 * any new tuple created by the trigger function will live till the end of
2353 * the tuple cycle.
2354 */
2356
2357 /*
2358 * Call the function, passing no arguments but setting a context.
2359 */
2360 InitFunctionCallInfoData(*fcinfo, finfo, 0,
2362
2364
2365 MyTriggerDepth++;
2366 PG_TRY();
2367 {
2368 result = FunctionCallInvoke(fcinfo);
2369 }
2370 PG_FINALLY();
2371 {
2372 MyTriggerDepth--;
2373 }
2374 PG_END_TRY();
2375
2377
2379
2380 /*
2381 * Trigger protocol allows function to return a null pointer, but NOT to
2382 * set the isnull result flag.
2383 */
2384 if (fcinfo->isnull)
2388 fcinfo->flinfo->fn_oid)));
2389
2390 /*
2391 * If doing EXPLAIN ANALYZE, stop charging time to this trigger, and count
2392 * one "tuple returned" (really the number of firings).
2393 */
2394 if (instr)
2396
2398}
#define InitFunctionCallInfoData(Fcinfo, Flinfo, Nargs, Collation, Context, Resultinfo)
Definition fmgr.h:150
void pgstat_init_function_usage(FunctionCallInfo fcinfo, PgStat_FunctionCallUsage *fcu)
Definition pgstat_function.c:72
void pgstat_end_function_usage(PgStat_FunctionCallUsage *fcu, bool finalize)
Definition pgstat_function.c:146
Definition pgstat.h:93
References AFTER_TRIGGER_DEFERRABLE, AFTER_TRIGGER_INITDEFERRED, Assert, DatumGetPointer(), ereport, errcode(), errmsg(), ERROR, fb(), fmgr_info(), FmgrInfo::fn_oid, FunctionCallInvoke, InitFunctionCallInfoData, InstrStartNode(), InstrStopNode(), InvalidOid, LOCAL_FCINFO, MemoryContextSwitchTo(), MyTriggerDepth, PG_END_TRY, PG_FINALLY, PG_TRY, pgstat_end_function_usage(), pgstat_init_function_usage(), TriggerData::tg_event, TriggerData::tg_newtable, TriggerData::tg_oldtable, TriggerData::tg_trigger, Trigger::tgfoid, TRIGGER_FIRED_AFTER, TRIGGER_FIRED_BY_DELETE, TRIGGER_FIRED_BY_INSERT, and TRIGGER_FIRED_BY_UPDATE.
Referenced by AfterTriggerExecute(), ExecBRDeleteTriggers(), ExecBRInsertTriggers(), ExecBRUpdateTriggers(), ExecBSDeleteTriggers(), ExecBSInsertTriggers(), ExecBSTruncateTriggers(), ExecBSUpdateTriggers(), ExecIRDeleteTriggers(), ExecIRInsertTriggers(), and ExecIRUpdateTriggers().
◆ ExecIRDeleteTriggers()
| bool ExecIRDeleteTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| HeapTuple | trigtuple | ||
| ) |
Definition at line 2848 of file trigger.c.
2850{
2855
2858 TRIGGER_EVENT_ROW |
2859 TRIGGER_EVENT_INSTEAD;
2861
2863
2865 {
2868
2870 TRIGGER_TYPE_ROW,
2871 TRIGGER_TYPE_INSTEAD,
2872 TRIGGER_TYPE_DELETE))
2873 continue;
2876 continue;
2877
2878 LocTriggerData.tg_trigslot = slot;
2882 i,
2883 relinfo->ri_TrigFunctions,
2884 relinfo->ri_TrigInstrument,
2885 GetPerTupleMemoryContext(estate));
2887 return false; /* Delete was suppressed */
2890 }
2891 return true;
2892}
References ExecCallTriggerFunc(), ExecForceStoreHeapTuple(), ExecGetTriggerOldSlot(), fb(), GetPerTupleMemoryContext, heap_freetuple(), i, TriggerDesc::numtriggers, TRIGGER_EVENT_DELETE, TRIGGER_EVENT_INSTEAD, TRIGGER_EVENT_ROW, TriggerEnabled(), TriggerDesc::triggers, and TriggerData::type.
Referenced by ExecDelete(), and ExecMergeMatched().
◆ ExecIRInsertTriggers()
| bool ExecIRInsertTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| TupleTableSlot * | slot | ||
| ) |
Definition at line 2569 of file trigger.c.
2571{
2577
2580 TRIGGER_EVENT_ROW |
2581 TRIGGER_EVENT_INSTEAD;
2584 {
2586 HeapTuple oldtuple;
2587
2589 TRIGGER_TYPE_ROW,
2590 TRIGGER_TYPE_INSTEAD,
2591 TRIGGER_TYPE_INSERT))
2592 continue;
2595 continue;
2596
2597 if (!newtuple)
2599
2600 LocTriggerData.tg_trigslot = slot;
2601 LocTriggerData.tg_trigtuple = oldtuple = newtuple;
2604 i,
2605 relinfo->ri_TrigFunctions,
2606 relinfo->ri_TrigInstrument,
2607 GetPerTupleMemoryContext(estate));
2609 {
2611 heap_freetuple(oldtuple);
2612 return false; /* "do nothing" */
2613 }
2614 else if (newtuple != oldtuple)
2615 {
2617
2619 heap_freetuple(oldtuple);
2620
2621 /* signal tuple should be re-fetched if used */
2622 newtuple = NULL;
2623 }
2624 }
2625
2626 return true;
2627}
References ExecCallTriggerFunc(), ExecFetchSlotHeapTuple(), ExecForceStoreHeapTuple(), fb(), GetPerTupleMemoryContext, heap_freetuple(), i, TriggerDesc::numtriggers, TRIGGER_EVENT_INSERT, TRIGGER_EVENT_INSTEAD, TRIGGER_EVENT_ROW, TriggerEnabled(), TriggerDesc::triggers, and TriggerData::type.
Referenced by CopyFrom(), and ExecInsert().
◆ ExecIRUpdateTriggers()
| bool ExecIRUpdateTriggers | ( | EState * | estate, |
| ResultRelInfo * | relinfo, | ||
| HeapTuple | trigtuple, | ||
| TupleTableSlot * | newslot | ||
| ) |
Definition at line 3214 of file trigger.c.
3216{
3223
3226 TRIGGER_EVENT_ROW |
3227 TRIGGER_EVENT_INSTEAD;
3229
3231
3233 {
3235 HeapTuple oldtuple;
3236
3238 TRIGGER_TYPE_ROW,
3239 TRIGGER_TYPE_INSTEAD,
3240 TRIGGER_TYPE_UPDATE))
3241 continue;
3244 continue;
3245
3246 if (!newtuple)
3248
3252 LocTriggerData.tg_newtuple = oldtuple = newtuple;
3253
3256 i,
3257 relinfo->ri_TrigFunctions,
3258 relinfo->ri_TrigInstrument,
3259 GetPerTupleMemoryContext(estate));
3261 {
3262 return false; /* "do nothing" */
3263 }
3264 else if (newtuple != oldtuple)
3265 {
3267
3269 heap_freetuple(oldtuple);
3270
3271 /* signal tuple should be re-fetched if used */
3272 newtuple = NULL;
3273 }
3274 }
3275
3276 return true;
3277}
References ExecCallTriggerFunc(), ExecFetchSlotHeapTuple(), ExecForceStoreHeapTuple(), ExecGetTriggerOldSlot(), fb(), GetPerTupleMemoryContext, heap_freetuple(), i, TriggerDesc::numtriggers, TRIGGER_EVENT_INSTEAD, TRIGGER_EVENT_ROW, TRIGGER_EVENT_UPDATE, TriggerEnabled(), TriggerDesc::triggers, and TriggerData::type.
Referenced by ExecMergeMatched(), and ExecUpdate().
◆ FindTriggerIncompatibleWithInheritance()
| const char * FindTriggerIncompatibleWithInheritance | ( | TriggerDesc * | trigdesc | ) |
Definition at line 2277 of file trigger.c.
2278{
2280 {
2282
2284 {
2286
2288 continue;
2291 }
2292 }
2293
2295}
References fb(), i, TriggerDesc::numtriggers, Trigger::tgname, and TriggerDesc::triggers.
Referenced by ATExecAddInherit(), and ATExecAttachPartition().
◆ FreeTriggerDesc()
| void FreeTriggerDesc | ( | TriggerDesc * | trigdesc | ) |
Definition at line 2145 of file trigger.c.
2146{
2149
2151 return;
2152
2155 {
2160 {
2164 }
2171 trigger++;
2172 }
2174 pfree(trigdesc);
2175}
References fb(), i, TriggerDesc::numtriggers, pfree(), and TriggerDesc::triggers.
Referenced by RelationBuildTriggers(), and RelationDestroyRelation().
◆ get_trigger_oid()
Definition at line 1370 of file trigger.c.
1371{
1376 Oid oid;
1377
1378 /*
1379 * Find the trigger, verify permissions, set up object address
1380 */
1382
1384 Anum_pg_trigger_tgrelid,
1386 ObjectIdGetDatum(relid));
1388 Anum_pg_trigger_tgname,
1390 CStringGetDatum(trigname));
1391
1394
1396
1398 {
1399 if (!missing_ok)
1403 trigname, get_rel_name(relid))));
1404 oid = InvalidOid;
1405 }
1406 else
1407 {
1409 }
1410
1413 return oid;
1414}
References AccessShareLock, BTEqualStrategyNumber, CStringGetDatum(), ereport, errcode(), errmsg(), ERROR, fb(), get_rel_name(), GETSTRUCT(), HeapTupleIsValid, InvalidOid, ObjectIdGetDatum(), ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().
Referenced by get_object_address_relobject().
◆ GetAfterTriggersStoreSlot()
|
static |
Definition at line 4908 of file trigger.c.
4910{
4911 /* Create it if not already done. */
4913 {
4915
4916 /*
4917 * We need this slot only until AfterTriggerEndQuery, but making it
4918 * last till end-of-subxact is good enough. It'll be freed by
4919 * AfterTriggerFreeQuery(). However, the passed-in tupdesc might have
4920 * a different lifespan, so we'd better make a copy of that.
4921 */
4923 tupdesc = CreateTupleDescCopy(tupdesc);
4926 }
4927
4929}
References CreateTupleDescCopy(), CurTransactionContext, fb(), MakeSingleTupleTableSlot(), MemoryContextSwitchTo(), table, and TTSOpsVirtual.
Referenced by TransitionTableAddTuple().
◆ GetAfterTriggersTableData()
|
static |
Definition at line 4866 of file trigger.c.
4867{
4872
4873 /* At this level, cmdType should not be, eg, CMD_MERGE */
4875 cmdType == CMD_UPDATE ||
4876 cmdType == CMD_DELETE);
4877
4878 /* Caller should have ensured query_depth is OK. */
4882
4884 {
4887 !table->closed)
4889 }
4890
4892
4894 table->relid = relid;
4895 table->cmdType = cmdType;
4897
4899
4901}
References afterTriggers, Assert, CMD_DELETE, CMD_INSERT, CMD_UPDATE, CurTransactionContext, fb(), lappend(), lfirst, AfterTriggersData::maxquerydepth, MemoryContextSwitchTo(), palloc0_object, AfterTriggersData::query_depth, AfterTriggersData::query_stack, and table.
Referenced by before_stmt_triggers_fired(), cancel_prior_stmt_triggers(), and MakeTransitionCaptureState().
◆ GetAfterTriggersTransitionTable()
|
static |
Definition at line 5535 of file trigger.c.
5539{
5545
5546 /*
5547 * For INSERT events NEW should be non-NULL, for DELETE events OLD should
5548 * be non-NULL, whereas for UPDATE events normally both OLD and NEW are
5549 * non-NULL. But for UPDATE events fired for capturing transition tuples
5550 * during UPDATE partition-key row movement, OLD is NULL when the event is
5551 * for a row being inserted, whereas NEW is NULL when the event is for a
5552 * row being deleted.
5553 */
5558
5560 {
5566 }
5568 {
5574 }
5575
5576 return tuplestore;
5577}
References Assert, fb(), AfterTriggersTableData::new_tuplestore, AfterTriggersTableData::old_tuplestore, TransitionCaptureState::tcs_delete_old_table, TransitionCaptureState::tcs_delete_private, TransitionCaptureState::tcs_insert_new_table, TransitionCaptureState::tcs_insert_private, TransitionCaptureState::tcs_update_new_table, TransitionCaptureState::tcs_update_old_table, TransitionCaptureState::tcs_update_private, TRIGGER_EVENT_DELETE, TRIGGER_EVENT_INSERT, TRIGGER_EVENT_UPDATE, and TupIsNull.
Referenced by AfterTriggerSaveEvent().
◆ GetCurrentFDWTuplestore()
|
static |
Definition at line 3971 of file trigger.c.
3972{
3973 Tuplestorestate *ret;
3974
3977 {
3980
3981 /*
3982 * Make the tuplestore valid until end of subtransaction. We really
3983 * only need it until AfterTriggerEndQuery().
3984 */
3988
3990
3993
3995 }
3996
3997 return ret;
3998}
References afterTriggers, CurrentResourceOwner, CurTransactionContext, CurTransactionResourceOwner, fb(), AfterTriggersQueryData::fdw_tuplestore, MemoryContextSwitchTo(), AfterTriggersData::query_depth, AfterTriggersData::query_stack, tuplestore_begin_heap(), and work_mem.
Referenced by AfterTriggerExecute(), and AfterTriggerSaveEvent().
◆ GetTupleForTrigger()
|
static |
Definition at line 3344 of file trigger.c.
3354{
3356
3358 {
3360 TM_FailureData tmfd;
3362
3364
3365 /* caller must pass an epqstate if EvalPlanQual is possible */
3367
3368 /*
3369 * lock tuple for update
3370 */
3374 estate->es_output_cid,
3375 lockmode, LockWaitBlock,
3376 lockflags,
3377 &tmfd);
3378
3379 /* Let the caller know about the status of this operation */
3383 *tmfdp = tmfd;
3384
3386 {
3388
3389 /*
3390 * The target tuple was already updated or deleted by the
3391 * current command, or by a later command in the current
3392 * transaction. We ignore the tuple in the former case, and
3393 * throw error in the latter case, for the same reasons
3394 * enumerated in ExecUpdate and ExecDelete in
3395 * nodeModifyTable.c.
3396 */
3400 errmsg("tuple to be updated was already modified by an operation triggered by the current command"),
3401 errhint("Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
3402
3403 /* treat it as deleted; do not process */
3404 return false;
3405
3408 {
3409 /*
3410 * Recheck the tuple using EPQ, if requested. Otherwise,
3411 * just return that it was concurrently updated.
3412 */
3414 {
3416 relation,
3417 relinfo->ri_RangeTableIndex,
3418 oldslot);
3419
3420 /*
3421 * If PlanQual failed for updated tuple - we must not
3422 * process this tuple!
3423 */
3425 {
3427 return false;
3428 }
3429 }
3430 else
3431 {
3434 return false;
3435 }
3436 }
3437 break;
3438
3445 break;
3446
3452 /* tuple was deleted */
3453 return false;
3454
3457 break;
3458
3459 default:
3461 return false; /* keep compiler quiet */
3462 }
3463 }
3464 else
3465 {
3466 /*
3467 * We expect the tuple to be present, thus very simple error handling
3468 * suffices.
3469 */
3471 oldslot))
3473 }
3474
3475 return true;
3476}
TupleTableSlot * EvalPlanQual(EPQState *epqstate, Relation relation, Index rti, TupleTableSlot *inputslot)
Definition execMain.c:2653
Definition tableam.h:148
static TM_Result table_tuple_lock(Relation rel, ItemPointer tid, Snapshot snapshot, TupleTableSlot *slot, CommandId cid, LockTupleMode mode, LockWaitPolicy wait_policy, uint8 flags, TM_FailureData *tmfd)
Definition tableam.h:1559
References Assert, TM_FailureData::cmax, elog, ereport, errcode(), ERRCODE_T_R_SERIALIZATION_FAILURE, errhint(), errmsg(), ERROR, EState::es_output_cid, EState::es_snapshot, EvalPlanQual(), fb(), IsolationUsesXactSnapshot, LockWaitBlock, SnapshotAny, table_tuple_fetch_row_version(), table_tuple_lock(), test(), TM_Deleted, TM_Invisible, TM_Ok, TM_SelfModified, TM_Updated, TM_FailureData::traversed, TupIsNull, and TUPLE_LOCK_FLAG_FIND_LAST_VERSION.
Referenced by ExecARDeleteTriggers(), ExecARUpdateTriggers(), ExecBRDeleteTriggers(), and ExecBRUpdateTriggers().
◆ MakeTransitionCaptureState()
| TransitionCaptureState * MakeTransitionCaptureState | ( | TriggerDesc * | trigdesc, |
| Oid | relid, | ||
| CmdType | cmdType | ||
| ) |
Definition at line 4957 of file trigger.c.
4958{
4961 need_new_upd,
4962 need_old_del,
4963 need_new_ins;
4969
4972
4973 /* Detect which table(s) we need. */
4974 switch (cmdType)
4975 {
4979 break;
4984 break;
4988 break;
4994 break;
4995 default:
4997 /* keep compiler quiet */
4999 break;
5000 }
5003
5004 /* Check state, like AfterTriggerSaveEvent. */
5007
5008 /* Be sure we have enough space to record events at this query depth. */
5010 AfterTriggerEnlargeQueryState();
5011
5012 /*
5013 * Find or create AfterTriggersTableData struct(s) to hold the
5014 * tuplestore(s). If there's a matching struct but it's marked closed,
5015 * ignore it; we need a newer one.
5016 *
5017 * Note: MERGE must use the same AfterTriggersTableData structs as INSERT,
5018 * UPDATE, and DELETE, so that any MERGE'd tuples are added to the same
5019 * tuplestores as tuples from any INSERT, UPDATE, or DELETE commands
5020 * running in the same top-level command (e.g., in a writable CTE).
5021 *
5022 * Note: the AfterTriggersTableData list, as well as the tuplestores, are
5023 * allocated in the current (sub)transaction's CurTransactionContext, and
5024 * the tuplestores are managed by the (sub)transaction's resource owner.
5025 * This is sufficient lifespan because we do not allow triggers using
5026 * transition tables to be deferrable; they will be fired during
5027 * AfterTriggerEndQuery, after which it's okay to delete the data.
5028 */
5031 else
5033
5036 else
5038
5041 else
5043
5044 /* Now create required tuplestore(s), if we don't have them already. */
5048
5057
5060
5061 /* Now build the TransitionCaptureState struct, in caller's context */
5070
5072}
References AfterTriggerEnlargeQueryState(), afterTriggers, CMD_DELETE, CMD_INSERT, CMD_MERGE, CMD_UPDATE, CurrentResourceOwner, CurTransactionContext, CurTransactionResourceOwner, elog, ERROR, fb(), GetAfterTriggersTableData(), AfterTriggersData::maxquerydepth, MemoryContextSwitchTo(), palloc0_object, AfterTriggersData::query_depth, TriggerDesc::trig_delete_old_table, TriggerDesc::trig_insert_new_table, TriggerDesc::trig_update_new_table, TriggerDesc::trig_update_old_table, tuplestore_begin_heap(), and work_mem.
Referenced by CopyFrom(), and ExecSetupTransitionCaptureState().
◆ pg_trigger_depth()
| Datum pg_trigger_depth | ( | PG_FUNCTION_ARGS | ) |
Definition at line 6718 of file trigger.c.
References MyTriggerDepth, and PG_RETURN_INT32.
◆ RangeVarCallbackForRenameTrigger()
|
static |
Definition at line 1420 of file trigger.c.
1422{
1423 HeapTuple tuple;
1425
1428 return; /* concurrently dropped */
1430
1431 /* only tables and views can have triggers */
1438 rv->relname),
1440
1441 /* you must own the table to rename one of its triggers */
1448 rv->relname)));
1449
1450 ReleaseSysCache(tuple);
1451}
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
Definition aclchk.c:4090
References aclcheck_error(), ACLCHECK_NOT_OWNER, allowSystemTableMods, ereport, errcode(), errdetail_relkind_not_supported(), errmsg(), ERROR, fb(), get_rel_relkind(), get_relkind_objtype(), GETSTRUCT(), GetUserId(), HeapTupleIsValid, IsSystemClass(), object_ownercheck(), ObjectIdGetDatum(), ReleaseSysCache(), RangeVar::relname, and SearchSysCache1().
Referenced by renametrig().
◆ RelationBuildTriggers()
Definition at line 1861 of file trigger.c.
1862{
1863 TriggerDesc *trigdesc;
1866 Trigger *triggers;
1870 HeapTuple htup;
1873
1874 /*
1875 * Allocate a working array to hold the triggers (the array is extended if
1876 * necessary)
1877 */
1878 maxtrigs = 16;
1880 numtrigs = 0;
1881
1882 /*
1883 * Note: since we scan the triggers using TriggerRelidNameIndexId, we will
1884 * be reading the triggers in name order, except possibly during
1885 * emergency-recovery operations (ie, IgnoreSystemIndexes). This in turn
1886 * ensures that triggers will be fired in name order.
1887 */
1889 Anum_pg_trigger_tgrelid,
1892
1896
1898 {
1901 Datum datum;
1902 bool isnull;
1903
1905 {
1906 maxtrigs *= 2;
1908 }
1910
1925 /* tgattr is first var-width field, so OK to access directly */
1928 {
1932 }
1933 else
1936 {
1938 char *p;
1939
1941 Anum_pg_trigger_tgargs,
1942 tgrel->rd_att, &isnull));
1943 if (isnull)
1945 RelationGetRelationName(relation));
1949 {
1951 p += strlen(p) + 1;
1952 }
1953 }
1954 else
1956
1958 tgrel->rd_att, &isnull);
1959 if (!isnull)
1960 build->tgoldtable =
1962 else
1964
1966 tgrel->rd_att, &isnull);
1967 if (!isnull)
1968 build->tgnewtable =
1970 else
1972
1974 tgrel->rd_att, &isnull);
1975 if (!isnull)
1977 else
1979
1980 numtrigs++;
1981 }
1982
1985
1986 /* There might not be any triggers */
1988 {
1989 pfree(triggers);
1990 return;
1991 }
1992
1993 /* Build trigdesc */
1995 trigdesc->triggers = triggers;
1999
2000 /* Copy completed trigdesc into cache storage */
2004
2005 /* Release working memory */
2006 FreeTriggerDesc(trigdesc);
2007}
static Datum fastgetattr(HeapTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
Definition htup_details.h:861
static void SetTriggerFlags(TriggerDesc *trigdesc, Trigger *trigger)
Definition trigger.c:2013
References AccessShareLock, BTEqualStrategyNumber, CacheMemoryContext, CopyTriggerDesc(), DatumGetByteaPP, DatumGetCString(), DirectFunctionCall1, elog, ERROR, fastgetattr(), fb(), FreeTriggerDesc(), GETSTRUCT(), HeapTupleIsValid, i, MemoryContextSwitchTo(), NameGetDatum(), nameout(), TriggerDesc::numtriggers, ObjectIdGetDatum(), OidIsValid, palloc(), palloc0_object, pfree(), pstrdup(), RelationGetRelationName, RelationGetRelid, repalloc(), ScanKeyInit(), SetTriggerFlags(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), TextDatumGetCString, Trigger::tgoid, RelationData::trigdesc, TriggerDesc::triggers, val, and VARDATA_ANY().
Referenced by RelationBuildDesc(), and RelationCacheInitializePhase3().
◆ RemoveTriggerById()
Definition at line 1291 of file trigger.c.
1292{
1297 Oid relid;
1298 Relation rel;
1299
1301
1302 /*
1303 * Find the trigger to delete.
1304 */
1306 Anum_pg_trigger_oid,
1308 ObjectIdGetDatum(trigOid));
1309
1312
1316
1317 /*
1318 * Open and exclusive-lock the relation the trigger belongs to.
1319 */
1321
1323
1331 RelationGetRelationName(rel)),
1333
1338 RelationGetRelationName(rel))));
1339
1340 /*
1341 * Delete the pg_trigger tuple.
1342 */
1344
1347
1348 /*
1349 * We do not bother to try to determine whether any other triggers remain,
1350 * which would be needed in order to decide whether it's safe to clear the
1351 * relation's relhastriggers. (In any case, there might be a concurrent
1352 * process adding new triggers.) Instead, just force a relcache inval to
1353 * make other backends (and this one too!) rebuild their relcache entries.
1354 * There's no great harm in leaving relhastriggers true even if there are
1355 * no triggers left.
1356 */
1357 CacheInvalidateRelcache(rel);
1358
1359 /* Keep lock on trigger's rel until end of xact */
1361}
void CatalogTupleDelete(Relation heapRel, const ItemPointerData *tid)
Definition indexing.c:365
References AccessExclusiveLock, allowSystemTableMods, BTEqualStrategyNumber, CacheInvalidateRelcache(), CatalogTupleDelete(), elog, ereport, errcode(), errdetail_relkind_not_supported(), errmsg(), ERROR, fb(), GETSTRUCT(), HeapTupleIsValid, IsSystemRelation(), NoLock, ObjectIdGetDatum(), RelationData::rd_rel, RelationGetRelationName, RowExclusiveLock, ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().
Referenced by doDeletion().
◆ renametrig()
| ObjectAddress renametrig | ( | RenameStmt * | stmt | ) |
Definition at line 1467 of file trigger.c.
1468{
1469 Oid tgoid;
1472 HeapTuple tuple;
1475 Oid relid;
1476 ObjectAddress address;
1477
1478 /*
1479 * Look up name, check permissions, and acquire lock (which we will NOT
1480 * release until end of transaction).
1481 */
1483 0,
1485 NULL);
1486
1487 /* Have lock already, so just need to build relcache entry. */
1489
1490 /*
1491 * On partitioned tables, this operation recurses to partitions. Lock all
1492 * tables upfront.
1493 */
1496
1498
1499 /*
1500 * Search for the trigger to modify.
1501 */
1502 ScanKeyInit(&key[0],
1503 Anum_pg_trigger_tgrelid,
1505 ObjectIdGetDatum(relid));
1506 ScanKeyInit(&key[1],
1507 Anum_pg_trigger_tgname,
1511 NULL, 2, key);
1513 {
1515
1517 tgoid = trigform->oid;
1518
1519 /*
1520 * If the trigger descends from a trigger on a parent partitioned
1521 * table, reject the rename. We don't allow a trigger in a partition
1522 * to differ in name from that of its parent: that would lead to an
1523 * inconsistency that pg_dump would not reproduce.
1524 */
1532
1533
1534 /* Rename the trigger on this relation ... */
1536 stmt->subname);
1537
1538 /* ... and if it is partitioned, recurse to its partitions */
1540 {
1542
1544 {
1546
1549 }
1550 }
1551 }
1552 else
1553 {
1558 }
1559
1561
1563
1565
1566 /*
1567 * Close rel, but keep exclusive lock!
1568 */
1570
1571 return address;
1572}
Oid RangeVarGetRelidExtended(const RangeVar *relation, LOCKMODE lockmode, uint32 flags, RangeVarGetRelidCallback callback, void *callback_arg)
Definition namespace.c:440
Oid get_partition_parent(Oid relid, bool even_if_detached)
Definition partition.c:53
static void renametrig_internal(Relation tgrel, Relation targetrel, HeapTuple trigtup, const char *newname, const char *expected_name)
Definition trigger.c:1582
static void RangeVarCallbackForRenameTrigger(const RangeVar *rv, Oid relid, Oid oldrelid, void *arg)
Definition trigger.c:1420
static void renametrig_partition(Relation tgrel, Oid partitionId, Oid parentTriggerOid, const char *newname, const char *expected_name)
Definition trigger.c:1653
References AccessExclusiveLock, BTEqualStrategyNumber, ereport, errcode(), errhint(), errmsg(), ERROR, fb(), find_all_inheritors(), get_partition_parent(), get_rel_name(), GETSTRUCT(), HeapTupleIsValid, i, NoLock, PartitionDescData::nparts, ObjectAddressSet, ObjectIdGetDatum(), OidIsValid, PartitionDescData::oids, PointerGetDatum(), RangeVarCallbackForRenameTrigger(), RangeVarGetRelidExtended(), relation_close(), relation_open(), RelationGetPartitionDesc(), RelationGetRelationName, renametrig_internal(), renametrig_partition(), RowExclusiveLock, ScanKeyInit(), stmt, systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().
Referenced by ExecRenameStmt().
◆ renametrig_internal()
|
static |
Definition at line 1582 of file trigger.c.
1584{
1585 HeapTuple tuple;
1589
1590 /* If the trigger already has the new name, nothing to do. */
1593 return;
1594
1595 /*
1596 * Before actually trying the rename, search for triggers with the same
1597 * name. The update would fail with an ugly message in that case, and it
1598 * is better to throw a nicer error.
1599 */
1600 ScanKeyInit(&key[0],
1601 Anum_pg_trigger_tgrelid,
1604 ScanKeyInit(&key[1],
1605 Anum_pg_trigger_tgname,
1607 PointerGetDatum(newname));
1609 NULL, 2, key);
1616
1617 /*
1618 * The target name is free; update the existing pg_trigger tuple with it.
1619 */
1622
1623 /*
1624 * If the trigger has a name different from what we expected, let the user
1625 * know. (We can proceed anyway, since we must have reached here following
1626 * a tgparentid link.)
1627 */
1633
1635
1637
1639
1640 /*
1641 * Invalidate relation's relcache entry so that other backends (and this
1642 * one too!) are sent SI message to make them rebuild relcache entries.
1643 * (Ideally this should happen automatically...)
1644 */
1646}
References BTEqualStrategyNumber, CacheInvalidateRelcache(), CatalogTupleUpdate(), ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg(), ERROR, fb(), GETSTRUCT(), heap_copytuple(), HeapTupleIsValid, InvokeObjectPostAlterHook, NameStr, namestrcpy(), NOTICE, ObjectIdGetDatum(), PointerGetDatum(), RelationGetRelationName, RelationGetRelid, ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), and HeapTupleData::t_self.
Referenced by renametrig(), and renametrig_partition().
◆ renametrig_partition()
|
static |
Definition at line 1653 of file trigger.c.
1655{
1658 HeapTuple tuple;
1659
1660 /*
1661 * Given a relation and the OID of a trigger on parent relation, find the
1662 * corresponding trigger in the child and rename that trigger to the given
1663 * name.
1664 */
1665 ScanKeyInit(&key,
1666 Anum_pg_trigger_tgrelid,
1670 NULL, 1, &key);
1672 {
1675
1677 continue; /* not our trigger */
1678
1680
1681 /* Rename the trigger on this partition */
1683
1684 /* And if this relation is partitioned, recurse to its partitions */
1686 {
1688 true);
1689
1691 {
1693
1696 }
1697 }
1699
1700 /* There should be at most one matching tuple */
1701 break;
1702 }
1704}
References BTEqualStrategyNumber, fb(), GETSTRUCT(), HeapTupleIsValid, i, NameStr, NoLock, PartitionDescData::nparts, ObjectIdGetDatum(), PartitionDescData::oids, RelationGetPartitionDesc(), renametrig_internal(), renametrig_partition(), ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().
Referenced by renametrig(), and renametrig_partition().
◆ SetConstraintStateAddItem()
|
static |
Definition at line 5736 of file trigger.c.
References Assert, fb(), Max, and repalloc().
Referenced by AfterTriggerSetState().
◆ SetConstraintStateCopy()
|
static |
Definition at line 5716 of file trigger.c.
5717{
5719
5721
5727
5729}
References fb(), and SetConstraintStateCreate().
Referenced by AfterTriggerSetState().
◆ SetConstraintStateCreate()
|
static |
Definition at line 5691 of file trigger.c.
5692{
5694
5695 /* Behave sanely with numalloc == 0 */
5696 if (numalloc <= 0)
5697 numalloc = 1;
5698
5699 /*
5700 * We assume that zeroing will correctly initialize the state values.
5701 */
5706
5707 state->numalloc = numalloc;
5708
5710}
References fb(), MemoryContextAllocZero(), and TopTransactionContext.
Referenced by AfterTriggerSetState(), and SetConstraintStateCopy().
◆ SetTriggerFlags()
|
static |
Definition at line 2013 of file trigger.c.
2014{
2016
2017 trigdesc->trig_insert_before_row |=
2020 trigdesc->trig_insert_after_row |=
2023 trigdesc->trig_insert_instead_row |=
2026 trigdesc->trig_insert_before_statement |=
2029 trigdesc->trig_insert_after_statement |=
2032 trigdesc->trig_update_before_row |=
2035 trigdesc->trig_update_after_row |=
2038 trigdesc->trig_update_instead_row |=
2041 trigdesc->trig_update_before_statement |=
2044 trigdesc->trig_update_after_statement |=
2047 trigdesc->trig_delete_before_row |=
2050 trigdesc->trig_delete_after_row |=
2053 trigdesc->trig_delete_instead_row |=
2056 trigdesc->trig_delete_before_statement |=
2059 trigdesc->trig_delete_after_statement |=
2062 /* there are no row-level truncate triggers */
2063 trigdesc->trig_truncate_before_statement |=
2066 trigdesc->trig_truncate_after_statement |=
2069
2070 trigdesc->trig_insert_new_table |=
2071 (TRIGGER_FOR_INSERT(tgtype) &&
2073 trigdesc->trig_update_old_table |=
2074 (TRIGGER_FOR_UPDATE(tgtype) &&
2076 trigdesc->trig_update_new_table |=
2077 (TRIGGER_FOR_UPDATE(tgtype) &&
2079 trigdesc->trig_delete_old_table |=
2080 (TRIGGER_FOR_DELETE(tgtype) &&
2082}
References fb(), TriggerDesc::trig_delete_after_row, TriggerDesc::trig_delete_after_statement, TriggerDesc::trig_delete_before_row, TriggerDesc::trig_delete_before_statement, TriggerDesc::trig_delete_instead_row, TriggerDesc::trig_delete_old_table, TriggerDesc::trig_insert_after_row, TriggerDesc::trig_insert_after_statement, TriggerDesc::trig_insert_before_row, TriggerDesc::trig_insert_before_statement, TriggerDesc::trig_insert_instead_row, TriggerDesc::trig_insert_new_table, TriggerDesc::trig_truncate_after_statement, TriggerDesc::trig_truncate_before_statement, TriggerDesc::trig_update_after_row, TriggerDesc::trig_update_after_statement, TriggerDesc::trig_update_before_row, TriggerDesc::trig_update_before_statement, TriggerDesc::trig_update_instead_row, TriggerDesc::trig_update_new_table, and TriggerDesc::trig_update_old_table.
Referenced by RelationBuildTriggers().
◆ TransitionTableAddTuple()
|
static |
Definition at line 5586 of file trigger.c.
5593{
5594 TupleConversionMap *map;
5595
5596 /*
5597 * Nothing needs to be done if we don't have a tuplestore.
5598 */
5600 return;
5601
5605 {
5607 TupleTableSlot *storeslot;
5608
5609 switch (event)
5610 {
5613 break;
5616 break;
5619 break;
5620 default:
5623 break;
5624 }
5625
5628 tuplestore_puttupleslot(tuplestore, storeslot);
5629 }
5630 else
5631 tuplestore_puttupleslot(tuplestore, slot);
5632}
References TupleConversionMap::attrMap, elog, ERROR, ExecGetChildToRootMap(), execute_attr_map_slot(), fb(), GetAfterTriggersStoreSlot(), TupleConversionMap::outdesc, table, TransitionCaptureState::tcs_delete_private, TransitionCaptureState::tcs_insert_private, TransitionCaptureState::tcs_update_private, TRIGGER_EVENT_DELETE, TRIGGER_EVENT_INSERT, TRIGGER_EVENT_UPDATE, and tuplestore_puttupleslot().
Referenced by AfterTriggerSaveEvent().
◆ TriggerEnabled()
|
static |
Definition at line 3482 of file trigger.c.
3486{
3487 /* Check replication-role-dependent enable state */
3489 {
3492 return false;
3493 }
3494 else /* ORIGIN or LOCAL role */
3495 {
3498 return false;
3499 }
3500
3501 /*
3502 * Check for column-specific trigger (only possible for UPDATE, and in
3503 * fact we *must* ignore tgattr for other event types)
3504 */
3506 {
3509
3512 {
3514 modifiedCols))
3515 {
3517 break;
3518 }
3519 }
3521 return false;
3522 }
3523
3524 /* Check for WHEN clause */
3526 {
3528 ExprContext *econtext;
3531
3533
3534 /*
3535 * trigger is an element of relinfo->ri_TrigDesc->triggers[]; find the
3536 * matching element of relinfo->ri_TrigWhenExprs[]
3537 */
3540
3541 /*
3542 * If first time through for this WHEN expression, build expression
3543 * nodetrees for it. Keep them in the per-query memory context so
3544 * they'll survive throughout the query.
3545 */
3547 {
3548 Node *tgqual;
3549
3554 /* Change references to OLD and NEW to INNER_VAR and OUTER_VAR */
3557 /* ExecPrepareQual wants implicit-AND form */
3561 }
3562
3563 /*
3564 * We will use the EState's per-tuple context for evaluating WHEN
3565 * expressions (creating it if it's not already there).
3566 */
3567 econtext = GetPerTupleExprContext(estate);
3568
3569 /*
3570 * Finally evaluate the expression, making the old and/or new tuples
3571 * available as INNER_VAR/OUTER_VAR respectively.
3572 */
3576 return false;
3577 }
3578
3579 return true;
3580}
Node * expand_generated_columns_in_expr(Node *node, Relation rel, int rt_index)
Definition rewriteHandler.c:4495
void ChangeVarNodes(Node *node, int rt_index, int new_index, int sublevels_up)
Definition rewriteManip.c:733
Definition execnodes.h:270
Definition execnodes.h:87
Definition primnodes.h:189
References Assert, bms_is_member(), ChangeVarNodes(), ExprContext::ecxt_innertuple, ExprContext::ecxt_outertuple, EState::es_query_cxt, ExecPrepareQual(), ExecQual(), expand_generated_columns_in_expr(), fb(), FirstLowInvalidHeapAttributeNumber, GetPerTupleExprContext, i, INNER_VAR, make_ands_implicit(), MemoryContextSwitchTo(), OUTER_VAR, PRS2_NEW_VARNO, PRS2_OLD_VARNO, SESSION_REPLICATION_ROLE_REPLICA, SessionReplicationRole, stringToNode(), TRIGGER_DISABLED, TRIGGER_FIRED_BY_UPDATE, TRIGGER_FIRES_ON_ORIGIN, and TRIGGER_FIRES_ON_REPLICA.
Referenced by AfterTriggerSaveEvent(), ExecBRDeleteTriggers(), ExecBRInsertTriggers(), ExecBRUpdateTriggers(), ExecBSDeleteTriggers(), ExecBSInsertTriggers(), ExecBSTruncateTriggers(), ExecBSUpdateTriggers(), ExecIRDeleteTriggers(), ExecIRInsertTriggers(), and ExecIRUpdateTriggers().
◆ TriggerSetParentTrigger()
| void TriggerSetParentTrigger | ( | Relation | trigRel, |
| Oid | childTrigId, | ||
| Oid | parentTrigId, | ||
| Oid | childTableId | ||
| ) |
Definition at line 1220 of file trigger.c.
1224{
1228 HeapTuple tuple,
1229 newtup;
1232
1233 /*
1234 * Find the trigger to delete.
1235 */
1237 Anum_pg_trigger_oid,
1240
1243
1250 {
1251 /* don't allow setting parent for a constraint that already has one */
1254 childTrigId);
1255
1257
1259
1261
1264
1267 }
1268 else
1269 {
1271
1273
1275 TriggerRelationId,
1276 DEPENDENCY_PARTITION_PRI);
1278 RelationRelationId,
1279 DEPENDENCY_PARTITION_SEC);
1280 }
1281
1284}
long deleteDependencyRecordsForClass(Oid classId, Oid objectId, Oid refclassId, char deptype)
Definition pg_depend.c:351
References BTEqualStrategyNumber, CatalogTupleUpdate(), deleteDependencyRecordsForClass(), DEPENDENCY_PARTITION_PRI, DEPENDENCY_PARTITION_SEC, elog, ERROR, fb(), GETSTRUCT(), heap_copytuple(), heap_freetuple(), HeapTupleIsValid, InvalidOid, ObjectAddressSet, ObjectIdGetDatum(), OidIsValid, recordDependencyOn(), ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), and HeapTupleData::t_self.
Referenced by AttachPartitionForeignKey(), and DetachPartitionFinalize().
Variable Documentation
◆ afterTriggers
|
static |
Definition at line 3930 of file trigger.c.
Referenced by afterTriggerAddEvent(), AfterTriggerBeginQuery(), AfterTriggerBeginSubXact(), AfterTriggerBeginXact(), afterTriggerCheckState(), afterTriggerCopyBitmap(), AfterTriggerEndQuery(), AfterTriggerEndSubXact(), AfterTriggerEndXact(), AfterTriggerEnlargeQueryState(), AfterTriggerFireDeferred(), afterTriggerMarkEvents(), AfterTriggerPendingOnRel(), AfterTriggerSaveEvent(), AfterTriggerSetState(), before_stmt_triggers_fired(), cancel_prior_stmt_triggers(), GetAfterTriggersTableData(), GetCurrentFDWTuplestore(), and MakeTransitionCaptureState().
◆ MyTriggerDepth
|
static |
Definition at line 66 of file trigger.c.
Referenced by ExecCallTriggerFunc(), and pg_trigger_depth().
◆ SessionReplicationRole
| int SessionReplicationRole = SESSION_REPLICATION_ROLE_ORIGIN |
Definition at line 63 of file trigger.c.
Referenced by assign_session_replication_role(), filter_event_trigger(), matchLocks(), and TriggerEnabled().
