python - sqlalchemy:获取受批量删除影响的行

Question

我需要像这样获取受批量删除影响的所有行:

Session.query(SomeClass).filter_by(foo='bar').delete()

我找到了 the possibility to subscribe to bulk delete events但无法弄清楚如何使用此事件来实际获取我需要的信息。

Answer 1

好的，找到答案了\☺/可以重新执行之前选择行进行批量删除的select语句。不幸的是，您无法查询 ORM 对象，但您可以获得所有已删除行的列表，其中旧列值作为元组:

def after_bulk_delete(session, query, query_context, result):
    affected_table = query_context.statement.froms[0]
    affected_rows = query_context.statement.execute().fetchall() 

sqlalchemy.event.listen(Session, "after_bulk_delete", after_bulk_delete)