13.3. 明确封锁

PostgreSQL提供了多种锁模式用于控制对表中数据的并发访问。 这些模式可以用于在MVCC无法给出期望行为的场合。同样, 大多数PostgreSQL命令自动施加恰当的锁以保证被引用的表在命令的执行过程中不会以一种不相容的方式被删除或者修改。 比如,在存在其它并发操作的时候,TRUNCATE是不能在同一个表上面执行的

要检查数据库服务器里所有当前正在被持有的锁, 可以使用pg_locks系统视图。 有关监控锁管理器子系统状态的更多信息,请参考第 27 章

13.3.1. 表级锁

下面的列表显示了可用的锁模式和它们被PostgreSQL自动使用的场合。 你也可以用LOCK命令明确获取这些锁。请注意所有这些锁模式都是表级锁, 即使它们的名字包含"row"单词(这些名称是历史的产物)。从某种角度而言, 这些名字反应了每种锁模式的典型用法— 但是语意却都是一样的。 两种锁模式之间真正的区别是它们有着不同的冲突锁集合(参见表 13-2)。 两个事务在同一时刻不能在同一个表上持有相互冲突的锁。不过,一个事务决不会和自身冲突。比如,它可以在一个表上请求ACCESS EXCLUSIVE然后接着请求 ACCESS SHARE。 非冲突锁模式可以被许多事务同时持有。请特别注意有些锁模式是自冲突的(比如,在任意时刻ACCESS EXCLUSIVE模式就不能够被多个事务拥有), 而其它锁模式不是自冲突的(比如,ACCESS SHARE可以被多个事务持有)。

表级锁模式

ACCESS SHARE

只与ACCESS EXCLUSIVE冲突。

SELECT命令在被引用的表上请求一个这种锁。通常, 任何只读取表而不修改它的命令都请求这种锁模式。

ROW SHARE

EXCLUSIVEACCESS EXCLUSIVE锁模式冲突。

SELECT FOR UPDATESELECT FOR SHARE命令在目标表上需要一个这样模式的锁 (加上在所有被引用但没有FOR UPDATE/FOR SHARE的表上的ACCESS SHARE锁)。

ROW EXCLUSIVE

SHARE, SHARE ROW EXCLUSIVE, EXCLUSIVEACCESS EXCLUSIVE锁模式冲突。

UPDATE,DELETEINSERT命令自动请求这个锁模式(加上所有其它被引用的表上的ACCESS SHARE锁)。 通常,这种锁将被任何修改表中数据的查询请求。

SHARE UPDATE EXCLUSIVE

SHARE UPDATE EXCLUSIVE, SHARE, SHARE ROW EXCLUSIVE, EXCLUSIVEACCESS EXCLUSIVE锁模式冲突。 这个模式保护一个表不被并发模式改变和VACUUM

VACUUM(不带FULL选项), ANALYZE, CREATE INDEX CONCURRENTLYALTER TABLE VALIDATE和其他ALTER TABLE 变体(全部细节请查看ALTER TABLE)请求这样的锁。

SHARE

ROW EXCLUSIVE, SHARE UPDATE EXCLUSIVE, SHARE ROW EXCLUSIVE, EXCLUSIVEACCESS EXCLUSIVE锁模式冲突。 这个模式避免表的并发数据修改。

CREATE INDEX(不带CONCURRENTLY选项)语句要求这样的锁模式。

SHARE ROW EXCLUSIVE

ROW EXCLUSIVE, SHARE UPDATE EXCLUSIVE, SHARE, SHARE ROW EXCLUSIVE, EXCLUSIVEACCESS EXCLUSIVE锁模式冲突。这个模式避免表的并发数据修改。 并且是自我排斥的,因此每次只有一个会话可以拥有它。

任何PostgreSQL命令都不会自动请求这个锁模式。

EXCLUSIVE

ROW SHARE, ROW EXCLUSIVE, SHARE UPDATE EXCLUSIVE, SHARE, SHARE ROW EXCLUSIVE, EXCLUSIVEACCESS EXCLUSIVE锁模式冲突。这个模式只允许并发ACCESS SHARE锁,也就是说, 只有对表的读动作可以和持有这个锁模式的事务并发执行。

REFRESH MATERIALIZED VIEW CONCURRENTLY请求这个锁模式。

ACCESS EXCLUSIVE

与所有模式冲突(ACCESS SHARE, ROW SHARE, ROW EXCLUSIVE, SHARE UPDATE EXCLUSIVE, SHARE, SHARE ROW EXCLUSIVE, EXCLUSIVEACCESS EXCLUSIVE)。这个模式保证其所有者(事务)是可以访问该表的唯一事务。

DROP TABLE, TRUNCATE, REINDEX, CLUSTERVACUUM FULL命令要求这样的锁。 ALTER TABLE的许多形式也在这个级别请求这样的锁 (参阅ALTER TABLE)。 在LOCK TABLE命令没有明确声明需要的锁模式时,它是缺省锁模式。

提示: 只有ACCESS EXCLUSIVE阻塞SELECT (不包含FOR UPDATE/SHARE语句)。

