Существует ли способ получения обновления состояния таблицы postgresql внешним процессом java?

Question

[vyn]

Предусловия: существует периодически растущая таблица в postgresql и java процесс, в котором хотелось бы обрабатывать вновь поступившие данные

Предположение: запрашивать из java процесса данные из этой таблицы и проверять их нерационально.

Вопрос: существует ли способ подписаться java процессу на обновления таблицы?

Answer 1

[Melkij]

https://www.postgresql.org/docs/current/logicaldec...
Инфраструктура Logical Decoding.

Либо триггером пишете в pgq, ваше приложение вычитывает очередь pgq. Это сильно проще.

Comments

[Сергей Горностаев]

Не устаю поражаться вашим знаниям. Опять узнал новое для себя. А можете показать пример использования Logical Decoding для решения задачи автора, если не трудно? На любом ЯП сойдёт.

[Melkij]

Сергей Горностаев, честно отвечу что сам не писал принимающую сторону для logical decoding. Но вживую видел, используется и вполне успешно
Для java в jdbc вроде даже штатные биндинги есть: https://jdbc.postgresql.org/documentation/head/rep...
Для C libpq можно в качестве примера взять pg_recvlogical https://github.com/postgres/postgres/blob/REL_11_S...

output plugin точно знаю у нас встречается wal2json
вероятно можно использовать штатный (начиная с postgresql 10) pgoutput - как раз он используется в штатной логической репликации и со стороны базы можно будет рулить именно штатными подписками.

В эксплуатации - лишь бы кто-то вычитывал данные и отчитывался об этом. Неиспользуемый слот логической репликации помимо безграничного накопления WAL так же будет мешать автовакууму работать.

Answer 2

[Сергей Горностаев]

Сделать триггер отправляющий NOTIFY при изменениях и выполнить LISTEN в программе.

Comments

[Melkij]

Очень хочу заострить внимание: notify не предоставляет каких-то гарантий.
https://github.com/postgres/postgres/blob/REL_11_S...