PostgreSQL源码学习（3）插入数据#1

  • Z时代
  • 2024-01-10
  • 分类：综合

database

相关数据结构

//src/interfaces/ecpg/preproc/type.h
/* 值为0时为非法，值为正数时表示共享缓冲区的索引，
    值为负数时表示本地缓冲区的索引 */
typedef int Buffer;

HeapTupleData的结构已在前面有过了解PostgreSQL源码学习（1）Page页。这里看一下其中的t_ctid（ItemPointerData结构体）。

//src/include/storage/itemptr.h
typedef struct ItemPointerData
{
	BlockIdData ip_blkid;	/* 数据块ID */
	OffsetNumber ip_posid;	/* 对应行指针在ItemIdData数组中的偏移 */
}

虽然在参数中传入了RelationData结构指针，但是函数内暂时还没用到，放到后面用到时再看。

void
RelationPutHeapTuple(Relation relation,
					 Buffer buffer,
					 HeapTuple tuple,
					 bool token);

RelationPutHeapTuple函数

//src/backend/access/heap/hio.c
/* 若token为真，表示设置了HEAP_INSERT_SPECULATIVE选项，
    这种情况下此行数据的ip_posid应该为SpecTokenOffsetNumber */
Assert(!token || HeapTupleHeaderIsSpeculative(tuple->t_data));
/* 从缓冲区中获取Page，将行数据写入page（上节讲过） */
pageHeader = BufferGetPage(buffer);
offnum = PageAddItem(pageHeader, (Item) tuple->t_data,
						 tuple->t_len, InvalidOffsetNumber, false, true);
/* 判断是否成功插入数据 */
if (offnum == InvalidOffsetNumber)
		elog(PANIC, "failed to add tuple to page");
/* 更新HeapTuple中行指针的位置t_self（ip_blkid和ip_posid）的值*/
ItemPointerSet(&(tuple->t_self), BufferGetBlockNumber(buffer), offnum);
/* 若token为真（设置了HEAP_INSERT_SPECULATIVE），流程结束，
    行数据的ip_posid仍然为SpecTokenOffsetNumber，
    若token为假，更新行数据中t_ctid的值与t_self一致 */
if (!token)
{
	ItemId		itemId = PageGetItemId(pageHeader, offnum);
	HeapTupleHeader item = (HeapTupleHeader) PageGetItem(pageHeader, itemId);
	item->t_ctid = tuple->t_self;
}

以上是 PostgreSQL源码学习（3）插入数据#1 的全部内容， 来源链接： utcz.com/z/533076.html

回到顶部