江苏龙网

  1. 主页 > 生活百科 > >

动态筛选出sqlalchemy中的数据

sqlalchemy

class Integration(Base, ModelBase, ModelSerializer):__tablename__ = 'integration'id = Column(Integer, primary_key=True)domain = relationship('Domain', backref='integration')created_at = Column(DateTime, default=datetime.now())updated_at = Column(DateTime, default=datetime.now())name = Column(String(512), index=True)meta = Column(JSON)tag = Column(String(512))identifier_id = Column(String(512), unique=True, index=True)def __repr__(self):return '<name {}>'.format(self.name)class Domain(Base, ModelBase, ModelSerializer):__tablename__ = 'domain'id = Column(Integer, primary_key=True)integration_id = Column(Integer, ForeignKey('integration.id'), index=True)url = relationship('Url', backref='domain')created_at = Column(DateTime, default=datetime.now())updated_at = Column(DateTime, default=datetime.now())name = Column(String(512), index=True)domain = Column(String(512), nullable=True)def __repr__(self):return '<name {}>'.format(self.name)class Url(Base, ModelBase, ModelSerializer):__tablename__ = 'url'id = Column(Integer, primary_key=True)domain_id = Column(Integer, ForeignKey('domain.id'), index=True)created_at = Column(DateTime, default=datetime.now())updated_at = Column(DateTime, default=datetime.now())name = Column(String(512), index=True)url = Column(String(512), nullable=True)meta = Column(JSON)auth = Column(JSON)def __repr__(self):return '<name {}>'.format(self.name)class ModelBase(object):def __repr__(self):return '<id {}>'.format(self.id)class ModelSerializer(object):def as_dict(self):return {attribute.name: getattr(self, attribute.name) for attribute in self.__table__.columns}现在，我需要根据过滤器过滤掉数据 。如果假定给出了integration_filters，则仅过滤Integration数据 。如果给出了Integration和Domain，则仅过滤域并通过将它们与URL和Domain联接在一起来进行集成
我尝试的解决方案-
1） 。不起作用，因为它不联接然后表 。后来发现add_entity不会添加模型 。
if integration_filter:query = query.add_entity(Integration)query = query.filter_by(**kwargs['integration_filter'])if domain_filter:query = query.add_entity(Domain)query = query.filter_by(**kwargs['domain_filter'])if url_filter:query = query.add_entity(Url)query = query.filter_by(**kwargs['url_filter'])它检查集成表中的属性“域”
if integration_filter:query = session.query(Integration).filter_by(**integration_filter)if domain_filter:if query:query = query.join(Domain)else:query = session.query(Domain)query = query.filter_by(**domain_filter)if url_filter:if query:query = query.join(Url)else:query = session.query(Url)query = query.filter_by(**url_filter)`3） 。这也不起作用
models = []joins = []if integration_filter:models.Append(Integration)if domain_filter:if models:joins.append((Integration, Domain, Integration.id == Domain.integration_id))models.append(Domain)if url_filter:if models:joins.append((Domain, Url, Domain.id == Url.domain_id))models.append(Url)query = session.query(*models)for join in joins:query = query.join(*join)【动态筛选出sqlalchemy中的数据】
 
解决方案


    推荐阅读


    上一篇：over IPsec CentOS8服务器搭建L2TP服务器操作指南

    下一篇：没有了