rebecca.repository 0.4

基本存储库

通过SQLAlchemy实现您的模型

from sqlalchemy import Column, Integer, Unicode
from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()
DBSession = scoped_session(sessionmaker())

class Person(Base):
    __tablename__ = "person"
    id = Column(Integer, primary_key=True)
    name = Column(Unicode(255))
    age = Column(Integer, default=0)
    job = Column(Unicode(255))

获取存储库

from rebecca.repository.sqla import SQLARepository

person_repository = SQALRepository(Person, Person.id, DBSession())

此存储库用于Person模型。要获取人员，请使用Person.id作为键。

条件存储库

存储库可以配置以设置条件

person_repository = SQALRepository(Person, Person.id, DBSession(), condition=Person.age>30)

存储库工厂

如果在请求时间传递参数，请使用工厂。

class JobPersonRepository(SQLARepository):
    def __init__(self, db_session, job):
        super(JobPersonRepository, self).__init__(Person, Person.id, dbsession,
                                                  condition=Person.job==job)

参数job将来自请求属性。

要注册存储库工厂，请添加add_repository_factory指令

config.add_repository_factory(JobPersonRepository, "job-person", args=(DBSession,))

或使用repository_factory_config装饰器

@repository_factory_config("job-person", args=(DBSession,))
class JobPersonRepository(SQLARepository):
    ....

要从注册的工厂创建存储库，请调用create_repository API

job = request.matchdict["job"]
repository = create_repository("person", args=(job,))