Jak mogę zapewnić, że zmaterializowany widok jest zawsze aktualny?

Będę musiał powoływać się na każdą zmianę tabel, prawda?

Tak, PostgreSQL sam w sobie nigdy nie wywoła go automatycznie, musisz to zrobić w jakiś sposób.

Jak mam to zrobić?

Chociaż, jeśli jesteś w wersji 9.4 lub nowszej, możesz dać mu opcję CONCURRENTLY:

REFRESH MATERIALIZED VIEW CONCURRENTLY my_mv;

To uzyska wyłączność i nie zablokuje SELECT zapytań, ale może mieć większy narzut (zależy od ilości zmienionych danych, jeśli kilka wierszy się zmieni, to może być szybciej). Chociaż nadal nie można uruchomić dwóch komend REFRESH jednocześnie.

Odśwież ręcznie

Planowanie operacji odświeżania

Pierwszą i powszechnie używaną opcją jest użycie jakiegoś systemu planowania do wywołania odświeżania, na przykład można skonfigurować podobny w zadaniu cron:

*/30 * * * * psql -d your_database -c "REFRESH MATERIALIZED VIEW CONCURRENTLY my_mv"

I wtedy twój zmaterializowany widok będzie odświeżany co 30 minut.

Rozważania

Ta opcja jest naprawdę dobra, szczególnie z opcją CONCURRENTLY, ale tylko wtedy, gdy możesz zaakceptować dane, które nie są w 100% aktualne przez cały czas. Należy pamiętać, że nawet z CONCURRENTLY lub bez REFRESH, Komenda REFRESH musi uruchomić całe zapytanie, więc musisz poświęcić czas potrzebny na uruchomienie wewnętrznego zapytania przed rozważeniem czasu na zaplanowanie REFRESH.

Odświeżanie za pomocą spustu

Inną opcją jest wywołanie REFRESH MATERIALIZED VIEW w funkcji wyzwalającej, jak to:

CREATE OR REPLACE FUNCTION tg_refresh_my_mv()
RETURNS trigger LANGUAGE plpgsql AS $$
BEGIN
    REFRESH MATERIALIZED VIEW CONCURRENTLY my_mv;
    RETURN NULL;
END;
$$;

Następnie, w dowolnej tabeli, która obejmuje zmiany w widoku, robisz:

CREATE TRIGGER tg_refresh_my_mv AFTER INSERT OR UPDATE OR DELETE
ON table_name
FOR EACH STATEMENT EXECUTE PROCEDURE tg_refresh_my_mv();

Rozważania

W związku z tym, że nie jest to możliwe, nie jest to konieczne, ponieważ nie jest to konieczne.]}
1. nawet z CONCURRENTLY, jedna REFRESH nadal blokuje inną, więc każda wstawka/aktualizacja/Usuń na zaangażowanych tabelach będzie bądź serializowana.

Odświeżanie za pomocą LISTEN / NOTIFY

Problem z poprzednią opcją polega na tym, że jest synchroniczna i nakłada duży narzut na każdą operację. Aby to złagodzić, można użyć wyzwalacza jak wcześniej, ale to wywołuje tylko NOTIFY operacja:

CREATE OR REPLACE FUNCTION tg_refresh_my_mv()
RETURNS trigger LANGUAGE plpgsql AS $$
BEGIN
    NOTIFY refresh_mv, 'my_mv';
    RETURN NULL;
END;
$$;

Więc możesz zbudować aplikację, która utrzymuje połączenie i używa LISTEN operacja w celu identyfikacji potrzeby wywołania REFRESH. Jednym z fajnych projektów, które możesz użyć do przetestowania tego jest pgsidekick , w tym projekcie możesz użyć skryptu powłoki do zrobienia LISTEN, więc możesz zaplanować REFRESH jako:

pglisten --listen=refresh_mv --print0 | xargs -0 -n1 -I? psql -d your_database -c "REFRESH MATERIALIZED VIEW CONCURRENTLY ?;"

Lub użyj pglater (również wewnątrz pgsidekick), aby upewnić się, że nie dzwonisz zbyt często. Na przykład, możesz użyć następującego wyzwalacza, aby zrobić to REFRESH, ale w ciągu 1 minuty (60 sekund):

CREATE OR REPLACE FUNCTION tg_refresh_my_mv()
RETURNS trigger LANGUAGE plpgsql AS $$
BEGIN
    NOTIFY refresh_mv, '60 REFRESH MATERIALIZED VIEW CONCURRENLTY my_mv';
    RETURN NULL;
END;
$$;

Więc nie zadzwoni REFRESH w mniej niż 60 sekund od siebie, a także jeśli NOTIFY wiele razy w czasie krótszym niż 60 sekund, REFRESH zostanie uruchomiony tylko raz.

Rozważania

Jako opcja cron, ta jest również dobra tylko wtedy, gdy możesz wydobyć trochę starych danych, ale ma to tę zaletę, że {[12] } jest wywoływany tylko wtedy, gdy jest naprawdę potrzebny, więc masz mniej kosztów ogólnych, a także dane są aktualizowane bardziej bliżej, gdy są potrzebne.

OBS: nie próbowałem jeszcze kodów i przykładów, więc jeśli ktoś znajdzie błąd, literówkę lub próbuje i działa (lub nie), proszę dać mi znać.