1

我试图在我的所有模型（时间戳）中共享一个简单的功能，并采用 SQLA 文档中描述的“增强基础”方法。到目前为止，我这样做了：

import sqlalchemy as sa
from datetime import datetime as dt

class EntityBase(object):

    @declared_attr
    def __tablename__(cls):
        return cls.__name__.lower()

    id = sa.Column(sa.Integer, primary_key=True)
    last_update = sa.Column(sa.DateTime, default=dt.utcnow())

def update_entity(mapper, connection, target):
    target.last_update = dt.utcnow()


Entity = declarative_base(cls=EntityBase)

sa.event.listen(Entity, 'before_insert', update_entity)
sa.event.listen(Entity, 'before_update', update_entity)

我所有的模型都是从Entity类派生的。但在运行时我得到sqlalchemy.orm.exc.UnmappedClassError: Class 'sqlalchemy.ext.declarative.Base' is not mapped. 我究竟做错了什么？

更新 我通过做简单的预处理绕过了这个问题，如下所示：

def setupEntities():
    ...
    for cls in Entity.__subclasses__():
        listen(cls, 'before_insert', update_entity)
        listen(cls, 'before_update', update_entity)
    ...

...但我想听听正确的方法。

4

1 回答 1

1

有趣的是，您在上面所做的方式可能应该有效。这会很方便。所以我为那个http://www.sqlalchemy.org/trac/ticket/2585添加了一张票。

目前，您可以这样做的一种方法是为新映射设置一个事件侦听器以及您的 Base：

Entity = declarative_base(cls=EntityBase):

from sqlalchemy.orm import mapper
@event.listens_for(mapper, 'mapper_configured')
def set_events(mapper, class_):
   if issubclass(class_, Entity):
        listen(class_, 'before_update', update_entity)
        listen(class_, 'before_insert', update_entity)

事实上，如果我为#2585 实现该功能，我可能也必须这样做非常相似。

于 2012-10-04T14:42:18.023 回答