Объедините две таблицы событий в одну временную шкалу

Даны две таблицы:

CREATE TABLE foo (ts timestamp, foo text);
CREATE TABLE bar (ts timestamp, bar text);

Я хочу написать запрос, который возвращает значения для ts, fooи barкоторый представляет собой единое представление самых последних значений. Другими словами, если fooсодержится:

ts | foo
--------
1  | A
7  | B

и barсодержит:

ts | bar
--------
3  | C
5  | D
9  | E

Я хочу запрос, который возвращает:

ts | foo | bar
--------------
1  | A   | null
3  | A   | C
5  | A   | D
7  | B   | D
9  | B   | E

Если в обеих таблицах одновременно происходит событие, порядок не имеет значения.

Я смог создать необходимую структуру, используя объединение всех и фиктивные значения:

SELECT ts, foo, null as bar FROM foo
UNION ALL SELECT ts, null as foo, bar FROM bar

что даст мне линейную шкалу времени новых значений, но я не совсем могу понять, как заполнить нулевые значения на основе предыдущих строк. Я пробовал lagоконную функцию, но AFAICT будет смотреть только на предыдущий ряд, а не рекурсивно назад. Я смотрел на рекурсивные CTE, но я не совсем уверен, как настроить условия начала и завершения.

Используйте FULL [OUTER] JOIN, в сочетании с двумя раундами оконных функций :

SELECT ts
     , min(foo) OVER (PARTITION BY foo_grp) AS foo
     , min(bar) OVER (PARTITION BY bar_grp) AS bar
FROM (
   SELECT ts, f.foo, b.bar
        , count(f.foo) OVER (ORDER BY ts) AS foo_grp
        , count(b.bar) OVER (ORDER BY ts) AS bar_grp
   FROM   foo f
   FULL   JOIN bar b USING (ts)
   ) sub;

Поскольку count()значения NULL не учитываются, удобно увеличиваться только с каждым ненулевым значением, тем самым формируя группы с одинаковым значением. Во внешнем SELECT, min()(или max()) также игнорирует значения NULL, тем самым выбирая значение один ненулевой для каждой группы. Вуаля.

Родственный FULL JOINслучай:

• Добавьте условные подсчеты для нескольких столбцов одной таблицы

Это один из тех случаев, когда процедурное решение может быть просто быстрее, поскольку оно может выполнить работу за одно сканирование. Как эта функция plpgsql :

CREATE OR REPLACE FUNCTION f_merge_foobar()
  RETURNS TABLE(ts int, foo text, bar text) AS
$func$
#variable_conflict use_column
DECLARE
   last_foo text;
   last_bar text;
BEGIN
   FOR ts, foo, bar IN
      SELECT ts, f.foo, b.bar
      FROM   foo f
      FULL   JOIN bar b USING (ts)
      ORDER  BY 1
   LOOP
      IF foo IS NULL THEN foo := last_foo;
      ELSE                last_foo := foo;
      END IF;

      IF bar IS NULL THEN bar := last_bar;
      ELSE                last_bar := bar;
      END IF;

      RETURN NEXT;
   END LOOP;
END
$func$ LANGUAGE plpgsql;

Вызов:

SELECT * FROM f_merge_foobar();

ДБ <> возиться здесь , демонстрируя оба.

Соответствующий ответ, объясняющий #variable_conflict use_column:

• Конфликт имен между параметром функции и результатом JOIN с предложением USING