#include "postgres.h"
#include "access/genam.h"
#include "access/heapam.h"
#include "access/htup_details.h"
#include "catalog/index.h"
#include "catalog/indexing.h"
#include "executor/executor.h"
#include "utils/rel.h"

Include dependency graph for indexing.c:

Functions
CatalogIndexState	CatalogOpenIndexes (Relation heapRel)

void	CatalogCloseIndexes (CatalogIndexState indstate)

static void	CatalogIndexInsert (CatalogIndexState indstate, HeapTuple heapTuple)

void	CatalogTupleInsert (Relation heapRel, HeapTuple tup)

void	CatalogTupleInsertWithInfo (Relation heapRel, HeapTuple tup, CatalogIndexState indstate)

void	CatalogTupleUpdate (Relation heapRel, ItemPointer otid, HeapTuple tup)

void	CatalogTupleUpdateWithInfo (Relation heapRel, ItemPointer otid, HeapTuple tup, CatalogIndexState indstate)

void	CatalogTupleDelete (Relation heapRel, ItemPointer tid)

Function Documentation

◆ CatalogCloseIndexes()

void CatalogCloseIndexes ( CatalogIndexState indstate )

Definition at line 60 of file indexing.c.

References ExecCloseIndices(), and pfree().

Referenced by AddNewAttributeTuples(), AppendAttributeTuples(), CatalogTupleInsert(), CatalogTupleUpdate(), copyTemplateDependencies(), inv_truncate(), inv_write(), recordMultipleDependencies(), and swap_relation_files().

 {
     ExecCloseIndices(indstate);
     pfree(indstate);
 }

◆ CatalogIndexInsert()

static void CatalogIndexInsert	(	CatalogIndexState	indstate,
		HeapTuple	heapTuple
	)

static

Definition at line 74 of file indexing.c.

References Assert, ExecDropSingleTupleTableSlot(), ExecStoreHeapTuple(), FormIndexDatum(), HeapTupleIsHeapOnly, i, IndexInfo::ii_ExclusionOps, IndexInfo::ii_Expressions, IndexInfo::ii_NumIndexKeyAttrs, IndexInfo::ii_Predicate, IndexInfo::ii_ReadyForInserts, index_insert(), INDEX_MAX_KEYS, MakeSingleTupleTableSlot(), NIL, RelationData::rd_index, ReindexIsProcessingIndex(), RelationGetDescr, RelationGetRelid, ResultRelInfo::ri_IndexRelationDescs, ResultRelInfo::ri_IndexRelationInfo, ResultRelInfo::ri_NumIndices, ResultRelInfo::ri_RelationDesc, HeapTupleData::t_self, TTSOpsHeapTuple, UNIQUE_CHECK_NO, UNIQUE_CHECK_YES, and values.

Referenced by CatalogTupleInsert(), CatalogTupleInsertWithInfo(), CatalogTupleUpdate(), and CatalogTupleUpdateWithInfo().

 {
     int         i;
     int         numIndexes;
     RelationPtr relationDescs;
     Relation    heapRelation;
     TupleTableSlot *slot;
     IndexInfo **indexInfoArray;
     Datum       values[INDEX_MAX_KEYS];
     bool        isnull[INDEX_MAX_KEYS];
 
     /*
      * HOT update does not require index inserts. But with asserts enabled we
      * want to check that it'd be legal to currently insert into the
      * table/index.
      */
 #ifndef USE_ASSERT_CHECKING
     if (HeapTupleIsHeapOnly(heapTuple))
         return;
 #endif
 
     /*
      * Get information from the state structure.  Fall out if nothing to do.
      */
     numIndexes = indstate->ri_NumIndices;
     if (numIndexes == 0)
         return;
     relationDescs = indstate->ri_IndexRelationDescs;
     indexInfoArray = indstate->ri_IndexRelationInfo;
     heapRelation = indstate->ri_RelationDesc;
 
     /* Need a slot to hold the tuple being examined */
     slot = MakeSingleTupleTableSlot(RelationGetDescr(heapRelation),
                                     &TTSOpsHeapTuple);
     ExecStoreHeapTuple(heapTuple, slot, false);
 
     /*
      * for each index, form and insert the index tuple
      */
     for (i = 0; i < numIndexes; i++)
     {
         IndexInfo  *indexInfo;
         Relation    index;
 
         indexInfo = indexInfoArray[i];
         index = relationDescs[i];
 
         /* If the index is marked as read-only, ignore it */
         if (!indexInfo->ii_ReadyForInserts)
             continue;
 
         /*
          * Expressional and partial indexes on system catalogs are not
          * supported, nor exclusion constraints, nor deferred uniqueness
          */
         Assert(indexInfo->ii_Expressions == NIL);
         Assert(indexInfo->ii_Predicate == NIL);
         Assert(indexInfo->ii_ExclusionOps == NULL);
         Assert(index->rd_index->indimmediate);
         Assert(indexInfo->ii_NumIndexKeyAttrs != 0);
 
         /* see earlier check above */
 #ifdef USE_ASSERT_CHECKING
         if (HeapTupleIsHeapOnly(heapTuple))
         {
             Assert(!ReindexIsProcessingIndex(RelationGetRelid(index)));
             continue;
         }
 #endif                          /* USE_ASSERT_CHECKING */
 
         /*
          * FormIndexDatum fills in its values and isnull parameters with the
          * appropriate values for the column(s) of the index.
          */
         FormIndexDatum(indexInfo,
                        slot,
                        NULL,    /* no expression eval to do */
                        values,
                        isnull);
 
         /*
          * The index AM does the rest.
          */
         index_insert(index,     /* index relation */
                      values,    /* array of index Datums */
                      isnull,    /* is-null flags */
                      &(heapTuple->t_self),  /* tid of heap tuple */
                      heapRelation,
                      index->rd_index->indisunique ?
                      UNIQUE_CHECK_YES : UNIQUE_CHECK_NO,
                      indexInfo);
     }
 
     ExecDropSingleTupleTableSlot(slot);
 }

