PostgreSQL / Psycopg2 upsert语法更新列
作者:互联网
我希望在存在id冲突时让Psycopg2更新col1,col2和col3.
在我的Python代码中,我将插入SQL当前作为:
insert_sql = '''INSERT INTO {t} (id,col1,col2,col3)
VALUES (%s,%s,NULLIF(%s, 'nan'), NULLIF(%s, 'nan'))
ON CONFLICT (id)
DO NOTHING;'''
基本上我没有想要设置:
(col1,col2,col3)=(%s,NULLIF(%s,’nan’),NULLIF(%s,’nan’))
这会忽略插入ID并更新col1,col2和col3.
问题是使用%s使用Psycopg2在Python中传递元组变量:
cur.execute(insert_sql.format(t='my_table'),(int(id),new_col1,new_col2,new_col3))
用于引用与col1,col2和col3相对应的%s以更新ON CONFLICT的语法是什么?
解决方法:
您可以使用EXCLUDED关键字来访问传递给INSERT的值.无需通过两次:
insert_sql = '''
INSERT INTO {t} (id,col1, col2, col3)
VALUES (%s, %s, NULLIF(%s, 'nan'), NULLIF(%s, 'nan'))
ON CONFLICT (id)
DO UPDATE SET
(col1, col2, col3)
= (EXCLUDED.col1, EXCLUDED.col2, EXCLUDED.col3) ;
'''
请参阅Postgres文档中有关ON CONFLICT
的使用示例.
标签:upsert,python,postgresql,insert 来源: https://codeday.me/bug/20190807/1605254.html