相关数据结构

//src/interfaces/ecpg/preproc/type.h

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

代码100分

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

代码100分//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函数

代码100分//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;
}

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至举报，一经查实，本站将立刻删除。
转载请注明出处: https://daima100.com/9082.html