Заполнить пустые пропущенные даты в результате сырого sql запроса

Question

У меня есть запрос, подобный приведенному ниже, который принимает min_date и max_date.

Select TO_CHAR(date_trunc('hour', table.date), 'YYYY-MM-DD HH24:00') as formatted_date,
count(DISTINCT table.order_id) as unique_orders, sum(table.price) as total_price from table
where table.date>=min_date and table.date<=max_date

result = ActiveRecord::Base.connection.execute(query).values.to_a

Это даст мне количество заказов и общую цену за «час». Например, скажем, это моя таблица

<id: 1, order_id: 1, date: 2020-06-10 10:18:01+00, price:10>
<id: 2, order_id: 1, date: 2020-06-10 10:43:19+00, price:14>
<id: 3, order_id: 2, date: 2020-06-10 12:10:00+00, price:15>
<id: 4, order_id: 3, date: 2020-06-10 12:20:21+00, price:10>
<id: 5, order_id: 3, date: 2020-06-10 14:10:54+00, price:20>

И мои min_date = 2020-06-10 09:00:00+00 и max_date = 2020-06-10 14:00:00+00. Это будет мой результат:

[[2020-06-10 10:00, 1, 24], [2020-06-10 12:00, 2, 25], [2020-06-10 14:00, 1, 20]]

Я хочу, чтобы недостающие часы между min_date и max_date были включены следующим образом:

[[2020-06-10 09:00, 0, 0], [2020-06-10 10:00, 1, 24], [2020-06-10 11:00, 0, 0], [2020-06-10 12:00, 2, 25], [2020-06-10 13:00, 0, 0] [2020-06-10 14:00, 1, 20]]

Так что я хочу также все часы, которые отсутствуют в таблице, но включены во временной диапазон между min_date и max_date. В этом сценарии это все часы, которые я хочу, но это могут быть все «недели» или «месяцы» в зависимости от аргумента, который я передаю в date_trunc.

Answer 1

Используйте generate_series(), чтобы рассчитать все даты, которые вам нужны. Затем используйте left join, чтобы ввести данные:

select to_char(gs.dte, 'YYYY-MM-DD HH24:00') as formatted_date,
       count(distinct t.order_id) as unique_orders, sum(t.price) as total_price
from generate_series(min_date, max_date, interval '1 hour') gs(dte) left join
     table t
     on t.date >= gs.dte and
        t.date < gs.dte + interval '1 hour' and table.date<=max_date
group by gs.dte
order by gs.dte;