◆ CatalogOpenIndexes()

CatalogIndexState CatalogOpenIndexes ( Relation heapRel )

Definition at line 42 of file indexing.c.

References ExecOpenIndices(), makeNode, ResultRelInfo::ri_RangeTableIndex, ResultRelInfo::ri_RelationDesc, and ResultRelInfo::ri_TrigDesc.

Referenced by AddNewAttributeTuples(), AppendAttributeTuples(), CatalogTupleInsert(), CatalogTupleUpdate(), copyTemplateDependencies(), inv_truncate(), inv_write(), recordMultipleDependencies(), and swap_relation_files().

 {
     ResultRelInfo *resultRelInfo;
 
     resultRelInfo = makeNode(ResultRelInfo);
     resultRelInfo->ri_RangeTableIndex = 0;  /* dummy */
     resultRelInfo->ri_RelationDesc = heapRel;
     resultRelInfo->ri_TrigDesc = NULL;  /* we don't fire triggers */
 
     ExecOpenIndices(resultRelInfo, false);
 
     return resultRelInfo;
 }

◆ CatalogTupleDelete()

void CatalogTupleDelete	(	Relation	heapRel,
		ItemPointer	tid
	)

Definition at line 269 of file indexing.c.

References simple_heap_delete().

Referenced by AlterSetting(), ATExecAlterColumnType(), ATExecDropExpression(), changeDependenciesOn(), changeDependencyFor(), CreateComments(), CreateSharedComments(), DeleteAttributeTuples(), DeleteComments(), deleteDependencyRecordsFor(), deleteDependencyRecordsForClass(), DeleteInheritsTuple(), DeleteInitPrivs(), deleteOneObject(), DeleteRelationTuple(), DeleteSecurityLabel(), DeleteSequenceTuple(), DeleteSharedComments(), DeleteSharedSecurityLabel(), DeleteSystemAttributeTuples(), DelRoleMems(), drop_parent_dependency(), DropCastById(), DropConfigurationMapping(), dropDatabaseDependencies(), dropdb(), DropProceduralLanguageById(), DropRole(), DropSetting(), DropSubscription(), DropTableSpace(), DropTransformById(), EnumValuesDelete(), heap_drop_with_catalog(), index_drop(), IndexSetParentIndex(), inv_truncate(), LargeObjectDrop(), MakeConfigurationMapping(), RangeDelete(), recordExtensionInitPrivWorker(), RelationRemoveInheritance(), RemoveAccessMethodById(), RemoveAmOpEntryById(), RemoveAmProcEntryById(), RemoveAttrDefaultById(), RemoveAttributeById(), RemoveCollationById(), RemoveConstraintById(), RemoveConversionById(), RemoveDefaultACLById(), RemoveEventTriggerById(), RemoveExtensionById(), RemoveForeignDataWrapperById(), RemoveForeignServerById(), RemoveFunctionById(), RemoveOpClassById(), RemoveOperatorById(), RemoveOpFamilyById(), RemovePartitionKeyByRelId(), RemovePolicyById(), RemovePublicationById(), RemovePublicationRelById(), RemoveRewriteRuleById(), RemoveSchemaById(), RemoveStatistics(), RemoveStatisticsById(), RemoveSubscriptionRel(), RemoveTriggerById(), RemoveTSConfigurationById(), RemoveTSDictionaryById(), RemoveTSParserById(), RemoveTSTemplateById(), RemoveTypeById(), RemoveUserMappingById(), replorigin_drop(), SetSecurityLabel(), SetSharedSecurityLabel(), shdepChangeDep(), and shdepDropDependency().

 {
     simple_heap_delete(heapRel, tid);
 }

