Ecto 查询 - 日期 + Postgres 间隔 + 查询插值

Question

我想创建一个 Ecto 查询，children按年龄过滤表中的记录（即“最小年龄（月）-> 最大年龄（月）”）。

一种简单的方法是使用 Ectodate_add功能：

from c in Child, where: c.birthday >
                          datetime_add(^Ecto.DateTime.utc, -1, "month")

问题在于并非所有孩子都在同一时区，当然也不是所有孩子都在Etc/UTC. 此查询将非常接近，但不会准确（有些会在一天内关闭）。

我一直在尝试使用 PostgreSQL 的interval功能来使这个查询工作。我可以使用 SQL 客户端让它工作，但是在尝试插入片段中的值时遇到了插入问题。

这有效（孩子的时区来自其location关联）：

query = from ch in Child, 
            join: loc in assoc(ch, :location),
            where: ch.birthday <= fragment("(now() AT TIME ZONE ?)::date - interval '2 months'", loc.time_zone)

Repo.all(query)

请注意，我在'2 months'间隔中进行了硬编码。

我认为这会工作，但确实不是：

query = from ch in Child, 
            join: loc in assoc(ch, :location),
            where: ch.birthday <= fragment("(now() AT TIME ZONE ?)::date - interval ?", loc.time_zone, ^"2 months")

Repo.all(query)

请注意，我正在尝试使用 Ecto 的查询插值将'2 months'值引入查询中。

错误如下：

[debug] QUERY ERROR source="children" db=1.7ms queue=0.1ms
SELECT c0."id", (... other properties) FROM "children" AS c0 INNER JOIN "programs" AS p2 ON p2."id" = c0."program_id" INNER JOIN "locations" AS l1 ON l1."id" = p2."location_id" WHERE (c0."birthday" <= (now() AT TIME ZONE l1."time_zone")::date - interval $1) ["2 months"]
** (Postgrex.Error) ERROR 42601 (syntax_error): syntax error at or near "$1"
    (ecto) lib/ecto/adapters/sql.ex:436: Ecto.Adapters.SQL.execute_and_cache/7
    (ecto) lib/ecto/repo/queryable.ex:130: Ecto.Repo.Queryable.execute/5
    (ecto) lib/ecto/repo/queryable.ex:35: Ecto.Repo.Queryable.all/4

失败的查询部分（我在 SQL 客户端尝试了相同的查询）是：

(now() AT TIME ZONE l1."time_zone")::date - interval $1)

它不喜欢$1那里的部分。是否不可能将值插入到这种查询中？

我尝试在 SQL 客户端中使用单引号，但遇到了相同的错误。我尝试了以下方法：

SELECT c0."id" FROM "children" AS c0 INNER JOIN "programs" AS p2 ON p2."id" = c0."program_id" INNER JOIN "locations" AS l1 ON l1."id" = p2."location_id" WHERE (c0."birthday" <= (now() AT TIME ZONE l1."time_zone")::date - interval $1) ['2 months']

任何帮助，将不胜感激！

Answer 1

不久前我需要完全做到这一点，并最终使用了一个事实，即您可以将间隔与$1.

postgres=# select interval '1 year' - interval '1 month' * 5;
 ?column?
----------
 7 mons
(1 row)

所以，这应该有效：

query = from ch in Child, 
            join: loc in assoc(ch, :location),
            where: ch.birthday <= fragment("(now() AT TIME ZONE ?)::date - interval '1 month' * ?", loc.time_zone, 2)

Repo.all(query)