python - SQLAlchemy Core - INSERT IGNORE 和 ON DUPLICATE KEY UPDATE

Question

我将 SQLAlchemy Core 与 MySQL 数据库一起使用，但很难找到针对 INSERT IGNORE/DUPLICATE KEY UPDATE 的解决方案。如果有办法处理这个问题，我讨厌在代码中手动编写一次性查询。我发现的大多数解决方案或讨论都围绕着 ORM，而不是核心。甚至其中一些是死链接。有可能吗？

Answer 1

我知道有点晚了..但如果有人还在寻找解决方案的话。

FOR:关于重复 key 更新

ins = insert(/* table_name*/ ).values(/*your values(with PK)*/)
do_update_stmt = ins.on_duplicate_key_update(/*your values(with out PK)*/)
connection.execute(do_update_stmt)

On duplicate key update docs

The ON DUPLICATE KEY UPDATE clause of INSERT supported by MySQL is now supported using a MySQL-specific version of the Insert object

sqlalchemy.insert() 不可用。

对于:插入忽略

这有点 hacky，但工作正常。

 ins_address_stmt = insert(/* table_name*/ ).values(/*your values*/). \
            prefix_with('IGNORE')

Insert prefix_with

MySQL 将抑制重复主键的错误并给出警告。