前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Postgresql源码(121)事务状态中childXids的作用

Postgresql源码(121)事务状态中childXids的作用

作者头像
mingjie
发布2024-02-19 08:08:30
690
发布2024-02-19 08:08:30
举报

总结

  • PG的子事务回滚是真回滚(直接回滚了,不管顶层事务提交还是回滚)。
  • PG的子事务提交是假提交(子事务提交后会把决定权交给顶层事务,随顶层事务提交、回滚)。

子事务提交后,将xid记录到父事务的childXids,父事务的childXids就表示下面已经提交的子事务,这些子事务xid在后续mvcc计算中,会完全等效与当前的事务xid。

childXids

在Postgresql的事务状态中,存在childXids数组,本篇分析该结构的用途和原理。

代码语言:javascript
复制
typedef struct TransactionStateData
{
	...

	TransactionId *childXids;	/* subcommitted child XIDs, in XID order */
	int			nChildXids;		/* # of subcommitted child XIDs */
	int			maxChildXids;	/* allocated size of childXids[] */

	...

	struct TransactionStateData *parent;	/* back link to parent */
} TransactionStateData;

typedef TransactionStateData *TransactionState;

用途

1 读取childXids:TransactionIdIsCurrentTransactionId

判断事务ID是否为当前事务。

如果xid和当前事务的xid不同,另外会从当前事务记录的childXids中再找一遍。

  • 因为childXids里面记录了当前事务下,已经提交了的子事务(只有提交了的,没有回滚的),所以这些提交的子事务xid就等同于主事务xid。
  • childXids是有序的,二分法即可。
代码语言:javascript
复制
bool
TransactionIdIsCurrentTransactionId(TransactionId xid)
{
	...

	if (TransactionIdEquals(xid, GetTopTransactionIdIfAny()))
		return true;

	...

	for (s = CurrentTransactionState; s != NULL; s = s->parent)
	{
		...

		low = 0;
		high = s->nChildXids - 1;
		while (low <= high)
		{
			int			middle;
			TransactionId probe;

			middle = low + (high - low) / 2;
			probe = s->childXids[middle];
			if (TransactionIdEquals(probe, xid))
				return true;
			else if (TransactionIdPrecedes(probe, xid))
				low = middle + 1;
			else
				high = middle - 1;
		}
	}

	return false;
}

2 写入childXids:AtSubCommit_childXids

在子事务提交时,会执行AtSubCommit_childXids:

  1. 将本层的xid添加到上层事务的childXids中。
  2. 将本层记录的childXids传递到上层事务的childXids中。
代码语言:javascript
复制
static void
AtSubCommit_childXids(void)
{
	...

	new_nChildXids = s->parent->nChildXids + s->nChildXids + 1;
  ...

	s->parent->childXids[s->parent->nChildXids] = XidFromFullTransactionId(s->fullTransactionId);

	if (s->nChildXids > 0)
		memcpy(&s->parent->childXids[s->parent->nChildXids + 1],
			   s->childXids,
			   s->nChildXids * sizeof(TransactionId));

	s->parent->nChildXids = new_nChildXids;

	/* Release child's array to avoid leakage */
	if (s->childXids != NULL)
		pfree(s->childXids);
	/* We must reset these to avoid double-free if fail later in commit */
	s->childXids = NULL;
	s->nChildXids = 0;
	s->maxChildXids = 0;
}

PG子事务维护链式结构,当子事务提交时,需要把自己记录“commited childs”信息逐层上交。

例如三层子事务的场景下:

代码语言:javascript
复制
												childXids
top-transaction     		    []
  sub-transaction-16401     []
    sub-transaction-16402   []
      sub-transaction-16403 []        <-- will commit
代码语言:javascript
复制
														childXids
top-transaction     		    		[]
  sub-transaction-16401     		[]
    sub-transaction-16402   		[]
    														^
    														|
      sub-transaction-16403 		[]				<-- committing
代码语言:javascript
复制
														childXids
top-transaction        					[]
  sub-transaction-16401     		[]
    sub-transaction-16402   		[16403]  	<-- committed
代码语言:javascript
复制
														childXids
top-transaction        					[]
  sub-transaction-16401     		[]
    sub-transaction-16402   		[16403]  	<-- will commit
代码语言:javascript
复制
														childXids
top-transaction        					[]
  sub-transaction-16401     		[16402, 16403]  <-- committed

当前事务记录的childXids在进行mvcc判断时,完全等效于自己的xid。

3 其他

AtSubAbort_childXids:子事务回滚时,需要清理childXids。

SerializeTransactionState:序列化事务状态。

其他还有初始化、清理等,不在列举。

本文参与?腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2024-02-18,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客?前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与?腾讯云自媒体分享计划? ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 总结
  • childXids
  • 用途
    • 1 读取childXids:TransactionIdIsCurrentTransactionId
      • 2 写入childXids:AtSubCommit_childXids
        • 3 其他
        领券
        问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
        http://www.vxiaotou.com