使用 SQLAlchemy，如何对 PGSQL 范围 window 子查询？

Question

我有一个类似于以下内容的查询：

  SELECT id, max(subq.foo), sum(subq.bar), etc...
  FROM (
      SELECT id,
           first_value(foo) over w as foo,
           etc...
      FROM my_table
      WHERE <where information>
      WINDOW w AS (PARTITION BY id 
                   ORDER BY time_stamp ASC
                   RANGE BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)
  ) as subq

我如何使用 sqlalchemy 完成此操作？特别是，我的问题是关于在内部查询中完成 window。 Sqlalchemy 似乎只有 partition_by 和 order_by 的参数，并且需要该范围参数。

谢谢！

Answer 1

最后这样做了：

# hack to get window supported
subq = subq.filter(text("TRUE WINDOW w AS (PARTITION BY id "
                        "ORDER BY time_stamp ASC "
                        "RANGE BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)"))

这将是应用于查询的最后一个过滤器，因此您最终会得到 sql，如下所示：

WHERE .... AND TRUE WINDOW w as (PARTITION BY id ORDER BY ...)

使用 SQLAlchemy，如何对 PGSQL 范围 window 子查询？

Using SQLAlchemy, how do to PGSQL ranged window subquery?

python

postgresql

sqlalchemy

window

range