64 #include "utils/fmgroids.h"
84 Datum *opclassOptions,
87 const List *exclusionOpNames,
89 const char *accessMethodName,
93 bool iswithoutoverlaps,
96 int *ddl_save_nestlevel);
98 const List *colnames,
const List *exclusionOpNames,
99 bool primary,
bool isconstraint);
180 const char *accessMethodName,
181 const List *attributeList,
182 const List *exclusionOpNames,
183 bool isWithoutOverlaps)
189 Datum *opclassOptions;
200 int numberOfAttributes;
216 isconstraint =
false;
219 Assert(numberOfAttributes > 0);
226 (
errcode(ERRCODE_UNDEFINED_OBJECT),
227 errmsg(
"access method \"%s\" does not exist",
230 accessMethodId = accessMethodForm->oid;
245 indexInfo =
makeIndexInfo(numberOfAttributes, numberOfAttributes,
246 accessMethodId,
NIL,
NIL,
false,
false,
247 false,
false, amsummarizing, isWithoutOverlaps);
254 typeIds, collationIds, opclassIds, opclassOptions,
255 coloptions, attributeList,
256 exclusionOpNames, relationId,
257 accessMethodName, accessMethodId,
258 amcanorder, isconstraint, isWithoutOverlaps,
InvalidOid,
264 elog(
ERROR,
"cache lookup failed for index %u", oldId);
273 indexForm->indisvalid))
280 old_natts = indexForm->indnkeyatts;
281 Assert(old_natts == numberOfAttributes);
289 ret = (memcmp(old_indclass->
values, opclassIds, old_natts *
sizeof(
Oid)) == 0 &&
290 memcmp(old_indcollation->
values, collationIds, old_natts *
sizeof(
Oid)) == 0);
299 for (
i = 0;
i < old_natts;
i++)
314 for (
i = 0;
i < old_natts;
i++)
319 pfree(oldOpclassOptions);
331 old_natts *
sizeof(
Oid)) == 0;
336 for (
i = 0;
i < old_natts && ret;
i++)
342 if ((IsPolymorphicType(left) || IsPolymorphicType(right)) &&
367 if (!opts1 && !opts2)
370 for (
i = 0;
i < natts;
i++)
375 if (opt1 == (
Datum) 0)
377 if (opt2 == (
Datum) 0)
382 else if (opt2 == (
Datum) 0)
443 for (
i = 0;
i < n_old_snapshots;
i++)
452 int n_newer_snapshots;
461 for (
j =
i;
j < n_old_snapshots;
j++)
465 for (k = 0; k < n_newer_snapshots; k++)
471 if (k >= n_newer_snapshots)
474 pfree(newer_snapshots);
541 Oid parentConstraintId,
545 bool check_not_in_use,
550 char *indexRelationName;
551 char *accessMethodName;
555 Datum *opclassOptions;
561 List *allIndexParams;
567 bool amissummarizing;
577 int numberOfAttributes;
578 int numberOfKeyAttributes;
585 Oid root_save_userid;
586 int root_save_sec_context;
587 int root_save_nestlevel;
598 if (
stmt->reset_default_tblspc)
648 stmt->indexIncludingParams);
651 if (numberOfKeyAttributes <= 0)
653 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
654 errmsg(
"must specify at least one column")));
657 (
errcode(ERRCODE_TOO_MANY_COLUMNS),
658 errmsg(
"cannot use more than %d columns in an index",
694 exclusion =
stmt->excludeOpNames ||
stmt->iswithoutoverlaps;
697 switch (rel->
rd_rel->relkind)
699 case RELKIND_RELATION:
700 case RELKIND_MATVIEW:
701 case RELKIND_PARTITIONED_TABLE:
706 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
707 errmsg(
"cannot create index on relation \"%s\"",
721 partitioned = rel->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE;
730 if (
stmt->concurrent)
732 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
733 errmsg(
"cannot create index on partitioned table \"%s\" concurrently",
742 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
743 errmsg(
"cannot create indexes on temporary tables of other sessions")));
751 if (check_not_in_use)
764 aclresult =
object_aclcheck(NamespaceRelationId, namespaceId, root_save_userid,
775 if (
stmt->tableSpace)
780 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
781 errmsg(
"cannot specify default tablespace for partitioned relations")));
796 aclresult =
object_aclcheck(TableSpaceRelationId, tablespaceId, root_save_userid,
808 if (rel->
rd_rel->relisshared)
809 tablespaceId = GLOBALTABLESPACE_OID;
810 else if (tablespaceId == GLOBALTABLESPACE_OID)
812 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
813 errmsg(
"only shared relations can be placed in pg_global tablespace")));
823 indexRelationName =
stmt->idxname;
824 if (indexRelationName == NULL)
828 stmt->excludeOpNames,
835 accessMethodName =
stmt->accessMethod;
843 if (strcmp(accessMethodName,
"rtree") == 0)
846 (
errmsg(
"substituting access method \"gist\" for obsolete method \"rtree\"")));
847 accessMethodName =
"gist";
853 (
errcode(ERRCODE_UNDEFINED_OBJECT),
854 errmsg(
"access method \"%s\" does not exist",
858 accessMethodId = accessMethodForm->oid;
866 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
867 errmsg(
"access method \"%s\" does not support unique indexes",
871 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
872 errmsg(
"access method \"%s\" does not support included columns",
876 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
877 errmsg(
"access method \"%s\" does not support multicolumn indexes",
879 if (exclusion && amRoutine->
amgettuple == NULL)
881 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
882 errmsg(
"access method \"%s\" does not support exclusion constraints",
884 if (
stmt->iswithoutoverlaps && strcmp(accessMethodName,
"gist") != 0)
886 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
887 errmsg(
"access method \"%s\" does not support WITHOUT OVERLAPS constraints",
900 if (
stmt->whereClause)
907 NULL, NULL,
false,
false);
917 numberOfKeyAttributes,
922 stmt->nulls_not_distinct,
926 stmt->iswithoutoverlaps);
934 typeIds, collationIds, opclassIds, opclassOptions,
935 coloptions, allIndexParams,
936 stmt->excludeOpNames, tableId,
937 accessMethodName, accessMethodId,
938 amcanorder,
stmt->isconstraint,
stmt->iswithoutoverlaps,
939 root_save_userid, root_save_sec_context,
940 &root_save_nestlevel);
958 if (partitioned && (
stmt->unique || exclusion))
961 const char *constraint_type;
965 constraint_type =
"PRIMARY KEY";
966 else if (
stmt->unique)
967 constraint_type =
"UNIQUE";
968 else if (
stmt->excludeOpNames)
969 constraint_type =
"EXCLUDE";
973 constraint_type = NULL;
980 for (
i = 0;
i <
key->partnatts;
i++)
999 key->partopcintype[
i],
1000 key->partopcintype[
i],
1003 elog(
ERROR,
"missing operator %d(%u,%u) in partition opfamily %u",
1004 eq_strategy,
key->partopcintype[
i],
key->partopcintype[
i],
1005 key->partopfamily[
i]);
1015 if (
stmt->unique && !
stmt->iswithoutoverlaps && accessMethodId != BTREE_AM_OID)
1017 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1018 errmsg(
"cannot match partition key to an index using access method \"%s\"",
1019 accessMethodName)));
1025 if (
key->partattrs[
i] == 0)
1027 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1028 errmsg(
"unsupported %s constraint with partition key definition",
1030 errdetail(
"%s constraints cannot be used when partition keys include expressions.",
1045 if (
key->partcollation[
i] != collationIds[
j])
1054 if (
stmt->unique && !
stmt->iswithoutoverlaps)
1063 if (ptkey_eqop == idx_eqop)
1079 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1080 errmsg(
"cannot match partition key to index on column \"%s\" using non-equal operator \"%s\"",
1093 key->partattrs[
i] - 1);
1095 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1096 errmsg(
"unique constraint on partitioned table must include all partitioning columns"),
1097 errdetail(
"%s constraint on table \"%s\" lacks column \"%s\" which is part of the partition key.",
1115 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1116 errmsg(
"index creation on system columns is not supported")));
1134 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1135 errmsg(
"index creation on system columns is not supported")));
1147 if (
stmt->isconstraint && !quiet)
1149 const char *constraint_type;
1152 constraint_type =
"PRIMARY KEY";
1153 else if (
stmt->unique)
1154 constraint_type =
"UNIQUE";
1155 else if (
stmt->excludeOpNames)
1156 constraint_type =
"EXCLUDE";
1160 constraint_type = NULL;
1164 (
errmsg_internal(
"%s %s will create implicit index \"%s\" for table \"%s\"",
1165 is_alter_table ?
"ALTER TABLE / ADD" :
"CREATE TABLE /",
1182 flags = constr_flags = 0;
1183 if (
stmt->isconstraint)
1185 if (skip_build || concurrent || partitioned)
1187 if (
stmt->if_not_exists)
1200 if (partitioned &&
stmt->relation && !
stmt->relation->inh)
1208 if (
stmt->deferrable)
1210 if (
stmt->initdeferred)
1212 if (
stmt->iswithoutoverlaps)
1216 index_create(rel, indexRelationName, indexRelationId, parentIndexId,
1218 stmt->oldNumber, indexInfo, indexColNames,
1219 accessMethodId, tablespaceId,
1220 collationIds, opclassIds, opclassOptions,
1221 coloptions, NULL, reloptions,
1222 flags, constr_flags,
1224 &createdConstraintId);
1258 if (
stmt->idxcomment != NULL)
1273 if ((!
stmt->relation ||
stmt->relation->inh) && partdesc->
nparts > 0)
1275 int nparts = partdesc->
nparts;
1277 bool invalidate_parent =
false;
1300 if (total_parts < 0)
1313 memcpy(part_oids, partdesc->
oids,
sizeof(
Oid) * nparts);
1323 parentIndex =
index_open(indexRelationId, lockmode);
1336 for (
int i = 0;
i < nparts;
i++)
1338 Oid childRelid = part_oids[
i];
1340 Oid child_save_userid;
1341 int child_save_sec_context;
1342 int child_save_nestlevel;
1351 &child_save_sec_context);
1362 if (childrel->
rd_rel->relkind == RELKIND_FOREIGN_TABLE)
1366 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1367 errmsg(
"cannot create unique index on partitioned table \"%s\"",
1369 errdetail(
"Table \"%s\" contains partitions that are foreign tables.",
1374 child_save_sec_context);
1385 foreach(cell, childidxs)
1431 createdConstraintId,
1435 invalidate_parent =
true;
1461 child_save_sec_context);
1490 root_save_sec_context);
1495 createdConstraintId,
1497 is_alter_table, check_rights,
1501 child_save_sec_context);
1509 invalidate_parent =
true;
1522 if (invalidate_parent)
1531 elog(
ERROR,
"cache lookup failed for index %u",
1627 const int progress_cols[] = {
1631 const int64 progress_vals[] = {
1734 limitXmin = snapshot->
xmin;
1826 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1827 errmsg(
"functions in index predicate must be marked IMMUTABLE")));
1844 Datum *opclassOptions,
1846 const List *attList,
1847 const List *exclusionOpNames,
1849 const char *accessMethodName,
1853 bool iswithoutoverlaps,
1855 int ddl_sec_context,
1856 int *ddl_save_nestlevel)
1863 int save_sec_context;
1866 if (exclusionOpNames)
1872 nextExclOp =
list_head(exclusionOpNames);
1883 if (iswithoutoverlaps)
1885 if (exclusionOpNames ==
NIL)
1901 foreach(lc, attList)
1910 if (attribute->
name != NULL)
1923 (
errcode(ERRCODE_UNDEFINED_COLUMN),
1924 errmsg(
"column \"%s\" named in key does not exist",
1928 (
errcode(ERRCODE_UNDEFINED_COLUMN),
1929 errmsg(
"column \"%s\" does not exist",
1934 atttype = attform->atttypid;
1935 attcollation = attform->attcollation;
1945 if (attn >= nkeycols)
1947 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1948 errmsg(
"expressions are not supported in included columns")));
1988 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1989 errmsg(
"functions in index expression must be marked IMMUTABLE")));
1993 typeOids[attn] = atttype;
1999 if (attn >= nkeycols)
2003 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
2004 errmsg(
"including column does not support a collation")));
2007 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
2008 errmsg(
"including column does not support an operator class")));
2011 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
2012 errmsg(
"including column does not support ASC/DESC options")));
2015 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
2016 errmsg(
"including column does not support NULLS FIRST/LAST options")));
2019 opclassOptions[attn] = (
Datum) 0;
2020 colOptions[attn] = 0;
2058 (
errcode(ERRCODE_INDETERMINATE_COLLATION),
2059 errmsg(
"could not determine which collation to use for index expression"),
2060 errhint(
"Use the COLLATE clause to set the collation explicitly.")));
2066 (
errcode(ERRCODE_DATATYPE_MISMATCH),
2067 errmsg(
"collations are not supported by type %s",
2071 collationOids[attn] = attcollation;
2133 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
2134 errmsg(
"operator %s is not commutative",
2136 errdetail(
"Only commutative operators can be used in exclusion constraints.")));
2156 elog(
ERROR,
"cache lookup failed for opfamily %u",
2161 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
2162 errmsg(
"operator %s is not a member of operator family \"%s\"",
2165 errdetail(
"The exclusion operator must be related to the index operator class for the constraint.")));
2171 nextExclOp =
lnext(exclusionOpNames, nextExclOp);
2173 else if (iswithoutoverlaps)
2178 if (attn == nkeycols - 1)
2194 colOptions[attn] = 0;
2199 colOptions[attn] |= INDOPTION_DESC;
2204 colOptions[attn] |= INDOPTION_NULLS_FIRST;
2207 colOptions[attn] |= INDOPTION_NULLS_FIRST;
2214 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2215 errmsg(
"access method \"%s\" does not support ASC/DESC options",
2216 accessMethodName)));
2219 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2220 errmsg(
"access method \"%s\" does not support NULLS FIRST/LAST options",
2221 accessMethodName)));
2229 opclassOptions[attn] =
2231 NULL, NULL,
false,
false);
2234 opclassOptions[attn] = (
Datum) 0;
2248 const char *accessMethodName,
Oid accessMethodId)
2263 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2264 errmsg(
"data type %s has no default operator class for access method \"%s\"",
2266 errhint(
"You must specify an operator class for the index or define a default operator class for the data type.")));
2294 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2295 errmsg(
"operator class \"%s\" does not exist for access method \"%s\"",
2296 opcname, accessMethodName)));
2302 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2303 errmsg(
"operator class \"%s\" does not exist for access method \"%s\"",
2311 opClassId = opform->oid;
2312 opInputType = opform->opcintype;
2316 (
errcode(ERRCODE_DATATYPE_MISMATCH),
2317 errmsg(
"operator class \"%s\" does not accept data type %s",
2336 int ncompatible = 0;
2337 int ncompatiblepreferred = 0;
2364 Anum_pg_opclass_opcmethod,
2376 if (!opclass->opcdefault)
2378 if (opclass->opcintype == type_id)
2381 result = opclass->oid;
2383 else if (nexact == 0 &&
2388 ncompatiblepreferred++;
2389 result = opclass->oid;
2391 else if (ncompatiblepreferred == 0)
2394 result = opclass->oid;
2407 errmsg(
"there are multiple default operator classes for data type %s",
2411 ncompatiblepreferred == 1 ||
2412 (ncompatiblepreferred == 0 && ncompatible == 1))
2461 elog(
ERROR,
"cache lookup failed for operator class %u", opclass);
2464 errcode(ERRCODE_UNDEFINED_OBJECT),
2468 errdetail(
"Could not translate strategy number %d for operator class \"%s\" for access method \"%s\".",
2478 rhstype = opcintype;
2488 elog(
ERROR,
"cache lookup failed for operator family %u", opfamily);
2491 errcode(ERRCODE_UNDEFINED_OBJECT),
2495 errdetail(
"There is no suitable operator in operator family \"%s\" for access method \"%s\".",
2532 name1chars = strlen(name1);
2535 name2chars = strlen(name2);
2541 overhead += strlen(
label) + 1;
2551 while (name1chars + name2chars > availchars)
2553 if (name1chars > name2chars)
2559 name1chars =
pg_mbcliplen(name1, name1chars, name1chars);
2561 name2chars =
pg_mbcliplen(name2, name2chars, name2chars);
2564 name =
palloc(name1chars + name2chars + overhead + 1);
2565 memcpy(
name, name1, name1chars);
2570 memcpy(
name + ndx, name2, name2chars);
2610 const char *
label,
Oid namespaceid,
2626 if (!isconstraint ||
2633 snprintf(modlabel,
sizeof(modlabel),
"%s%d",
label, ++pass);
2646 const List *colnames,
const List *exclusionOpNames,
2647 bool primary,
bool isconstraint)
2660 else if (exclusionOpNames !=
NIL)
2668 else if (isconstraint)
2707 foreach(lc, colnames)
2709 const char *
name = (
const char *)
lfirst(lc);
2712 buf[buflen++] =
'_';
2719 buflen += strlen(
buf + buflen);
2739 foreach(lc, indexElems)
2742 const char *origname;
2743 const char *curname;
2750 else if (ielem->
name)
2751 origname = ielem->
name;
2763 foreach(lc2, result)
2765 if (strcmp(curname, (
char *)
lfirst(lc2)) == 0)
2776 memcpy(
buf, origname, nlen);
2777 strcpy(
buf + nlen, nbuf);
2799 bool concurrently =
false;
2801 char *tablespacename = NULL;
2804 foreach(lc,
stmt->params)
2808 if (strcmp(opt->
defname,
"verbose") == 0)
2810 else if (strcmp(opt->
defname,
"concurrently") == 0)
2812 else if (strcmp(opt->
defname,
"tablespace") == 0)
2816 (
errcode(ERRCODE_SYNTAX_ERROR),
2817 errmsg(
"unrecognized REINDEX option \"%s\"",
2824 "REINDEX CONCURRENTLY");
2834 if (tablespacename != NULL)
2875 "REINDEX DATABASE");
2879 elog(
ERROR,
"unrecognized object type: %d",
2924 if (relkind == RELKIND_PARTITIONED_INDEX)
2927 persistence != RELPERSISTENCE_TEMP)
2965 if (relId != oldRelId &&
OidIsValid(oldRelId))
2983 if (relkind != RELKIND_INDEX &&
2984 relkind != RELKIND_PARTITIONED_INDEX)
2986 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
3001 if (relId != oldRelId)
3010 state->locked_table_oid = table_oid;
3049 (
errmsg(
"table \"%s\" has no indexes that can be reindexed concurrently",
3063 (
errmsg(
"table \"%s\" has no indexes to reindex",
3091 bool concurrent_warning =
false;
3092 bool tablespace_warning =
false;
3093 const char *objectName =
stmt->name;
3109 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3110 errmsg(
"cannot reindex system catalogs concurrently")));
3133 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3134 errmsg(
"can only reindex the currently open database")));
3148 "ReindexMultipleTables",
3160 Anum_pg_class_relnamespace,
3178 Oid relid = classtuple->oid;
3187 if (classtuple->relkind != RELKIND_RELATION &&
3188 classtuple->relkind != RELKIND_MATVIEW)
3192 if (classtuple->relpersistence == RELPERSISTENCE_TEMP &&
3212 if (classtuple->relisshared &&
3223 if (!concurrent_warning)
3225 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3226 errmsg(
"cannot reindex system catalogs concurrently, skipping all")));
3227 concurrent_warning =
true;
3237 bool skip_rel =
false;
3243 if (RELKIND_HAS_STORAGE(classtuple->relkind) &&
3256 if (!tablespace_warning)
3258 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
3259 errmsg(
"cannot move system relations, skipping all")));
3260 tablespace_warning =
true;
3275 if (relid == RelationRelationId)
3304 if (errinfo->
relkind == RELKIND_PARTITIONED_TABLE)
3305 errcontext(
"while reindexing partitioned table \"%s.%s\"",
3307 else if (errinfo->
relkind == RELKIND_PARTITIONED_INDEX)
3308 errcontext(
"while reindexing partitioned index \"%s.%s\"",
3331 Assert(RELKIND_HAS_PARTITIONS(relkind));
3341 errcallback.
arg = (
void *) &errinfo;
3346 relkind == RELKIND_PARTITIONED_TABLE ?
3347 "REINDEX TABLE" :
"REINDEX INDEX");
3369 foreach(lc, inhoids)
3379 if (!RELKIND_HAS_STORAGE(partkind))
3382 Assert(partkind == RELKIND_INDEX ||
3383 partkind == RELKIND_RELATION);
3424 char relpersistence;
3464 Assert(!RELKIND_HAS_PARTITIONS(relkind));
3467 relpersistence != RELPERSISTENCE_TEMP)
3477 else if (relkind == RELKIND_INDEX)
3501 (
errmsg(
"table \"%s.%s\" was reindexed",
3541 typedef struct ReindexIndexInfo
3558 char *relationName = NULL;
3559 char *relationNamespace = NULL;
3561 const int progress_index[] = {
3567 int64 progress_vals[4];
3576 "ReindexConcurrent",
3600 case RELKIND_RELATION:
3601 case RELKIND_MATVIEW:
3602 case RELKIND_TOASTVALUE:
3614 heapRelationIds =
lappend_oid(heapRelationIds, relationOid);
3620 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3621 errmsg(
"cannot reindex system catalogs concurrently")));
3639 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3640 errmsg(
"cannot move system relation \"%s\"",
3650 if (!indexRelation->
rd_index->indisvalid)
3652 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
3653 errmsg(
"skipping reindex of invalid index \"%s.%s\"",
3656 errhint(
"Use DROP INDEX or REINDEX INDEX.")));
3657 else if (indexRelation->
rd_index->indisexclusion)
3659 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3660 errmsg(
"cannot reindex exclusion constraint index \"%s.%s\" concurrently, skipping",
3665 ReindexIndexInfo *
idx;
3671 idx->indexId = cellOid;
3685 Oid toastOid = heapRelation->
rd_rel->reltoastrelid;
3693 heapRelationIds =
lappend_oid(heapRelationIds, toastOid);
3703 if (!indexRelation->
rd_index->indisvalid)
3705 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
3706 errmsg(
"skipping reindex of invalid index \"%s.%s\"",
3709 errhint(
"Use DROP INDEX or REINDEX INDEX.")));
3712 ReindexIndexInfo *
idx;
3721 idx->indexId = cellOid;
3742 ReindexIndexInfo *
idx;
3750 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3751 errmsg(
"cannot reindex system catalogs concurrently")));
3761 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3762 errmsg(
"cannot reindex invalid index on TOAST table")));
3785 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3786 errmsg(
"cannot move system relation \"%s\"",
3802 idx->indexId = relationOid;
3810 case RELKIND_PARTITIONED_TABLE:
3811 case RELKIND_PARTITIONED_INDEX:
3815 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
3816 errmsg(
"cannot reindex this type of relation concurrently")));
3827 if (indexIds ==
NIL)
3833 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3834 errmsg(
"cannot move non-shared relation to tablespace \"%s\"",
3864 foreach(lc, indexIds)
3866 char *concurrentName;
3868 ReindexIndexInfo *newidx;
3873 int save_sec_context;
3898 #ifdef USE_INJECTION_POINTS
3909 if (indexRel->
rd_rel->relpersistence == RELPERSISTENCE_TEMP)
3910 elog(
ERROR,
"cannot reindex a temporary table concurrently");
3915 progress_vals[1] = 0;
3916 progress_vals[2] =
idx->indexId;
3917 progress_vals[3] =
idx->amId;
3929 heapRel->
rd_rel->relkind != RELKIND_TOASTVALUE)
3932 tablespaceid = indexRel->
rd_rel->reltablespace;
3952 newidx->indexId = newIndexId;
3953 newidx->safe =
idx->safe;
3954 newidx->tableId =
idx->tableId;
3955 newidx->amId =
idx->amId;
3957 newIndexIds =
lappend(newIndexIds, newidx);
3967 relationLocks =
lappend(relationLocks, lockrelid);
3970 relationLocks =
lappend(relationLocks, lockrelid);
4004 foreach(lc, heapRelationIds)
4016 relationLocks =
lappend(relationLocks, lockrelid);
4022 lockTags =
lappend(lockTags, heaplocktag);
4031 foreach(lc, relationLocks)
4062 foreach(lc, newIndexIds)
4064 ReindexIndexInfo *newidx =
lfirst(lc);
4090 progress_vals[2] = newidx->indexId;
4091 progress_vals[3] = newidx->amId;
4121 foreach(lc, newIndexIds)
4123 ReindexIndexInfo *newidx =
lfirst(lc);
4154 progress_vals[2] = newidx->indexId;
4155 progress_vals[3] = newidx->amId;
4164 limitXmin = snapshot->
xmin;
4213 forboth(lc, indexIds, lc2, newIndexIds)
4215 ReindexIndexInfo *oldidx =
lfirst(lc);
4216 ReindexIndexInfo *newidx =
lfirst(lc2);
4286 foreach(lc, indexIds)
4288 ReindexIndexInfo *oldidx =
lfirst(lc);
4333 foreach(lc, indexIds)
4338 object.
classId = RelationRelationId;
4339 object.objectId =
idx->indexId;
4340 object.objectSubId = 0;
4359 foreach(lc, relationLocks)
4372 if (relkind == RELKIND_INDEX)
4374 (
errmsg(
"index \"%s.%s\" was reindexed",
4375 relationNamespace, relationName),
4380 foreach(lc, newIndexIds)
4383 Oid indOid =
idx->indexId;
4386 (
errmsg(
"index \"%s.%s\" was reindexed",
4393 (
errmsg(
"table \"%s.%s\" was reindexed",
4394 relationNamespace, relationName),
4424 Assert(partitionIdx->
rd_rel->relkind == RELKIND_INDEX ||
4425 partitionIdx->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX);
4432 Anum_pg_inherits_inhrelid,
4436 Anum_pg_inherits_inhseqno,
4478 if (inhForm->inhparent != parentOid)
4481 elog(
ERROR,
"bogus pg_inherit row: inhrelid %u inhparent %u",
4482 inhForm->inhrelid, inhForm->inhparent);
4555 elog(
ERROR,
"cache lookup failed for relation %u", relationId);
Datum idx(PG_FUNCTION_ARGS)
bool has_privs_of_role(Oid member, Oid role)
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult object_aclcheck(Oid classid, Oid objectid, Oid roleid, AclMode mode)
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
AclResult pg_class_aclcheck(Oid table_oid, Oid roleid, AclMode mode)
IndexAmRoutine * GetIndexAmRoutine(Oid amhandler)
bytea *(* amoptions_function)(Datum reloptions, bool validate)
Datum array_eq(PG_FUNCTION_ARGS)
void free_attrmap(AttrMap *map)
AttrMap * build_attrmap_by_name(TupleDesc indesc, TupleDesc outdesc, bool missing_ok)
#define InvalidAttrNumber
char * get_tablespace_name(Oid spc_oid)
Oid get_tablespace_oid(const char *tablespacename, bool missing_ok)
Oid GetDefaultTablespace(char relpersistence, bool partitioned)
void pgstat_progress_start_command(ProgressCommandType cmdtype, Oid relid)
void pgstat_progress_incr_param(int index, int64 incr)
void pgstat_progress_update_param(int index, int64 val)
void pgstat_progress_update_multi_param(int nparam, const int *index, const int64 *val)
void pgstat_progress_end_command(void)
@ PROGRESS_COMMAND_CREATE_INDEX
bool bms_is_member(int x, const Bitmapset *a)
#define Assert(condition)
#define OidIsValid(objectId)
bool IsToastNamespace(Oid namespaceId)
bool IsSystemRelation(Relation relation)
bool IsCatalogRelationOid(Oid relid)
bool IsSystemClass(Oid relid, Form_pg_class reltuple)
bool contain_mutable_functions_after_planning(Expr *expr)
char * get_database_name(Oid dbid)
bool defGetBoolean(DefElem *def)
char * defGetString(DefElem *def)
void performMultipleDeletions(const ObjectAddresses *objects, DropBehavior behavior, int flags)
ObjectAddresses * new_object_addresses(void)
void add_exact_object_address(const ObjectAddress *object, ObjectAddresses *addrs)
@ DEPENDENCY_PARTITION_PRI
@ DEPENDENCY_PARTITION_SEC
#define PERFORM_DELETION_CONCURRENT_LOCK
#define PERFORM_DELETION_INTERNAL
int errmsg_internal(const char *fmt,...)
int errdetail(const char *fmt,...)
ErrorContextCallback * error_context_stack
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
void EventTriggerCollectSimpleCommand(ObjectAddress address, ObjectAddress secondaryObject, Node *parsetree)
#define palloc_object(type)
#define palloc_array(type, count)
#define DirectFunctionCall2(func, arg1, arg2)
void systable_endscan(SysScanDesc sysscan)
HeapTuple systable_getnext(SysScanDesc sysscan)
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
StrategyNumber GistTranslateStratnum(Oid opclass, StrategyNumber strat)
bool allowSystemTableMods
int NewGUCNestLevel(void)
void RestrictSearchPath(void)
void AtEOXact_GUC(bool isCommit, int nestLevel)
int set_config_option(const char *name, const char *value, GucContext context, GucSource source, GucAction action, bool changeVal, int elevel, bool is_reload)
HeapTuple heap_getnext(TableScanDesc sscan, ScanDirection direction)
HeapTuple heap_copytuple(HeapTuple tuple)
bool heap_attisnull(HeapTuple tup, int attnum, TupleDesc tupleDesc)
void heap_freetuple(HeapTuple htup)
#define HeapTupleIsValid(tuple)
void validate_index(Oid heapId, Oid indexId, Snapshot snapshot)
Oid IndexGetRelation(Oid indexId, bool missing_ok)
void index_concurrently_set_dead(Oid heapId, Oid indexId)
Oid index_create(Relation heapRelation, const char *indexRelationName, Oid indexRelationId, Oid parentIndexRelid, Oid parentConstraintId, RelFileNumber relFileNumber, IndexInfo *indexInfo, const List *indexColNames, Oid accessMethodId, Oid tableSpaceId, const Oid *collationIds, const Oid *opclassIds, const Datum *opclassOptions, const int16 *coloptions, const NullableDatum *stattargets, Datum reloptions, bits16 flags, bits16 constr_flags, bool allow_system_table_mods, bool is_internal, Oid *constraintId)
void index_concurrently_swap(Oid newIndexId, Oid oldIndexId, const char *oldName)
void index_set_state_flags(Oid indexId, IndexStateFlagsAction action)
bool CompareIndexInfo(const IndexInfo *info1, const IndexInfo *info2, const Oid *collations1, const Oid *collations2, const Oid *opfamilies1, const Oid *opfamilies2, const AttrMap *attmap)
bool reindex_relation(const ReindexStmt *stmt, Oid relid, int flags, const ReindexParams *params)
Oid index_concurrently_create_copy(Relation heapRelation, Oid oldIndexId, Oid tablespaceOid, const char *newName)
void index_check_primary_key(Relation heapRel, const IndexInfo *indexInfo, bool is_alter_table, const IndexStmt *stmt)
void index_concurrently_build(Oid heapRelationId, Oid indexRelationId)
IndexInfo * BuildIndexInfo(Relation index)
void reindex_index(const ReindexStmt *stmt, Oid indexId, bool skip_constraint_checks, char persistence, const ReindexParams *params)
#define INDEX_CREATE_IS_PRIMARY
#define INDEX_CREATE_IF_NOT_EXISTS
#define REINDEX_REL_PROCESS_TOAST
#define INDEX_CREATE_PARTITIONED
#define REINDEXOPT_CONCURRENTLY
#define REINDEXOPT_MISSING_OK
#define INDEX_CREATE_INVALID
#define INDEX_CONSTR_CREATE_WITHOUT_OVERLAPS
#define INDEX_CREATE_ADD_CONSTRAINT
#define INDEX_CREATE_SKIP_BUILD
#define INDEX_CONSTR_CREATE_DEFERRABLE
#define REINDEXOPT_REPORT_PROGRESS
#define INDEX_CONSTR_CREATE_INIT_DEFERRED
#define INDEX_CREATE_CONCURRENT
#define REINDEXOPT_VERBOSE
#define REINDEX_REL_CHECK_CONSTRAINTS
void index_close(Relation relation, LOCKMODE lockmode)
Relation index_open(Oid relationId, LOCKMODE lockmode)
static bool ReindexRelationConcurrently(const ReindexStmt *stmt, Oid relationOid, const ReindexParams *params)
char * makeObjectName(const char *name1, const char *name2, const char *label)
void ExecReindex(ParseState *pstate, const ReindexStmt *stmt, bool isTopLevel)
ObjectAddress DefineIndex(Oid tableId, IndexStmt *stmt, Oid indexRelationId, Oid parentIndexId, Oid parentConstraintId, int total_parts, bool is_alter_table, bool check_rights, bool check_not_in_use, bool skip_build, bool quiet)
static void set_indexsafe_procflags(void)
static void reindex_error_callback(void *arg)
static void ComputeIndexAttrs(IndexInfo *indexInfo, Oid *typeOids, Oid *collationOids, Oid *opclassOids, Datum *opclassOptions, int16 *colOptions, const List *attList, const List *exclusionOpNames, Oid relId, const char *accessMethodName, Oid accessMethodId, bool amcanorder, bool isconstraint, bool iswithoutoverlaps, Oid ddl_userid, int ddl_sec_context, int *ddl_save_nestlevel)
static void ReindexIndex(const ReindexStmt *stmt, const ReindexParams *params, bool isTopLevel)
void IndexSetParentIndex(Relation partitionIdx, Oid parentOid)
Oid GetDefaultOpClass(Oid type_id, Oid am_id)
static char * ChooseIndexNameAddition(const List *colnames)
static void ReindexMultipleTables(const ReindexStmt *stmt, const ReindexParams *params)
static bool CompareOpclassOptions(const Datum *opts1, const Datum *opts2, int natts)
static void update_relispartition(Oid relationId, bool newval)
bool CheckIndexCompatible(Oid oldId, const char *accessMethodName, const List *attributeList, const List *exclusionOpNames, bool isWithoutOverlaps)
void GetOperatorFromWellKnownStrategy(Oid opclass, Oid rhstype, Oid *opid, StrategyNumber *strat)
void WaitForOlderSnapshots(TransactionId limitXmin, bool progress)
Oid ResolveOpClass(const List *opclass, Oid attrType, const char *accessMethodName, Oid accessMethodId)
static void ReindexPartitions(const ReindexStmt *stmt, Oid relid, const ReindexParams *params, bool isTopLevel)
struct ReindexErrorInfo ReindexErrorInfo
static Oid ReindexTable(const ReindexStmt *stmt, const ReindexParams *params, bool isTopLevel)
static void CheckPredicate(Expr *predicate)
static void ReindexMultipleInternal(const ReindexStmt *stmt, const List *relids, const ReindexParams *params)
static void RangeVarCallbackForReindexIndex(const RangeVar *relation, Oid relId, Oid oldRelId, void *arg)
static List * ChooseIndexColumnNames(const List *indexElems)
static char * ChooseIndexName(const char *tabname, Oid namespaceId, const List *colnames, const List *exclusionOpNames, bool primary, bool isconstraint)
char * ChooseRelationName(const char *name1, const char *name2, const char *label, Oid namespaceid, bool isconstraint)
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
#define INJECTION_POINT(name)
void CacheInvalidateRelcacheByRelid(Oid relid)
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
void list_free(List *list)
List * lcons_oid(Oid datum, List *list)
List * list_concat_copy(const List *list1, const List *list2)
void UnlockRelationOid(Oid relid, LOCKMODE lockmode)
void WaitForLockersMultiple(List *locktags, LOCKMODE lockmode, bool progress)
void LockRelationIdForSession(LockRelId *relid, LOCKMODE lockmode)
void LockRelationOid(Oid relid, LOCKMODE lockmode)
void WaitForLockers(LOCKTAG heaplocktag, LOCKMODE lockmode, bool progress)
void UnlockRelationIdForSession(LockRelId *relid, LOCKMODE lockmode)
void UnlockTuple(Relation relation, ItemPointer tid, LOCKMODE lockmode)
bool VirtualXactLock(VirtualTransactionId vxid, bool wait)
#define VirtualTransactionIdIsValid(vxid)
#define SET_LOCKTAG_RELATION(locktag, dboid, reloid)
#define VirtualTransactionIdEquals(vxid1, vxid2)
#define SetInvalidVirtualTransactionId(vxid)
#define AccessExclusiveLock
#define InplaceUpdateTupleLock
#define ShareUpdateExclusiveLock
char get_rel_persistence(Oid relid)
char * get_opname(Oid opno)
bool get_index_isvalid(Oid index_oid)
Oid get_opclass_input_type(Oid opclass)
Oid get_opclass_family(Oid opclass)
char * get_namespace_name(Oid nspid)
bool get_opclass_opfamily_and_input_type(Oid opclass, Oid *opfamily, Oid *opcintype)
Datum get_attoptions(Oid relid, int16 attnum)
char get_rel_relkind(Oid relid)
Oid get_rel_namespace(Oid relid)
RegProcedure get_opcode(Oid opno)
int get_op_opfamily_strategy(Oid opno, Oid opfamily)
char * get_rel_name(Oid relid)
Oid get_opfamily_member(Oid opfamily, Oid lefttype, Oid righttype, int16 strategy)
bool type_is_collatable(Oid typid)
Oid getBaseType(Oid typid)
Oid get_relname_relid(const char *relname, Oid relnamespace)
Oid get_commutator(Oid opno)
void op_input_types(Oid opno, Oid *lefttype, Oid *righttype)
bool LWLockAcquire(LWLock *lock, LWLockMode mode)
void LWLockRelease(LWLock *lock)
List * make_ands_implicit(Expr *clause)
IndexInfo * makeIndexInfo(int numattrs, int numkeyattrs, Oid amoid, List *expressions, List *predicates, bool unique, bool nulls_not_distinct, bool isready, bool concurrent, bool summarizing, bool withoutoverlaps)
int pg_mbcliplen(const char *mbstr, int len, int limit)
char * pstrdup(const char *in)
void pfree(void *pointer)
void MemoryContextDelete(MemoryContext context)
MemoryContext PortalContext
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define ALLOCSET_SMALL_SIZES
#define IsBootstrapProcessingMode()
#define SECURITY_RESTRICTED_OPERATION
#define CHECK_FOR_INTERRUPTS()
void GetUserIdAndSecContext(Oid *userid, int *sec_context)
void SetUserIdAndSecContext(Oid userid, int sec_context)
Oid OpclassnameGetOpcid(Oid amid, const char *opcname)
Oid LookupExplicitNamespace(const char *nspname, bool missing_ok)
bool isTempNamespace(Oid namespaceId)
Oid get_collation_oid(List *collname, bool missing_ok)
void DeconstructQualifiedName(const List *names, char **nspname_p, char **objname_p)
Oid get_namespace_oid(const char *nspname, bool missing_ok)
char * NameListToString(const List *names)
Oid RangeVarGetRelidExtended(const RangeVar *relation, LOCKMODE lockmode, uint32 flags, RangeVarGetRelidCallback callback, void *callback_arg)
Oid exprType(const Node *expr)
Oid exprCollation(const Node *expr)
#define IsA(nodeptr, _type_)
const ObjectAddress InvalidObjectAddress
#define ObjectAddressSet(addr, class_id, object_id)
TYPCATEGORY TypeCategory(Oid type)
bool IsBinaryCoercible(Oid srctype, Oid targettype)
bool IsPreferredType(TYPCATEGORY category, Oid type)
int parser_errposition(ParseState *pstate, int location)
Oid compatible_oper_opid(List *op, Oid arg1, Oid arg2, bool noError)
IndexStmt * generateClonedIndexStmt(RangeVar *heapRel, Relation source_idx, const AttrMap *attmap, Oid *constraintOid)
@ PARTITION_STRATEGY_HASH
@ REINDEX_OBJECT_DATABASE
PartitionKey RelationGetPartitionKey(Relation rel)
PartitionDesc RelationGetPartitionDesc(Relation rel, bool omit_detached)
FormData_pg_am * Form_pg_am
FormData_pg_attribute * Form_pg_attribute
static void fix_dependencies(ArchiveHandle *AH)
int errdetail_relkind_not_supported(char relkind)
FormData_pg_class * Form_pg_class
Oid get_relation_idx_constraint_oid(Oid relationId, Oid indexId)
void ConstraintSetParentConstraint(Oid childConstrId, Oid parentConstrId, Oid childTableId)
bool ConstraintNameExists(const char *conname, Oid namespaceid)
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
long deleteDependencyRecordsForClass(Oid classId, Oid objectId, Oid refclassId, char deptype)
FormData_pg_index * Form_pg_index
List * find_all_inheritors(Oid parentrelId, LOCKMODE lockmode, List **numparents)
void StoreSingleInheritance(Oid relationId, Oid parentOid, int32 seqNumber)
bool has_superclass(Oid relationId)
FormData_pg_inherits * Form_pg_inherits
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
#define list_make1_oid(x1)
static ListCell * list_head(const List *l)
static ListCell * lnext(const List *l, const ListCell *c)
FormData_pg_opclass * Form_pg_opclass
FormData_pg_opfamily * Form_pg_opfamily
const char * pg_rusage_show(const PGRUsage *ru0)
void pg_rusage_init(PGRUsage *ru0)
size_t strlcpy(char *dst, const char *src, size_t siz)
static bool DatumGetBool(Datum X)
static Datum PointerGetDatum(const void *X)
static Datum ObjectIdGetDatum(Oid X)
static Pointer DatumGetPointer(Datum X)
static Datum Int32GetDatum(int32 X)
#define PROC_IS_AUTOVACUUM
PGPROC * ProcNumberGetProc(ProcNumber procNumber)
VirtualTransactionId * GetCurrentVirtualXIDs(TransactionId limitXmin, bool excludeXmin0, bool allDbs, int excludeVacuum, int *nvxids)
#define PROGRESS_CREATEIDX_PHASE_WAIT_4
#define PROGRESS_CREATEIDX_PHASE_BUILD
#define PROGRESS_CREATEIDX_PARTITIONS_DONE
#define PROGRESS_CREATEIDX_PHASE_WAIT_1
#define PROGRESS_CREATEIDX_COMMAND_CREATE_CONCURRENTLY
#define PROGRESS_CREATEIDX_ACCESS_METHOD_OID
#define PROGRESS_WAITFOR_DONE
#define PROGRESS_CREATEIDX_PHASE_WAIT_3
#define PROGRESS_WAITFOR_TOTAL
#define PROGRESS_CREATEIDX_COMMAND_REINDEX_CONCURRENTLY
#define PROGRESS_CREATEIDX_COMMAND_CREATE
#define PROGRESS_WAITFOR_CURRENT_PID
#define PROGRESS_CREATEIDX_PHASE_WAIT_2
#define PROGRESS_CREATEIDX_PHASE
#define PROGRESS_CREATEIDX_PHASE_VALIDATE_IDXSCAN
#define PROGRESS_CREATEIDX_PHASE_WAIT_5
#define PROGRESS_CREATEIDX_INDEX_OID
#define PROGRESS_CREATEIDX_PARTITIONS_TOTAL
#define PROGRESS_CREATEIDX_COMMAND
MemoryContextSwitchTo(old_ctx)
char * format_operator(Oid operator_oid)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
#define RELATION_IS_OTHER_TEMP(relation)
#define RelationGetNamespace(relation)
List * RelationGetIndexList(Relation relation)
List * RelationGetIndexPredicate(Relation relation)
void RelationGetExclusionInfo(Relation indexRelation, Oid **operators, Oid **procs, uint16 **strategies)
List * RelationGetIndexExpressions(Relation relation)
bytea * index_reloptions(amoptions_function amoptions, Datum reloptions, bool validate)
Datum transformRelOptions(Datum oldOptions, List *defList, const char *namspace, const char *const validnsps[], bool acceptOidsOff, bool isReset)
#define RelFileNumberIsValid(relnumber)
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
Snapshot GetTransactionSnapshot(void)
void UnregisterSnapshot(Snapshot snapshot)
void PushActiveSnapshot(Snapshot snapshot)
bool ActiveSnapshotSet(void)
Snapshot RegisterSnapshot(Snapshot snapshot)
void PopActiveSnapshot(void)
void relation_close(Relation relation, LOCKMODE lockmode)
Relation relation_open(Oid relationId, LOCKMODE lockmode)
#define RTOverlapStrategyNumber
#define RTEqualStrategyNumber
#define HTEqualStrategyNumber
#define BTEqualStrategyNumber
#define RTContainedByStrategyNumber
#define ERRCODE_DUPLICATE_OBJECT
struct ErrorContextCallback * previous
void(* callback)(void *arg)
amoptions_function amoptions
amgettuple_function amgettuple
SortByNulls nulls_ordering
uint16 * ii_ExclusionStrats
AttrNumber ii_IndexAttrNumbers[INDEX_MAX_KEYS]
Oid values[FLEXIBLE_ARRAY_MEMBER]
#define FirstLowInvalidHeapAttributeNumber
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCacheLockedCopy1(int cacheId, Datum key1)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
HeapTuple SearchSysCache3(int cacheId, Datum key1, Datum key2, Datum key3)
HeapTuple SearchSysCacheAttName(Oid relid, const char *attname)
Datum SysCacheGetAttrNotNull(int cacheId, HeapTuple tup, AttrNumber attributeNumber)
#define SearchSysCacheExists1(cacheId, key1)
Relation try_table_open(Oid relationId, LOCKMODE lockmode)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
TableScanDesc table_beginscan_catalog(Relation relation, int nkeys, struct ScanKeyData *key)
static void table_endscan(TableScanDesc scan)
void CheckTableNotInUse(Relation rel, const char *stmt)
void SetRelationHasSubclass(Oid relationId, bool relhassubclass)
void RangeVarCallbackMaintainsTable(const RangeVar *relation, Oid relId, Oid oldRelId, void *arg)
#define InvalidTransactionId
#define TupleDescAttr(tupdesc, i)
void pull_varattnos(Node *node, Index varno, Bitmapset **varattnos)
void CommandCounterIncrement(void)
void PreventInTransactionBlock(bool isTopLevel, const char *stmtType)
void StartTransactionCommand(void)
void CommitTransactionCommand(void)