postgresql技术大讲堂 -凯发app官方网站

postgresql从小白到专家，是从入门逐渐能力提升的一个系列教程，内容包括对pg基础的认知、包括安装使用、包括角色权限、包括维护管理、、等内容，希望对热爱pg、学习pg的同学们有帮助，欢迎持续关注cuug pg技术大讲堂。

第21讲：行可见性规则

内容1：postgresql事务id介绍

内容2：postgresql dml操作原理

内容3：事务快照在可见性规则中的作用

内容4：t_xmin状态对于可见性规则判断的重要度

内容5：常见的行可见性规则的介绍

内容6：实现闪回功能

txid介绍

· 事务id(txid)

当一个事务开始时，postgresql中的事务管理系统会为该事务分配一个唯一标识符,即事务id(txid).postgresql中的txid被定义为一个32位的无符号整数，也就是说，它能记录大约42亿个事务。通常txid对我们是透明的，但是我们可以利用postgresql内部的函数来获取当前事务的txid。

事务id用来标识一个事务的先后顺序，该顺序决定了锁申请的优先权，已经访问一张表时对行的可见性规则判断。

testdb=# select txid_current();

txid_current

--------------

100

(1 row)

tuples structure

· 元组(行)结构

t_xmin保存插入此元组的事务的txid，它的状态是行可见性判断关键的依据。

t_xmax保存删除或更新此元组的事务的txid。如果此元组未被删除或更新，则t_xmax设置为0，这意味着无效，它的状态也是行可见性判断关键的依据。

dml操作原理

· insertion

· deletion

· update

执行{banned}中国第一个更新命令时，通过将txid 100设置为t_xmax，逻辑上删除tuple_1，然后插入tuple_2。然后，将元组1的t_ctid重写为指向元组2。

当执行第二个update命令时，与{banned}中国第一个update命令一样，tuple_2在逻辑上被删除，tuple_3被插入。

事务状态

· 四种事务状态

in_progress

committed

aborted

sub_committed

commit log

· 事务状态记录方式

事务快照

· 事务快照概述

事务快照是一个数据集，用于存储有关单个事务在某个时间点上是否所有事务都处于活动状态的信息。在这里，活动事务表示它正在进行或尚未启动。txid_current_snapshot的文本表示为“xmin:xmax:xip_list”，组件描述如下：

xmin：{banned}最佳早仍在活动的txid。所有以前的事务要么提交并可见，要么回滚并停止。

xmax：{banned}中国第一个尚未分配的txid。截至快照时，所有大于或等于此值的txid尚未启动，此不可见。

xip_list：快照时的活动txid。该列表仅包含xmin和xmax之间的活动txid。

testdb=# select txid_current_snapshot();

txid_current_snapshot

-----------------------

100:104:100,102

(1 row)

例如，在快照'100:104:100,102'中，xmin是'100'，xmax是'104'，xip_list是'100,102'。

可见性规则世界观

· 事务快照在可见性规则中的意义

富有哲理性的判断规则：过去发生过的为可见，将来未发生的为不可见。

行可见性判断重要因素

· 可见性判断的重要因素

可见性检查规则是一组规则，关键的判断因素有：t_xmin、t_xmax、clog和获取的事务快照确定每个元组是否可见。

t_xmin的三种状态aborted、in_progress、committed是判断的{banned}中国第一前提条件。

aborted状态

· t_xmin =aborted

t_xmin =aborted，则判断此行不可见

/* t_xmin status = aborted */

rule 1: if t_xmin status is 'aborted' then

return 'invisible'

end if

in_progress状态

· t_xmin=in_progress

t_xmin=in_progress，当前事务可见，其它事务不可见

/* t_xmin status = in_progress */

if t_xmin status is 'in_progress' then

if t_xmin = current_txid then

rule 2: if t_xmax = invalid then

return 'visible'

rule 3: else /* this tuple has been deleted or updated by the current transaction itself. */

return 'invisible'

end if

rule 4: else /* t_xmin ≠ current_txid */

return 'invisible'

end if

end if

committed状态

· t_xmin=committed

t_xmin=committed，此状态判断时还得看t_xmax的值，如果t_xmax的值为0，则此行可见;如果不为0，那么判断时还得看t_xmax的状态是当前事务还是非当前事务，判断规则就比较复杂。

/* t_xmin status = committed */

if t_xmin status is 'committed' then

rule 5: if t_xmin is active in the obtained transaction snapshot then

return 'invisible'

rule 6: else if t_xmax = invalid or status of t_xmax is 'aborted' then

return 'visible'

else if t_xmax status is 'in_progress' then

rule 7: if t_xmax = current_txid then

return 'invisible'

rule 8: else /* t_xmax ≠ current_txid */

return 'visible'

end if

else if t_xmax status is 'committed' then

rule 9: if t_xmax is active in the obtained transaction snapshot then

return 'visible'

rule 10: else

return 'invisible'

end if

end if

end if

可见性判断概述

· 可见性判断示例

r6判断规则

