用于更新-用于postgres的psycopg2游标

Question

我们使用psycopg2 jsonb游标来获取数据并进行处理，但是当出现新的线程或处理时，它不应该获取和处理第一个进程或线程的相同记录。

为此，我们尝试使用For UPDATE，但我们只想知道我们是否使用了正确的语法。

    con = self.dbPool.getconn()
    cur = conn.cursor()             
    sql="""SELECT jsondoc FROM %s WHERE jsondoc @> %s"”"             
    if 'sql' in queryFilter:                 
   sql += queryFilter 'sql’]   
   When we print this query, it will be shown as below:             
         Query: "SELECT jsondoc FROM %s WHERE jsondoc @> %s AND (jsondoc ->> ‘claimDate')::float <= 1536613219.0 AND ( jsondoc ->> ‘claimstatus' = ‘done' OR jsondoc ->> 'claimstatus' =                    'failed' ) limit 2 FOR UPDATE"         
 cur.execute(sql, (AsIs(self.tablename), Json(queryFilter),)) 
    cur.execute()
    dbResult = cur.fetchall()

请帮助我们澄清语法，并解释该语法是否正确，然后此查询如何锁定第一线程的获取记录。

谢谢，桑杰。

Answer 1

如果执行该示例性查询

select * 
from my_table
order by id
limit 2
for update; -- wrong

然后锁定两个结果行，直到事务结束(即next connection.rollback()或connection.commit()或连接关闭)。如果另一个事务在这段时间内尝试运行相同的查询，它将停止，直到两行解锁。所以it is not the behaviour你是期望的。您应该添加skip locked子句：

select * 
from my_table
order by id
limit 2
for update skip locked; -- correct

有了这个子句，第二个事务将跳过锁定的行并返回下两个onces，而无需等待。

请在the documentation.上阅读相关信息