72 #include "utils/fmgroids.h"
104 const List *indexColNames,
106 const Oid *collationIds,
107 const Oid *opclassIds);
109 int numatts,
Oid indexoid);
114 const Oid *collationOids,
115 const Oid *opclassOids,
116 const int16 *coloptions,
160 foreach(indexoidscan, indexoidlist)
167 elog(
ERROR,
"cache lookup failed for index %u", indexoid);
214 if ((is_alter_table || heapRel->
rd_rel->relispartition) &&
218 (
errcode(ERRCODE_INVALID_TABLE_DEFINITION),
219 errmsg(
"multiple primary keys for table \"%s\" are not allowed",
232 (
errcode(ERRCODE_INVALID_TABLE_DEFINITION),
233 errmsg(
"primary keys cannot use NULLS NOT DISTINCT indexes")));
249 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
250 errmsg(
"primary keys cannot be expressions")));
260 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
264 if (!attform->attnotnull)
266 (
errcode(ERRCODE_INVALID_TABLE_DEFINITION),
267 errmsg(
"primary key column \"%s\" is not marked NOT NULL",
282 const List *indexColNames,
284 const Oid *collationIds,
285 const Oid *opclassIds)
312 for (
i = 0;
i < numatts;
i++)
323 to->attcacheoff = -1;
324 to->attislocal =
true;
325 to->attcollation = (
i < numkeyatts) ? collationIds[
i] :
InvalidOid;
330 if (colnames_item == NULL)
331 elog(
ERROR,
"too few entries in colnames list");
333 colnames_item =
lnext(indexColNames, colnames_item);
348 elog(
ERROR,
"invalid column number %d", atnum);
352 to->atttypid = from->atttypid;
353 to->attlen = from->attlen;
354 to->attndims = from->attndims;
355 to->atttypmod = from->atttypmod;
356 to->attbyval = from->attbyval;
357 to->attalign = from->attalign;
358 to->attstorage = from->attstorage;
359 to->attcompression = from->attcompression;
366 if (indexpr_item == NULL)
367 elog(
ERROR,
"too few entries in indexprs list");
377 elog(
ERROR,
"cache lookup failed for type %u", keyType);
383 to->atttypid = keyType;
384 to->attlen = typeTup->typlen;
386 to->attbyval = typeTup->typbyval;
387 to->attalign = typeTup->typalign;
388 to->attstorage = typeTup->typstorage;
411 to->atttypid, to->attcollation,
429 if (i < indexInfo->ii_NumIndexKeyAttrs)
433 elog(
ERROR,
"cache lookup failed for opclass %u", opclassIds[
i]);
436 keyType = opclassTup->opckeytype;
447 if (keyType == ANYELEMENTOID && opclassTup->opcintype == ANYARRAYOID)
451 elog(
ERROR,
"could not get element type of array type %u",
462 if (
OidIsValid(keyType) && keyType != to->atttypid)
466 elog(
ERROR,
"cache lookup failed for type %u", keyType);
469 to->atttypid = keyType;
471 to->attlen = typeTup->typlen;
472 to->attbyval = typeTup->typbyval;
473 to->attalign = typeTup->typalign;
474 to->attstorage = typeTup->typstorage;
501 for (
i = 0;
i < numatts;
i += 1)
565 const Oid *collationOids,
566 const Oid *opclassOids,
567 const int16 *coloptions,
581 bool nulls[Natts_pg_index] = {0};
609 exprsDatum = (
Datum) 0;
624 predDatum = (
Datum) 0;
654 values[Anum_pg_index_indexprs - 1] = exprsDatum;
655 if (exprsDatum == (
Datum) 0)
656 nulls[Anum_pg_index_indexprs - 1] =
true;
657 values[Anum_pg_index_indpred - 1] = predDatum;
658 if (predDatum == (
Datum) 0)
659 nulls[Anum_pg_index_indpred - 1] =
true;
725 const char *indexRelationName,
727 Oid parentIndexRelid,
728 Oid parentConstraintId,
731 const List *indexColNames,
734 const Oid *collationIds,
735 const Oid *opclassIds,
736 const Datum *opclassOptions,
737 const int16 *coloptions,
742 bool allow_system_table_mods,
750 bool shared_relation;
751 bool mapped_relation;
766 Assert((constr_flags == 0) ||
771 relkind = partitioned ? RELKIND_PARTITIONED_INDEX : RELKIND_INDEX;
783 shared_relation = heapRelation->
rd_rel->relisshared;
785 relpersistence = heapRelation->
rd_rel->relpersistence;
791 elog(
ERROR,
"must index at least one column");
793 if (!allow_system_table_mods &&
797 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
798 errmsg(
"user-defined indexes on system catalog tables are not supported")));
821 Oid collation = collationIds[
i];
822 Oid opclass = opclassIds[
i];
826 if ((opclass == TEXT_BTREE_PATTERN_OPS_OID ||
827 opclass == VARCHAR_BTREE_PATTERN_OPS_OID ||
828 opclass == BPCHAR_BTREE_PATTERN_OPS_OID) &&
835 elog(
ERROR,
"cache lookup failed for operator class %u", opclass);
837 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
838 errmsg(
"nondeterministic collations are not supported for operator class \"%s\"",
852 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
853 errmsg(
"concurrent index creation on system catalog tables is not supported")));
859 if (concurrent && is_exclusion)
861 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
862 errmsg(
"concurrent index creation for exclusion constraints is not supported")));
870 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
871 errmsg(
"shared indexes cannot be created after initdb")));
876 if (shared_relation && tableSpaceId != GLOBALTABLESPACE_OID)
877 elog(
ERROR,
"shared relations must be placed in pg_global tablespace");
890 (
errcode(ERRCODE_DUPLICATE_TABLE),
891 errmsg(
"relation \"%s\" already exists, skipping",
892 indexRelationName)));
898 (
errcode(ERRCODE_DUPLICATE_TABLE),
899 errmsg(
"relation \"%s\" already exists",
900 indexRelationName)));
913 errmsg(
"constraint \"%s\" for relation \"%s\" already exists",
940 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
941 errmsg(
"pg_class index OID value not set when in binary upgrade mode")));
947 if ((relkind == RELKIND_INDEX) &&
950 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
951 errmsg(
"index relfilenumber value not set when in binary upgrade mode")));
985 allow_system_table_mods,
1007 indexRelation->
rd_rel->relowner = heapRelation->
rd_rel->relowner;
1008 indexRelation->
rd_rel->relam = accessMethodId;
1045 collationIds, opclassIds, coloptions,
1046 isprimary, is_exclusion,
1088 char constraintType;
1092 constraintType = CONSTRAINT_PRIMARY;
1094 constraintType = CONSTRAINT_UNIQUE;
1095 else if (is_exclusion)
1096 constraintType = CONSTRAINT_EXCLUSION;
1099 elog(
ERROR,
"constraint must be PRIMARY, UNIQUE or EXCLUDE");
1110 allow_system_table_mods,
1113 *constraintId = localaddr.
objectId;
1117 bool have_simple_col =
false;
1130 have_simple_col =
true;
1140 if (!have_simple_col)
1174 if (
OidIsValid(collationIds[
i]) && collationIds[
i] != DEFAULT_COLLATION_OID)
1219 indexRelationId, 0, is_internal);
1275 index_build(heapRelation, indexRelation, indexInfo,
false,
true);
1284 return indexRelationId;
1298 Oid tablespaceOid,
const char *newName)
1306 Datum indclassDatum,
1309 Datum *opclassOptions;
1329 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1330 errmsg(
"concurrent index creation for exclusion constraints is not supported")));
1335 elog(
ERROR,
"cache lookup failed for index %u", oldIndexId);
1337 Anum_pg_index_indclass);
1341 Anum_pg_index_indoption);
1347 elog(
ERROR,
"cache lookup failed for relation %u", oldIndexId);
1349 Anum_pg_class_reloptions, &isnull);
1362 Anum_pg_index_indexprs);
1373 Anum_pg_index_indpred);
1426 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
1428 dat =
SysCacheGetAttr(ATTNUM, tp, Anum_pg_attribute_attstattarget, &isnull);
1430 stattargets[
i].
value = dat;
1431 stattargets[
i].
isnull = isnull;
1449 indexRelation->
rd_rel->relam,
1482 Oid indexRelationId)
1486 int save_sec_context;
1521 index_build(heapRel, indexRelation, indexInfo,
false,
true);
1565 Oid indexConstraintOid;
1581 elog(
ERROR,
"could not find tuple for relation %u", oldIndexId);
1585 elog(
ERROR,
"could not find tuple for relation %u", newIndexId);
1595 isPartition = newClassForm->relispartition;
1596 newClassForm->relispartition = oldClassForm->relispartition;
1597 oldClassForm->relispartition = isPartition;
1611 elog(
ERROR,
"could not find tuple for relation %u", oldIndexId);
1615 elog(
ERROR,
"could not find tuple for relation %u", newIndexId);
1624 newIndexForm->indisprimary = oldIndexForm->indisprimary;
1625 oldIndexForm->indisprimary =
false;
1626 newIndexForm->indisexclusion = oldIndexForm->indisexclusion;
1627 oldIndexForm->indisexclusion =
false;
1628 newIndexForm->indimmediate = oldIndexForm->indimmediate;
1629 oldIndexForm->indimmediate =
true;
1632 newIndexForm->indisreplident = oldIndexForm->indisreplident;
1635 newIndexForm->indisclustered = oldIndexForm->indisclustered;
1641 newIndexForm->indisvalid =
true;
1642 oldIndexForm->indisvalid =
false;
1643 oldIndexForm->indisclustered =
false;
1644 oldIndexForm->indisreplident =
false;
1661 constraintOids =
lappend_oid(constraintOids, indexConstraintOid);
1666 foreach(lc, constraintOids)
1679 elog(
ERROR,
"could not find tuple for constraint %u", constraintOid);
1683 if (conForm->conindid == oldIndexId)
1685 conForm->conindid = newIndexId;
1694 Anum_pg_trigger_tgconstraint,
1705 if (tgForm->tgconstrindid != oldIndexId)
1712 tgForm->tgconstrindid = newIndexId;
1731 bool nulls[Natts_pg_description] = {0};
1732 bool replaces[Natts_pg_description] = {0};
1735 replaces[Anum_pg_description_objoid - 1] =
true;
1738 Anum_pg_description_objoid,
1742 Anum_pg_description_classoid,
1746 Anum_pg_description_objsubid,
1758 values, nulls, replaces);
1882 Oid indexRelationId,
1883 Oid parentConstraintId,
1885 const char *constraintName,
1886 char constraintType,
1888 bool allow_system_table_mods,
1897 bool mark_as_primary;
1900 bool is_without_overlaps;
1912 if (!allow_system_table_mods &&
1916 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1917 errmsg(
"user-defined indexes on system catalog tables are not supported")));
1921 constraintType != CONSTRAINT_EXCLUSION)
1922 elog(
ERROR,
"constraints cannot have index expressions");
1983 is_without_overlaps,
2022 trigger->
trigname = (constraintType == CONSTRAINT_PRIMARY) ?
2023 "PK_ConstraintTrigger" :
2024 "Unique_ConstraintTrigger";
2028 trigger->
row =
true;
2029 trigger->
timing = TRIGGER_TYPE_AFTER;
2030 trigger->
events = TRIGGER_TYPE_INSERT | TRIGGER_TYPE_UPDATE;
2052 (mark_as_primary || deferrable))
2058 bool marked_as_primary =
false;
2065 elog(
ERROR,
"cache lookup failed for index %u", indexRelationId);
2068 if (mark_as_primary && !indexForm->indisprimary)
2070 indexForm->indisprimary =
true;
2072 marked_as_primary =
true;
2075 if (deferrable && indexForm->indimmediate)
2077 indexForm->indimmediate =
false;
2091 if (marked_as_primary)
2137 (!concurrent && !concurrent_lock_mode));
2159 userHeapRelation =
table_open(heapId, lockmode);
2160 userIndexRelation =
index_open(indexId, lockmode);
2216 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2217 errmsg(
"DROP INDEX CONCURRENTLY must be first action in transaction")));
2312 if (RELKIND_HAS_STORAGE(userIndexRelation->
rd_rel->relkind))
2334 elog(
ERROR,
"cache lookup failed for index %u", indexId);
2415 numAtts = indexStruct->indnatts;
2417 elog(
ERROR,
"invalid indnatts %d for index %u",
2425 indexStruct->indnkeyatts,
2426 index->rd_rel->relam,
2429 indexStruct->indisunique,
2430 indexStruct->indnullsnotdistinct,
2431 indexStruct->indisready,
2433 index->rd_indam->amsummarizing);
2436 for (
i = 0;
i < numAtts;
i++)
2440 if (indexStruct->indisexclusion)
2474 numAtts = indexStruct->indnatts;
2476 elog(
ERROR,
"invalid indnatts %d for index %u",
2484 indexStruct->indnkeyatts,
2485 index->rd_rel->relam,
2488 indexStruct->indisunique,
2489 indexStruct->indnullsnotdistinct,
2490 indexStruct->indisready,
2492 index->rd_indam->amsummarizing);
2495 for (
i = 0;
i < numAtts;
i++)
2515 const Oid *collations1,
const Oid *collations2,
2516 const Oid *opfamilies1,
const Oid *opfamilies2,
2569 if (collations1[
i] != collations2[
i])
2571 if (opfamilies1[
i] != opfamilies2[
i])
2583 bool found_whole_row;
2589 if (found_whole_row)
2607 bool found_whole_row;
2613 if (found_whole_row)
2657 if (
index->rd_rel->relam != BTREE_AM_OID)
2658 elog(
ERROR,
"unexpected non-btree speculative unique index");
2669 for (
i = 0;
i < indnkeyatts;
i++)
2678 elog(
ERROR,
"missing operator %d(%u,%u) in opfamily %u",
2733 else if (keycol != 0)
2746 if (indexpr_item == NULL)
2747 elog(
ERROR,
"wrong number of index expressions");
2757 if (indexpr_item != NULL)
2758 elog(
ERROR,
"wrong number of index expressions");
2853 elog(
ERROR,
"could not find tuple for relation %u", relid);
2857 Assert(rd_rel->relkind != RELKIND_PARTITIONED_INDEX);
2865 if (reltuples == 0 && rd_rel->reltuples < 0)
2871 if (rd_rel->relhasindex != hasindex)
2873 rd_rel->relhasindex = hasindex;
2882 if (rd_rel->relkind != RELKIND_INDEX)
2887 if (rd_rel->relpages != (
int32) relpages)
2889 rd_rel->relpages = (
int32) relpages;
2892 if (rd_rel->reltuples != (
float4) reltuples)
2894 rd_rel->reltuples = (
float4) reltuples;
2897 if (rd_rel->relallvisible != (
int32) relallvisible)
2899 rd_rel->relallvisible = (
int32) relallvisible;
2949 int save_sec_context;
2979 (
errmsg_internal(
"building index \"%s\" on table \"%s\" with request for %d parallel workers",
2997 const int progress_index[] = {
3005 const int64 progress_vals[] = {
3028 if (indexRelation->
rd_rel->relpersistence == RELPERSISTENCE_UNLOGGED &&
3078 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3082 Assert(!indexForm->indcheckxmin);
3084 indexForm->indcheckxmin =
true;
3187 if (predicate != NULL)
3189 if (!
ExecQual(predicate, econtext))
3206 indexRelation, indexInfo,
3298 int save_sec_context;
3302 const int progress_index[] = {
3309 const int64 progress_vals[] = {
3346 ivinfo.
index = indexRelation;
3347 ivinfo.
heaprel = heapRelation;
3373 const int progress_index[] = {
3378 const int64 progress_vals[] = {
3402 "validate_index found %.0f heap tuples, %.0f index tuples; inserted %.0f missing tuples",
3452 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3460 Assert(indexForm->indislive);
3461 Assert(!indexForm->indisready);
3462 Assert(!indexForm->indisvalid);
3463 indexForm->indisready =
true;
3467 Assert(indexForm->indislive);
3468 Assert(indexForm->indisready);
3469 Assert(!indexForm->indisvalid);
3470 indexForm->indisvalid =
true;
3487 indexForm->indisvalid =
false;
3488 indexForm->indisclustered =
false;
3489 indexForm->indisreplident =
false;
3500 Assert(!indexForm->indisvalid);
3501 Assert(!indexForm->indisclustered);
3502 Assert(!indexForm->indisreplident);
3503 indexForm->indisready =
false;
3504 indexForm->indislive =
false;
3531 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3536 result =
index->indrelid;
3546 bool skip_constraint_checks,
char persistence,
3553 int save_sec_context;
3556 volatile bool skipped_constraint =
false;
3559 bool set_tablespace =
false;
3595 const int progress_cols[] = {
3599 const int64 progress_vals[] = {
3654 if (iRel->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX)
3655 elog(
ERROR,
"cannot reindex partitioned index \"%s.%s\"",
3665 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3666 errmsg(
"cannot reindex temporary tables of other sessions")));
3676 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3677 errmsg(
"cannot reindex invalid index on TOAST table")));
3692 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3693 errmsg(
"cannot move system relation \"%s\"",
3699 set_tablespace =
true;
3733 if (skip_constraint_checks)
3736 skipped_constraint =
true;
3751 index_build(heapRelation, iRel, indexInfo,
true,
true);
3784 if (!skipped_constraint)
3796 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3799 index_bad = (!indexForm->indisvalid ||
3800 !indexForm->indisready ||
3801 !indexForm->indislive);
3806 indexForm->indcheckxmin =
false;
3808 indexForm->indcheckxmin =
true;
3809 indexForm->indisvalid =
true;
3810 indexForm->indisready =
true;
3811 indexForm->indislive =
true;
3830 (
errmsg(
"index \"%s\" was reindexed",
3892 bool result =
false;
3914 if (rel->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
3915 elog(
ERROR,
"cannot reindex partitioned table \"%s.%s\"",
3919 toast_relid = rel->
rd_rel->reltoastrelid;
3973 persistence = RELPERSISTENCE_UNLOGGED;
3975 persistence = RELPERSISTENCE_PERMANENT;
3977 persistence = rel->
rd_rel->relpersistence;
3981 foreach(indexId, indexIds)
3995 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3996 errmsg(
"cannot reindex invalid index \"%s.%s\" on TOAST table, skipping",
4003 persistence, params);
4021 result |= (indexIds !=
NIL);
4085 elog(
ERROR,
"cannot reindex while reindexing");
4117 elog(
ERROR,
"cannot reindex while reindexing");
4119 elog(
ERROR,
"cannot modify reindex state during a parallel operation");
4132 elog(
ERROR,
"cannot modify reindex state during a parallel operation");
IndexAmRoutine * GetIndexAmRoutineByAmId(Oid amoid, bool noerror)
#define AttrNumberGetAttrOffset(attNum)
#define InvalidAttrNumber
void pgstat_progress_start_command(ProgressCommandType cmdtype, Oid relid)
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
static Datum values[MAXATTR]
void index_register(Oid heap, Oid ind, const IndexInfo *indexInfo)
#define RelationGetNumberOfBlocks(reln)
#define CStringGetTextDatum(s)
#define TextDatumGetCString(d)
TransactionId MultiXactId
#define PointerIsValid(pointer)
#define FLEXIBLE_ARRAY_MEMBER
#define MemSet(start, val, len)
#define OidIsValid(objectId)
bool IsToastNamespace(Oid namespaceId)
bool IsSystemRelation(Relation relation)
RelFileNumber GetNewRelFileNumber(Oid reltablespace, Relation pg_class, char relpersistence)
bool IsCatalogRelation(Relation relation)
void record_object_address_dependencies(const ObjectAddress *depender, ObjectAddresses *referenced, DependencyType behavior)
void recordDependencyOnSingleRelExpr(const ObjectAddress *depender, Node *expr, Oid relId, DependencyType behavior, DependencyType self_behavior, bool reverse_self)
ObjectAddresses * new_object_addresses(void)
void add_exact_object_address(const ObjectAddress *object, ObjectAddresses *addrs)
void free_object_addresses(ObjectAddresses *addrs)
@ DEPENDENCY_PARTITION_PRI
@ DEPENDENCY_PARTITION_SEC
int errmsg_internal(const char *fmt,...)
int errdetail_internal(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool equal(const void *a, const void *b)
void EventTriggerCollectSimpleCommand(ObjectAddress address, ObjectAddress secondaryObject, Node *parsetree)
ExprState * ExecPrepareQual(List *qual, EState *estate)
List * ExecPrepareExprList(List *nodes, EState *estate)
void check_exclusion_constraint(Relation heap, Relation index, IndexInfo *indexInfo, ItemPointer tupleid, const Datum *values, const bool *isnull, EState *estate, bool newIndex)
void ExecDropSingleTupleTableSlot(TupleTableSlot *slot)
EState * CreateExecutorState(void)
void FreeExecutorState(EState *estate)
#define GetPerTupleExprContext(estate)
static bool ExecQual(ExprState *state, ExprContext *econtext)
static Datum ExecEvalExprSwitchContext(ExprState *state, ExprContext *econtext, bool *isNull)
#define palloc0_array(type, count)
Datum Int64GetDatum(int64 X)
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)
int NewGUCNestLevel(void)
void RestrictSearchPath(void)
void AtEOXact_GUC(bool isCommit, int nestLevel)
void DeleteRelationTuple(Oid relid)
void DeleteAttributeTuples(Oid relid)
void RemoveStatistics(Oid relid, AttrNumber attnum)
void CheckAttributeType(const char *attname, Oid atttypid, Oid attcollation, List *containing_rowtypes, int flags)
void CopyStatistics(Oid fromrelid, Oid torelid)
void InsertPgClassTuple(Relation pg_class_desc, Relation new_rel_desc, Oid new_rel_oid, Datum relacl, Datum reloptions)
void InsertPgAttributeTuples(Relation pg_attribute_rel, TupleDesc tupdesc, Oid new_rel_oid, const FormExtraData_pg_attribute tupdesc_extra[], CatalogIndexState indstate)
Relation heap_create(const char *relname, Oid relnamespace, Oid reltablespace, Oid relid, RelFileNumber relfilenumber, Oid accessmtd, TupleDesc tupDesc, char relkind, char relpersistence, bool shared_relation, bool mapped_relation, bool allow_system_table_mods, TransactionId *relfrozenxid, MultiXactId *relminmxid, bool create_storage)
void heap_inplace_update(Relation relation, HeapTuple tuple)
HeapTuple heap_getnext(TableScanDesc sscan, ScanDirection direction)
HeapTuple heap_modify_tuple(HeapTuple tuple, TupleDesc tupleDesc, const Datum *replValues, const bool *replIsnull, const bool *doReplace)
HeapTuple heap_copytuple(HeapTuple tuple)
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
bool heap_attisnull(HeapTuple tup, int attnum, TupleDesc tupleDesc)
void heap_freetuple(HeapTuple htup)
#define HeapTupleIsValid(tuple)
bool ReindexIsProcessingIndex(Oid indexOid)
static bool validate_index_callback(ItemPointer itemptr, void *opaque)
void validate_index(Oid heapId, Oid indexId, Snapshot snapshot)
void index_drop(Oid indexId, bool concurrent, bool concurrent_lock_mode)
void ResetReindexState(int nestLevel)
Oid IndexGetRelation(Oid indexId, bool missing_ok)
static int reindexingNestLevel
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)
static Oid currentlyReindexedHeap
static void ResetReindexProcessing(void)
void index_concurrently_swap(Oid newIndexId, Oid oldIndexId, const char *oldName)
static void RemoveReindexPending(Oid indexOid)
static List * pendingReindexedIndexes
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)
RelFileNumber binary_upgrade_next_index_pg_class_relfilenumber
IndexInfo * BuildDummyIndexInfo(Relation index)
bool reindex_relation(const ReindexStmt *stmt, Oid relid, int flags, const ReindexParams *params)
void SerializeReindexState(Size maxsize, char *start_address)
static void index_update_stats(Relation rel, bool hasindex, double reltuples)
static bool relationHasPrimaryKey(Relation rel)
static void SetReindexProcessing(Oid heapOid, Oid indexOid)
static void IndexCheckExclusion(Relation heapRelation, Relation indexRelation, IndexInfo *indexInfo)
static void InitializeAttributeOids(Relation indexRelation, int numatts, Oid indexoid)
Oid index_concurrently_create_copy(Relation heapRelation, Oid oldIndexId, Oid tablespaceOid, const char *newName)
Oid binary_upgrade_next_index_pg_class_oid
static void AppendAttributeTuples(Relation indexRelation, const Datum *attopts, const NullableDatum *stattargets)
void BuildSpeculativeIndexInfo(Relation index, IndexInfo *ii)
void index_check_primary_key(Relation heapRel, const IndexInfo *indexInfo, bool is_alter_table, const IndexStmt *stmt)
bool ReindexIsProcessingHeap(Oid heapOid)
static bool ReindexIsCurrentlyProcessingIndex(Oid indexOid)
void RestoreReindexState(const void *reindexstate)
static TupleDesc ConstructTupleDescriptor(Relation heapRelation, const IndexInfo *indexInfo, const List *indexColNames, Oid accessMethodId, const Oid *collationIds, const Oid *opclassIds)
void index_build(Relation heapRelation, Relation indexRelation, IndexInfo *indexInfo, bool isreindex, bool parallel)
ObjectAddress index_constraint_create(Relation heapRelation, Oid indexRelationId, Oid parentConstraintId, const IndexInfo *indexInfo, const char *constraintName, char constraintType, bits16 constr_flags, bool allow_system_table_mods, bool is_internal)
void FormIndexDatum(IndexInfo *indexInfo, TupleTableSlot *slot, EState *estate, Datum *values, bool *isnull)
static void SetReindexPending(List *indexes)
void index_concurrently_build(Oid heapRelationId, Oid indexRelationId)
static void UpdateIndexRelation(Oid indexoid, Oid heapoid, Oid parentIndexId, const IndexInfo *indexInfo, const Oid *collationOids, const Oid *opclassOids, const int16 *coloptions, bool primary, bool isexclusion, bool immediate, bool isvalid, bool isready)
static Oid currentlyReindexedIndex
Size EstimateReindexStateSpace(void)
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_MISSING_OK
#define INDEX_CREATE_INVALID
#define INDEX_CONSTR_CREATE_WITHOUT_OVERLAPS
static int64 itemptr_encode(ItemPointer itemptr)
#define INDEX_CREATE_ADD_CONSTRAINT
#define INDEX_CREATE_SKIP_BUILD
#define INDEX_CONSTR_CREATE_UPDATE_INDEX
#define REINDEX_REL_FORCE_INDEXES_UNLOGGED
#define INDEX_CONSTR_CREATE_REMOVE_OLD_DEPS
#define INDEX_CONSTR_CREATE_DEFERRABLE
#define REINDEXOPT_REPORT_PROGRESS
#define INDEX_CONSTR_CREATE_MARK_AS_PRIMARY
#define REINDEX_REL_SUPPRESS_INDEX_USE
#define REINDEX_REL_FORCE_INDEXES_PERMANENT
#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 try_index_open(Oid relationId, LOCKMODE lockmode)
IndexBulkDeleteResult * index_bulk_delete(IndexVacuumInfo *info, IndexBulkDeleteResult *istat, IndexBulkDeleteCallback callback, void *callback_state)
Relation index_open(Oid relationId, LOCKMODE lockmode)
bytea * index_opclass_options(Relation indrel, AttrNumber attnum, Datum attoptions, bool validate)
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
void CatalogCloseIndexes(CatalogIndexState indstate)
void CatalogTupleInsert(Relation heapRel, HeapTuple tup)
CatalogIndexState CatalogOpenIndexes(Relation heapRel)
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
int2vector * buildint2vector(const int16 *int2s, int n)
void CacheInvalidateRelcache(Relation relation)
void CacheInvalidateRelcacheByTuple(HeapTuple classTuple)
invalidindex index d is invalid
if(TABLE==NULL||TABLE_index==NULL)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
List * list_copy(const List *oldlist)
List * list_delete_oid(List *list, Oid datum)
void list_free(List *list)
bool list_member_oid(const List *list, Oid datum)
void LockRelationIdForSession(LockRelId *relid, LOCKMODE lockmode)
void LockRelation(Relation relation, LOCKMODE lockmode)
void WaitForLockers(LOCKTAG heaplocktag, LOCKMODE lockmode, bool progress)
void UnlockRelationIdForSession(LockRelId *relid, LOCKMODE lockmode)
#define SET_LOCKTAG_RELATION(locktag, dboid, reloid)
#define AccessExclusiveLock
#define ShareUpdateExclusiveLock
bool get_rel_relispartition(Oid relid)
char get_rel_persistence(Oid relid)
bool get_index_isvalid(Oid index_oid)
char * get_namespace_name(Oid nspid)
Datum get_attoptions(Oid relid, int16 attnum)
Oid get_rel_namespace(Oid relid)
RegProcedure get_opcode(Oid opno)
char * get_rel_name(Oid relid)
Oid get_opfamily_member(Oid opfamily, Oid lefttype, Oid righttype, int16 strategy)
bool get_collation_isdeterministic(Oid colloid)
Oid get_base_element_type(Oid typid)
Oid get_relname_relid(const char *relname, Oid relnamespace)
List * make_ands_implicit(Expr *clause)
Expr * make_ands_explicit(List *andclauses)
IndexInfo * makeIndexInfo(int numattrs, int numkeyattrs, Oid amoid, List *expressions, List *predicates, bool unique, bool nulls_not_distinct, bool isready, bool concurrent, bool summarizing)
void MemoryContextReset(MemoryContext context)
void pfree(void *pointer)
MemoryContext TopMemoryContext
void * palloc0(Size size)
#define IsBootstrapProcessingMode()
#define SECURITY_RESTRICTED_OPERATION
#define CHECK_FOR_INTERRUPTS()
#define IsNormalProcessingMode()
void GetUserIdAndSecContext(Oid *userid, int *sec_context)
void SetUserIdAndSecContext(Oid userid, int sec_context)
#define InvalidMultiXactId
void namestrcpy(Name name, const char *str)
Oid exprType(const Node *expr)
int32 exprTypmod(const Node *expr)
#define InvokeObjectPostAlterHookArg(classId, objectId, subId, auxiliaryId, is_internal)
#define InvokeObjectPostCreateHookArg(classId, objectId, subId, is_internal)
const ObjectAddress InvalidObjectAddress
#define ObjectAddressSet(addr, class_id, object_id)
#define ObjectAddressSubSet(addr, class_id, object_id, object_sub_id)
oidvector * buildoidvector(const Oid *oids, int n)
char * nodeToString(const void *obj)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
List * SystemFuncName(char *name)
List * get_partition_ancestors(Oid relid)
#define ATTRIBUTE_FIXED_PART_SIZE
FormData_pg_attribute * Form_pg_attribute
FormData_pg_class * Form_pg_class
bool ConstraintNameIsUsed(ConstraintCategory conCat, Oid objId, const char *conname)
Oid CreateConstraintEntry(const char *constraintName, Oid constraintNamespace, char constraintType, bool isDeferrable, bool isDeferred, bool isValidated, Oid parentConstrId, Oid relId, const int16 *constraintKey, int constraintNKeys, int constraintNTotalKeys, Oid domainId, Oid indexRelId, Oid foreignRelId, const int16 *foreignKey, const Oid *pfEqOp, const Oid *ppEqOp, const Oid *ffEqOp, int foreignNKeys, char foreignUpdateType, char foreignDeleteType, const int16 *fkDeleteSetCols, int numFkDeleteSetCols, char foreignMatchType, const Oid *exclOp, Node *conExpr, const char *conBin, bool conIsLocal, int conInhCount, bool conNoInherit, bool conPeriod, bool is_internal)
FormData_pg_constraint * Form_pg_constraint
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
long deleteDependencyRecordsForClass(Oid classId, Oid objectId, Oid refclassId, char deptype)
long changeDependenciesOf(Oid classId, Oid oldObjectId, Oid newObjectId)
long changeDependenciesOn(Oid refClassId, Oid oldRefObjectId, Oid newRefObjectId)
Oid get_index_constraint(Oid indexId)
List * get_index_ref_constraints(Oid indexId)
FormData_pg_index * Form_pg_index
bool DeleteInheritsTuple(Oid inhrelid, Oid inhparent, bool expect_detach_pending, const char *childname)
void StoreSingleInheritance(Oid relationId, Oid parentOid, int32 seqNumber)
static int list_length(const List *l)
static ListCell * list_head(const List *l)
static ListCell * lnext(const List *l, const ListCell *c)
FormData_pg_opclass * Form_pg_opclass
const char * pg_rusage_show(const PGRUsage *ru0)
void pg_rusage_init(PGRUsage *ru0)
FormData_pg_trigger * Form_pg_trigger
FormData_pg_type * Form_pg_type
void pgstat_copy_relation_stats(Relation dst, Relation src)
void pgstat_drop_relation(Relation rel)
int plan_create_index_workers(Oid tableOid, Oid indexOid)
static Datum PointerGetDatum(const void *X)
static Datum Int16GetDatum(int16 X)
static Datum BoolGetDatum(bool X)
static Datum ObjectIdGetDatum(Oid X)
static Pointer DatumGetPointer(Datum X)
static Datum Int32GetDatum(int32 X)
void TransferPredicateLocksToHeapRelation(Relation relation)
#define PROGRESS_CREATEIDX_PHASE_BUILD
#define PROGRESS_CREATEIDX_PHASE_VALIDATE_TABLESCAN
#define PROGRESS_CREATEIDX_ACCESS_METHOD_OID
#define PROGRESS_CREATEIDX_TUPLES_TOTAL
#define PROGRESS_CREATEIDX_PHASE_VALIDATE_SORT
#define PROGRESS_SCAN_BLOCKS_DONE
#define PROGRESS_CREATEIDX_TUPLES_DONE
#define PROGRESS_CREATEIDX_SUBPHASE
#define PROGRESS_CREATEIDX_SUBPHASE_INITIALIZE
#define PROGRESS_CREATEIDX_PHASE
#define PROGRESS_CREATEIDX_COMMAND_REINDEX
#define PROGRESS_CLUSTER_INDEX_REBUILD_COUNT
#define PROGRESS_CREATEIDX_PHASE_VALIDATE_IDXSCAN
#define PROGRESS_SCAN_BLOCKS_TOTAL
#define PROGRESS_CREATEIDX_INDEX_OID
#define PROGRESS_CREATEIDX_COMMAND
void * stringToNode(const char *str)
#define RelationGetForm(relation)
#define RelationGetRelid(relation)
static SMgrRelation RelationGetSmgr(Relation rel)
#define RelationGetDescr(relation)
#define RelationIsMapped(relation)
#define RelationGetRelationName(relation)
#define RELATION_IS_OTHER_TEMP(relation)
#define RelationIsValid(relation)
#define RelationGetNamespace(relation)
#define IndexRelationGetNumberOfKeyAttributes(relation)
List * RelationGetIndexList(Relation relation)
void RelationInitIndexAccessInfo(Relation relation)
List * RelationGetIndexPredicate(Relation relation)
List * RelationGetDummyIndexExpressions(Relation relation)
void RelationSetNewRelfilenumber(Relation relation, char persistence)
void RelationForgetRelation(Oid rid)
void RelationAssumeNewRelfilelocator(Relation relation)
void RelationGetExclusionInfo(Relation indexRelation, Oid **operators, Oid **procs, uint16 **strategies)
List * RelationGetIndexExpressions(Relation relation)
#define InvalidRelFileNumber
#define RelFileNumberIsValid(relnumber)
Node * map_variable_attnos(Node *node, int target_varno, int sublevels_up, const AttrMap *attno_map, Oid to_rowtype, bool *found_whole_row)
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
Size mul_size(Size s1, Size s2)
void smgrcreate(SMgrRelation reln, ForkNumber forknum, bool isRedo)
bool smgrexists(SMgrRelation reln, ForkNumber forknum)
Snapshot GetLatestSnapshot(void)
void UnregisterSnapshot(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)
void log_smgrcreate(const RelFileLocator *rlocator, ForkNumber forkNum)
void RelationDropStorage(Relation rel)
#define BTEqualStrategyNumber
#define ERRCODE_DUPLICATE_OBJECT
MemoryContext ecxt_per_tuple_memory
TupleTableSlot * ecxt_scantuple
ambuildempty_function ambuildempty
uint16 * ii_ExclusionStrats
ExprState * ii_PredicateState
List * ii_ExpressionsState
AttrNumber ii_IndexAttrNumbers[INDEX_MAX_KEYS]
BufferAccessStrategy strategy
struct IndexAmRoutine * rd_indam
MemoryContext rd_indexcxt
RelFileLocator rd_locator
Oid currentlyReindexedHeap
Oid currentlyReindexedIndex
int numPendingReindexedIndexes
Oid pendingReindexedIndexes[FLEXIBLE_ARRAY_MEMBER]
int16 values[FLEXIBLE_ARRAY_MEMBER]
Oid values[FLEXIBLE_ARRAY_MEMBER]
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Datum SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
HeapTuple SearchSysCache2(int cacheId, Datum key1, Datum key2)
Datum SysCacheGetAttrNotNull(int cacheId, HeapTuple tup, AttrNumber attributeNumber)
#define SearchSysCacheCopy1(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)
TupleTableSlot * table_slot_create(Relation relation, List **reglist)
static void table_endscan(TableScanDesc scan)
static void table_index_validate_scan(Relation table_rel, Relation index_rel, struct IndexInfo *index_info, Snapshot snapshot, struct ValidateIndexState *state)
static TableScanDesc table_beginscan_strat(Relation rel, Snapshot snapshot, int nkeys, struct ScanKeyData *key, bool allow_strat, bool allow_sync)
static bool table_scan_getnextslot(TableScanDesc sscan, ScanDirection direction, TupleTableSlot *slot)
void CheckTableNotInUse(Relation rel, const char *stmt)
bool CheckRelationTableSpaceMove(Relation rel, Oid newTableSpaceId)
void SetRelationHasSubclass(Oid relationId, bool relhassubclass)
void SetRelationTableSpace(Relation rel, Oid newTableSpaceId, RelFileNumber newRelFilenumber)
#define InvalidCompressionMethod
#define InvalidTransactionId
ObjectAddress CreateTrigger(CreateTrigStmt *stmt, const char *queryString, Oid relOid, Oid refRelOid, Oid constraintOid, Oid indexOid, Oid funcoid, Oid parentTriggerOid, Node *whenClause, bool isInternal, bool in_partition)
TupleDesc CreateTemplateTupleDesc(int natts)
#define TupleDescAttr(tupdesc, i)
void tuplesort_performsort(Tuplesortstate *state)
void tuplesort_end(Tuplesortstate *state)
void tuplesort_putdatum(Tuplesortstate *state, Datum val, bool isNull)
Tuplesortstate * tuplesort_begin_datum(Oid datumType, Oid sortOperator, Oid sortCollation, bool nullsFirstFlag, int workMem, SortCoordinate coordinate, int sortopt)
static Datum slot_getsysattr(TupleTableSlot *slot, int attnum, bool *isnull)
static Datum slot_getattr(TupleTableSlot *slot, int attnum, bool *isnull)
void visibilitymap_count(Relation rel, BlockNumber *all_visible, BlockNumber *all_frozen)
int GetCurrentTransactionNestLevel(void)
void CommandCounterIncrement(void)
TransactionId GetTopTransactionIdIfAny(void)
void StartTransactionCommand(void)
bool IsInParallelMode(void)
void CommitTransactionCommand(void)