Postgresql 可序列化事务未按预期工作

Question

我想实现的任务分配 em>的系统。用户可以从池中请求任务。即使设置为序列，交易有时会给出相同的任务给多个用户，即使它不应该。 P>

简化架构： H3>

CREATE TABLE tasks(
  _id CHAR(24) PRIMARY KEY,
  totalInstances BIGINT NOT NULL
);

CREATE TABLE assigned(
  _id CHAR(24) PRIMARY KEY,
  _task CHAR(24) NOT NULL
);

在工作表中充满了许多行，让我们说每个人都有totalInstances = 1，这意味着每个任务应该最多分配一次。 P>

查询中添加一行assigned： H3>

WITH task_instances AS (
  SELECT t._id, t.totalInstances - COUNT(assigned._id) openInstances
  FROM tasks t
  LEFT JOIN assigned ON t._id = assigned._task
  GROUP BY t._id, t.totalInstances
),

selected_task AS (
  SELECT _id
  FROM task_instances
  WHERE openInstances > 0
  LIMIT 1
)

INSERT INTO assigned(_id, _task)
SELECT $1, _id
FROM selected_task;

与$1被传递到每个查询的随机ID。 P>

症状 H3>

我们有大约100个活跃用户reqularly请求的任务。该作品如预期，在1000个请求可能除了一次。 然后，两个assigned为相同 EM> _task时并行请求ID创建的行。我期望可序列化的执行回滚第二个，由于openInstances本来应该通过的第一个下降到0。 P>

设置

我们使用的Postgres 10.3和该查询从Scala代码经由油滑3.2.3 withTransactionIsolation(Serializable)运行。没有其他查询从删除或插入assigned表。 P>

Postgres的日志显示请求被在不同的会话中运行，并且SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL SERIALIZABLE;是每个任务分配查询之前执行。 P>

我试图重写在不同风格的查询，inculding VIEW S的使用量为WITH子查询，以及围绕与BEGIN和COMMIT但没有效果。 P>的查询

感谢任何帮助。

编辑

我要补充一点，有时预期的序列错误/回滚的不 em>的出现，在我们的应用程序重试查询。我看到这个正确的行为中的最后一个小时日志10倍，但2次它仍然错误地分配相同的任务两次，如上所述。 P>

Answer 1

Serializable 隔离级别并不意味着事务实际上是串行的。它只保证读取已提交、可重复读取和不存在幻读。而且您所描述的行为看起来并不违法。

为了避免重复记录，你可以简单地做

select ... from task_instances for update

由于这个“for update”子句，选定的行将在事务生命周期内被锁定。所以只有一个事务能够更新，第二个事务必须等到第一个事务被提交。结果，第二个事务将读取第一个事务更新的值 - 这正是您需要的保证。

同样重要的是，如果你在这种情况下使用“select for update”，你甚至不需要 Serializable 隔离级别，读提交就足够了。

Answer 2

我试过你的例子是这样的：

第 1 节：

BEGIN TRANSACTION ISOLATION LEVEL SERIALIZABLE;

WITH task_instances AS (
  SELECT t._id, t.totalInstances - COUNT(assigned._id) openInstances
  FROM tasks t
  LEFT JOIN assigned ON t._id = assigned._task
  GROUP BY t._id, t.totalInstances
),
selected_task AS (
  SELECT _id
  FROM task_instances
  WHERE openInstances > 0
  LIMIT 1
)
INSERT INTO assigned(_id, _task)
SELECT 1, _id
FROM selected_task;

第 2 节：

BEGIN TRANSACTION ISOLATION LEVEL SERIALIZABLE;

WITH task_instances AS (
  SELECT t._id, t.totalInstances - COUNT(assigned._id) openInstances
  FROM tasks t
  LEFT JOIN assigned ON t._id = assigned._task
  GROUP BY t._id, t.totalInstances
),
selected_task AS (
  SELECT _id
  FROM task_instances
  WHERE openInstances > 0
  LIMIT 1
)
INSERT INTO assigned(_id, _task)
SELECT 2, _id
FROM selected_task;

COMMIT;

第 1 节：

COMMIT;

这就是我得到的：

ERROR:  could not serialize access due to read/write dependencies among transactions
DETAIL:  Reason code: Canceled on identification as a pivot, during commit attempt.
HINT:  The transaction might succeed if retried.

所以它按预期工作。

我的唯一解释是你的设置有问题，而且你毕竟没有使用SERIALIZABLE。

您是否曾在应用程序中看到序列化错误？如果不是，那将证实我的怀疑。