在SQLAlchemy中跟踪模型更改

Question

我想记录每个操作将使用某些SQLAlchemy模型执行的操作。

所以，我有一个after_insert，after_delete和before_update钩，在这里我将节省模型的以前和当前的表示，

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模型钩子，SQLA返回修改（脏）版本。 如何在更新之前获取旧版本的模型？ 有没有不同的方式来保持模型的变化？

谢谢！

Answer 1

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

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

    for attr in state.attrs: 
     hist = state.get_history(attr.key, True) 

     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