我无法使用 ecto 的 `over/2` 函数在窗口中添加特定的 frame_clause

Posted 2023-03-31

【中文标题】我无法使用 ecto 的 `over/2` 函数在窗口中添加特定的 frame_clause

【英文标题】：I cannot add a specific frame_clause in a window using ecto's `over/2` function

【发布时间】：2020-04-16 17:10:41

【问题描述】：

我使用 ecto 查询 Postgres 数据库，我需要添加一个 Window 函数来保持累积和。除了所讨论的“金额”的重复值之外，这工作正常，它们被加在一起以获得累积总和。在原始 sql 中，解决方案是添加自定义框架子句 (ROWS UNBOUNDED PRECEDING)，但没有明显的方法可以使用查询 DSL 将其添加到 ecto。

在我们的数据库中，我们有多种产品，其中大部分产品都会收到多个带有金额的评级。我需要确定所有评分的总和，还需要确定特定子集中数量的累积总和（与问题无关，仅针对某些上下文）。当前查询的一个例子是：

 from(p in Product,
      left_join: ratings in assoc(p, :ratings),
      select: [
        p.id,
        sum(ratings.amount),
        sum(sum(ratings.amount))
        |> over(
          partition_by: p.selection_0,
          order_by: sum(ratings.amount)
        )
      ],
      group_by: p.id
    )

正如我所说，除了总量相等的产品外，这很好用。这是意料之中的，因为它在原始 postgresql 中的工作方式相同，正如在这个问题中询问和回答的那样：Duplicate lines with postgres window functions

我找不到将 frame_clause 添加到使用 over/2 函数创建的窗口的明显方法。我考虑过使用片段，但期望一个不适用于 frame_clause 的键列表表示法（例如where: fragment("...")）。

【参考方案1】：

看起来你在Elixir Forums 上得到了答案：

from(p in Product,
  left_join: ratings in assoc(p, :ratings),
  select: [
    p.id,
    sum(ratings.amount),
    over(sum(sum(ratings.amount)), :w1)
  ],
  windows: [
    w1: [
      partition_by: p.selection_0,
      order_by: sum(ratings.amount),
      frame: fragment("rows unbounded preceding")
    ]
  ],
  group_by: p.id
)

供参考：https://hexdocs.pm/ecto/Ecto.Query.html#windows/3-frame