大家好，我是考100分的小小码 ，祝大家学习进步，加薪顺利呀。今天说一说PostgreSQL源码学习（3）插入数据#1,希望您对编程的造诣更进一步.
相关数据结构
//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
