11

我正在开发一个库,用户可以在其中简单地声明一些由数据库自动支持的类。简而言之,隐藏在代码中的某个地方,有

from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class LibraryBase(Base):
    # important library stuff

然后用户应该做

class MyStuff(LibraryBase):
    # important personal stuff

class MyStuff_2(LibraryBase):
    # important personal stuff

mystuff = MyStuff()
Library.register(mystuff)
mystuff.changeIt() # apply some changes to the instance
Library.save(mystuff) # and save it

# same for all other classes

在静态环境中,例如用户创建了一个包含所有个人类的文件并导入该文件,这非常有效。所有类名都是固定的,SQLAlchemy 知道如何映射每个类。

在交互式环境中,情况有所不同:现在,一个类有可能被定义两次。两个类可能有不同的模块;但 SQLAlchemy 仍然会抱怨:

SAWarning: 类名 'MyStuff' 已经在此声明性基础的注册表中,映射到 <class 'OtherModule.MyStuff' >

有没有办法解决这个问题?我可以以某种方式从它的类中卸载一个类,declarative_base以便我可以用一个新的类交换它的定义吗?

4

3 回答 3

4

您可以使用:

sqlalchemy.orm.instrumentation.unregister_class(cl)
del cl._decl_class_registry[cl.__name__]

第一行是防止意外使用您未注册的课程。第二个取消注册并将阻止警告。

于 2012-12-03T08:59:42.253 回答
2

看起来,我不确定这是否有效,但我认为你想要的是

sqlalchemy.orm.instrumentation.unregister_class()

http://hg.sqlalchemy.org/sqlalchemy/file/762548ff8eef/lib/sqlalchemy/orm/instrumentation.py#l466

于 2011-03-08T06:13:35.493 回答
0

在我的项目中,我使用了这个解决方案。其中库指定的列定义为 mixindeclared_attr和目标映射器通过type调用与基地创建,结果我有完整的功能映射器。

from sqlalchemy import create_engine, BigInteger, Column
from sqlalchemy.orm import sessionmaker, scoped_session
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.ext.declarative import declared_attr


Base = declarative_base()


class LibraryBase(object):
    __tablename__ = 'model'

    @declared_attr
    def library_field(self):
        return Column(BigInteger)


class MyLibrary(object):

    @classmethod
    def register(cls, entity):
        tablename = entity.__tablename__
        Mapper = type('Entity_%s' % tablename, (Base, LibraryBase, entity), {
            '__tablename__': tablename,
            'id': Column(BigInteger, primary_key=True),
        })
        return Mapper

    @classmethod
    def setup(cls):
        Base.metadata.create_all()


class MyStaff(object):
    __tablename__ = 'sometable1'

    @declared_attr
    def staff_field(self):
        return Column(BigInteger)

    def mymethod(self):
        print('My method:', self)


class MyStaff2(MyStaff):
    __tablename__ = 'sometable2'


if __name__ == '__main__':
    engine = create_engine('sqlite://', echo=True)
    Base.metadata.bind = engine
    Session = scoped_session(sessionmaker(bind=engine))
    session = Session()

    # register and install
    MyStaffMapper = MyLibrary.register(MyStaff)
    MyStaffMapper2 = MyLibrary.register(MyStaff2)
    MyLibrary.setup()

    MyStaffMapper().mymethod()
    MyStaffMapper2().mymethod()

    session.query(MyStaffMapper.library_field) \
        .filter(MyStaffMapper.staff_field != None) \
        .all() 
于 2013-06-10T13:22:12.030 回答