列更新上的 sqlalchemy 事件答案

【问题标题】：sqlalchemy event on column update列更新上的 sqlalchemy 事件
【发布时间】：2014-06-02 20:19:07
【问题描述】：

我在更新User.name 注册了一个事件，以便在更新之后或之前应用一些规则。

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy import event
from sqlalchemy import Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
engine = create_engine('sqlite:///:memory:', echo=True)
Session = sessionmaker(bind=engine)   # engine part

Base = declarative_base()


class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, primary_key=True)
    name = Column(String)
    fullname = Column(String)
    password = Column(String)
    rule = Column(String)
Base.metadata.create_all(engine)


session = Session()
u1 = User(id=1, name="hello world", fullname="hello kitty")
u2 = User(id=2, name="hello world2", fullname="hello kitty2")
session.add(u1)
session.add(u2)


@event.listens_for(User, 'before_update')
def User_before_update(target, value, initiator):
    print ":::::received before insert event for target"


@event.listens_for(User.name, 'set')
def name_set(target, value, old_value, initiator):
    print ":::::set before insert event for target"


### option A
user = session.query(User).get(2)
user.name = u"wawamsma"
session.merge(user)

### option B
session.query(User).filter(User.id == 2).update({User.name: u"eenimenee"})

选项A

一切正常，但我有一些更新方法使用许多字段到 sqlalchemy。

选项 B

已更新，但不触发两个打印功能。

所以我想知道，这是错误的注册事件方式还是错误的更新方式？

【问题讨论】：

标签： python session events orm sqlalchemy

【解决方案1】：

要在使用 query.update() 方法时接收事件，您需要使用after_bulk_update 事件。由于此操作不处理单个对象，而是直接发出 UPDATE 语句，因此此处可能受到影响的内存中的实际对象在本地不可用；您可能需要查询它们。如果“synchronize_session”设置为“evaluate”，则上下文将具有matched_objects 属性。

【讨论】：