Содержание

5.12.1. Примеры логического декодирования

5.12.2. Основные концепции логического декодирования

5.12.2.1. Логическое декодирование

5.12.2.2. Слоты репликации

5.12.2.3. Синхронизация слотов репликации

5.12.2.4. Плагины вывода

5.12.2.5. Экспортируемые снимки

5.12.3. Интерфейс протокола потоковой репликации

5.12.4. Логическое декодирование SQL Интерфейс

5.12.5. Системные каталоги, связанные с логическим декодированием

5.12.6. Плагины вывода логического декодирования

5.12.6.1. Функция инициализации

5.12.6.2. Возможности

5.12.6.3. Режимы вывода

5.12.6.4. Функции обратного вызова плагина вывода

5.12.6.5. Функции для формирования вывода

5.12.7. Механизмы записи вывода логического декодирования

5.12.8. Поддержка синхронной репликации при логическом декодировании

5.12.8.1. Обзор

5.12.8.2. Предостережения

5.12.9. Потоковая передача больших транзакций при логическом декодировании

5.12.10. Поддержка двухфазной фиксации в логическом декодировании

PostgreSQL предоставляет инфраструктуру для потоковой передачи внешним потребителям изменений, выполненных с помощью SQL. Данный функционал может использоваться для различных целей, включая построение решений для репликации и аудит.

Изменения передаются в виде потоков, идентифицируемых слотами логической репликации.

Формат потоковой передачи этих изменений определяется используемым плагином вывода. Пример плагина входит в состав дистрибутива PostgreSQL. Дополнительные плагины могут быть написаны для расширения выбора доступных форматов без изменения кода ядра. Каждый плагин вывода имеет доступ к каждой отдельной новой строке, созданной INSERT и к новой версии строки, созданной UPDATE . Доступность старых версий строк для UPDATE и DELETE зависит от настроенного идентификатора реплики (см. REPLICA IDENTITY ).

Изменения могут быть получены либо с помощью протокола потоковой репликации (см. Раздел 7.4.4 и Раздел 5.12.3 ), либо путем вызова функций через SQL (см. Раздел 5.12.4 ). Также возможно создание дополнительных методов получения данных из слота репликации без модификации основного кода (см. Раздел 5.12.7 ).