2016-09-18 86 views
1

我要显示一个日期范围(统计)喜欢的:使用外生在Postgres的generate_series并检索空值设为“0”

Dates  | Count 
-------------------- 
"2016-09-01" | 0 
"2016-09-02" | 0 
"2016-09-03" | 0 
"2016-09-04" | 0 
"2016-09-05" | 0 
"2016-09-06" | 12 
"2016-09-07" | 9 
"2016-09-08" | 0 
"2016-09-09" | 90 

原始SQL查询:

select date(d) as day, count(clicks.id) 
    from generate_series(
    current_date - interval '13 day', 
    current_date, 
    '1 day' 
) d 
left join clicks on date(clicks.inserted_at) = d and clicks.link_id = 15 
group by day order by day; 

我很想与外生使用它没有我找到了原始SQL

最接近的事是:

query = from c in Like 
    where: c.link_id == ^link.id 

... 

from(c in query, 
    join: day in fragment("select generate_series(current_date - interval '10 day', current_date, '1 day')::date AS d "), 
    on: fragment("date(?) = d", field(c, :inserted_at)), 
    group_by: fragment("day"), 
    order_by: fragment("day"), 
    select: %{ 
    day: fragment("date(d) as day"), 
    count: count(c.id) 
    } 
) 

但它只返回表格中的日期而不是整个范围(即;对于没有像那天

回答

4

您可以使用right_join因为你的外生查询与clicks加入clicks与产生的日期,而不是生成的日期就像你在原始SQL确实日期)显示0 。

测试:

alias MyApp.{Click, Repo} 
import Ecto.Query 

from(c in Click, 
    order_by: c.inserted_at, 
    select: fragment("date(?) as day", c.inserted_at) 
) 
|> Repo.all 
|> IO.inspect 

from(c in Click, 
    right_join: day in fragment("select generate_series(current_date - interval '10 day', current_date, '1 day')::date AS d "), 
    on: fragment("date(?) = d", field(c, :inserted_at)), 
    group_by: fragment("day"), 
    order_by: fragment("day"), 
    select: %{ 
    day: fragment("date(d) as day"), 
    count: count(c.id) 
    } 
) 
|> Repo.all 
|> IO.inspect 

输出:

[debug] QUERY OK source="clicks" db=1.9ms 
SELECT date(c0."inserted_at") as day FROM "clicks" AS c0 ORDER BY c0."inserted_at" [] 
[{2016, 9, 12}, {2016, 9, 13}, {2016, 9, 13}, {2016, 9, 13}, {2016, 9, 13}, 
{2016, 9, 15}, {2016, 9, 17}, {2016, 9, 17}] 
[debug] QUERY OK source="clicks" db=1.8ms 
SELECT date(d) as day, count(c0."id") FROM "clicks" AS c0 RIGHT OUTER JOIN (select generate_series(current_date - interval '10 day', current_date, '1 day')::date AS d) AS f1 ON date(c0."inserted_at") = d GROUP BY day ORDER BY day [] 
[%{count: 0, day: {2016, 9, 8}}, %{count: 0, day: {2016, 9, 9}}, 
%{count: 0, day: {2016, 9, 10}}, %{count: 0, day: {2016, 9, 11}}, 
%{count: 1, day: {2016, 9, 12}}, %{count: 4, day: {2016, 9, 13}}, 
%{count: 0, day: {2016, 9, 14}}, %{count: 1, day: {2016, 9, 15}}, 
%{count: 0, day: {2016, 9, 16}}, %{count: 2, day: {2016, 9, 17}}, 
%{count: 0, day: {2016, 9, 18}}] 

编辑:您可能还需要更多地利用外生强大的查询能力,并减少依赖asfragment。下面的查询生成相同的输出:

from(c in Click, 
    right_join: day in fragment("select generate_series(current_date - interval '10 day', current_date, '1 day')::date AS d"), 
    on: day.d == fragment("date(?)", c.inserted_at), 
    group_by: day.d, 
    order_by: day.d, 
    select: %{ 
    day: fragment("date(?)", day.d), 
    count: count(c.id) 
    } 
) 
+0

哦谢谢@Dogbert非常为您的解决方案,它的伟大工程,并解释:) – kayne

+0

谢谢你这么多的辉煌! – pip