一旦请求已获得某种锁,那么该锁模式将持续到事务结束。但是如果在建立保存点之后才获得锁, 那么在回滚到这个保存点的时候将立即释放所有该保存点之后获得的锁。这与ROLLBACK取消所有保存点之后对表的影响的原则一致。 同样的原则也适用于PL/pgSQL异常块中获得的锁: 一个跳出块的错误将释放在块中获得的锁。

表 13-2. 冲突锁模式

Requested Lock ModeCurrent Lock Mode
ACCESS SHAREROW SHAREROW EXCLUSIVESHARE UPDATE EXCLUSIVESHARESHARE ROW EXCLUSIVEEXCLUSIVEACCESS EXCLUSIVE
ACCESS SHARE       X
ROW SHARE      XX
ROW EXCLUSIVE    XXXX
SHARE UPDATE EXCLUSIVE   XXXXX
SHARE  XX XXX
SHARE ROW EXCLUSIVE  XXXXXX
EXCLUSIVE XXXXXXX
ACCESS EXCLUSIVEXXXXXXXX

13.3.2. 行级锁

除了表级锁以外,还有行级锁,它们在下面列出,内容是PostgreSQL 自动使用的那些。参阅表 13-3获取行级锁冲突的完整表格。 请注意,一个事务可以在相同的行上持有冲突的锁,即使是在不同的子事务中; 但是除此之外,两个事务在同一行上永远不能持有冲突的锁。 行级锁不影响对数据的查询,它们只阻塞对同一行的写入和锁定

行级锁模式

FOR UPDATE

FOR UPDATE导致由SELECT 语句检索的行就像要更新那样被锁定。这阻止了其他事务锁定、 修改或删除这些行,直到当前事务结束。也就是说,其他尝试 UPDATEDELETESELECT FOR UPDATESELECT FOR NO KEY UPDATESELECT FOR SHARESELECT FOR KEY SHARE这些行的事务将被阻塞, 直到当前事务结束;相反的,SELECT FOR UPDATE 将等待在相同行上运行任意这些命令的并发事务,并且将锁定并返回更新了的行 (或零行,如果行被删除了)。在一个REPEATABLE READSERIALIZABLE事务中,然而,如果一个要被锁定的行在事务开始以来已经发生了改变, 将抛出一个错误。更多的讨论请查看第 13.4 节

行上的任意DELETEUPDATE修改特定字段上的值也请求 FOR UPDATE锁模式。当前,UPDATE 考虑的字段集是那些有一个唯一索引、可以用作外键的字段 (因此没有考虑部分索引和表达式索引),但是这个在将来可能会改变。

FOR NO KEY UPDATE

行为类似于FOR UPDATE,除了锁请求较弱一些: 这个锁将不会阻塞在相同行上请求锁的SELECT FOR KEY SHARE命令。 任何不请求FOR UPDATE锁的UPDATE也请求这个锁模式。

FOR SHARE

行为类似于FOR NO KEY UPDATE,除了它在每个检索的行上请求一个共享锁, 而不是排他锁。一个共享锁阻塞其他事务在这些行上执行 UPDATEDELETESELECT FOR UPDATESELECT FOR NO KEY UPDATE,但是它不阻止它们执行 SELECT FOR SHARESELECT FOR KEY SHARE

FOR KEY SHARE

行为类似于FOR SHARE,除了这个锁稍弱些: SELECT FOR UPDATE是阻塞的,但是 SELECT FOR NO KEY UPDATE不是。一个共享键锁定阻塞其他事务执行 DELETE或任何修改该键值的UPDATE, 但是不阻塞其他UPDATE,也不阻止 SELECT FOR NO KEY UPDATESELECT FOR SHARE、 或SELECT FOR KEY SHARE

PostgreSQL不会在内存里保存任何关于已修改行的信息,因此对一次封锁的行数没有限制。 不过,锁住一行会导致一次磁盘写;因为SELECT FOR UPDATE将修改选中的行以标记它们被锁住了, 所以会导致磁盘写。

表 13-3. 冲突的行级锁

请求的锁模式当前锁模式
FOR KEY SHAREFOR SHAREFOR NO KEY UPDATEFOR UPDATE
FOR KEY SHARE   X
FOR SHARE  XX
FOR NO KEY UPDATE XXX
FOR UPDATEXXXX

13.3.3. 页面级锁

除了表级别和行级别的锁以外,页面级别的共享/排他锁也用于控制共享缓冲池中表页面的读/写。 这些锁在抓取或者更新一行后马上被释放。应用程序员通常不需要关心页级锁, 我们在这里提到它们只是为了完整。

13.3.4. 死锁

明确封锁的使用可能会增加死锁的可能性,死锁是指两个(或多个)事务相互持有对方期待的锁。 比如,如果事务 1 在表 A 上持有一个排他锁,同时试图请求一个在表 B 上的排他锁, 而事务 2 已经持有表 B 的排他锁,而却正在请求在表 A 上的一个排他锁, 那么两个事务就都不能执行。 PostgreSQL能够自动侦测死锁条件并且会通过终止其中一个事务从而允许其它事务完成来解决这个问题。 具体哪个事务会被退出是很难预计的,而且也不应该依靠这样的预计。

