我使用 SqlAlchemy
在 PostgreSQL 中创建了一张表:
my_table = Table('test_table', meta,
Column('id', Integer,primary_key=True,unique=True),
Column('value1', Integer),
Column('value2', Integer)
)
我想通过数据框来更新此表:
id value1 value2
0 1 32.0 1
1 2 2.0 32
2 3 NaN 3
3 4 213.0 23
我尝试使用SqlAlchemy
中的on_conflict_do_update
来进行代码更新,代码如下:
insert_statement = sqlalchemy.dialects.postgresql.insert(my_table,).values(df.to_dict(orient='records'))
upsert_statement = insert_statement.on_conflict_do_update(
index_elements=['id'],
set_= df.to_dict(orient='dict')
)
conn.execute(upsert_statement)
但是显示以下错误:
我的 SqlAlchemy 版本是 1.2.10,而 psycopg2 版本是 2.7.5。有人能帮我吗?(psycopg2.ProgrammingError) 无法适应类型 'dict'