PostgreSQL Source Code  git master
sequence.c
Go to the documentation of this file.
1 /*-------------------------------------------------------------------------
2  *
3  * sequence.c
4  * PostgreSQL sequences support code.
5  *
6  * Portions Copyright (c) 1996-2024, PostgreSQL Global Development Group
7  * Portions Copyright (c) 1994, Regents of the University of California
8  *
9  *
10  * IDENTIFICATION
11  * src/backend/commands/sequence.c
12  *
13  *-------------------------------------------------------------------------
14  */
15 #include "postgres.h"
16 
17 #include "access/bufmask.h"
18 #include "access/htup_details.h"
19 #include "access/multixact.h"
20 #include "access/relation.h"
21 #include "access/sequence.h"
22 #include "access/table.h"
23 #include "access/transam.h"
24 #include "access/xact.h"
25 #include "access/xlog.h"
26 #include "access/xloginsert.h"
27 #include "access/xlogutils.h"
28 #include "catalog/dependency.h"
29 #include "catalog/indexing.h"
30 #include "catalog/namespace.h"
31 #include "catalog/objectaccess.h"
32 #include "catalog/pg_sequence.h"
33 #include "catalog/pg_type.h"
34 #include "catalog/storage_xlog.h"
35 #include "commands/defrem.h"
36 #include "commands/sequence.h"
37 #include "commands/tablecmds.h"
38 #include "funcapi.h"
39 #include "miscadmin.h"
40 #include "nodes/makefuncs.h"
41 #include "parser/parse_type.h"
42 #include "storage/lmgr.h"
43 #include "storage/proc.h"
44 #include "storage/smgr.h"
45 #include "utils/acl.h"
46 #include "utils/builtins.h"
47 #include "utils/lsyscache.h"
48 #include "utils/resowner.h"
49 #include "utils/syscache.h"
50 #include "utils/varlena.h"
51 
52 
53 /*
54  * We don't want to log each fetching of a value from a sequence,
55  * so we pre-log a few fetches in advance. In the event of
56  * crash we can lose (skip over) as many values as we pre-logged.
57  */
58 #define SEQ_LOG_VALS 32
59 
60 /*
61  * The "special area" of a sequence's buffer page looks like this.
62  */
63 #define SEQ_MAGIC 0x1717
64 
65 typedef struct sequence_magic
66 {
69 
70 /*
71  * We store a SeqTable item for every sequence we have touched in the current
72  * session. This is needed to hold onto nextval/currval state. (We can't
73  * rely on the relcache, since it's only, well, a cache, and may decide to
74  * discard entries.)
75  */
76 typedef struct SeqTableData
77 {
78  Oid relid; /* pg_class OID of this sequence (hash key) */
79  RelFileNumber filenumber; /* last seen relfilenumber of this sequence */
80  LocalTransactionId lxid; /* xact in which we last did a seq op */
81  bool last_valid; /* do we have a valid "last" value? */
82  int64 last; /* value last returned by nextval */
83  int64 cached; /* last value already cached for nextval */
84  /* if last != cached, we have not used up all the cached values */
85  int64 increment; /* copy of sequence's increment field */
86  /* note that increment is zero until we first do nextval_internal() */
88 
90 
91 static HTAB *seqhashtab = NULL; /* hash table for SeqTable items */
92 
93 /*
94  * last_used_seq is updated by nextval() to point to the last used
95  * sequence.
96  */
97 static SeqTableData *last_used_seq = NULL;
98 
99 static void fill_seq_with_data(Relation rel, HeapTuple tuple);
100 static void fill_seq_fork_with_data(Relation rel, HeapTuple tuple, ForkNumber forkNum);
102 static void create_seq_hashtable(void);
103 static void init_sequence(Oid relid, SeqTable *p_elm, Relation *p_rel);
105  Buffer *buf, HeapTuple seqdatatuple);
106 static void init_params(ParseState *pstate, List *options, bool for_identity,
107  bool isInit,
108  Form_pg_sequence seqform,
109  Form_pg_sequence_data seqdataform,
110  bool *need_seq_rewrite,
111  List **owned_by);
112 static void do_setval(Oid relid, int64 next, bool iscalled);
113 static void process_owned_by(Relation seqrel, List *owned_by, bool for_identity);
114 
115 
116 /*
117  * DefineSequence
118  * Creates a new sequence relation
119  */
122 {
123  FormData_pg_sequence seqform;
124  FormData_pg_sequence_data seqdataform;
125  bool need_seq_rewrite;
126  List *owned_by;
128  Oid seqoid;
129  ObjectAddress address;
130  Relation rel;
131  HeapTuple tuple;
132  TupleDesc tupDesc;
134  bool null[SEQ_COL_LASTCOL];
135  Datum pgs_values[Natts_pg_sequence];
136  bool pgs_nulls[Natts_pg_sequence];
137  int i;
138 
139  /*
140  * If if_not_exists was given and a relation with the same name already
141  * exists, bail out. (Note: we needn't check this when not if_not_exists,
142  * because DefineRelation will complain anyway.)
143  */
144  if (seq->if_not_exists)
145  {
147  if (OidIsValid(seqoid))
148  {
149  /*
150  * If we are in an extension script, insist that the pre-existing
151  * object be a member of the extension, to avoid security risks.
152  */
153  ObjectAddressSet(address, RelationRelationId, seqoid);
155 
156  /* OK to skip */
157  ereport(NOTICE,
158  (errcode(ERRCODE_DUPLICATE_TABLE),
159  errmsg("relation \"%s\" already exists, skipping",
160  seq->sequence->relname)));
161  return InvalidObjectAddress;
162  }
163  }
164 
165  /* Check and set all option values */
166  init_params(pstate, seq->options, seq->for_identity, true,
167  &seqform, &seqdataform,
168  &need_seq_rewrite, &owned_by);
169 
170  /*
171  * Create relation (and fill value[] and null[] for the tuple)
172  */
173  stmt->tableElts = NIL;
174  for (i = SEQ_COL_FIRSTCOL; i <= SEQ_COL_LASTCOL; i++)
175  {
176  ColumnDef *coldef = NULL;
177 
178  switch (i)
179  {
180  case SEQ_COL_LASTVAL:
181  coldef = makeColumnDef("last_value", INT8OID, -1, InvalidOid);
182  value[i - 1] = Int64GetDatumFast(seqdataform.last_value);
183  break;
184  case SEQ_COL_LOG:
185  coldef = makeColumnDef("log_cnt", INT8OID, -1, InvalidOid);
186  value[i - 1] = Int64GetDatum((int64) 0);
187  break;
188  case SEQ_COL_CALLED:
189  coldef = makeColumnDef("is_called", BOOLOID, -1, InvalidOid);
190  value[i - 1] = BoolGetDatum(false);
191  break;
192  }
193 
194  coldef->is_not_null = true;
195  null[i - 1] = false;
196 
197  stmt->tableElts = lappend(stmt->tableElts, coldef);
198  }
199 
200  stmt->relation = seq->sequence;
201  stmt->inhRelations = NIL;
202  stmt->constraints = NIL;
203  stmt->options = NIL;
204  stmt->oncommit = ONCOMMIT_NOOP;
205  stmt->tablespacename = NULL;
206  stmt->if_not_exists = seq->if_not_exists;
207 
208  address = DefineRelation(stmt, RELKIND_SEQUENCE, seq->ownerId, NULL, NULL);
209  seqoid = address.objectId;
210  Assert(seqoid != InvalidOid);
211 
212  rel = sequence_open(seqoid, AccessExclusiveLock);
213  tupDesc = RelationGetDescr(rel);
214 
215  /* now initialize the sequence's data */
216  tuple = heap_form_tuple(tupDesc, value, null);
217  fill_seq_with_data(rel, tuple);
218 
219  /* process OWNED BY if given */
220  if (owned_by)
221  process_owned_by(rel, owned_by, seq->for_identity);
222 
223  sequence_close(rel, NoLock);
224 
225  /* fill in pg_sequence */
226  rel = table_open(SequenceRelationId, RowExclusiveLock);
227  tupDesc = RelationGetDescr(rel);
228 
229  memset(pgs_nulls, 0, sizeof(pgs_nulls));
230 
231  pgs_values[Anum_pg_sequence_seqrelid - 1] = ObjectIdGetDatum(seqoid);
232  pgs_values[Anum_pg_sequence_seqtypid - 1] = ObjectIdGetDatum(seqform.seqtypid);
233  pgs_values[Anum_pg_sequence_seqstart - 1] = Int64GetDatumFast(seqform.seqstart);
234  pgs_values[Anum_pg_sequence_seqincrement - 1] = Int64GetDatumFast(seqform.seqincrement);
235  pgs_values[Anum_pg_sequence_seqmax - 1] = Int64GetDatumFast(seqform.seqmax);
236  pgs_values[Anum_pg_sequence_seqmin - 1] = Int64GetDatumFast(seqform.seqmin);
237  pgs_values[Anum_pg_sequence_seqcache - 1] = Int64GetDatumFast(seqform.seqcache);
238  pgs_values[Anum_pg_sequence_seqcycle - 1] = BoolGetDatum(seqform.seqcycle);
239 
240  tuple = heap_form_tuple(tupDesc, pgs_values, pgs_nulls);
241  CatalogTupleInsert(rel, tuple);
242 
243  heap_freetuple(tuple);
245 
246  return address;
247 }
248 
249 /*
250  * Reset a sequence to its initial value.
251  *
252  * The change is made transactionally, so that on failure of the current
253  * transaction, the sequence will be restored to its previous state.
254  * We do that by creating a whole new relfilenumber for the sequence; so this
255  * works much like the rewriting forms of ALTER TABLE.
256  *
257  * Caller is assumed to have acquired AccessExclusiveLock on the sequence,
258  * which must not be released until end of transaction. Caller is also
259  * responsible for permissions checking.
260  */
261 void
262 ResetSequence(Oid seq_relid)
263 {
264  Relation seq_rel;
265  SeqTable elm;
267  Buffer buf;
268  HeapTupleData seqdatatuple;
269  HeapTuple tuple;
270  HeapTuple pgstuple;
271  Form_pg_sequence pgsform;
272  int64 startv;
273 
274  /*
275  * Read the old sequence. This does a bit more work than really
276  * necessary, but it's simple, and we do want to double-check that it's
277  * indeed a sequence.
278  */
279  init_sequence(seq_relid, &elm, &seq_rel);
280  (void) read_seq_tuple(seq_rel, &buf, &seqdatatuple);
281 
282  pgstuple = SearchSysCache1(SEQRELID, ObjectIdGetDatum(seq_relid));
283  if (!HeapTupleIsValid(pgstuple))
284  elog(ERROR, "cache lookup failed for sequence %u", seq_relid);
285  pgsform = (Form_pg_sequence) GETSTRUCT(pgstuple);
286  startv = pgsform->seqstart;
287  ReleaseSysCache(pgstuple);
288 
289  /*
290  * Copy the existing sequence tuple.
291  */
292  tuple = heap_copytuple(&seqdatatuple);
293 
294  /* Now we're done with the old page */
296 
297  /*
298  * Modify the copied tuple to execute the restart (compare the RESTART
299  * action in AlterSequence)
300  */
301  seq = (Form_pg_sequence_data) GETSTRUCT(tuple);
302  seq->last_value = startv;
303  seq->is_called = false;
304  seq->log_cnt = 0;
305 
306  /*
307  * Create a new storage file for the sequence.
308  */
309  RelationSetNewRelfilenumber(seq_rel, seq_rel->rd_rel->relpersistence);
310 
311  /*
312  * Ensure sequence's relfrozenxid is at 0, since it won't contain any
313  * unfrozen XIDs. Same with relminmxid, since a sequence will never
314  * contain multixacts.
315  */
316  Assert(seq_rel->rd_rel->relfrozenxid == InvalidTransactionId);
317  Assert(seq_rel->rd_rel->relminmxid == InvalidMultiXactId);
318 
319  /*
320  * Insert the modified tuple into the new storage file.
321  */
322  fill_seq_with_data(seq_rel, tuple);
323 
324  /* Clear local cache so that we don't think we have cached numbers */
325  /* Note that we do not change the currval() state */
326  elm->cached = elm->last;
327 
328  sequence_close(seq_rel, NoLock);
329 }
330 
331 /*
332  * Initialize a sequence's relation with the specified tuple as content
333  *
334  * This handles unlogged sequences by writing to both the main and the init
335  * fork as necessary.
336  */
337 static void
339 {
341 
342  if (rel->rd_rel->relpersistence == RELPERSISTENCE_UNLOGGED)
343  {
344  SMgrRelation srel;
345 
347  smgrcreate(srel, INIT_FORKNUM, false);
351  smgrclose(srel);
352  }
353 }
354 
355 /*
356  * Initialize a sequence's relation fork with the specified tuple as content
357  */
358 static void
360 {
361  Buffer buf;
362  Page page;
363  sequence_magic *sm;
364  OffsetNumber offnum;
365 
366  /* Initialize first page of relation with special magic number */
367 
368  buf = ExtendBufferedRel(BMR_REL(rel), forkNum, NULL,
371 
372  page = BufferGetPage(buf);
373 
374  PageInit(page, BufferGetPageSize(buf), sizeof(sequence_magic));
375  sm = (sequence_magic *) PageGetSpecialPointer(page);
376  sm->magic = SEQ_MAGIC;
377 
378  /* Now insert sequence tuple */
379 
380  /*
381  * Since VACUUM does not process sequences, we have to force the tuple to
382  * have xmin = FrozenTransactionId now. Otherwise it would become
383  * invisible to SELECTs after 2G transactions. It is okay to do this
384  * because if the current transaction aborts, no other xact will ever
385  * examine the sequence tuple anyway.
386  */
393 
394  /* check the comment above nextval_internal()'s equivalent call. */
395  if (RelationNeedsWAL(rel))
397 
399 
401 
402  offnum = PageAddItem(page, (Item) tuple->t_data, tuple->t_len,
403  InvalidOffsetNumber, false, false);
404  if (offnum != FirstOffsetNumber)
405  elog(ERROR, "failed to add sequence tuple to page");
406 
407  /* XLOG stuff */
408  if (RelationNeedsWAL(rel) || forkNum == INIT_FORKNUM)
409  {
410  xl_seq_rec xlrec;
411  XLogRecPtr recptr;
412 
413  XLogBeginInsert();
415 
416  xlrec.locator = rel->rd_locator;
417 
418  XLogRegisterData((char *) &xlrec, sizeof(xl_seq_rec));
419  XLogRegisterData((char *) tuple->t_data, tuple->t_len);
420 
421  recptr = XLogInsert(RM_SEQ_ID, XLOG_SEQ_LOG);
422 
423  PageSetLSN(page, recptr);
424  }
425 
427 
429 }
430 
431 /*
432  * AlterSequence
433  *
434  * Modify the definition of a sequence relation
435  */
438 {
439  Oid relid;
440  SeqTable elm;
441  Relation seqrel;
442  Buffer buf;
443  HeapTupleData datatuple;
444  Form_pg_sequence seqform;
445  Form_pg_sequence_data newdataform;
446  bool need_seq_rewrite;
447  List *owned_by;
448  ObjectAddress address;
449  Relation rel;
450  HeapTuple seqtuple;
451  HeapTuple newdatatuple;
452 
453  /* Open and lock sequence, and check for ownership along the way. */
454  relid = RangeVarGetRelidExtended(stmt->sequence,
456  stmt->missing_ok ? RVR_MISSING_OK : 0,
458  NULL);
459  if (relid == InvalidOid)
460  {
461  ereport(NOTICE,
462  (errmsg("relation \"%s\" does not exist, skipping",
463  stmt->sequence->relname)));
464  return InvalidObjectAddress;
465  }
466 
467  init_sequence(relid, &elm, &seqrel);
468 
469  rel = table_open(SequenceRelationId, RowExclusiveLock);
470  seqtuple = SearchSysCacheCopy1(SEQRELID,
471  ObjectIdGetDatum(relid));
472  if (!HeapTupleIsValid(seqtuple))
473  elog(ERROR, "cache lookup failed for sequence %u",
474  relid);
475 
476  seqform = (Form_pg_sequence) GETSTRUCT(seqtuple);
477 
478  /* lock page buffer and read tuple into new sequence structure */
479  (void) read_seq_tuple(seqrel, &buf, &datatuple);
480 
481  /* copy the existing sequence data tuple, so it can be modified locally */
482  newdatatuple = heap_copytuple(&datatuple);
483  newdataform = (Form_pg_sequence_data) GETSTRUCT(newdatatuple);
484 
486 
487  /* Check and set new values */
488  init_params(pstate, stmt->options, stmt->for_identity, false,
489  seqform, newdataform,
490  &need_seq_rewrite, &owned_by);
491 
492  /* If needed, rewrite the sequence relation itself */
493  if (need_seq_rewrite)
494  {
495  /* check the comment above nextval_internal()'s equivalent call. */
496  if (RelationNeedsWAL(seqrel))
498 
499  /*
500  * Create a new storage file for the sequence, making the state
501  * changes transactional.
502  */
503  RelationSetNewRelfilenumber(seqrel, seqrel->rd_rel->relpersistence);
504 
505  /*
506  * Ensure sequence's relfrozenxid is at 0, since it won't contain any
507  * unfrozen XIDs. Same with relminmxid, since a sequence will never
508  * contain multixacts.
509  */
510  Assert(seqrel->rd_rel->relfrozenxid == InvalidTransactionId);
511  Assert(seqrel->rd_rel->relminmxid == InvalidMultiXactId);
512 
513  /*
514  * Insert the modified tuple into the new storage file.
515  */
516  fill_seq_with_data(seqrel, newdatatuple);
517  }
518 
519  /* Clear local cache so that we don't think we have cached numbers */
520  /* Note that we do not change the currval() state */
521  elm->cached = elm->last;
522 
523  /* process OWNED BY if given */
524  if (owned_by)
525  process_owned_by(seqrel, owned_by, stmt->for_identity);
526 
527  /* update the pg_sequence tuple (we could skip this in some cases...) */
528  CatalogTupleUpdate(rel, &seqtuple->t_self, seqtuple);
529 
530  InvokeObjectPostAlterHook(RelationRelationId, relid, 0);
531 
532  ObjectAddressSet(address, RelationRelationId, relid);
533 
535  sequence_close(seqrel, NoLock);
536 
537  return address;
538 }
539 
540 void
541 SequenceChangePersistence(Oid relid, char newrelpersistence)
542 {
543  SeqTable elm;
544  Relation seqrel;
545  Buffer buf;
546  HeapTupleData seqdatatuple;
547 
548  init_sequence(relid, &elm, &seqrel);
549 
550  /* check the comment above nextval_internal()'s equivalent call. */
551  if (RelationNeedsWAL(seqrel))
553 
554  (void) read_seq_tuple(seqrel, &buf, &seqdatatuple);
555  RelationSetNewRelfilenumber(seqrel, newrelpersistence);
556  fill_seq_with_data(seqrel, &seqdatatuple);
558 
559  sequence_close(seqrel, NoLock);
560 }
561 
562 void
564 {
565  Relation rel;
566  HeapTuple tuple;
567 
568  rel = table_open(SequenceRelationId, RowExclusiveLock);
569 
570  tuple = SearchSysCache1(SEQRELID, ObjectIdGetDatum(relid));
571  if (!HeapTupleIsValid(tuple))
572  elog(ERROR, "cache lookup failed for sequence %u", relid);
573 
574  CatalogTupleDelete(rel, &tuple->t_self);
575 
576  ReleaseSysCache(tuple);
578 }
579 
580 /*
581  * Note: nextval with a text argument is no longer exported as a pg_proc
582  * entry, but we keep it around to ease porting of C code that may have
583  * called the function directly.
584  */
585 Datum
587 {
588  text *seqin = PG_GETARG_TEXT_PP(0);
589  RangeVar *sequence;
590  Oid relid;
591 
593 
594  /*
595  * XXX: This is not safe in the presence of concurrent DDL, but acquiring
596  * a lock here is more expensive than letting nextval_internal do it,
597  * since the latter maintains a cache that keeps us from hitting the lock
598  * manager more than once per transaction. It's not clear whether the
599  * performance penalty is material in practice, but for now, we do it this
600  * way.
601  */
602  relid = RangeVarGetRelid(sequence, NoLock, false);
603 
604  PG_RETURN_INT64(nextval_internal(relid, true));
605 }
606 
607 Datum
609 {
610  Oid relid = PG_GETARG_OID(0);
611 
612  PG_RETURN_INT64(nextval_internal(relid, true));
613 }
614 
615 int64
616 nextval_internal(Oid relid, bool check_permissions)
617 {
618  SeqTable elm;
619  Relation seqrel;
620  Buffer buf;
621  Page page;
622  HeapTuple pgstuple;
623  Form_pg_sequence pgsform;
624  HeapTupleData seqdatatuple;
626  int64 incby,
627  maxv,
628  minv,
629  cache,
630  log,
631  fetch,
632  last;
633  int64 result,
634  next,
635  rescnt = 0;
636  bool cycle;
637  bool logit = false;
638 
639  /* open and lock sequence */
640  init_sequence(relid, &elm, &seqrel);
641 
642  if (check_permissions &&
645  ereport(ERROR,
646  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
647  errmsg("permission denied for sequence %s",
648  RelationGetRelationName(seqrel))));
649 
650  /* read-only transactions may only modify temp sequences */
651  if (!seqrel->rd_islocaltemp)
652  PreventCommandIfReadOnly("nextval()");
653 
654  /*
655  * Forbid this during parallel operation because, to make it work, the
656  * cooperating backends would need to share the backend-local cached
657  * sequence information. Currently, we don't support that.
658  */
659  PreventCommandIfParallelMode("nextval()");
660 
661  if (elm->last != elm->cached) /* some numbers were cached */
662  {
663  Assert(elm->last_valid);
664  Assert(elm->increment != 0);
665  elm->last += elm->increment;
666  sequence_close(seqrel, NoLock);
667  last_used_seq = elm;
668  return elm->last;
669  }
670 
671  pgstuple = SearchSysCache1(SEQRELID, ObjectIdGetDatum(relid));
672  if (!HeapTupleIsValid(pgstuple))
673  elog(ERROR, "cache lookup failed for sequence %u", relid);
674  pgsform = (Form_pg_sequence) GETSTRUCT(pgstuple);
675  incby = pgsform->seqincrement;
676  maxv = pgsform->seqmax;
677  minv = pgsform->seqmin;
678  cache = pgsform->seqcache;
679  cycle = pgsform->seqcycle;
680  ReleaseSysCache(pgstuple);
681 
682  /* lock page buffer and read tuple */
683  seq = read_seq_tuple(seqrel, &buf, &seqdatatuple);
684  page = BufferGetPage(buf);
685 
686  last = next = result = seq->last_value;
687  fetch = cache;
688  log = seq->log_cnt;
689 
690  if (!seq->is_called)
691  {
692  rescnt++; /* return last_value if not is_called */
693  fetch--;
694  }
695 
696  /*
697  * Decide whether we should emit a WAL log record. If so, force up the
698  * fetch count to grab SEQ_LOG_VALS more values than we actually need to
699  * cache. (These will then be usable without logging.)
700  *
701  * If this is the first nextval after a checkpoint, we must force a new
702  * WAL record to be written anyway, else replay starting from the
703  * checkpoint would fail to advance the sequence past the logged values.
704  * In this case we may as well fetch extra values.
705  */
706  if (log < fetch || !seq->is_called)
707  {
708  /* forced log to satisfy local demand for values */
709  fetch = log = fetch + SEQ_LOG_VALS;
710  logit = true;
711  }
712  else
713  {
714  XLogRecPtr redoptr = GetRedoRecPtr();
715 
716  if (PageGetLSN(page) <= redoptr)
717  {
718  /* last update of seq was before checkpoint */
719  fetch = log = fetch + SEQ_LOG_VALS;
720  logit = true;
721  }
722  }
723 
724  while (fetch) /* try to fetch cache [+ log ] numbers */
725  {
726  /*
727  * Check MAXVALUE for ascending sequences and MINVALUE for descending
728  * sequences
729  */
730  if (incby > 0)
731  {
732  /* ascending sequence */
733  if ((maxv >= 0 && next > maxv - incby) ||
734  (maxv < 0 && next + incby > maxv))
735  {
736  if (rescnt > 0)
737  break; /* stop fetching */
738  if (!cycle)
739  ereport(ERROR,
740  (errcode(ERRCODE_SEQUENCE_GENERATOR_LIMIT_EXCEEDED),
741  errmsg("nextval: reached maximum value of sequence \"%s\" (%lld)",
742  RelationGetRelationName(seqrel),
743  (long long) maxv)));
744  next = minv;
745  }
746  else
747  next += incby;
748  }
749  else
750  {
751  /* descending sequence */
752  if ((minv < 0 && next < minv - incby) ||
753  (minv >= 0 && next + incby < minv))
754  {
755  if (rescnt > 0)
756  break; /* stop fetching */
757  if (!cycle)
758  ereport(ERROR,
759  (errcode(ERRCODE_SEQUENCE_GENERATOR_LIMIT_EXCEEDED),
760  errmsg("nextval: reached minimum value of sequence \"%s\" (%lld)",
761  RelationGetRelationName(seqrel),
762  (long long) minv)));
763  next = maxv;
764  }
765  else
766  next += incby;
767  }
768  fetch--;
769  if (rescnt < cache)
770  {
771  log--;
772  rescnt++;
773  last = next;
774  if (rescnt == 1) /* if it's first result - */
775  result = next; /* it's what to return */
776  }
777  }
778 
779  log -= fetch; /* adjust for any unfetched numbers */
780  Assert(log >= 0);
781 
782  /* save info in local cache */
783  elm->increment = incby;
784  elm->last = result; /* last returned number */
785  elm->cached = last; /* last fetched number */
786  elm->last_valid = true;
787 
788  last_used_seq = elm;
789 
790  /*
791  * If something needs to be WAL logged, acquire an xid, so this
792  * transaction's commit will trigger a WAL flush and wait for syncrep.
793  * It's sufficient to ensure the toplevel transaction has an xid, no need
794  * to assign xids subxacts, that'll already trigger an appropriate wait.
795  * (Have to do that here, so we're outside the critical section)
796  */
797  if (logit && RelationNeedsWAL(seqrel))
799 
800  /* ready to change the on-disk (or really, in-buffer) tuple */
802 
803  /*
804  * We must mark the buffer dirty before doing XLogInsert(); see notes in
805  * SyncOneBuffer(). However, we don't apply the desired changes just yet.
806  * This looks like a violation of the buffer update protocol, but it is in
807  * fact safe because we hold exclusive lock on the buffer. Any other
808  * process, including a checkpoint, that tries to examine the buffer
809  * contents will block until we release the lock, and then will see the
810  * final state that we install below.
811  */
813 
814  /* XLOG stuff */
815  if (logit && RelationNeedsWAL(seqrel))
816  {
817  xl_seq_rec xlrec;
818  XLogRecPtr recptr;
819 
820  /*
821  * We don't log the current state of the tuple, but rather the state
822  * as it would appear after "log" more fetches. This lets us skip
823  * that many future WAL records, at the cost that we lose those
824  * sequence values if we crash.
825  */
826  XLogBeginInsert();
828 
829  /* set values that will be saved in xlog */
830  seq->last_value = next;
831  seq->is_called = true;
832  seq->log_cnt = 0;
833 
834  xlrec.locator = seqrel->rd_locator;
835 
836  XLogRegisterData((char *) &xlrec, sizeof(xl_seq_rec));
837  XLogRegisterData((char *) seqdatatuple.t_data, seqdatatuple.t_len);
838 
839  recptr = XLogInsert(RM_SEQ_ID, XLOG_SEQ_LOG);
840 
841  PageSetLSN(page, recptr);
842  }
843 
844  /* Now update sequence tuple to the intended final state */
845  seq->last_value = last; /* last fetched number */
846  seq->is_called = true;
847  seq->log_cnt = log; /* how much is logged */
848 
850 
852 
853  sequence_close(seqrel, NoLock);
854 
855  return result;
856 }
857 
858 Datum
860 {
861  Oid relid = PG_GETARG_OID(0);
862  int64 result;
863  SeqTable elm;
864  Relation seqrel;
865 
866  /* open and lock sequence */
867  init_sequence(relid, &elm, &seqrel);
868 
869  if (pg_class_aclcheck(elm->relid, GetUserId(),
871  ereport(ERROR,
872  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
873  errmsg("permission denied for sequence %s",
874  RelationGetRelationName(seqrel))));
875 
876  if (!elm->last_valid)
877  ereport(ERROR,
878  (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
879  errmsg("currval of sequence \"%s\" is not yet defined in this session",
880  RelationGetRelationName(seqrel))));
881 
882  result = elm->last;
883 
884  sequence_close(seqrel, NoLock);
885 
886  PG_RETURN_INT64(result);
887 }
888 
889 Datum
891 {
892  Relation seqrel;
893  int64 result;
894 
895  if (last_used_seq == NULL)
896  ereport(ERROR,
897  (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
898  errmsg("lastval is not yet defined in this session")));
899 
900  /* Someone may have dropped the sequence since the last nextval() */
902  ereport(ERROR,
903  (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
904  errmsg("lastval is not yet defined in this session")));
905 
907 
908  /* nextval() must have already been called for this sequence */
910 
913  ereport(ERROR,
914  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
915  errmsg("permission denied for sequence %s",
916  RelationGetRelationName(seqrel))));
917 
918  result = last_used_seq->last;
919  sequence_close(seqrel, NoLock);
920 
921  PG_RETURN_INT64(result);
922 }
923 
924 /*
925  * Main internal procedure that handles 2 & 3 arg forms of SETVAL.
926  *
927  * Note that the 3 arg version (which sets the is_called flag) is
928  * only for use in pg_dump, and setting the is_called flag may not
929  * work if multiple users are attached to the database and referencing
930  * the sequence (unlikely if pg_dump is restoring it).
931  *
932  * It is necessary to have the 3 arg version so that pg_dump can
933  * restore the state of a sequence exactly during data-only restores -
934  * it is the only way to clear the is_called flag in an existing
935  * sequence.
936  */
937 static void
938 do_setval(Oid relid, int64 next, bool iscalled)
939 {
940  SeqTable elm;
941  Relation seqrel;
942  Buffer buf;
943  HeapTupleData seqdatatuple;
945  HeapTuple pgstuple;
946  Form_pg_sequence pgsform;
947  int64 maxv,
948  minv;
949 
950  /* open and lock sequence */
951  init_sequence(relid, &elm, &seqrel);
952 
954  ereport(ERROR,
955  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
956  errmsg("permission denied for sequence %s",
957  RelationGetRelationName(seqrel))));
958 
959  pgstuple = SearchSysCache1(SEQRELID, ObjectIdGetDatum(relid));
960  if (!HeapTupleIsValid(pgstuple))
961  elog(ERROR, "cache lookup failed for sequence %u", relid);
962  pgsform = (Form_pg_sequence) GETSTRUCT(pgstuple);
963  maxv = pgsform->seqmax;
964  minv = pgsform->seqmin;
965  ReleaseSysCache(pgstuple);
966 
967  /* read-only transactions may only modify temp sequences */
968  if (!seqrel->rd_islocaltemp)
969  PreventCommandIfReadOnly("setval()");
970 
971  /*
972  * Forbid this during parallel operation because, to make it work, the
973  * cooperating backends would need to share the backend-local cached
974  * sequence information. Currently, we don't support that.
975  */
976  PreventCommandIfParallelMode("setval()");
977 
978  /* lock page buffer and read tuple */
979  seq = read_seq_tuple(seqrel, &buf, &seqdatatuple);
980 
981  if ((next < minv) || (next > maxv))
982  ereport(ERROR,
983  (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
984  errmsg("setval: value %lld is out of bounds for sequence \"%s\" (%lld..%lld)",
985  (long long) next, RelationGetRelationName(seqrel),
986  (long long) minv, (long long) maxv)));
987 
988  /* Set the currval() state only if iscalled = true */
989  if (iscalled)
990  {
991  elm->last = next; /* last returned number */
992  elm->last_valid = true;
993  }
994 
995  /* In any case, forget any future cached numbers */
996  elm->cached = elm->last;
997 
998  /* check the comment above nextval_internal()'s equivalent call. */
999  if (RelationNeedsWAL(seqrel))
1001 
1002  /* ready to change the on-disk (or really, in-buffer) tuple */
1004 
1005  seq->last_value = next; /* last fetched number */
1006  seq->is_called = iscalled;
1007  seq->log_cnt = 0;
1008 
1010 
1011  /* XLOG stuff */
1012  if (RelationNeedsWAL(seqrel))
1013  {
1014  xl_seq_rec xlrec;
1015  XLogRecPtr recptr;
1016  Page page = BufferGetPage(buf);
1017 
1018  XLogBeginInsert();
1020 
1021  xlrec.locator = seqrel->rd_locator;
1022  XLogRegisterData((char *) &xlrec, sizeof(xl_seq_rec));
1023  XLogRegisterData((char *) seqdatatuple.t_data, seqdatatuple.t_len);
1024 
1025  recptr = XLogInsert(RM_SEQ_ID, XLOG_SEQ_LOG);
1026 
1027  PageSetLSN(page, recptr);
1028  }
1029 
1030  END_CRIT_SECTION();
1031 
1033 
1034  sequence_close(seqrel, NoLock);
1035 }
1036 
1037 /*
1038  * Implement the 2 arg setval procedure.
1039  * See do_setval for discussion.
1040  */
1041 Datum
1043 {
1044  Oid relid = PG_GETARG_OID(0);
1045  int64 next = PG_GETARG_INT64(1);
1046 
1047  do_setval(relid, next, true);
1048 
1050 }
1051 
1052 /*
1053  * Implement the 3 arg setval procedure.
1054  * See do_setval for discussion.
1055  */
1056 Datum
1058 {
1059  Oid relid = PG_GETARG_OID(0);
1060  int64 next = PG_GETARG_INT64(1);
1061  bool iscalled = PG_GETARG_BOOL(2);
1062 
1063  do_setval(relid, next, iscalled);
1064 
1066 }
1067 
1068 
1069 /*
1070  * Open the sequence and acquire lock if needed
1071  *
1072  * If we haven't touched the sequence already in this transaction,
1073  * we need to acquire a lock. We arrange for the lock to
1074  * be owned by the top transaction, so that we don't need to do it
1075  * more than once per xact.
1076  */
1077 static Relation
1079 {
1080  LocalTransactionId thislxid = MyProc->vxid.lxid;
1081 
1082  /* Get the lock if not already held in this xact */
1083  if (seq->lxid != thislxid)
1084  {
1085  ResourceOwner currentOwner;
1086 
1087  currentOwner = CurrentResourceOwner;
1089 
1091 
1092  CurrentResourceOwner = currentOwner;
1093 
1094  /* Flag that we have a lock in the current xact */
1095  seq->lxid = thislxid;
1096  }
1097 
1098  /* We now know we have the lock, and can safely open the rel */
1099  return sequence_open(seq->relid, NoLock);
1100 }
1101 
1102 /*
1103  * Creates the hash table for storing sequence data
1104  */
1105 static void
1107 {
1108  HASHCTL ctl;
1109 
1110  ctl.keysize = sizeof(Oid);
1111  ctl.entrysize = sizeof(SeqTableData);
1112 
1113  seqhashtab = hash_create("Sequence values", 16, &ctl,
1114  HASH_ELEM | HASH_BLOBS);
1115 }
1116 
1117 /*
1118  * Given a relation OID, open and lock the sequence. p_elm and p_rel are
1119  * output parameters.
1120  */
1121 static void
1122 init_sequence(Oid relid, SeqTable *p_elm, Relation *p_rel)
1123 {
1124  SeqTable elm;
1125  Relation seqrel;
1126  bool found;
1127 
1128  /* Find or create a hash table entry for this sequence */
1129  if (seqhashtab == NULL)
1131 
1132  elm = (SeqTable) hash_search(seqhashtab, &relid, HASH_ENTER, &found);
1133 
1134  /*
1135  * Initialize the new hash table entry if it did not exist already.
1136  *
1137  * NOTE: seqhashtab entries are stored for the life of a backend (unless
1138  * explicitly discarded with DISCARD). If the sequence itself is deleted
1139  * then the entry becomes wasted memory, but it's small enough that this
1140  * should not matter.
1141  */
1142  if (!found)
1143  {
1144  /* relid already filled in */
1147  elm->last_valid = false;
1148  elm->last = elm->cached = 0;
1149  }
1150 
1151  /*
1152  * Open the sequence relation.
1153  */
1154  seqrel = lock_and_open_sequence(elm);
1155 
1156  /*
1157  * If the sequence has been transactionally replaced since we last saw it,
1158  * discard any cached-but-unissued values. We do not touch the currval()
1159  * state, however.
1160  */
1161  if (seqrel->rd_rel->relfilenode != elm->filenumber)
1162  {
1163  elm->filenumber = seqrel->rd_rel->relfilenode;
1164  elm->cached = elm->last;
1165  }
1166 
1167  /* Return results */
1168  *p_elm = elm;
1169  *p_rel = seqrel;
1170 }
1171 
1172 
1173 /*
1174  * Given an opened sequence relation, lock the page buffer and find the tuple
1175  *
1176  * *buf receives the reference to the pinned-and-ex-locked buffer
1177  * *seqdatatuple receives the reference to the sequence tuple proper
1178  * (this arg should point to a local variable of type HeapTupleData)
1179  *
1180  * Function's return value points to the data payload of the tuple
1181  */
1182 static Form_pg_sequence_data
1184 {
1185  Page page;
1186  ItemId lp;
1187  sequence_magic *sm;
1189 
1190  *buf = ReadBuffer(rel, 0);
1192 
1193  page = BufferGetPage(*buf);
1194  sm = (sequence_magic *) PageGetSpecialPointer(page);
1195 
1196  if (sm->magic != SEQ_MAGIC)
1197  elog(ERROR, "bad magic number in sequence \"%s\": %08X",
1198  RelationGetRelationName(rel), sm->magic);
1199 
1200  lp = PageGetItemId(page, FirstOffsetNumber);
1201  Assert(ItemIdIsNormal(lp));
1202 
1203  /* Note we currently only bother to set these two fields of *seqdatatuple */
1204  seqdatatuple->t_data = (HeapTupleHeader) PageGetItem(page, lp);
1205  seqdatatuple->t_len = ItemIdGetLength(lp);
1206 
1207  /*
1208  * Previous releases of Postgres neglected to prevent SELECT FOR UPDATE on
1209  * a sequence, which would leave a non-frozen XID in the sequence tuple's
1210  * xmax, which eventually leads to clog access failures or worse. If we
1211  * see this has happened, clean up after it. We treat this like a hint
1212  * bit update, ie, don't bother to WAL-log it, since we can certainly do
1213  * this again if the update gets lost.
1214  */
1215  Assert(!(seqdatatuple->t_data->t_infomask & HEAP_XMAX_IS_MULTI));
1217  {
1219  seqdatatuple->t_data->t_infomask &= ~HEAP_XMAX_COMMITTED;
1220  seqdatatuple->t_data->t_infomask |= HEAP_XMAX_INVALID;
1221  MarkBufferDirtyHint(*buf, true);
1222  }
1223 
1224  seq = (Form_pg_sequence_data) GETSTRUCT(seqdatatuple);
1225 
1226  return seq;
1227 }
1228 
1229 /*
1230  * init_params: process the options list of CREATE or ALTER SEQUENCE, and
1231  * store the values into appropriate fields of seqform, for changes that go
1232  * into the pg_sequence catalog, and fields of seqdataform for changes to the
1233  * sequence relation itself. Set *need_seq_rewrite to true if we changed any
1234  * parameters that require rewriting the sequence's relation (interesting for
1235  * ALTER SEQUENCE). Also set *owned_by to any OWNED BY option, or to NIL if
1236  * there is none.
1237  *
1238  * If isInit is true, fill any unspecified options with default values;
1239  * otherwise, do not change existing options that aren't explicitly overridden.
1240  *
1241  * Note: we force a sequence rewrite whenever we change parameters that affect
1242  * generation of future sequence values, even if the seqdataform per se is not
1243  * changed. This allows ALTER SEQUENCE to behave transactionally. Currently,
1244  * the only option that doesn't cause that is OWNED BY. It's *necessary* for
1245  * ALTER SEQUENCE OWNED BY to not rewrite the sequence, because that would
1246  * break pg_upgrade by causing unwanted changes in the sequence's
1247  * relfilenumber.
1248  */
1249 static void
1250 init_params(ParseState *pstate, List *options, bool for_identity,
1251  bool isInit,
1252  Form_pg_sequence seqform,
1253  Form_pg_sequence_data seqdataform,
1254  bool *need_seq_rewrite,
1255  List **owned_by)
1256 {
1257  DefElem *as_type = NULL;
1258  DefElem *start_value = NULL;
1259  DefElem *restart_value = NULL;
1260  DefElem *increment_by = NULL;
1261  DefElem *max_value = NULL;
1262  DefElem *min_value = NULL;
1263  DefElem *cache_value = NULL;
1264  DefElem *is_cycled = NULL;
1265  ListCell *option;
1266  bool reset_max_value = false;
1267  bool reset_min_value = false;
1268 
1269  *need_seq_rewrite = false;
1270  *owned_by = NIL;
1271 
1272  foreach(option, options)
1273  {
1274  DefElem *defel = (DefElem *) lfirst(option);
1275 
1276  if (strcmp(defel->defname, "as") == 0)
1277  {
1278  if (as_type)
1279  errorConflictingDefElem(defel, pstate);
1280  as_type = defel;
1281  *need_seq_rewrite = true;
1282  }
1283  else if (strcmp(defel->defname, "increment") == 0)
1284  {
1285  if (increment_by)
1286  errorConflictingDefElem(defel, pstate);
1287  increment_by = defel;
1288  *need_seq_rewrite = true;
1289  }
1290  else if (strcmp(defel->defname, "start") == 0)
1291  {
1292  if (start_value)
1293  errorConflictingDefElem(defel, pstate);
1294  start_value = defel;
1295  *need_seq_rewrite = true;
1296  }
1297  else if (strcmp(defel->defname, "restart") == 0)
1298  {
1299  if (restart_value)
1300  errorConflictingDefElem(defel, pstate);
1301  restart_value = defel;
1302  *need_seq_rewrite = true;
1303  }
1304  else if (strcmp(defel->defname, "maxvalue") == 0)
1305  {
1306  if (max_value)
1307  errorConflictingDefElem(defel, pstate);
1308  max_value = defel;
1309  *need_seq_rewrite = true;
1310  }
1311  else if (strcmp(defel->defname, "minvalue") == 0)
1312  {
1313  if (min_value)
1314  errorConflictingDefElem(defel, pstate);
1315  min_value = defel;
1316  *need_seq_rewrite = true;
1317  }
1318  else if (strcmp(defel->defname, "cache") == 0)
1319  {
1320  if (cache_value)
1321  errorConflictingDefElem(defel, pstate);
1322  cache_value = defel;
1323  *need_seq_rewrite = true;
1324  }
1325  else if (strcmp(defel->defname, "cycle") == 0)
1326  {
1327  if (is_cycled)
1328  errorConflictingDefElem(defel, pstate);
1329  is_cycled = defel;
1330  *need_seq_rewrite = true;
1331  }
1332  else if (strcmp(defel->defname, "owned_by") == 0)
1333  {
1334  if (*owned_by)
1335  errorConflictingDefElem(defel, pstate);
1336  *owned_by = defGetQualifiedName(defel);
1337  }
1338  else if (strcmp(defel->defname, "sequence_name") == 0)
1339  {
1340  /*
1341  * The parser allows this, but it is only for identity columns, in
1342  * which case it is filtered out in parse_utilcmd.c. We only get
1343  * here if someone puts it into a CREATE SEQUENCE.
1344  */
1345  ereport(ERROR,
1346  (errcode(ERRCODE_SYNTAX_ERROR),
1347  errmsg("invalid sequence option SEQUENCE NAME"),
1348  parser_errposition(pstate, defel->location)));
1349  }
1350  else
1351  elog(ERROR, "option \"%s\" not recognized",
1352  defel->defname);
1353  }
1354 
1355  /*
1356  * We must reset log_cnt when isInit or when changing any parameters that
1357  * would affect future nextval allocations.
1358  */
1359  if (isInit)
1360  seqdataform->log_cnt = 0;
1361 
1362  /* AS type */
1363  if (as_type != NULL)
1364  {
1365  Oid newtypid = typenameTypeId(pstate, defGetTypeName(as_type));
1366 
1367  if (newtypid != INT2OID &&
1368  newtypid != INT4OID &&
1369  newtypid != INT8OID)
1370  ereport(ERROR,
1371  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1372  for_identity
1373  ? errmsg("identity column type must be smallint, integer, or bigint")
1374  : errmsg("sequence type must be smallint, integer, or bigint")));
1375 
1376  if (!isInit)
1377  {
1378  /*
1379  * When changing type and the old sequence min/max values were the
1380  * min/max of the old type, adjust sequence min/max values to
1381  * min/max of new type. (Otherwise, the user chose explicit
1382  * min/max values, which we'll leave alone.)
1383  */
1384  if ((seqform->seqtypid == INT2OID && seqform->seqmax == PG_INT16_MAX) ||
1385  (seqform->seqtypid == INT4OID && seqform->seqmax == PG_INT32_MAX) ||
1386  (seqform->seqtypid == INT8OID && seqform->seqmax == PG_INT64_MAX))
1387  reset_max_value = true;
1388  if ((seqform->seqtypid == INT2OID && seqform->seqmin == PG_INT16_MIN) ||
1389  (seqform->seqtypid == INT4OID && seqform->seqmin == PG_INT32_MIN) ||
1390  (seqform->seqtypid == INT8OID && seqform->seqmin == PG_INT64_MIN))
1391  reset_min_value = true;
1392  }
1393 
1394  seqform->seqtypid = newtypid;
1395  }
1396  else if (isInit)
1397  {
1398  seqform->seqtypid = INT8OID;
1399  }
1400 
1401  /* INCREMENT BY */
1402  if (increment_by != NULL)
1403  {
1404  seqform->seqincrement = defGetInt64(increment_by);
1405  if (seqform->seqincrement == 0)
1406  ereport(ERROR,
1407  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1408  errmsg("INCREMENT must not be zero")));
1409  seqdataform->log_cnt = 0;
1410  }
1411  else if (isInit)
1412  {
1413  seqform->seqincrement = 1;
1414  }
1415 
1416  /* CYCLE */
1417  if (is_cycled != NULL)
1418  {
1419  seqform->seqcycle = boolVal(is_cycled->arg);
1420  Assert(BoolIsValid(seqform->seqcycle));
1421  seqdataform->log_cnt = 0;
1422  }
1423  else if (isInit)
1424  {
1425  seqform->seqcycle = false;
1426  }
1427 
1428  /* MAXVALUE (null arg means NO MAXVALUE) */
1429  if (max_value != NULL && max_value->arg)
1430  {
1431  seqform->seqmax = defGetInt64(max_value);
1432  seqdataform->log_cnt = 0;
1433  }
1434  else if (isInit || max_value != NULL || reset_max_value)
1435  {
1436  if (seqform->seqincrement > 0 || reset_max_value)
1437  {
1438  /* ascending seq */
1439  if (seqform->seqtypid == INT2OID)
1440  seqform->seqmax = PG_INT16_MAX;
1441  else if (seqform->seqtypid == INT4OID)
1442  seqform->seqmax = PG_INT32_MAX;
1443  else
1444  seqform->seqmax = PG_INT64_MAX;
1445  }
1446  else
1447  seqform->seqmax = -1; /* descending seq */
1448  seqdataform->log_cnt = 0;
1449  }
1450 
1451  /* Validate maximum value. No need to check INT8 as seqmax is an int64 */
1452  if ((seqform->seqtypid == INT2OID && (seqform->seqmax < PG_INT16_MIN || seqform->seqmax > PG_INT16_MAX))
1453  || (seqform->seqtypid == INT4OID && (seqform->seqmax < PG_INT32_MIN || seqform->seqmax > PG_INT32_MAX)))
1454  ereport(ERROR,
1455  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1456  errmsg("MAXVALUE (%lld) is out of range for sequence data type %s",
1457  (long long) seqform->seqmax,
1458  format_type_be(seqform->seqtypid))));
1459 
1460  /* MINVALUE (null arg means NO MINVALUE) */
1461  if (min_value != NULL && min_value->arg)
1462  {
1463  seqform->seqmin = defGetInt64(min_value);
1464  seqdataform->log_cnt = 0;
1465  }
1466  else if (isInit || min_value != NULL || reset_min_value)
1467  {
1468  if (seqform->seqincrement < 0 || reset_min_value)
1469  {
1470  /* descending seq */
1471  if (seqform->seqtypid == INT2OID)
1472  seqform->seqmin = PG_INT16_MIN;
1473  else if (seqform->seqtypid == INT4OID)
1474  seqform->seqmin = PG_INT32_MIN;
1475  else
1476  seqform->seqmin = PG_INT64_MIN;
1477  }
1478  else
1479  seqform->seqmin = 1; /* ascending seq */
1480  seqdataform->log_cnt = 0;
1481  }
1482 
1483  /* Validate minimum value. No need to check INT8 as seqmin is an int64 */
1484  if ((seqform->seqtypid == INT2OID && (seqform->seqmin < PG_INT16_MIN || seqform->seqmin > PG_INT16_MAX))
1485  || (seqform->seqtypid == INT4OID && (seqform->seqmin < PG_INT32_MIN || seqform->seqmin > PG_INT32_MAX)))
1486  ereport(ERROR,
1487  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1488  errmsg("MINVALUE (%lld) is out of range for sequence data type %s",
1489  (long long) seqform->seqmin,
1490  format_type_be(seqform->seqtypid))));
1491 
1492  /* crosscheck min/max */
1493  if (seqform->seqmin >= seqform->seqmax)
1494  ereport(ERROR,
1495  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1496  errmsg("MINVALUE (%lld) must be less than MAXVALUE (%lld)",
1497  (long long) seqform->seqmin,
1498  (long long) seqform->seqmax)));
1499 
1500  /* START WITH */
1501  if (start_value != NULL)
1502  {
1503  seqform->seqstart = defGetInt64(start_value);
1504  }
1505  else if (isInit)
1506  {
1507  if (seqform->seqincrement > 0)
1508  seqform->seqstart = seqform->seqmin; /* ascending seq */
1509  else
1510  seqform->seqstart = seqform->seqmax; /* descending seq */
1511  }
1512 
1513  /* crosscheck START */
1514  if (seqform->seqstart < seqform->seqmin)
1515  ereport(ERROR,
1516  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1517  errmsg("START value (%lld) cannot be less than MINVALUE (%lld)",
1518  (long long) seqform->seqstart,
1519  (long long) seqform->seqmin)));
1520  if (seqform->seqstart > seqform->seqmax)
1521  ereport(ERROR,
1522  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1523  errmsg("START value (%lld) cannot be greater than MAXVALUE (%lld)",
1524  (long long) seqform->seqstart,
1525  (long long) seqform->seqmax)));
1526 
1527  /* RESTART [WITH] */
1528  if (restart_value != NULL)
1529  {
1530  if (restart_value->arg != NULL)
1531  seqdataform->last_value = defGetInt64(restart_value);
1532  else
1533  seqdataform->last_value = seqform->seqstart;
1534  seqdataform->is_called = false;
1535  seqdataform->log_cnt = 0;
1536  }
1537  else if (isInit)
1538  {
1539  seqdataform->last_value = seqform->seqstart;
1540  seqdataform->is_called = false;
1541  }
1542 
1543  /* crosscheck RESTART (or current value, if changing MIN/MAX) */
1544  if (seqdataform->last_value < seqform->seqmin)
1545  ereport(ERROR,
1546  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1547  errmsg("RESTART value (%lld) cannot be less than MINVALUE (%lld)",
1548  (long long) seqdataform->last_value,
1549  (long long) seqform->seqmin)));
1550  if (seqdataform->last_value > seqform->seqmax)
1551  ereport(ERROR,
1552  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1553  errmsg("RESTART value (%lld) cannot be greater than MAXVALUE (%lld)",
1554  (long long) seqdataform->last_value,
1555  (long long) seqform->seqmax)));
1556 
1557  /* CACHE */
1558  if (cache_value != NULL)
1559  {
1560  seqform->seqcache = defGetInt64(cache_value);
1561  if (seqform->seqcache <= 0)
1562  ereport(ERROR,
1563  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1564  errmsg("CACHE (%lld) must be greater than zero",
1565  (long long) seqform->seqcache)));
1566  seqdataform->log_cnt = 0;
1567  }
1568  else if (isInit)
1569  {
1570  seqform->seqcache = 1;
1571  }
1572 }
1573 
1574 /*
1575  * Process an OWNED BY option for CREATE/ALTER SEQUENCE
1576  *
1577  * Ownership permissions on the sequence are already checked,
1578  * but if we are establishing a new owned-by dependency, we must
1579  * enforce that the referenced table has the same owner and namespace
1580  * as the sequence.
1581  */
1582 static void
1583 process_owned_by(Relation seqrel, List *owned_by, bool for_identity)
1584 {
1585  DependencyType deptype;
1586  int nnames;
1587  Relation tablerel;
1589 
1590  deptype = for_identity ? DEPENDENCY_INTERNAL : DEPENDENCY_AUTO;
1591 
1592  nnames = list_length(owned_by);
1593  Assert(nnames > 0);
1594  if (nnames == 1)
1595  {
1596  /* Must be OWNED BY NONE */
1597  if (strcmp(strVal(linitial(owned_by)), "none") != 0)
1598  ereport(ERROR,
1599  (errcode(ERRCODE_SYNTAX_ERROR),
1600  errmsg("invalid OWNED BY option"),
1601  errhint("Specify OWNED BY table.column or OWNED BY NONE.")));
1602  tablerel = NULL;
1603  attnum = 0;
1604  }
1605  else
1606  {
1607  List *relname;
1608  char *attrname;
1609  RangeVar *rel;
1610 
1611  /* Separate relname and attr name */
1612  relname = list_copy_head(owned_by, nnames - 1);
1613  attrname = strVal(llast(owned_by));
1614 
1615  /* Open and lock rel to ensure it won't go away meanwhile */
1617  tablerel = relation_openrv(rel, AccessShareLock);
1618 
1619  /* Must be a regular or foreign table */
1620  if (!(tablerel->rd_rel->relkind == RELKIND_RELATION ||
1621  tablerel->rd_rel->relkind == RELKIND_FOREIGN_TABLE ||
1622  tablerel->rd_rel->relkind == RELKIND_VIEW ||
1623  tablerel->rd_rel->relkind == RELKIND_PARTITIONED_TABLE))
1624  ereport(ERROR,
1625  (errcode(ERRCODE_WRONG_OBJECT_TYPE),
1626  errmsg("sequence cannot be owned by relation \"%s\"",
1627  RelationGetRelationName(tablerel)),
1628  errdetail_relkind_not_supported(tablerel->rd_rel->relkind)));
1629 
1630  /* We insist on same owner and schema */
1631  if (seqrel->rd_rel->relowner != tablerel->rd_rel->relowner)
1632  ereport(ERROR,
1633  (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1634  errmsg("sequence must have same owner as table it is linked to")));
1635  if (RelationGetNamespace(seqrel) != RelationGetNamespace(tablerel))
1636  ereport(ERROR,
1637  (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1638  errmsg("sequence must be in same schema as table it is linked to")));
1639 
1640  /* Now, fetch the attribute number from the system cache */
1641  attnum = get_attnum(RelationGetRelid(tablerel), attrname);
1642  if (attnum == InvalidAttrNumber)
1643  ereport(ERROR,
1644  (errcode(ERRCODE_UNDEFINED_COLUMN),
1645  errmsg("column \"%s\" of relation \"%s\" does not exist",
1646  attrname, RelationGetRelationName(tablerel))));
1647  }
1648 
1649  /*
1650  * Catch user explicitly running OWNED BY on identity sequence.
1651  */
1652  if (deptype == DEPENDENCY_AUTO)
1653  {
1654  Oid tableId;
1655  int32 colId;
1656 
1657  if (sequenceIsOwned(RelationGetRelid(seqrel), DEPENDENCY_INTERNAL, &tableId, &colId))
1658  ereport(ERROR,
1659  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1660  errmsg("cannot change ownership of identity sequence"),
1661  errdetail("Sequence \"%s\" is linked to table \"%s\".",
1662  RelationGetRelationName(seqrel),
1663  get_rel_name(tableId))));
1664  }
1665 
1666  /*
1667  * OK, we are ready to update pg_depend. First remove any existing
1668  * dependencies for the sequence, then optionally add a new one.
1669  */
1670  deleteDependencyRecordsForClass(RelationRelationId, RelationGetRelid(seqrel),
1671  RelationRelationId, deptype);
1672 
1673  if (tablerel)
1674  {
1675  ObjectAddress refobject,
1676  depobject;
1677 
1678  refobject.classId = RelationRelationId;
1679  refobject.objectId = RelationGetRelid(tablerel);
1680  refobject.objectSubId = attnum;
1681  depobject.classId = RelationRelationId;
1682  depobject.objectId = RelationGetRelid(seqrel);
1683  depobject.objectSubId = 0;
1684  recordDependencyOn(&depobject, &refobject, deptype);
1685  }
1686 
1687  /* Done, but hold lock until commit */
1688  if (tablerel)
1689  relation_close(tablerel, NoLock);
1690 }
1691 
1692 
1693 /*
1694  * Return sequence parameters in a list of the form created by the parser.
1695  */
1696 List *
1698 {
1699  HeapTuple pgstuple;
1700  Form_pg_sequence pgsform;
1701  List *options = NIL;
1702 
1703  pgstuple = SearchSysCache1(SEQRELID, ObjectIdGetDatum(relid));
1704  if (!HeapTupleIsValid(pgstuple))
1705  elog(ERROR, "cache lookup failed for sequence %u", relid);
1706  pgsform = (Form_pg_sequence) GETSTRUCT(pgstuple);
1707 
1708  /* Use makeFloat() for 64-bit integers, like gram.y does. */
1710  makeDefElem("cache", (Node *) makeFloat(psprintf(INT64_FORMAT, pgsform->seqcache)), -1));
1712  makeDefElem("cycle", (Node *) makeBoolean(pgsform->seqcycle), -1));
1714  makeDefElem("increment", (Node *) makeFloat(psprintf(INT64_FORMAT, pgsform->seqincrement)), -1));
1716  makeDefElem("maxvalue", (Node *) makeFloat(psprintf(INT64_FORMAT, pgsform->seqmax)), -1));
1718  makeDefElem("minvalue", (Node *) makeFloat(psprintf(INT64_FORMAT, pgsform->seqmin)), -1));
1720  makeDefElem("start", (Node *) makeFloat(psprintf(INT64_FORMAT, pgsform->seqstart)), -1));
1721 
1722  ReleaseSysCache(pgstuple);
1723 
1724  return options;
1725 }
1726 
1727 /*
1728  * Return sequence parameters (formerly for use by information schema)
1729  */
1730 Datum
1732 {
1733  Oid relid = PG_GETARG_OID(0);
1734  TupleDesc tupdesc;
1735  Datum values[7];
1736  bool isnull[7];
1737  HeapTuple pgstuple;
1738  Form_pg_sequence pgsform;
1739 
1741  ereport(ERROR,
1742  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1743  errmsg("permission denied for sequence %s",
1744  get_rel_name(relid))));
1745 
1746  if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
1747  elog(ERROR, "return type must be a row type");
1748 
1749  memset(isnull, 0, sizeof(isnull));
1750 
1751  pgstuple = SearchSysCache1(SEQRELID, ObjectIdGetDatum(relid));
1752  if (!HeapTupleIsValid(pgstuple))
1753  elog(ERROR, "cache lookup failed for sequence %u", relid);
1754  pgsform = (Form_pg_sequence) GETSTRUCT(pgstuple);
1755 
1756  values[0] = Int64GetDatum(pgsform->seqstart);
1757  values[1] = Int64GetDatum(pgsform->seqmin);
1758  values[2] = Int64GetDatum(pgsform->seqmax);
1759  values[3] = Int64GetDatum(pgsform->seqincrement);
1760  values[4] = BoolGetDatum(pgsform->seqcycle);
1761  values[5] = Int64GetDatum(pgsform->seqcache);
1762  values[6] = ObjectIdGetDatum(pgsform->seqtypid);
1763 
1764  ReleaseSysCache(pgstuple);
1765 
1766  return HeapTupleGetDatum(heap_form_tuple(tupdesc, values, isnull));
1767 }
1768 
1769 /*
1770  * Return the last value from the sequence
1771  *
1772  * Note: This has a completely different meaning than lastval().
1773  */
1774 Datum
1776 {
1777  Oid relid = PG_GETARG_OID(0);
1778  SeqTable elm;
1779  Relation seqrel;
1780  Buffer buf;
1781  HeapTupleData seqtuple;
1783  bool is_called;
1784  int64 result;
1785 
1786  /* open and lock sequence */
1787  init_sequence(relid, &elm, &seqrel);
1788 
1790  ereport(ERROR,
1791  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1792  errmsg("permission denied for sequence %s",
1793  RelationGetRelationName(seqrel))));
1794 
1795  seq = read_seq_tuple(seqrel, &buf, &seqtuple);
1796 
1797  is_called = seq->is_called;
1798  result = seq->last_value;
1799 
1801  sequence_close(seqrel, NoLock);
1802 
1803  if (is_called)
1804  PG_RETURN_INT64(result);
1805  else
1806  PG_RETURN_NULL();
1807 }
1808 
1809 
1810 void
1812 {
1813  XLogRecPtr lsn = record->EndRecPtr;
1814  uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
1815  Buffer buffer;
1816  Page page;
1817  Page localpage;
1818  char *item;
1819  Size itemsz;
1820  xl_seq_rec *xlrec = (xl_seq_rec *) XLogRecGetData(record);
1821  sequence_magic *sm;
1822 
1823  if (info != XLOG_SEQ_LOG)
1824  elog(PANIC, "seq_redo: unknown op code %u", info);
1825 
1826  buffer = XLogInitBufferForRedo(record, 0);
1827  page = (Page) BufferGetPage(buffer);
1828 
1829  /*
1830  * We always reinit the page. However, since this WAL record type is also
1831  * used for updating sequences, it's possible that a hot-standby backend
1832  * is examining the page concurrently; so we mustn't transiently trash the
1833  * buffer. The solution is to build the correct new page contents in
1834  * local workspace and then memcpy into the buffer. Then only bytes that
1835  * are supposed to change will change, even transiently. We must palloc
1836  * the local page for alignment reasons.
1837  */
1838  localpage = (Page) palloc(BufferGetPageSize(buffer));
1839 
1840  PageInit(localpage, BufferGetPageSize(buffer), sizeof(sequence_magic));
1841  sm = (sequence_magic *) PageGetSpecialPointer(localpage);
1842  sm->magic = SEQ_MAGIC;
1843 
1844  item = (char *) xlrec + sizeof(xl_seq_rec);
1845  itemsz = XLogRecGetDataLen(record) - sizeof(xl_seq_rec);
1846 
1847  if (PageAddItem(localpage, (Item) item, itemsz,
1848  FirstOffsetNumber, false, false) == InvalidOffsetNumber)
1849  elog(PANIC, "seq_redo: failed to add item to page");
1850 
1851  PageSetLSN(localpage, lsn);
1852 
1853  memcpy(page, localpage, BufferGetPageSize(buffer));
1854  MarkBufferDirty(buffer);
1855  UnlockReleaseBuffer(buffer);
1856 
1857  pfree(localpage);
1858 }
1859 
1860 /*
1861  * Flush cached sequence information.
1862  */
1863 void
1865 {
1866  if (seqhashtab)
1867  {
1869  seqhashtab = NULL;
1870  }
1871 
1872  last_used_seq = NULL;
1873 }
1874 
1875 /*
1876  * Mask a Sequence page before performing consistency checks on it.
1877  */
1878 void
1879 seq_mask(char *page, BlockNumber blkno)
1880 {
1882 
1883  mask_unused_space(page);
1884 }
Relation sequence_open(Oid relationId, LOCKMODE lockmode)
Definition: sequence.c:37
void sequence_close(Relation relation, LOCKMODE lockmode)
Definition: sequence.c:58
@ ACLCHECK_OK
Definition: acl.h:183
AclResult pg_class_aclcheck(Oid table_oid, Oid roleid, AclMode mode)
Definition: aclchk.c:4079
int16 AttrNumber
Definition: attnum.h:21
#define InvalidAttrNumber
Definition: attnum.h:23
uint32 BlockNumber
Definition: block.h:31
static int32 next
Definition: blutils.c:221
static Datum values[MAXATTR]
Definition: bootstrap.c:152
int Buffer
Definition: buf.h:23
void mask_page_lsn_and_checksum(Page page)
Definition: bufmask.c:31
void mask_unused_space(Page page)
Definition: bufmask.c:71
BlockNumber BufferGetBlockNumber(Buffer buffer)
Definition: bufmgr.c:3667
Buffer ExtendBufferedRel(BufferManagerRelation bmr, ForkNumber forkNum, BufferAccessStrategy strategy, uint32 flags)
Definition: bufmgr.c:845
void UnlockReleaseBuffer(Buffer buffer)
Definition: bufmgr.c:4867
void MarkBufferDirty(Buffer buffer)
Definition: bufmgr.c:2474
void LockBuffer(Buffer buffer, int mode)
Definition: bufmgr.c:5085
void MarkBufferDirtyHint(Buffer buffer, bool buffer_std)
Definition: bufmgr.c:4914
void FlushRelationBuffers(Relation rel)
Definition: bufmgr.c:4435
Buffer ReadBuffer(Relation reln, BlockNumber blockNum)
Definition: bufmgr.c:745
static Page BufferGetPage(Buffer buffer)
Definition: bufmgr.h:408
static Size BufferGetPageSize(Buffer buffer)
Definition: bufmgr.h:397
@ EB_SKIP_EXTENSION_LOCK
Definition: bufmgr.h:74
@ EB_LOCK_FIRST
Definition: bufmgr.h:86
#define BUFFER_LOCK_EXCLUSIVE
Definition: bufmgr.h:199
#define BMR_REL(p_rel)
Definition: bufmgr.h:107
void PageInit(Page page, Size pageSize, Size specialSize)
Definition: bufpage.c:42
Pointer Page
Definition: bufpage.h:78
static Item PageGetItem(Page page, ItemId itemId)
Definition: bufpage.h:351
static ItemId PageGetItemId(Page page, OffsetNumber offsetNumber)
Definition: bufpage.h:240
static void PageSetLSN(Page page, XLogRecPtr lsn)
Definition: bufpage.h:388
static XLogRecPtr PageGetLSN(Page page)
Definition: bufpage.h:383
static char * PageGetSpecialPointer(Page page)
Definition: bufpage.h:336
#define PageAddItem(page, item, size, offsetNumber, overwrite, is_heap)
Definition: bufpage.h:468
unsigned int uint32
Definition: c.h:506
#define PG_INT32_MAX
Definition: c.h:589
signed int int32
Definition: c.h:494
#define INT64_FORMAT
Definition: c.h:548
#define Assert(condition)
Definition: c.h:858
#define BoolIsValid(boolean)
Definition: c.h:757
#define FirstCommandId
Definition: c.h:668
#define PG_INT16_MIN
Definition: c.h:585
#define PG_INT64_MAX
Definition: c.h:592
#define PG_INT64_MIN
Definition: c.h:591
#define PG_INT32_MIN
Definition: c.h:588
uint32 LocalTransactionId
Definition: c.h:654
unsigned char uint8
Definition: c.h:504
#define PG_INT16_MAX
Definition: c.h:586
#define OidIsValid(objectId)
Definition: c.h:775
size_t Size
Definition: c.h:605
ObjectAddress DefineSequence(ParseState *pstate, CreateSeqStmt *seq)
Definition: sequence.c:121
static void fill_seq_fork_with_data(Relation rel, HeapTuple tuple, ForkNumber forkNum)
Definition: sequence.c:359
void ResetSequence(Oid seq_relid)
Definition: sequence.c:262
static void fill_seq_with_data(Relation rel, HeapTuple tuple)
Definition: sequence.c:338
struct sequence_magic sequence_magic
Datum setval_oid(PG_FUNCTION_ARGS)
Definition: sequence.c:1042
static SeqTableData * last_used_seq
Definition: sequence.c:97
ObjectAddress AlterSequence(ParseState *pstate, AlterSeqStmt *stmt)
Definition: sequence.c:437
Datum pg_sequence_parameters(PG_FUNCTION_ARGS)
Definition: sequence.c:1731
Datum nextval_oid(PG_FUNCTION_ARGS)
Definition: sequence.c:608
static void init_sequence(Oid relid, SeqTable *p_elm, Relation *p_rel)
Definition: sequence.c:1122
#define SEQ_MAGIC
Definition: sequence.c:63
Datum setval3_oid(PG_FUNCTION_ARGS)
Definition: sequence.c:1057
#define SEQ_LOG_VALS
Definition: sequence.c:58
static Form_pg_sequence_data read_seq_tuple(Relation rel, Buffer *buf, HeapTuple seqdatatuple)
Definition: sequence.c:1183
Datum lastval(PG_FUNCTION_ARGS)
Definition: sequence.c:890
void seq_mask(char *page, BlockNumber blkno)
Definition: sequence.c:1879
Datum nextval(PG_FUNCTION_ARGS)
Definition: sequence.c:586
int64 nextval_internal(Oid relid, bool check_permissions)
Definition: sequence.c:616
void SequenceChangePersistence(Oid relid, char newrelpersistence)
Definition: sequence.c:541
static void process_owned_by(Relation seqrel, List *owned_by, bool for_identity)
Definition: sequence.c:1583
static HTAB * seqhashtab
Definition: sequence.c:91
Datum pg_sequence_last_value(PG_FUNCTION_ARGS)
Definition: sequence.c:1775
Datum currval_oid(PG_FUNCTION_ARGS)
Definition: sequence.c:859
static void do_setval(Oid relid, int64 next, bool iscalled)
Definition: sequence.c:938
List * sequence_options(Oid relid)
Definition: sequence.c:1697
static void init_params(ParseState *pstate, List *options, bool for_identity, bool isInit, Form_pg_sequence seqform, Form_pg_sequence_data seqdataform, bool *need_seq_rewrite, List **owned_by)
Definition: sequence.c:1250
SeqTableData * SeqTable
Definition: sequence.c:89
void seq_redo(XLogReaderState *record)
Definition: sequence.c:1811
struct SeqTableData SeqTableData
void ResetSequenceCaches(void)
Definition: sequence.c:1864
static void create_seq_hashtable(void)
Definition: sequence.c:1106
static Relation lock_and_open_sequence(SeqTable seq)
Definition: sequence.c:1078
void DeleteSequenceTuple(Oid relid)
Definition: sequence.c:563
#define SEQ_COL_LASTVAL
Definition: sequence.h:38
FormData_pg_sequence_data * Form_pg_sequence_data
Definition: sequence.h:32
#define SEQ_COL_CALLED
Definition: sequence.h:40
#define SEQ_COL_LASTCOL
Definition: sequence.h:43
#define SEQ_COL_LOG
Definition: sequence.h:39
#define SEQ_COL_FIRSTCOL
Definition: sequence.h:42
struct xl_seq_rec xl_seq_rec
#define XLOG_SEQ_LOG
Definition: sequence.h:46
List * defGetQualifiedName(DefElem *def)
Definition: define.c:252
int64 defGetInt64(DefElem *def)
Definition: define.c:186
void errorConflictingDefElem(DefElem *defel, ParseState *pstate)
Definition: define.c:384
TypeName * defGetTypeName(DefElem *def)
Definition: define.c:284
DependencyType
Definition: dependency.h:32
@ DEPENDENCY_AUTO
Definition: dependency.h:34
@ DEPENDENCY_INTERNAL
Definition: dependency.h:35
void hash_destroy(HTAB *hashp)
Definition: dynahash.c:865
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
Definition: dynahash.c:955
HTAB * hash_create(const char *tabname, long nelem, const HASHCTL *info, int flags)
Definition: dynahash.c:352
int errdetail(const char *fmt,...)
Definition: elog.c:1205
int errhint(const char *fmt,...)
Definition: elog.c:1319
int errcode(int sqlerrcode)
Definition: elog.c:859
int errmsg(const char *fmt,...)
Definition: elog.c:1072
#define PANIC
Definition: elog.h:42
#define ERROR
Definition: elog.h:39
#define elog(elevel,...)
Definition: elog.h:224
#define NOTICE
Definition: elog.h:35
#define ereport(elevel,...)
Definition: elog.h:149
Datum Int64GetDatum(int64 X)
Definition: fmgr.c:1807
#define PG_GETARG_OID(n)
Definition: fmgr.h:275
#define PG_GETARG_TEXT_PP(n)
Definition: fmgr.h:309
#define PG_RETURN_INT64(x)
Definition: fmgr.h:368
#define PG_RETURN_NULL()
Definition: fmgr.h:345
#define PG_GETARG_INT64(n)
Definition: fmgr.h:283
#define PG_GETARG_BOOL(n)
Definition: fmgr.h:274
#define PG_FUNCTION_ARGS
Definition: fmgr.h:193
char * format_type_be(Oid type_oid)
Definition: format_type.c:343
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
Definition: funcapi.c:276
@ TYPEFUNC_COMPOSITE
Definition: funcapi.h:149
static Datum HeapTupleGetDatum(const HeapTupleData *tuple)
Definition: funcapi.h:230
HeapTuple heap_copytuple(HeapTuple tuple)
Definition: heaptuple.c:776
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
Definition: heaptuple.c:1116
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1434
@ HASH_ENTER
Definition: hsearch.h:114
#define HASH_ELEM
Definition: hsearch.h:95
#define HASH_BLOBS
Definition: hsearch.h:97
HeapTupleHeaderData * HeapTupleHeader
Definition: htup.h:23
#define HeapTupleIsValid(tuple)
Definition: htup.h:78
#define HeapTupleHeaderSetXminFrozen(tup)
Definition: htup_details.h:348
#define HeapTupleHeaderSetXmin(tup, xid)
Definition: htup_details.h:315
#define HeapTupleHeaderSetXmax(tup, xid)
Definition: htup_details.h:376
#define HeapTupleHeaderSetCmin(tup, cid)
Definition: htup_details.h:393
#define HEAP_XMAX_IS_MULTI
Definition: htup_details.h:209
#define HEAP_XMAX_COMMITTED
Definition: htup_details.h:207
#define GETSTRUCT(TUP)
Definition: htup_details.h:653
#define HEAP_XMAX_INVALID
Definition: htup_details.h:208
#define HeapTupleHeaderGetRawXmax(tup)
Definition: htup_details.h:371
#define stmt
Definition: indent_codes.h:59
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
Definition: indexing.c:313
void CatalogTupleInsert(Relation heapRel, HeapTuple tup)
Definition: indexing.c:233
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
Definition: indexing.c:365
static struct @155 value
int i
Definition: isn.c:73
Pointer Item
Definition: item.h:17
#define ItemIdGetLength(itemId)
Definition: itemid.h:59
#define ItemIdIsNormal(itemId)
Definition: itemid.h:99
static void ItemPointerSet(ItemPointerData *pointer, BlockNumber blockNumber, OffsetNumber offNum)
Definition: itemptr.h:135
List * lappend(List *list, void *datum)
Definition: list.c:339
List * list_copy_head(const List *oldlist, int len)
Definition: list.c:1593
void LockRelationOid(Oid relid, LOCKMODE lockmode)
Definition: lmgr.c:108
#define InvalidLocalTransactionId
Definition: lock.h:65
#define NoLock
Definition: lockdefs.h:34
#define AccessExclusiveLock
Definition: lockdefs.h:43
#define ShareRowExclusiveLock
Definition: lockdefs.h:41
#define AccessShareLock
Definition: lockdefs.h:36
#define RowExclusiveLock
Definition: lockdefs.h:38
AttrNumber get_attnum(Oid relid, const char *attname)
Definition: lsyscache.c:858
char * get_rel_name(Oid relid)
Definition: lsyscache.c:1928
DefElem * makeDefElem(char *name, Node *arg, int location)
Definition: makefuncs.c:564
ColumnDef * makeColumnDef(const char *colname, Oid typeOid, int32 typmod, Oid collOid)
Definition: makefuncs.c:492
void pfree(void *pointer)
Definition: mcxt.c:1520
void * palloc(Size size)
Definition: mcxt.c:1316
#define START_CRIT_SECTION()
Definition: miscadmin.h:149
#define END_CRIT_SECTION()
Definition: miscadmin.h:151
Oid GetUserId(void)
Definition: miscinit.c:514
#define InvalidMultiXactId
Definition: multixact.h:24
Oid RangeVarGetAndCheckCreationNamespace(RangeVar *relation, LOCKMODE lockmode, Oid *existing_relation_id)
Definition: namespace.c:724
RangeVar * makeRangeVarFromNameList(const List *names)
Definition: namespace.c:3539
Oid RangeVarGetRelidExtended(const RangeVar *relation, LOCKMODE lockmode, uint32 flags, RangeVarGetRelidCallback callback, void *callback_arg)
Definition: namespace.c:426
@ RVR_MISSING_OK
Definition: namespace.h:72
#define RangeVarGetRelid(relation, lockmode, missing_ok)
Definition: namespace.h:80
#define makeNode(_type_)
Definition: nodes.h:155
#define InvokeObjectPostAlterHook(classId, objectId, subId)
Definition: objectaccess.h:197
const ObjectAddress InvalidObjectAddress
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
#define InvalidOffsetNumber
Definition: off.h:26
uint16 OffsetNumber
Definition: off.h:24
#define FirstOffsetNumber
Definition: off.h:27
int parser_errposition(ParseState *pstate, int location)
Definition: parse_node.c:106
Oid typenameTypeId(ParseState *pstate, const TypeName *typeName)
Definition: parse_type.c:291
#define ACL_USAGE
Definition: parsenodes.h:84
#define ACL_UPDATE
Definition: parsenodes.h:78
#define ACL_SELECT
Definition: parsenodes.h:77
int16 attnum
Definition: pg_attribute.h:74
int errdetail_relkind_not_supported(char relkind)
Definition: pg_class.c:24
NameData relname
Definition: pg_class.h:38
void checkMembershipInCurrentExtension(const ObjectAddress *object)
Definition: pg_depend.c:257
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
Definition: pg_depend.c:44
long deleteDependencyRecordsForClass(Oid classId, Oid objectId, Oid refclassId, char deptype)
Definition: pg_depend.c:350
bool sequenceIsOwned(Oid seqId, char deptype, Oid *tableId, int32 *colId)
Definition: pg_depend.c:827
#define lfirst(lc)
Definition: pg_list.h:172
#define llast(l)
Definition: pg_list.h:198
static int list_length(const List *l)
Definition: pg_list.h:152
#define NIL
Definition: pg_list.h:68
#define linitial(l)
Definition: pg_list.h:178
static char ** options
FormData_pg_sequence
Definition: pg_sequence.h:33
FormData_pg_sequence * Form_pg_sequence
Definition: pg_sequence.h:40
static char * buf
Definition: pg_test_fsync.c:73
#define Int64GetDatumFast(X)
Definition: postgres.h:554
uintptr_t Datum
Definition: postgres.h:64
static Datum BoolGetDatum(bool X)
Definition: postgres.h:102
static Datum ObjectIdGetDatum(Oid X)
Definition: postgres.h:252
#define InvalidOid
Definition: postgres_ext.h:36
unsigned int Oid
Definition: postgres_ext.h:31
@ ONCOMMIT_NOOP
Definition: primnodes.h:57
#define INVALID_PROC_NUMBER
Definition: procnumber.h:26
char * psprintf(const char *fmt,...)
Definition: psprintf.c:46
tree ctl
Definition: radixtree.h:1847
#define RelationGetRelid(relation)
Definition: rel.h:505
#define RelationGetDescr(relation)
Definition: rel.h:531
#define RelationGetRelationName(relation)
Definition: rel.h:539
#define RelationNeedsWAL(relation)
Definition: rel.h:628
#define RelationGetNamespace(relation)
Definition: rel.h:546
void RelationSetNewRelfilenumber(Relation relation, char persistence)
Definition: relcache.c:3726
Oid RelFileNumber
Definition: relpath.h:25
ForkNumber
Definition: relpath.h:48
@ MAIN_FORKNUM
Definition: relpath.h:50
@ INIT_FORKNUM
Definition: relpath.h:53
#define InvalidRelFileNumber
Definition: relpath.h:26
ResourceOwner TopTransactionResourceOwner
Definition: resowner.c:167
ResourceOwner CurrentResourceOwner
Definition: resowner.c:165
SMgrRelation smgropen(RelFileLocator rlocator, ProcNumber backend)
Definition: smgr.c:198
void smgrcreate(SMgrRelation reln, ForkNumber forknum, bool isRedo)
Definition: smgr.c:411
void smgrclose(SMgrRelation reln)
Definition: smgr.c:320
void relation_close(Relation relation, LOCKMODE lockmode)
Definition: relation.c:205
Relation relation_openrv(const RangeVar *relation, LOCKMODE lockmode)
Definition: relation.c:137
PGPROC * MyProc
Definition: proc.c:66
void log_smgrcreate(const RelFileLocator *rlocator, ForkNumber forkNum)
Definition: storage.c:186
bool is_not_null
Definition: parsenodes.h:731
bool if_not_exists
Definition: parsenodes.h:3133
List * options
Definition: parsenodes.h:3130
RangeVar * sequence
Definition: parsenodes.h:3129
char * defname
Definition: parsenodes.h:815
ParseLoc location
Definition: parsenodes.h:819
Node * arg
Definition: parsenodes.h:816
Definition: dynahash.c:220
ItemPointerData t_self
Definition: htup.h:65
uint32 t_len
Definition: htup.h:64
HeapTupleHeader t_data
Definition: htup.h:68
ItemPointerData t_ctid
Definition: htup_details.h:161
Definition: pg_list.h:54
Definition: nodes.h:129
LocalTransactionId lxid
Definition: proc.h:196
struct PGPROC::@117 vxid
char * relname
Definition: primnodes.h:82
bool rd_islocaltemp
Definition: rel.h:61
RelFileLocator rd_locator
Definition: rel.h:57
Form_pg_class rd_rel
Definition: rel.h:111
RelFileNumber filenumber
Definition: sequence.c:79
LocalTransactionId lxid
Definition: sequence.c:80
int64 cached
Definition: sequence.c:83
bool last_valid
Definition: sequence.c:81
int64 last
Definition: sequence.c:82
int64 increment
Definition: sequence.c:85
XLogRecPtr EndRecPtr
Definition: xlogreader.h:207
uint32 magic
Definition: sequence.c:67
Definition: c.h:687
RelFileLocator locator
Definition: sequence.h:50
void ReleaseSysCache(HeapTuple tuple)
Definition: syscache.c:266
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Definition: syscache.c:218
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:86
#define SearchSysCacheExists1(cacheId, key1)
Definition: syscache.h:95
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:126
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:40
ObjectAddress DefineRelation(CreateStmt *stmt, char relkind, Oid ownerId, ObjectAddress *typaddress, const char *queryString)
Definition: tablecmds.c:699
void RangeVarCallbackOwnsRelation(const RangeVar *relation, Oid relId, Oid oldRelId, void *arg)
Definition: tablecmds.c:18422
#define FrozenTransactionId
Definition: transam.h:33
#define InvalidTransactionId
Definition: transam.h:31
void PreventCommandIfReadOnly(const char *cmdname)
Definition: utility.c:404
void PreventCommandIfParallelMode(const char *cmdname)
Definition: utility.c:422
Boolean * makeBoolean(bool val)
Definition: value.c:49
Float * makeFloat(char *numericStr)
Definition: value.c:37
#define boolVal(v)
Definition: value.h:81
#define strVal(v)
Definition: value.h:82
List * textToQualifiedNameList(text *textval)
Definition: varlena.c:3399
TransactionId GetTopTransactionId(void)
Definition: xact.c:423
XLogRecPtr GetRedoRecPtr(void)
Definition: xlog.c:6393
uint64 XLogRecPtr
Definition: xlogdefs.h:21
void XLogRegisterData(char *data, uint32 len)
Definition: xloginsert.c:364
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
Definition: xloginsert.c:474
void XLogRegisterBuffer(uint8 block_id, Buffer buffer, uint8 flags)
Definition: xloginsert.c:242
void XLogBeginInsert(void)
Definition: xloginsert.c:149
#define REGBUF_WILL_INIT
Definition: xloginsert.h:33
#define XLogRecGetDataLen(decoder)
Definition: xlogreader.h:416
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:410
#define XLogRecGetData(decoder)
Definition: xlogreader.h:415
#define XLR_INFO_MASK
Definition: xlogrecord.h:62
Buffer XLogInitBufferForRedo(XLogReaderState *record, uint8 block_id)
Definition: xlogutils.c:326