要注意的是死锁也可能会因为行级锁而发生(即使是没有使用明确的封锁)。 考虑如下情况,两个并发事务在修改一个表。第一个事务执行了:

UPDATE accounts SET balance = balance + 100.00 WHERE acctnum = 11111;

这样就在指定帐号的行上请求了一个行级锁。然后,第二个事务执行:

UPDATE accounts SET balance = balance + 100.00 WHERE acctnum = 22222;
UPDATE accounts SET balance = balance - 100.00 WHERE acctnum = 11111;

第一个UPDATE语句成功地在指定行上请求到了一个行级锁,因此它成功更新了该行。 但是第二个UPDATE语句发现它试图更新的行已经被锁住了,因此它等待持有该锁的事务结束。 事务二现在就在等待事务一结束,然后再继续执行。现在,事务一执行:

UPDATE accounts SET balance = balance - 100.00 WHERE acctnum = 22222;

事务一企图在指定行上请求一个行级锁,但是它得不到:事务二已经持有这样的锁了。 所以它等待事务二完成。因此,事务一被事务二阻塞住了,而事务二也被事务一阻塞住了: 这就是一个死锁条件。PostgreSQL将侦测这样的条件并终止其中一个事务。

防止死锁的最好方法通常是保证所有使用一个数据库的应用都以一致的顺序在多个对象上请求封锁。 在上面的例子里,如果两个事务以同样的顺序更新那些行,那么就不会发生死锁。 我们也要保证在一个对象上请求的第一个锁是该对象需要的最高的锁模式。 如果我们无法提前核实这些问题,那么我们可以通过在现场重新尝试因死锁而终止的事务的方法来处理。

只要没有检测到死锁条件,事务将一直等待表级锁或行级锁的释放。 这意味着一个事务持续的时间太长不是什么好事(比如等待用户输入)。

13.3.5. 咨询锁

PostgreSQL允许创建由应用定义其含义的锁。这种锁被称为咨询锁, 因为系统并不强迫其使用— 而是由应用来保证其被恰当的使用。 咨询锁可用于 MVCC 难以实现的封锁策略。 比如,咨询锁一般用于模拟常见于"平面文件"数据管理系统的悲观锁策略。 虽然可以用存储在表中的一个特定标志达到同样的目的,但是使用咨询锁更快,还可以避免表臃肿, 更可以在会话结束的时候由系统自动执行清理工作。

PostgreSQL中有两种方式可以获得咨询锁:会话级别或者事务级别。 咨询锁一旦被持有就将持续到被明确释放或会话结束。 不同于各种标准的锁,咨询锁并不考虑事务的语意: 在一个被回滚的事务中获得的咨询锁并不会被自动释放,同样的, 在一个失败的事务中释放的咨询锁仍将保持释放。同一个咨询锁可以被它自己的进程多次获得: 对于每一个封锁请求必须有一个相应的释放请求,这样才能最终真正释放该锁。 另一方面,事务级别的锁请求,表现得更像普通锁请求:它们在事务结束时自动释放, 并且没有明确的解锁操作。这种行为在短期使用咨询锁时通常比会话级别的行为更方便。 对相同的咨询锁标识符的会话级别和事务级别的锁请求将互相阻塞,这也是所期望的。 如果某个会话已经持有一个咨询锁,那么对该锁的多次封锁请求将总会成功,即使其它会话正在等候该锁的释放也是如此。 不管已持有的锁和新的锁请求是会话级别还是事务级别,这一结论都成立。

PostgreSQL中其它锁一样, 可以在pg_locks系统视图中查看当前被会话持有的所有咨询锁。

咨询锁和普通锁存储在共享内存池中,其中大小由max_locks_per_transactionmax_connections配置参数决定。 千万不要耗尽这些内存,否则服务器将不能再获取任何新锁。 因此服务器可以获得的咨询锁数量是有限的,根据服务器的配置不同, 这个限制可能是几万到几十万个。

在某些使用咨询锁的情况下,特别是查询包括显式的排序和LIMIT子句的时候, 由于 SQL 表达式求值顺序的影响,必须注意控制咨询锁的获取。例如:

SELECT pg_advisory_lock(id) FROM foo WHERE id = 12345; -- ok
SELECT pg_advisory_lock(id) FROM foo WHERE id > 12345 LIMIT 100; -- danger!
SELECT pg_advisory_lock(q.id) FROM
(
  SELECT id FROM foo WHERE id > 12345 LIMIT 100
) q; -- ok

在上述查询中,第二种形式是危险的,因为LIMIT 并不一定在封锁函数执行之前被应用。 这可能导致获得某些应用不期望的锁,并因此在会话结束之前无法释放。从应用的角度来看, 这样的锁将被挂起,虽然它们仍然在pg_locks中可见。

用于操作咨询锁的函数在第 9.26.9 节中描述。