mirror of
https://git.postgresql.org/git/postgresql.git
synced 2026-02-16 03:17:00 +08:00
94a8b45feb
For correctness of summarization results, it is critical that the snapshot used during the summarization scan is able to see all tuples that are live to all transactions -- including tuples inserted or deleted by in-progress transactions. Otherwise, it would be possible for a transaction to insert a tuple, then idle for a long time while a concurrent transaction executes summarization of the range: this would result in the inserted value not being considered in the summary. Previously we were trying to use a MVCC snapshot in conjunction with adding a "placeholder" tuple in the index: the snapshot would see all committed tuples, and the placeholder tuple would catch insertions by any new inserters. The hole is that prior insertions by transactions that are still in progress by the time the MVCC snapshot was taken were ignored. Kevin Grittner reported this as a bogus error message during vacuum with default transaction isolation mode set to repeatable read (because the error report mentioned a function name not being invoked during), but the problem is larger than that. To fix, tweak IndexBuildHeapRangeScan to have a new mode that behaves the way we need using SnapshotAny visibility rules. This change simplifies the BRIN code a bit, mainly by removing large comments that were mistaken. Instead, rely on the SnapshotAny semantics to provide what it needs. (The business about a placeholder tuple needs to remain: that covers the case that a transaction inserts a a tuple in a page that summarization already scanned.) Discussion: https://www.postgresql.org/message-id/20150731175700.GX2441@postgresql.org In passing, remove a couple of unused declarations from brin.h and reword a comment to be proper English. This part submitted by Kevin Grittner. Backpatch to 9.5, where BRIN was introduced.
135 lines
3.6 KiB
C
135 lines
3.6 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* index.h
|
|
* prototypes for catalog/index.c.
|
|
*
|
|
*
|
|
* Portions Copyright (c) 1996-2015, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* src/include/catalog/index.h
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#ifndef INDEX_H
|
|
#define INDEX_H
|
|
|
|
#include "catalog/objectaddress.h"
|
|
#include "nodes/execnodes.h"
|
|
|
|
|
|
#define DEFAULT_INDEX_TYPE "btree"
|
|
|
|
/* Typedef for callback function for IndexBuildHeapScan */
|
|
typedef void (*IndexBuildCallback) (Relation index,
|
|
HeapTuple htup,
|
|
Datum *values,
|
|
bool *isnull,
|
|
bool tupleIsAlive,
|
|
void *state);
|
|
|
|
/* Action code for index_set_state_flags */
|
|
typedef enum
|
|
{
|
|
INDEX_CREATE_SET_READY,
|
|
INDEX_CREATE_SET_VALID,
|
|
INDEX_DROP_CLEAR_VALID,
|
|
INDEX_DROP_SET_DEAD
|
|
} IndexStateFlagsAction;
|
|
|
|
|
|
extern void index_check_primary_key(Relation heapRel,
|
|
IndexInfo *indexInfo,
|
|
bool is_alter_table);
|
|
|
|
extern Oid index_create(Relation heapRelation,
|
|
const char *indexRelationName,
|
|
Oid indexRelationId,
|
|
Oid relFileNode,
|
|
IndexInfo *indexInfo,
|
|
List *indexColNames,
|
|
Oid accessMethodObjectId,
|
|
Oid tableSpaceId,
|
|
Oid *collationObjectId,
|
|
Oid *classObjectId,
|
|
int16 *coloptions,
|
|
Datum reloptions,
|
|
bool isprimary,
|
|
bool isconstraint,
|
|
bool deferrable,
|
|
bool initdeferred,
|
|
bool allow_system_table_mods,
|
|
bool skip_build,
|
|
bool concurrent,
|
|
bool is_internal,
|
|
bool if_not_exists);
|
|
|
|
extern ObjectAddress index_constraint_create(Relation heapRelation,
|
|
Oid indexRelationId,
|
|
IndexInfo *indexInfo,
|
|
const char *constraintName,
|
|
char constraintType,
|
|
bool deferrable,
|
|
bool initdeferred,
|
|
bool mark_as_primary,
|
|
bool update_pgindex,
|
|
bool remove_old_dependencies,
|
|
bool allow_system_table_mods,
|
|
bool is_internal);
|
|
|
|
extern void index_drop(Oid indexId, bool concurrent);
|
|
|
|
extern IndexInfo *BuildIndexInfo(Relation index);
|
|
|
|
extern void BuildSpeculativeIndexInfo(Relation index, IndexInfo *ii);
|
|
|
|
extern void FormIndexDatum(IndexInfo *indexInfo,
|
|
TupleTableSlot *slot,
|
|
EState *estate,
|
|
Datum *values,
|
|
bool *isnull);
|
|
|
|
extern void index_build(Relation heapRelation,
|
|
Relation indexRelation,
|
|
IndexInfo *indexInfo,
|
|
bool isprimary,
|
|
bool isreindex);
|
|
|
|
extern double IndexBuildHeapScan(Relation heapRelation,
|
|
Relation indexRelation,
|
|
IndexInfo *indexInfo,
|
|
bool allow_sync,
|
|
IndexBuildCallback callback,
|
|
void *callback_state);
|
|
extern double IndexBuildHeapRangeScan(Relation heapRelation,
|
|
Relation indexRelation,
|
|
IndexInfo *indexInfo,
|
|
bool allow_sync,
|
|
bool anyvisible,
|
|
BlockNumber start_blockno,
|
|
BlockNumber end_blockno,
|
|
IndexBuildCallback callback,
|
|
void *callback_state);
|
|
|
|
extern void validate_index(Oid heapId, Oid indexId, Snapshot snapshot);
|
|
|
|
extern void index_set_state_flags(Oid indexId, IndexStateFlagsAction action);
|
|
|
|
extern void reindex_index(Oid indexId, bool skip_constraint_checks,
|
|
char relpersistence, int options);
|
|
|
|
/* Flag bits for reindex_relation(): */
|
|
#define REINDEX_REL_PROCESS_TOAST 0x01
|
|
#define REINDEX_REL_SUPPRESS_INDEX_USE 0x02
|
|
#define REINDEX_REL_CHECK_CONSTRAINTS 0x04
|
|
#define REINDEX_REL_FORCE_INDEXES_UNLOGGED 0x08
|
|
#define REINDEX_REL_FORCE_INDEXES_PERMANENT 0x10
|
|
|
|
extern bool reindex_relation(Oid relid, int flags, int options);
|
|
|
|
extern bool ReindexIsProcessingHeap(Oid heapOid);
|
|
extern bool ReindexIsProcessingIndex(Oid indexOid);
|
|
extern Oid IndexGetRelation(Oid indexId, bool missing_ok);
|
|
|
|
#endif /* INDEX_H */
|