python - 如果记录具有与其相关的外键对象,则过滤 SQLAlchemy 对象中的记录

标签 python flask sqlalchemy flask-sqlalchemy

使用 the Flask-SQLAlchemy Quickstart 中的示例:

from datetime import datetime

class Post(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    title = db.Column(db.String(80))
    body = db.Column(db.Text)
    pub_date = db.Column(db.DateTime)

    category_id = db.Column(db.Integer, db.ForeignKey('category.id'))
    category = db.relationship('Category',
        backref=db.backref('posts', lazy='dynamic'))

    def __init__(self, title, body, category, pub_date=None):
        self.title = title
        self.body = body
        if pub_date is None:
            pub_date = datetime.utcnow()
        self.pub_date = pub_date
        self.category = category

    def __repr__(self):
        return '<Post %r>' % self.title


class Category(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(50))

    def __init__(self, name):
        self.name = name

    def __repr__(self):
        return '<Category %r>' % self.name

我按照与示例相同的方式重新创建了类别和帖子:

>>> py = Category('Python')
>>> p = Post('Hello Python!', 'Python is pretty cool', py)
>>> db.session.add(py)
>>> db.session.add(p)
>>> py.posts.all()
[<Post 'Hello Python!'>]

然后我添加一个新类别:

>>> ru = Category('Ruby')
>>> db.session.add(ru)

如何构建查询来获取包含帖子的所有类别。

想做这样的事情,但使用 SQLAlchemy 过滤器:

>>> categories_with_post = []
>>> For c in Category.query.all():
...     if len(c.posts.all()) > 0:
...         categories_with_post.append(c) 

最佳答案

由于您想要的只是包含帖子的类别,因此您可以尝试如下操作:

from sqlalchemy import distinct
db.session.query(distinct(Category.id), Category).join(Post.category).all()

加入将阻止返回任何没有帖子的类别。

注意distinct函数的使用,当多个帖子指向同一类别时,它将防止类别重复。但是它不能用于 Category 类本身,因此我在 Category.id 属性中使用它,并添加 Category 作为第二个参数来获取整个对象。它将返回 (id, Category) 元组列表。

关于python - 如果记录具有与其相关的外键对象,则过滤 SQLAlchemy 对象中的记录,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32702735/

相关文章:

python - 等待值然后停止服务器,在 'werkzeug.server.shutdown' 被弃用并删除之后

Python 数据集包 & 循环/更新行 --

python - 使用 else pass 的列表理解

python - cURL 请求拒绝连接 Flask 服务器

python - Flask Restplus 检查所需的 header

oracle - Pandas 通过 SQL Alchemy : UnicodeEncodeError: 'ascii' codec can't encode character 到 Oracle

Python(金字塔框架)在请求之间保留数据,我不明白为什么

python - 如果不满足条件,则返回该用户的数据,否则另一个查询

python - 使用 pandas DataFrame 将 2 列连接到新短语列中

python - 如何有效地获取 DataFrame 的前 x%?