SQLAlchemy 事件不起作用

Per*_*nce 6 python sqlalchemy python-2.7

我正在使用 SQLAlchemy 并尝试将事件添加到我的代码中。虽然一切正常,但不会触发事件。这是我的简化代码:

from sqlalchemy import Column, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy import event

alchemy_base = declarative_base()

class Person(alchemy_base):
    __tablename__ = 'my_table'
    name = Column(String, primary_key=True)

@event.listens_for(Person, "before_insert")
def before_insert(mapper, connection, instance):
    print("before_insert", mapper, connection, instance)

engine = create_engine('sqlite:///:memory:', echo=True)
alchemy_base.metadata.create_all(engine)
session_maker = sessionmaker(bind=engine)
session = session_maker()

insert_dicts = [{'name': "ami"}, {'name': "beni"}]
engine.execute(Person.__table__.insert(), insert_dicts)
session.commit()
Run Code Online (Sandbox Code Playgroud)

before_insert尽管值已输入到 DB 中,但并未调用该函数。

我在 Mac OS 上使用 python 2.7.10,SQLAlchemy 1.0.10。

jum*_*pap 5

before_insert是一个 ORM 事件。您正在使用 SQLAlchemy Core 而不是 ORM。这有效。

>>> p = Person(name='Ami')
>>> session.add(p)
>>> session.commit()
2016-01-13 23:37:42,887 INFO sqlalchemy.engine.base.Engine BEGIN (implicit)
('before_insert', <Mapper at 0x1059e4dd0; Person>, <sqlalchemy.engine.base.Connection object at 0x105a2e990>, <__main__.Person object at 0x105a2e790>)
2016-01-13 23:37:42,888 INFO sqlalchemy.engine.base.Engine INSERT INTO my_table (name) VALUES (?)
2016-01-13 23:37:42,888 INFO sqlalchemy.engine.base.Engine ('Ami',)
2016-01-13 23:37:42,888 INFO sqlalchemy.engine.base.Engine COMMIT
Run Code Online (Sandbox Code Playgroud)

  • 你是对的,这些监听器不适用于所有级别的 sqlalchemy。这在文档中的任何地方都没有提到。如果您将此作为答案发布,我会接受。 (3认同)