77 #include "utils/fmgroids.h"
109 const List *indexColNames,
111 const Oid *collationIds,
112 const Oid *opclassIds);
114 int numatts,
Oid indexoid);
119 const Oid *collationOids,
120 const Oid *opclassOids,
121 const int16 *coloptions,
165 foreach(indexoidscan, indexoidlist)
172 elog(
ERROR,
"cache lookup failed for index %u", indexoid);
219 if ((is_alter_table || heapRel->
rd_rel->relispartition) &&
223 (
errcode(ERRCODE_INVALID_TABLE_DEFINITION),
224 errmsg(
"multiple primary keys for table \"%s\" are not allowed",
237 (
errcode(ERRCODE_INVALID_TABLE_DEFINITION),
238 errmsg(
"primary keys cannot use NULLS NOT DISTINCT indexes")));
254 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
255 errmsg(
"primary keys cannot be expressions")));
265 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
269 if (!attform->attnotnull)
271 (
errcode(ERRCODE_INVALID_TABLE_DEFINITION),
272 errmsg(
"primary key column \"%s\" is not marked NOT NULL",
287 const List *indexColNames,
289 const Oid *collationIds,
290 const Oid *opclassIds)
317 for (
i = 0;
i < numatts;
i++)
328 to->attstattarget = -1;
329 to->attcacheoff = -1;
330 to->attislocal =
true;
331 to->attcollation = (
i < numkeyatts) ? collationIds[
i] :
InvalidOid;
336 if (colnames_item == NULL)
337 elog(
ERROR,
"too few entries in colnames list");
339 colnames_item =
lnext(indexColNames, colnames_item);
354 elog(
ERROR,
"invalid column number %d", atnum);
358 to->atttypid = from->atttypid;
359 to->attlen = from->attlen;
360 to->attndims = from->attndims;
361 to->atttypmod = from->atttypmod;
362 to->attbyval = from->attbyval;
363 to->attalign = from->attalign;
364 to->attstorage = from->attstorage;
365 to->attcompression = from->attcompression;
372 if (indexpr_item == NULL)
373 elog(
ERROR,
"too few entries in indexprs list");
383 elog(
ERROR,
"cache lookup failed for type %u", keyType);
389 to->atttypid = keyType;
390 to->attlen = typeTup->typlen;
392 to->attbyval = typeTup->typbyval;
393 to->attalign = typeTup->typalign;
394 to->attstorage = typeTup->typstorage;
417 to->atttypid, to->attcollation,
435 if (i < indexInfo->ii_NumIndexKeyAttrs)
439 elog(
ERROR,
"cache lookup failed for opclass %u", opclassIds[
i]);
442 keyType = opclassTup->opckeytype;
453 if (keyType == ANYELEMENTOID && opclassTup->opcintype == ANYARRAYOID)
457 elog(
ERROR,
"could not get element type of array type %u",
468 if (
OidIsValid(keyType) && keyType != to->atttypid)
472 elog(
ERROR,
"cache lookup failed for type %u", keyType);
475 to->atttypid = keyType;
477 to->attlen = typeTup->typlen;
478 to->attbyval = typeTup->typbyval;
479 to->attalign = typeTup->typalign;
480 to->attstorage = typeTup->typstorage;
507 for (
i = 0;
i < numatts;
i += 1)
552 const Oid *collationOids,
553 const Oid *opclassOids,
554 const int16 *coloptions,
568 bool nulls[Natts_pg_index] = {0};
596 exprsDatum = (
Datum) 0;
611 predDatum = (
Datum) 0;
641 values[Anum_pg_index_indexprs - 1] = exprsDatum;
642 if (exprsDatum == (
Datum) 0)
643 nulls[Anum_pg_index_indexprs - 1] =
true;
644 values[Anum_pg_index_indpred - 1] = predDatum;
645 if (predDatum == (
Datum) 0)
646 nulls[Anum_pg_index_indpred - 1] =
true;
712 const char *indexRelationName,
714 Oid parentIndexRelid,
715 Oid parentConstraintId,
718 const List *indexColNames,
721 const Oid *collationIds,
722 const Oid *opclassIds,
723 const Datum *opclassOptions,
724 const int16 *coloptions,
728 bool allow_system_table_mods,
736 bool shared_relation;
737 bool mapped_relation;
752 Assert((constr_flags == 0) ||
757 relkind = partitioned ? RELKIND_PARTITIONED_INDEX : RELKIND_INDEX;
769 shared_relation = heapRelation->
rd_rel->relisshared;
771 relpersistence = heapRelation->
rd_rel->relpersistence;
777 elog(
ERROR,
"must index at least one column");
779 if (!allow_system_table_mods &&
783 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
784 errmsg(
"user-defined indexes on system catalog tables are not supported")));
807 Oid collation = collationIds[
i];
808 Oid opclass = opclassIds[
i];
812 if ((opclass == TEXT_BTREE_PATTERN_OPS_OID ||
813 opclass == VARCHAR_BTREE_PATTERN_OPS_OID ||
814 opclass == BPCHAR_BTREE_PATTERN_OPS_OID) &&
821 elog(
ERROR,
"cache lookup failed for operator class %u", opclass);
823 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
824 errmsg(
"nondeterministic collations are not supported for operator class \"%s\"",
838 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
839 errmsg(
"concurrent index creation on system catalog tables is not supported")));
845 if (concurrent && is_exclusion)
847 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
848 errmsg(
"concurrent index creation for exclusion constraints is not supported")));
856 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
857 errmsg(
"shared indexes cannot be created after initdb")));
862 if (shared_relation && tableSpaceId != GLOBALTABLESPACE_OID)
863 elog(
ERROR,
"shared relations must be placed in pg_global tablespace");
876 (
errcode(ERRCODE_DUPLICATE_TABLE),
877 errmsg(
"relation \"%s\" already exists, skipping",
878 indexRelationName)));
884 (
errcode(ERRCODE_DUPLICATE_TABLE),
885 errmsg(
"relation \"%s\" already exists",
886 indexRelationName)));
899 errmsg(
"constraint \"%s\" for relation \"%s\" already exists",
926 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
927 errmsg(
"pg_class index OID value not set when in binary upgrade mode")));
933 if ((relkind == RELKIND_INDEX) &&
936 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
937 errmsg(
"index relfilenumber value not set when in binary upgrade mode")));
971 allow_system_table_mods,
993 indexRelation->
rd_rel->relowner = heapRelation->
rd_rel->relowner;
994 indexRelation->
rd_rel->relam = accessMethodId;
1031 collationIds, opclassIds, coloptions,
1032 isprimary, is_exclusion,
1074 char constraintType;
1078 constraintType = CONSTRAINT_PRIMARY;
1080 constraintType = CONSTRAINT_UNIQUE;
1081 else if (is_exclusion)
1082 constraintType = CONSTRAINT_EXCLUSION;
1085 elog(
ERROR,
"constraint must be PRIMARY, UNIQUE or EXCLUDE");
1096 allow_system_table_mods,
1099 *constraintId = localaddr.
objectId;
1103 bool have_simple_col =
false;
1116 have_simple_col =
true;
1126 if (!have_simple_col)
1160 if (
OidIsValid(collationIds[
i]) && collationIds[
i] != DEFAULT_COLLATION_OID)
1205 indexRelationId, 0, is_internal);
1261 index_build(heapRelation, indexRelation, indexInfo,
false,
true);
1270 return indexRelationId;
1284 Oid tablespaceOid,
const char *newName)
1292 Datum indclassDatum,
1295 Datum *opclassOptions;
1314 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1315 errmsg(
"concurrent index creation for exclusion constraints is not supported")));
1320 elog(
ERROR,
"cache lookup failed for index %u", oldIndexId);
1322 Anum_pg_index_indclass);
1326 Anum_pg_index_indoption);
1332 elog(
ERROR,
"cache lookup failed for relation %u", oldIndexId);
1334 Anum_pg_class_reloptions, &isnull);
1347 Anum_pg_index_indexprs);
1358 Anum_pg_index_indpred);
1417 indexRelation->
rd_rel->relam,
1449 Oid indexRelationId)
1453 int save_sec_context;
1487 index_build(heapRel, indexRelation, indexInfo,
false,
true);
1531 Oid indexConstraintOid;
1547 elog(
ERROR,
"could not find tuple for relation %u", oldIndexId);
1551 elog(
ERROR,
"could not find tuple for relation %u", newIndexId);
1561 isPartition = newClassForm->relispartition;
1562 newClassForm->relispartition = oldClassForm->relispartition;
1563 oldClassForm->relispartition = isPartition;
1577 elog(
ERROR,
"could not find tuple for relation %u", oldIndexId);
1581 elog(
ERROR,
"could not find tuple for relation %u", newIndexId);
1590 newIndexForm->indisprimary = oldIndexForm->indisprimary;
1591 oldIndexForm->indisprimary =
false;
1592 newIndexForm->indisexclusion = oldIndexForm->indisexclusion;
1593 oldIndexForm->indisexclusion =
false;
1594 newIndexForm->indimmediate = oldIndexForm->indimmediate;
1595 oldIndexForm->indimmediate =
true;
1598 newIndexForm->indisreplident = oldIndexForm->indisreplident;
1601 newIndexForm->indisclustered = oldIndexForm->indisclustered;
1607 newIndexForm->indisvalid =
true;
1608 oldIndexForm->indisvalid =
false;
1609 oldIndexForm->indisclustered =
false;
1610 oldIndexForm->indisreplident =
false;
1627 constraintOids =
lappend_oid(constraintOids, indexConstraintOid);
1632 foreach(lc, constraintOids)
1645 elog(
ERROR,
"could not find tuple for constraint %u", constraintOid);
1649 if (conForm->conindid == oldIndexId)
1651 conForm->conindid = newIndexId;
1660 Anum_pg_trigger_tgconstraint,
1671 if (tgForm->tgconstrindid != oldIndexId)
1678 tgForm->tgconstrindid = newIndexId;
1697 bool nulls[Natts_pg_description] = {0};
1698 bool replaces[Natts_pg_description] = {0};
1701 replaces[Anum_pg_description_objoid - 1] =
true;
1704 Anum_pg_description_objoid,
1708 Anum_pg_description_classoid,
1712 Anum_pg_description_objsubid,
1724 values, nulls, replaces);
1774 Anum_pg_attribute_attrelid,
1778 true, NULL, 1,
key);
1783 Datum repl_val[Natts_pg_attribute];
1784 bool repl_null[Natts_pg_attribute];
1785 bool repl_repl[Natts_pg_attribute];
1790 if (att->attisdropped)
1799 if (attstattarget == att->attstattarget)
1802 memset(repl_val, 0,
sizeof(repl_val));
1803 memset(repl_null,
false,
sizeof(repl_null));
1804 memset(repl_repl,
false,
sizeof(repl_repl));
1806 repl_repl[Anum_pg_attribute_attstattarget - 1] =
true;
1807 repl_val[Anum_pg_attribute_attstattarget - 1] =
Int16GetDatum(attstattarget);
1811 repl_val, repl_null, repl_repl);
1903 Oid indexRelationId,
1904 Oid parentConstraintId,
1906 const char *constraintName,
1907 char constraintType,
1909 bool allow_system_table_mods,
1918 bool mark_as_primary;
1931 if (!allow_system_table_mods &&
1935 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1936 errmsg(
"user-defined indexes on system catalog tables are not supported")));
1940 constraintType != CONSTRAINT_EXCLUSION)
1941 elog(
ERROR,
"constraints cannot have index expressions");
2040 trigger->
trigname = (constraintType == CONSTRAINT_PRIMARY) ?
2041 "PK_ConstraintTrigger" :
2042 "Unique_ConstraintTrigger";
2046 trigger->
row =
true;
2047 trigger->
timing = TRIGGER_TYPE_AFTER;
2048 trigger->
events = TRIGGER_TYPE_INSERT | TRIGGER_TYPE_UPDATE;
2070 (mark_as_primary || deferrable))
2076 bool marked_as_primary =
false;
2083 elog(
ERROR,
"cache lookup failed for index %u", indexRelationId);
2086 if (mark_as_primary && !indexForm->indisprimary)
2088 indexForm->indisprimary =
true;
2090 marked_as_primary =
true;
2093 if (deferrable && indexForm->indimmediate)
2095 indexForm->indimmediate =
false;
2109 if (marked_as_primary)
2155 (!concurrent && !concurrent_lock_mode));
2177 userHeapRelation =
table_open(heapId, lockmode);
2178 userIndexRelation =
index_open(indexId, lockmode);
2234 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2235 errmsg(
"DROP INDEX CONCURRENTLY must be first action in transaction")));
2330 if (RELKIND_HAS_STORAGE(userIndexRelation->
rd_rel->relkind))
2352 elog(
ERROR,
"cache lookup failed for index %u", indexId);
2433 numAtts = indexStruct->indnatts;
2435 elog(
ERROR,
"invalid indnatts %d for index %u",
2443 indexStruct->indnkeyatts,
2444 index->rd_rel->relam,
2447 indexStruct->indisunique,
2448 indexStruct->indnullsnotdistinct,
2449 indexStruct->indisready,
2451 index->rd_indam->amsummarizing);
2454 for (
i = 0;
i < numAtts;
i++)
2458 if (indexStruct->indisexclusion)
2492 numAtts = indexStruct->indnatts;
2494 elog(
ERROR,
"invalid indnatts %d for index %u",
2502 indexStruct->indnkeyatts,
2503 index->rd_rel->relam,
2506 indexStruct->indisunique,
2507 indexStruct->indnullsnotdistinct,
2508 indexStruct->indisready,
2510 index->rd_indam->amsummarizing);
2513 for (
i = 0;
i < numAtts;
i++)
2533 const Oid *collations1,
const Oid *collations2,
2534 const Oid *opfamilies1,
const Oid *opfamilies2,
2587 if (collations1[
i] != collations2[
i])
2589 if (opfamilies1[
i] != opfamilies2[
i])
2601 bool found_whole_row;
2607 if (found_whole_row)
2625 bool found_whole_row;
2631 if (found_whole_row)
2675 if (
index->rd_rel->relam != BTREE_AM_OID)
2676 elog(
ERROR,
"unexpected non-btree speculative unique index");
2687 for (
i = 0;
i < indnkeyatts;
i++)
2696 elog(
ERROR,
"missing operator %d(%u,%u) in opfamily %u",
2751 else if (keycol != 0)
2764 if (indexpr_item == NULL)
2765 elog(
ERROR,
"wrong number of index expressions");
2775 if (indexpr_item != NULL)
2776 elog(
ERROR,
"wrong number of index expressions");
2871 elog(
ERROR,
"could not find tuple for relation %u", relid);
2875 Assert(rd_rel->relkind != RELKIND_PARTITIONED_INDEX);
2883 if (reltuples == 0 && rd_rel->reltuples < 0)
2889 if (rd_rel->relhasindex != hasindex)
2891 rd_rel->relhasindex = hasindex;
2900 if (rd_rel->relkind != RELKIND_INDEX)
2905 if (rd_rel->relpages != (
int32) relpages)
2907 rd_rel->relpages = (
int32) relpages;
2910 if (rd_rel->reltuples != (
float4) reltuples)
2912 rd_rel->reltuples = (
float4) reltuples;
2915 if (rd_rel->relallvisible != (
int32) relallvisible)
2917 rd_rel->relallvisible = (
int32) relallvisible;
2967 int save_sec_context;
2985 indexRelation->
rd_rel->relam == BTREE_AM_OID)
2997 (
errmsg_internal(
"building index \"%s\" on table \"%s\" with request for %d parallel workers",
3014 const int progress_index[] = {
3022 const int64 progress_vals[] = {
3045 if (indexRelation->
rd_rel->relpersistence == RELPERSISTENCE_UNLOGGED &&
3095 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3099 Assert(!indexForm->indcheckxmin);
3101 indexForm->indcheckxmin =
true;
3204 if (predicate != NULL)
3206 if (!
ExecQual(predicate, econtext))
3223 indexRelation, indexInfo,
3315 int save_sec_context;
3319 const int progress_index[] = {
3326 const int64 progress_vals[] = {
3362 ivinfo.
index = indexRelation;
3363 ivinfo.
heaprel = heapRelation;
3389 const int progress_index[] = {
3394 const int64 progress_vals[] = {
3418 "validate_index found %.0f heap tuples, %.0f index tuples; inserted %.0f missing tuples",
3468 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3476 Assert(indexForm->indislive);
3477 Assert(!indexForm->indisready);
3478 Assert(!indexForm->indisvalid);
3479 indexForm->indisready =
true;
3483 Assert(indexForm->indislive);
3484 Assert(indexForm->indisready);
3485 Assert(!indexForm->indisvalid);
3486 indexForm->indisvalid =
true;
3503 indexForm->indisvalid =
false;
3504 indexForm->indisclustered =
false;
3505 indexForm->indisreplident =
false;
3516 Assert(!indexForm->indisvalid);
3517 Assert(!indexForm->indisclustered);
3518 Assert(!indexForm->indisreplident);
3519 indexForm->indisready =
false;
3520 indexForm->indislive =
false;
3547 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3552 result =
index->indrelid;
3568 int save_sec_context;
3571 volatile bool skipped_constraint =
false;
3574 bool set_tablespace =
false;
3609 const int progress_cols[] = {
3613 const int64 progress_vals[] = {
3637 if (iRel->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX)
3638 elog(
ERROR,
"cannot reindex partitioned index \"%s.%s\"",
3648 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3649 errmsg(
"cannot reindex temporary tables of other sessions")));
3659 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3660 errmsg(
"cannot reindex invalid index on TOAST table")));
3675 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3676 errmsg(
"cannot move system relation \"%s\"",
3682 set_tablespace =
true;
3716 if (skip_constraint_checks)
3719 skipped_constraint =
true;
3734 index_build(heapRelation, iRel, indexInfo,
true,
true);
3767 if (!skipped_constraint)
3779 elog(
ERROR,
"cache lookup failed for index %u", indexId);
3782 index_bad = (!indexForm->indisvalid ||
3783 !indexForm->indisready ||
3784 !indexForm->indislive);
3789 indexForm->indcheckxmin =
false;
3791 indexForm->indcheckxmin =
true;
3792 indexForm->indisvalid =
true;
3793 indexForm->indisready =
true;
3794 indexForm->indislive =
true;
3813 (
errmsg(
"index \"%s\" was reindexed",
3896 if (rel->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
3897 elog(
ERROR,
"cannot reindex partitioned table \"%s.%s\"",
3901 toast_relid = rel->
rd_rel->reltoastrelid;
3927 persistence = RELPERSISTENCE_UNLOGGED;
3929 persistence = RELPERSISTENCE_PERMANENT;
3931 persistence = rel->
rd_rel->relpersistence;
3935 foreach(indexId, indexIds)
3949 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3950 errmsg(
"cannot reindex invalid index \"%s.%s\" on TOAST table, skipping",
3957 persistence, params);
3975 result = (indexIds !=
NIL);
4058 elog(
ERROR,
"cannot reindex while reindexing");
4090 elog(
ERROR,
"cannot reindex while reindexing");
4092 elog(
ERROR,
"cannot modify reindex state during a parallel operation");
4105 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)
elog(ERROR, "%s: %s", p2, msg)
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)
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)
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 AtEOXact_GUC(bool isCommit, int nestLevel)
void DeleteRelationTuple(Oid relid)
void DeleteAttributeTuples(Oid relid)
void RemoveStatistics(Oid relid, AttrNumber attnum)
void InsertPgAttributeTuples(Relation pg_attribute_rel, TupleDesc tupdesc, Oid new_rel_oid, const Datum *attoptions, CatalogIndexState indstate)
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)
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)
static Oid currentlyReindexedHeap
static void ResetReindexProcessing(void)
void index_concurrently_swap(Oid newIndexId, Oid oldIndexId, const char *oldName)
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, Datum reloptions, bits16 flags, bits16 constr_flags, bool allow_system_table_mods, bool is_internal, Oid *constraintId)
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(Oid relid, int flags, const ReindexParams *params)
static void AppendAttributeTuples(Relation indexRelation, const Datum *attopts)
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
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)
void reindex_index(Oid indexId, bool skip_constraint_checks, char persistence, const ReindexParams *params)
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)
#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
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)
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)
int get_attstattarget(Oid relid, AttrNumber attnum)
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)
#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 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)