python - 在 SQLAlchemy 中跟踪模型更改

Question

我想记录使用某些 SQLAlchemy-Model 将完成的每个操作。

所以，我有一个 after_insert、after_delete 和 before_update 钩子(Hook)，我将在其中保存模型的先前和当前表示，

def keep_logs(cls):
    @event.listens_for(cls, 'after_delete')
    def after_delete_trigger(mapper, connection, target):
        pass

    @event.listens_for(cls, 'after_insert')
    def after_insert_trigger(mapper, connection, target):
        pass

    @event.listens_for(cls, 'before_update')
    def before_update_trigger(mapper, connection, target):
        prev = cls.query.filter_by(id=target.id).one()
        # comparing previous and current model


MODELS_TO_LOGGING = (
    User,
)
for cls in MODELS_TO_LOGGING:
    keep_logs(cls)

但是有一个问题:当我试图在 before_update 钩子(Hook)中查找模型时，SQLA 返回修改(脏)版本。如何在更新之前获得以前版本的模型？是否有其他方法来保持模型更改？

谢谢!

Answer 1

SQLAlchemy 跟踪每个属性的更改。您不需要(也不应该)在事件中再次查询该实例。此外，任何已修改的实例都会触发该事件，即使该修改不会更改任何数据。循环遍历每一列，检查它是否已被修改，并存储任何新值。

@event.listens_for(cls, 'before_update')
def before_update(mapper, connection, target):
    state = db.inspect(target)
    changes = {}

    for attr in state.attrs:
        hist = attr.load_history()

        if not hist.has_changes():
            continue

        # hist.deleted holds old value
        # hist.added holds new value
        changes[attr.key] = hist.added

    # now changes map keys to new values