无论如何要在 Python 中使用 PostgreSQL 更新数据库

Question

我想以最少的努力进行更新，为简单起见，我减少了列，这不起作用：

sql = '''INSERT INTO temp.tickets
    (id, created_at, updated_at, emails, status)
VALUES
    (%s, %s, %s, %s, %s)
    ON CONFLICT (id)
    DO UPDATE SET ( emails, status) values (%s,%s) 
    
    '''

cursor = cm.cursor()
## cm is a custom module
cursor.execute(sql, (ticket['id'],
                     ticket['created_at'],
                     ticket['updated_at'],
                     ticket['emails'], ticket['status'], )

此代码显示错误：

    return super(DictCursor, self).execute(query, vars)
IndexError: tuple index out of range

我需要更改cursor.execute() 中的哪些内容才能工作？

波纹管代码有效，但我喜欢使用 %s 而不是每列输入：email = excluded.email

sql = '''INSERT INTO temp.tickets
    (id, created_at, updated_at, emails, status)
VALUES
    (%s, %s, %s, %s, %s)
    ON CONFLICT (id)
    DO UPDATE SET emails = excluded.eamils, status = excluded.status
    
    '''

cursor = cm.cursor() 
# cm is a custom module

cursor.execute(sql, (ticket['id'],
                     ticket['created_at'],
                     ticket['updated_at'],
                     ticket['emails'], ticket['status'], )

有两个相关问题link1，link2

Answer 1

我会尝试这样的：

sql = '''INSERT INTO temp.tickets
    (id, created_at, updated_at, emails, status)
VALUES
    (%s, %s, %s, %s, %s)
    ON CONFLICT (id)
    DO UPDATE SET ( emails, status) values (%s,%s) 
    
    '''

cursor = cm.cursor()
## cm is a custom module
cursor.execute(sql, (ticket['id'],
                     ticket['created_at'],
                     ticket['updated_at'],
                     ticket['emails'], 
                     ticket['status'],
                     ticket['emails'], 
                      ticket['status'] )

%s 的三个数量必须与参数的数量匹配。

Answer 2

当 Postgres 遇到捕获的冲突时，它基本上会创建一个名为 EXCLUDED 的记录，其中包含您尝试插入的值，您可以在 DO UPDATE 中引用此记录。请尝试以下操作：

INSERT INTO temp.tickets
    (id, created_at, updated_at, emails, status)
VALUES
    (%s, %s, %s, %s, %s)
    ON CONFLICT (id)
    DO UPDATE 
          SET emails = excluded.emails
            , status = excluded.status
            , updated_at = excluded.updated_at    -- my assumption.  
 ... 

您必须按照源语言的要求进行格式化。