| 1 | /* |
| 2 | moddatetime.c |
| 3 | |
| 4 | contrib/spi/moddatetime.c |
| 5 | |
| 6 | What is this? |
| 7 | It is a function to be called from a trigger for the purpose of updating |
| 8 | a modification datetime stamp in a record when that record is UPDATEd. |
| 9 | |
| 10 | Credits |
| 11 | This is 95%+ based on autoinc.c, which I used as a starting point as I do |
| 12 | not really know what I am doing. I also had help from |
| 13 | Jan Wieck <jwieck@debis.com> who told me about the timestamp_in("now") function. |
| 14 | OH, me, I'm Terry Mackintosh <terry@terrym.com> |
| 15 | */ |
| 16 | #include "postgres.h" |
| 17 | |
| 18 | #include "access/htup_details.h" |
| 19 | #include "catalog/pg_type.h" |
| 20 | #include "executor/spi.h" |
| 21 | #include "commands/trigger.h" |
| 22 | #include "utils/builtins.h" |
| 23 | #include "utils/rel.h" |
| 24 | |
| 25 | PG_MODULE_MAGIC; |
| 26 | |
| 27 | PG_FUNCTION_INFO_V1(moddatetime); |
| 28 | |
| 29 | Datum |
| 30 | moddatetime(PG_FUNCTION_ARGS) |
| 31 | { |
| 32 | TriggerData *trigdata = (TriggerData *) fcinfo->context; |
| 33 | Trigger *trigger; /* to get trigger name */ |
| 34 | int nargs; /* # of arguments */ |
| 35 | int attnum; /* positional number of field to change */ |
| 36 | Oid atttypid; /* type OID of field to change */ |
| 37 | Datum newdt; /* The current datetime. */ |
| 38 | bool newdtnull; /* null flag for it */ |
| 39 | char **args; /* arguments */ |
| 40 | char *relname; /* triggered relation name */ |
| 41 | Relation rel; /* triggered relation */ |
| 42 | HeapTuple rettuple = NULL; |
| 43 | TupleDesc tupdesc; /* tuple description */ |
| 44 | |
| 45 | if (!CALLED_AS_TRIGGER(fcinfo)) |
| 46 | /* internal error */ |
| 47 | elog(ERROR, "moddatetime: not fired by trigger manager" ); |
| 48 | |
| 49 | if (!TRIGGER_FIRED_FOR_ROW(trigdata->tg_event)) |
| 50 | /* internal error */ |
| 51 | elog(ERROR, "moddatetime: must be fired for row" ); |
| 52 | |
| 53 | if (!TRIGGER_FIRED_BEFORE(trigdata->tg_event)) |
| 54 | /* internal error */ |
| 55 | elog(ERROR, "moddatetime: must be fired before event" ); |
| 56 | |
| 57 | if (TRIGGER_FIRED_BY_INSERT(trigdata->tg_event)) |
| 58 | /* internal error */ |
| 59 | elog(ERROR, "moddatetime: cannot process INSERT events" ); |
| 60 | else if (TRIGGER_FIRED_BY_UPDATE(trigdata->tg_event)) |
| 61 | rettuple = trigdata->tg_newtuple; |
| 62 | else |
| 63 | /* internal error */ |
| 64 | elog(ERROR, "moddatetime: cannot process DELETE events" ); |
| 65 | |
| 66 | rel = trigdata->tg_relation; |
| 67 | relname = SPI_getrelname(rel); |
| 68 | |
| 69 | trigger = trigdata->tg_trigger; |
| 70 | |
| 71 | nargs = trigger->tgnargs; |
| 72 | |
| 73 | if (nargs != 1) |
| 74 | /* internal error */ |
| 75 | elog(ERROR, "moddatetime (%s): A single argument was expected" , relname); |
| 76 | |
| 77 | args = trigger->tgargs; |
| 78 | /* must be the field layout? */ |
| 79 | tupdesc = rel->rd_att; |
| 80 | |
| 81 | /* |
| 82 | * This gets the position in the tuple of the field we want. args[0] being |
| 83 | * the name of the field to update, as passed in from the trigger. |
| 84 | */ |
| 85 | attnum = SPI_fnumber(tupdesc, args[0]); |
| 86 | |
| 87 | /* |
| 88 | * This is where we check to see if the field we are supposed to update |
| 89 | * even exists. |
| 90 | */ |
| 91 | if (attnum <= 0) |
| 92 | ereport(ERROR, |
| 93 | (errcode(ERRCODE_TRIGGERED_ACTION_EXCEPTION), |
| 94 | errmsg("\"%s\" has no attribute \"%s\"" , |
| 95 | relname, args[0]))); |
| 96 | |
| 97 | /* |
| 98 | * Check the target field has an allowed type, and get the current |
| 99 | * datetime as a value of that type. |
| 100 | */ |
| 101 | atttypid = SPI_gettypeid(tupdesc, attnum); |
| 102 | if (atttypid == TIMESTAMPOID) |
| 103 | newdt = DirectFunctionCall3(timestamp_in, |
| 104 | CStringGetDatum("now" ), |
| 105 | ObjectIdGetDatum(InvalidOid), |
| 106 | Int32GetDatum(-1)); |
| 107 | else if (atttypid == TIMESTAMPTZOID) |
| 108 | newdt = DirectFunctionCall3(timestamptz_in, |
| 109 | CStringGetDatum("now" ), |
| 110 | ObjectIdGetDatum(InvalidOid), |
| 111 | Int32GetDatum(-1)); |
| 112 | else |
| 113 | { |
| 114 | ereport(ERROR, |
| 115 | (errcode(ERRCODE_TRIGGERED_ACTION_EXCEPTION), |
| 116 | errmsg("attribute \"%s\" of \"%s\" must be type TIMESTAMP or TIMESTAMPTZ" , |
| 117 | args[0], relname))); |
| 118 | newdt = (Datum) 0; /* keep compiler quiet */ |
| 119 | } |
| 120 | newdtnull = false; |
| 121 | |
| 122 | /* Replace the attnum'th column with newdt */ |
| 123 | rettuple = heap_modify_tuple_by_cols(rettuple, tupdesc, |
| 124 | 1, &attnum, &newdt, &newdtnull); |
| 125 | |
| 126 | /* Clean up */ |
| 127 | pfree(relname); |
| 128 | |
| 129 | return PointerGetDatum(rettuple); |
| 130 | } |
| 131 | |