postgresql - Postgres SSI 行为

Question

我试图了解 SSI 在 Postgres 中的实际行为。我的理解是，如果我有两个事务与同一个表交互，但事务不与表中的相同行交互，则不会发生异常。

但是，我正在运行以下测试，其中事务一执行以下操作:

cur = engine.cursor()
cur.execute('SELECT SUM(value) FROM mytab WHERE class = 1')
s = cur.fetchall()[0][0]
print('retrieved sum is...')
print(s)
print('sleeping....')
time.sleep(10)
cur.execute('INSERT INTO mytab (class, value) VALUES (%s, %s)', (1, s))
engine.commit()

当上面的第一个事务处于休眠状态时，我运行第二个事务:

cur = engine.cursor()
cur.execute('SELECT SUM(value) FROM mytab WHERE class = 2')
s = cur.fetchall()[0][0]
print('retrieved sum is...')
print(s)
cur.execute('INSERT INTO mytab (class, value) VALUES (%s, %s)', (2, s))
engine.commit()

在这种情况下，第二个事务只涉及类 = 2 的行，而第一个事务只涉及类 = 1 的行。但这导致第一个事务失败并出现以下异常:

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

供引用 mytab 非常简单，看起来像这样:

class   value
1   10
1   20
2   100
2   200

除了标准的 engine = psycopg2.connect 设置外，我还在运行上述代码之前使用此行设置事务隔离级别:

engine.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_SERIALIZABLE)

Answer 1

你的理解基本上是正确的，但是SSI算法并不完美，所以总会有一些误报的风险(例如docs中提到的，行锁可能会组合成页锁，优化以精度为代价获取内存)。

此处的行为是 predicate locking implementation 的限制，即:

For a table scan, the entire relation will be locked.

基本上，在您的第一个查询 WHERE class = 1 运行后，需要检查来自其他事务的 future 插入以查看它们是否会满足此条件他们是可见的。实际上，除了最简单的情况外，对所有情况执行此检查都是不切实际或不可能的，因此为了谨慎起见，改为在整个表上采用谓词锁。

细粒度谓词锁实现是based on indexing ，因为根据例如关系的受影响子集来推理要容易得多B 树范围比任意 WHERE 约束。

换句话说，如果您在 class 列上有一个索引 - 并且您的表中有足够的记录供规划人员实际使用它 - 您应该会得到您期望的行为。