在PostgreSQL中处理竞争条件

Question

我有几个工作人员，每个工作人员都拥有与PostgreSQL的连接。工人用不同的桌子操纵。

工作人员处理来自系统外部的并行请求。被访问的表之一是用户表。当收到一些信息时，我首先需要确保表中有该用户的记录。如果没有记录，我希望首先创建一个。

我正在使用以下成语：

if [user does not exist] then [create user]

的代码[user does not exist]是：

SELECT id FROM myschema.users WHERE userId='xyz'

然后测试是否返回任何行。

的（简化）代码[create user]为：

INSERT INTO myschema.users VALUES ('xyz')

当我的系统处理与 同一 用户有关 的 不同信息的并行流时，我经常会收到PostgreSQL错误：

Key (id)=(xyz) already exists

发生这种情况是因为该SELECT命令不返回任何行，然后另一个工作人员创建了用户，而我的任何工作人员都试图执行该操作，从而导致示例性的并发错误。

根据PostgreSQL文档，默认情况下，每当我隐式启动事务时，只要我不提交该表，该表就会被锁定。我没有使用自动提交，我只在块中提交事务，例如在整个if- else块之后。

确实，我可以将这些if- else东西直接放入SQL中，但是它通常不能解决我的锁定问题。我以为“获胜者会全力以赴”范例将起作用，并且设法执行SELECT命令的第一个工作人员将拥有锁，直到调用为止COMMIT。

我在SO上阅读了许多不同的主题，但是我仍然不确定什么是正确的解决方案。我应该使用表的显式锁定，因为隐式锁定不起作用？如何确保只有一个工人同时拥有一张桌子？

Answer 1

您必须关心事务隔离级别。应将其设置为“ SERIALIZABLE”。

原因是Phantom Reads-事务不会锁定整个表，而只会锁定已被事务读取的行。

因此，如果另一个事务插入新数据，则尚未锁定它们，并且会出现错误。

可序列化可通过阻止所有其他事务来避免这种情况，直到完成这一事务为止。

您可以通过

SET TRANSACTION ISOLATION LEVEL SERIALIZABLE;

文档：http :
//www.postgresql.org/docs/9.1/static/transaction-
iso.html