Gabungkan dua tabel acara menjadi satu garis waktu

Diberikan dua tabel:

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

Saya ingin menulis query yang kembali nilai-nilai untuk ts, foodan baryang mewakili pandangan terpadu yang paling nilai-nilai baru-baru ini. Dengan kata lain, jika fooberisi:

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

dan barberisi:

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

Saya ingin kueri yang mengembalikan:

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

Jika kedua tabel memiliki acara secara bersamaan, urutannya tidak menjadi masalah.

Saya telah berhasil membuat struktur yang dibutuhkan dengan menggunakan nilai union all dan dummy:

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

yang akan memberi saya garis waktu linier dari nilai-nilai baru, tapi saya tidak cukup bisa mengetahui bagaimana mengisi nilai nol berdasarkan baris sebelumnya. Saya sudah mencoba lagfungsi jendela, tetapi AFAICT hanya akan melihat baris sebelumnya, tidak secara rekursif mundur. Saya telah melihat CTE rekursif, tapi saya tidak yakin bagaimana mengatur kondisi awal dan terminasi.

Gunakan a FULL [OUTER] JOIN, dikombinasikan dengan dua putaran fungsi jendela :

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;

Karena count()tidak menghitung nilai NULL, nilai ini hanya meningkat dengan setiap nilai bukan nol, sehingga membentuk grup yang akan berbagi nilai yang sama. Di bagian luar SELECT, min()(atau max()) juga mengabaikan nilai NULL, sehingga memilih satu nilai non-null per grup. Voila.

FULL JOINKasus terkait :

• Tambahkan jumlah bersyarat pada beberapa kolom dari tabel yang sama

Ini adalah salah satu kasus di mana solusi prosedural mungkin lebih cepat, karena dapat menyelesaikan pekerjaan dalam satu pemindaian. Seperti fungsi plpgsql ini :

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;

Panggilan:

SELECT * FROM f_merge_foobar();

db <> bermain-main di sini , menunjukkan keduanya.

Jawaban terkait menjelaskan #variable_conflict use_column:

• Penamaan konflik antara parameter fungsi dan hasil GABUNG dengan MENGGUNAKAN klausa