· t3 时根据规则6进行判断

rule6(tuple_1)?status(t_xmin:199) = committed ∧ t_xmax = invalid ?visible

t_xmin=commit，并且t_xman=0，该行对于所有的事务均可见

r7与r2判断规则

· t5时事务id为200的根据规则7、2进行判断

rule7(tuple_1): status(t_xmin:199) = committed ∧ status(t_xmax:200) = in_progress ∧ t_xmax:200 = current_txid:200 ? invisible

rule2(tuple_2): status(t_xmin:200) = in_progress ∧ t_xmin:200 = current_txid:200 ∧ t_xmax = invaild ? visible

此时块中包含两行数据，对于事务id=200来说，它的判断规则是：

{banned}中国第一行数据根据规则7判断，t_xmin=commit，同时(t_xmax=200)= in_progress，并且t_xmax:200为当前事务id，则{banned}中国第一行判断为不可见。

第二行根据规则2判断， t_xmin=commit，同时(t_xmax=200)为当前事务id，并且t_xmax为无效，则该行可见。

testdb=# -- txid 200

testdb=# select * from tbl;

name

------

hyde

r8与r4判断规则

· t5时事务id为201的根据规则8、4进行判断

rule8(tuple_1): status(t_xmin:199) = committed ∧ status(t_xmax:200) = in_progress ∧ t_xmax:200 ≠ current_txid:201? visible

rule4(tuple_2): status(t_xmin:200) = in_progress ∧ t_xmin:200 ≠ current_txid:201? invisible

此时块中包含两行数据，对于事务id=201来说，它的判断规则是：

{banned}中国第一行数据根据规则8判断，t_xmin=commit，同时(t_xmax=200)= in_progress，并且t_xmax:200不是当前事务id，则{banned}中国第一行判断为可见。

第二行根据规则2判断， (t_xmax=200)状态为in_progress，同时t_xmin不是当前事务id，则该行不可见。

testdb=# -- txid 201

testdb=# select * from tbl;

name

--------

jekyll

r10与r6判断规则

· t7时事务id为201的根据规则10、6进行判断(read commited)

rule10(tuple_1): status(t_xmin:199) = committed ∧ status(t_xmax:200) = committed ∧ snapshot(t_xmax:200) ≠ active?invisible

rule6(tuple_2): status(t_xmin:200) = committed ∧ t_xmax = invalid ?visible

t7时事务id为200的提交了事务，对于事务id=201来说，它的判断规则是：

{banned}中国第一行根据规则10判断，t_xmin=commit，同时(t_xmax=200)= committed ，并且snapshot(t_xmax:200) 状态为非活动，则{banned}中国第一行判断为不可见。

第二行根据规则6判断， (t_xmax=200)状态为committed ，同时t_xmax为无效，则该行可见。

testdb=# -- txid 201 (read committed)

testdb=# select * from tbl;

name

------

hyde

r9与r5判断规则

· t7时事务id为201的根据规则9、5进行判断(repeatable read)

rule9(tuple_1): status(t_xmin:199) = committed ∧ status(t_xmax:200) = committed ∧ snapshot(t_xmax:200) = active ? visible

rule5(tuple_2): status(t_xmin:200) = committed ∧ snapshot(t_xmin:200) = active ? invisible

如果事务的隔离级别是可重复读，那么其判断规则就会发生变化，t7时事务id为200的提交了事务，对于事务id=201来说，它的判断规则是：

{banned}中国第一行根据规则9判断，t_xmin=commit，同时(t_xmax=200)= committed ，并且snapshot(t_xmax:200) 状态为活动，则{banned}中国第一行判断为可见。

第二行根据规则5判断， t_xmax=200状态为committed ， snapshot(t_xmin:200) 为活动，则该行不可见，通过该规则，不会导致幻读发生。

testdb=# -- txid 201 (repeatable read)

testdb=# select * from tbl;

name

--------

jekyll

提高判断效率

· hint bits

由于进行行可见性判断时都要查看存储在clog中t_xmin和t_xmax的状态，为了解决对clog频繁访问这个问题，postgresql使用了提示位，如下所示：

#define heap_xmin_committed 0x0100 /* t_xmin committed */

#define heap_xmin_invalid 0x0200 /* t_xmin invalid/aborted */

#define heap_xmax_committed 0x0400 /* t_xmax committed */

#define heap_xmax_invalid 0x0800 /* t_xmax invalid/aborted */

实现闪回功能

postgresql由于数据的更新时新旧数据都保留在数据块中，那么如果要实现像oracle一样的闪回查询功能应该是可以实现的，只要在判断时先判断该查询是否是闪回查询，然后再根据一个针对闪回查询的可见性规则判断就可以实现。

如果实现闪回查询，那么涉及到vacuum操作时需要考虑更多的因素，需要有一个参数来设置块中被删除的行保留的时间长度。

以上就是【postgresql从小白到专家】第21讲 - 行可见性规则 的内容，欢迎一起探讨交流，往期视频及文档，联系cuug