◆ CatalogTupleInsert()

void CatalogTupleInsert	(	Relation	heapRel,
		HeapTuple	tup
	)

Definition at line 183 of file indexing.c.

References CatalogCloseIndexes(), CatalogIndexInsert(), CatalogOpenIndexes(), and simple_heap_insert().

Referenced by AddEnumLabel(), AddRoleMems(), AddSubscriptionRelState(), AggregateCreate(), AlterSetting(), CollationCreate(), ConversionCreate(), create_proc_lang(), CreateAccessMethod(), CreateCast(), CreateComments(), CreateConstraintEntry(), createdb(), CreateForeignDataWrapper(), CreateForeignServer(), CreateForeignTable(), CreateOpFamily(), CreatePolicy(), CreatePublication(), CreateRole(), CreateSharedComments(), CreateStatistics(), CreateSubscription(), CreateTableSpace(), CreateTransform(), CreateTrigger(), CreateUserMapping(), DefineOpClass(), DefineSequence(), DefineTSConfiguration(), DefineTSDictionary(), DefineTSParser(), DefineTSTemplate(), EnumValuesCreate(), IndexSetParentIndex(), insert_event_trigger_tuple(), InsertExtensionTuple(), InsertPgAttributeTuple(), InsertPgClassTuple(), InsertRule(), LargeObjectCreate(), MakeConfigurationMapping(), NamespaceCreate(), OperatorCreate(), OperatorShellMake(), ProcedureCreate(), publication_add_relation(), RangeCreate(), recordExtensionInitPrivWorker(), replorigin_create(), SetDefaultACL(), SetSecurityLabel(), SetSharedSecurityLabel(), shdepAddDependency(), shdepChangeDep(), StoreAttrDefault(), storeOperators(), StorePartitionKey(), storeProcedures(), StoreSingleInheritance(), TypeCreate(), TypeShellMake(), update_attstats(), and UpdateIndexRelation().

 {
     CatalogIndexState indstate;
 
     indstate = CatalogOpenIndexes(heapRel);
 
     simple_heap_insert(heapRel, tup);
 
     CatalogIndexInsert(indstate, tup);
     CatalogCloseIndexes(indstate);
 }

◆ CatalogTupleInsertWithInfo()

void CatalogTupleInsertWithInfo	(	Relation	heapRel,
		HeapTuple	tup,
		CatalogIndexState	indstate
	)

Definition at line 204 of file indexing.c.

References CatalogIndexInsert(), and simple_heap_insert().

Referenced by copyTemplateDependencies(), InsertPgAttributeTuple(), inv_truncate(), inv_write(), and recordMultipleDependencies().

 {
     simple_heap_insert(heapRel, tup);
 
     CatalogIndexInsert(indstate, tup);
 }

◆ CatalogTupleUpdate()

void CatalogTupleUpdate	(	Relation	heapRel,
		ItemPointer	otid,
		HeapTuple	tup
	)

Definition at line 224 of file indexing.c.

References CatalogCloseIndexes(), CatalogIndexInsert(), CatalogOpenIndexes(), and simple_heap_update().

