使用 sqlalchemy 查询特定的 JSON 列（postgres）答案

【问题标题】：Query a specific JSON column (postgres) with sqlalchemy使用 sqlalchemy 查询特定的 JSON 列（postgres）
【发布时间】：2018-01-23 04:13:57
【问题描述】：

我有一个带有 JSON 字段的模型：

class Item(db.Model)
   ...
   data = db.Column(JSON, nullable=False)
   ...

数据中包含一些 JSON，例如：

{
    "cost": 10.00,
    "passengers": 2,
    "surcharge": 1.6
}

我希望能够使用过滤器获得表中所有行的成本总和。我尝试了以下方法，但似乎没有用。

db.session.query(func.count(Item.data['cost'])).filter(
          Item.data["surcharge"].cast(Float) > 1
      ).scalar()

【问题讨论】：

【解决方案1】：

您使用了错误的aggregate。 count(expression) 计算 表达式 不为空的行数。如果你想要一个总和，请使用sum(expression)：

db.session.query(func.sum(Item.data['cost'].astext.cast(Numeric))).\
    filter(Item.data['surcharge'].astext.cast(Numeric) > 1).\
    scalar()

请注意，由于binary floats not being able to represent all decimal values，货币值和二进制浮点数学是一种糟糕的混合。而是使用正确的monetary type 或Numeric，在这种情况下，SQLAlchemy 使用Decimal 在 Python 中表示结果。

【讨论】：

【解决方案2】：

您需要使用Float 而不是Integer 作为cast 的参数

db.session.query(func.count(Item)).filter(
          Item.data['surcharge'].cast(Float) > 1
      ).all()

【讨论】：