本节介绍heap_insert函数的代码流程

本节前置

toast机制：https://www.postgresql.org/docs/12/storage-toast.html

可见性映射表：https://www.postgresql.org/docs/12/storage-vm.html

事务一致性检查：https://www.postgresql.org/docs/12/transaction-iso.html

WAL机制：https://www.postgresql.org/docs/12/wal-intro.html

相关数据结构

void
heap_insert(Relation relation, HeapTuple tup, CommandId cid,
			int options, BulkInsertState bistate);

heap_insert函数

//class="lazy" data-src/backend/access/heap/heapam.c


heaptup = heap_prepare_insert(relation, tup, xid, cid, options);


buffer = RelationGetBufferForTuple(relation, heaptup->t_len,
								   InvalidBuffer, options, bistate, 
								   &vmbuffer, NULL);


CheckForSerializableConflictIn(relation, NULL, InvalidBuffer);


START_CRIT_SECTION();


RelationPutHeapTuple(relation, buffer, heaptup,
					 (options & HEAP_INSERT_SPECULATIVE) != 0);


if (PageIsAllVisible(BufferGetPage(buffer)))
{
	all_visible_cleared = true;
	PageClearAllVisible(BufferGetPage(buffer));
	visibilitymap_clear(relation,
						ItemPointerGetBlockNumber(&(heaptup->t_self)),
						vmbuffer, VISIBILITYMAP_VALID_BITS);
}


MarkBufferDirty(buffer);


if (!(options & HEAP_INSERT_SKIP_WAL) && RelationNeedsWAL(relation))
{
	
	if (RelationIsAccessibleInLogicalDecoding(relation))
		log_heap_new_cid(relation, heaptup);
	
	
	if (ItemPointerGetOffsetNumber(&(heaptup->t_self)) == FirstOffsetNumber &&
		PageGetMaxOffsetNumber(page) == FirstOffsetNumber)
	{
		info |= XLOG_HEAP_INIT_PAGE;
		bufflags |= REGBUF_WILL_INIT;
	}
	
	
	XLogBeginInsert();
	XLogRegisterData((char *) &xlrec, SizeOfHeapInsert);
	
	
	XLogRegisterBuffer(0, buffer, REGBUF_STANDARD | bufflags);
	XLogRegisterBufData(0, (char *) &xlhdr, SizeOfHeapHeader);
	XLogRegisterBufData(0,
						(char *) heaptup->t_data + SizeofHeapTupleHeader,
						heaptup->t_len - SizeofHeapTupleHeader);
	
	
	XLogSetRecordFlags(XLOG_INCLUDE_ORIGIN);
	
	
	recptr = XLogInsert(RM_HEAP_ID, info);
	
	
	PageSetLSN(page, recptr);
}


END_CRIT_SECTION();


UnlockReleaseBuffer(buffer);
if (vmbuffer != InvalidBuffer)
	ReleaseBuffer(vmbuffer);


CacheInvalidateHeapTuple(relation, heaptup, NULL);


pgstat_count_heap_insert(relation, 1);


if (heaptup != tup)
{
	tup->t_self = heaptup->t_self;
	heap_freetuple(heaptup);
}