时间戳

首页 > 解决方案 > 在 SQLAlchemy 中使用字典/数据框值执行更新

python - 在 SQLAlchemy 中使用字典/数据框值执行更新

问题描述

我正在尝试更新user_id并date_synced在我的 user_table 中。我正在使用 MySQL。我的表如下：User(user_id, mail, active, activity_level, date_synced)。这些值来自我的 DataFrameUsers：

user_id date_synced
1   2019-05-20 20:48:04
8   2019-05-20 20:48:04

转换为 dict dictUsers = dfUsers.to_dict()：

{'date_synced': {1: '2019-05-20 20:48:04', 8: '2019-05-20 20:48:04'}}

当我执行：

conn.execute(user_table.update(), [ 
        dictUsers
    ]
)

我得到错误：

ProgrammingError: (pymysql.err.ProgrammingError) (1064, 'You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near \'1: "\'2019-05-20 20:48:04\'", 8: "\'2019-05-20 20:48:04\'"}\' at line 1')
[SQL: UPDATE `User` SET date_synced=%(date_synced)s]
[parameters: {'date_synced': {1: '2019-05-20 20:48:04', 8: '2019-05-20 20:48:04'}}]

预期结果将在数据库中更新。

如何使用 SQLAlchemy 插入此字典？不必是字典，可以转换。我只是想让它工作。谢谢！

标签： pythonpandassqlalchemy

解决方案

您的参数格式错误。sqlalchemy现在不知道如何搜索行和更新什么。正确格式：

[
    {'user_id': 1, 'date_synced': '2019-05-20 20:48:04'},
    {'user_id': 8, 'date_synced': '2019-05-20 20:48:04'}
]

所以你只需要转换dictUsers. 只是一个例子：

from sqlalchemy.sql.expression import bindparam, update
from sqlalchemy.sql.expression import func

data = {'date_synced': {1: '2019-05-20 20:48:05', 2: '2019-05-20 20:48:05'}}
params = []
for user_id, date_synced in data['date_synced'].items():
    params.append({'_id': user_id, 'date_synced': date_synced})

stmt = update(User).\
    where(User.user_id == bindparam('_id')).\
    values({
        'date_synced': bindparam('date_synced'),
    })

db.session.execute(stmt, params)
db.session.commit()

希望这可以帮助。

推荐阅读