Referenced by AddRoleMems(), AggregateCreate(), AlterCollation(), AlterConstraintNamespaces(), AlterDatabase(), AlterDatabaseOwner(), AlterDomainDefault(), AlterDomainNotNull(), AlterDomainValidateConstraint(), AlterEventTrigger(), AlterEventTriggerOwner_internal(), AlterExtensionNamespace(), AlterForeignDataWrapper(), AlterForeignDataWrapperOwner_internal(), AlterForeignServer(), AlterForeignServerOwner_internal(), AlterFunction(), AlterObjectNamespace_internal(), AlterObjectOwner_internal(), AlterObjectRename_internal(), AlterOperator(), AlterPolicy(), AlterPublicationOptions(), AlterPublicationOwner_internal(), AlterRelationNamespaceInternal(), AlterRole(), AlterSchemaOwner_internal(), AlterSequence(), AlterSetting(), AlterStatistics(), AlterSubscription(), AlterSubscriptionOwner_internal(), AlterTableSpaceOptions(), AlterTSDictionary(), AlterTypeNamespaceInternal(), AlterTypeOwnerInternal(), AlterUserMapping(), ApplyExtensionUpdates(), ATExecAddColumn(), ATExecAddIdentity(), ATExecAddOf(), ATExecAlterColumnGenericOptions(), ATExecAlterColumnType(), ATExecAlterConstraint(), ATExecChangeOwner(), ATExecDetachPartition(), ATExecDisableRowSecurity(), ATExecDropColumn(), ATExecDropConstraint(), ATExecDropExpression(), ATExecDropIdentity(), ATExecDropNotNull(), ATExecDropOf(), ATExecEnableRowSecurity(), ATExecForceNoForceRowSecurity(), ATExecGenericOptions(), ATExecSetIdentity(), ATExecSetNotNull(), ATExecSetOptions(), ATExecSetRelOptions(), ATExecSetStatistics(), ATExecSetStorage(), ATExecSetTableSpace(), ATExecSetTableSpaceNoStorage(), ATExecValidateConstraint(), change_owner_fix_column_acls(), changeDependenciesOf(), changeDependenciesOn(), changeDependencyFor(), ConstraintSetParentConstraint(), copy_table_data(), create_proc_lang(), create_toast_table(), CreateComments(), CreateSharedComments(), CreateTransform(), CreateTrigger(), DefineIndex(), DefineQueryRewrite(), DelRoleMems(), EnableDisableRule(), EnableDisableTrigger(), ExecGrant_Attribute(), ExecGrant_Database(), ExecGrant_Fdw(), ExecGrant_ForeignServer(), ExecGrant_Function(), ExecGrant_Language(), ExecGrant_Largeobject(), ExecGrant_Namespace(), ExecGrant_Relation(), ExecGrant_Tablespace(), ExecGrant_Type(), extension_config_remove(), finish_heap_swap(), index_build(), index_concurrently_swap(), index_constraint_create(), InsertRule(), MakeConfigurationMapping(), mark_index_clustered(), MergeAttributesIntoExisting(), MergeConstraintsIntoExisting(), MergeWithExistingConstraint(), movedb(), OperatorCreate(), OperatorUpd(), pg_extension_config_dump(), ProcedureCreate(), recordExtensionInitPrivWorker(), reindex_index(), relation_mark_replica_identity(), RelationClearMissing(), RelationSetNewRelfilenode(), RemoveAttrDefaultById(), RemoveAttributeById(), RemoveConstraintById(), RemoveInheritance(), RemoveRoleFromObjectPolicy(), rename_policy(), renameatt_internal(), RenameConstraintById(), RenameDatabase(), RenameEnumLabel(), RenameRelationInternal(), RenameRewriteRule(), RenameRole(), RenameSchema(), RenameTableSpace(), renametrig(), RenameTypeInternal(), RenumberEnumType(), SetAttrMissing(), SetDefaultACL(), SetFunctionArgType(), SetFunctionReturnType(), SetMatViewPopulatedState(), SetRelationHasSubclass(), SetRelationNumChecks(), SetRelationRuleStatus(), SetSecurityLabel(), SetSharedSecurityLabel(), shdepChangeDep(), statext_store(), StoreAttrDefault(), StorePartitionBound(), TypeCreate(), update_attstats(), update_default_partition_oid(), update_relispartition(), UpdateStatisticsForTypeChange(), UpdateSubscriptionRelState(), and validatePartitionedIndex().

 {
     CatalogIndexState indstate;
 
     indstate = CatalogOpenIndexes(heapRel);
 
     simple_heap_update(heapRel, otid, tup);
 
     CatalogIndexInsert(indstate, tup);
     CatalogCloseIndexes(indstate);
 }

◆ CatalogTupleUpdateWithInfo()

void CatalogTupleUpdateWithInfo	(	Relation	heapRel,
		ItemPointer	otid,
		HeapTuple	tup,
		CatalogIndexState	indstate
	)

Definition at line 245 of file indexing.c.

References CatalogIndexInsert(), and simple_heap_update().

Referenced by inv_truncate(), inv_write(), and swap_relation_files().

 {
     simple_heap_update(heapRel, otid, tup);
 
     CatalogIndexInsert(indstate, tup);
 }

Functions