postgres_fdw

Параметры подключения

• user, password и sslpassword следует задавать в сопоставлениях пользователей или в файле описания служб;
• client_encoding автоматически принимается равной локальной кодировке сервера;
• fallback_application_name всегда = postgres_fdw;
• sslkey и sslcert могут задаваться в свойствах соединения и/или сопоставления пользователей, при этом настройки сопоставления пользователей более приоритетны.

ALTER USER MAPPING FOR some_non_superuser SERVER loopback_nopw
OPTIONS (ADD password_required 'false');

• любые клиентские сертификаты и записи в файлах .pgpass, .pg_service.conf в домашнем каталоге системного пользователя, от имени которого работает сервер postgres;
• доверенные режимы аутентификации, например peer или ident.

Параметры имени объекта

Оценка стоимости

• включено, postgres_fdw:
  • получает количество строк и оценку стоимости с удаленного сервера;
  • добавляет к оценке стоимости fdw_startup_cost и fdw_tuple_cost.
• отключено, postgres_fdw:
  • рассчитывает число строк и оценку стоимости локально;
  • добавляет к этой оценке fdw_startup_cost и fdw_tuple_cost.

Удаленное выполнение

• extensions – перечисленные через запятую расширения PostgreSQL, которые установлены и имеют совместимые версии на локальном и на удаленном сервере. Относящиеся к перечисленным расширениям и при этом постоянные (immutable) функции и операторы могут передаваться на выполнение удаленному серверу. Этот параметр можно задать только для стороннего сервера, но не для таблицы; при использовании параметра extensions пользователь сам отвечает за то, чтобы перечисленные расширения существовали, и их поведение было одинаковым на локальном и удаленном сервере, в противном случае, удаленные запросы могут выдавать ошибки или неожиданные результаты;
• fetch_size – количество строк, которое должна получать postgres_fdw в одной операции выборки; можно задать для сторонней таблицы или стороннего сервера; значение по умолчанию — 100 строк.

Изменение данных

Импорт

Управление соединением

Управление транзакциями

• открывает транзакцию на удаленном сервере, если такая транзакция еще не была открыта для текущей локальной транзакции;
• удаленная транзакция фиксируется или прерывается, когда фиксируется или прерывается локальная транзакция.

Оптимизация удаленных запросов

Окружение удаленного выполнения запросов

Ограничения

1. Не поддерживаются операторы INSERT с предложением ON CONFLICT DO UPDATE.
2. Предложение ON CONFLICT DO NOTHING поддерживается при отсутствии указания для выбора уникального индекса.
3. Поддерживается перемещение строк, вызванное командами UPDATE для секционированных таблиц; в то же время невозможно выполнить изменение, при котором удаленная секция, выбранная для добавления перемещаемой строки, также является целевой секцией для UPDATE и должна модифицироваться позже той же командой.

Использование модуля

1. Создайте объект стороннего сервера с помощью команды CREATE SERVER. Сторонний сервер будет представлять удаленную базу данных, к которой необходимо подключаться. В параметрах объекта сервера указываются свойства подключения:

   CREATE SERVER test_foreign_server
       FOREIGN DATA WRAPPER postgres_fdw
       OPTIONS (host '<host>', port '5433', dbname 'test_pgfdw');
   

2. Создайте сопоставление пользователей, используя CREATE USER MAPPING, для каждого пользователя базы, которому нужен доступ к удаленному серверу. Укажите имя и пароль удаленного пользователя в параметрах сопоставления user и password.

   CREATE USER MAPPING FOR postgres
       SERVER test_foreign_server
       OPTIONS (user 'pgfdw', password '<password>');
   

3. Создайте стороннюю таблицу, используя CREATE FOREIGN TABLE или IMPORT FOREIGN SCHEMA, для каждой удаленной таблицы, к которой необходимо обращаться. Столбцы сторонней таблицы должны соответствовать столбцам целевой удаленной таблицы. Можно также использовать локально имена таблиц и/или столбцов, отличные от удаленных, если указать корректные имена в параметрах объекта сторонней таблицы.

   CREATE FOREIGN TABLE test_foreign_table (
       num int,
       name text,
       name1 varchar
       )
       SERVER test_foreign_server
       OPTIONS (
         schema_name 'ext',
         table_name 'tst_pgfdw'
         );
   

   Сторонняя таблица может быть объявлена с меньшим количеством или другим порядком столбцов, чем в удаленной таблице. Сопоставление столбцов удаленной таблицы осуществляется по имени, а не по позиции.
   В случае успешного создания внешняя таблица Foreign table появится в списке объектов:

   Раскрыть type=sql
                                     Foreign table "ext.test_foreign_table"
   Column |       Type        | Collation | Nullable | Default | FDW options | Storage  | Stats target | Description
   --------+-------------------+-----------+----------+---------+-------------+----------+--------------+-------------
    num    | integer           |           |          |         |             | plain    |              |
    name   | text              |           |          |         |             | extended |              |
    name1  | character varying |           |          |         |             | extended |              |
   Server: test_foreign_server
   FDW options: (schema_name 'ext', table_name 'tst_pgfdw')
   

4. Для обращения к данным, хранящимся в удаленной таблице, можно выполнять SELECT. Также можно изменять данные в удаленной таблице, выполняя INSERT, UPDATE, DELETE или COPY. Удаленный пользователь, указанный в сопоставлении, должен иметь необходимые права для этого.

   select * from test_foreign_table;
    num |  name   |   name1
   -----+---------+-----------
      1 | Ivanov  | Ingeneer
      2 | Petrov  | Developer
      3 | Sidorov | QA
   (3 rows)
   

Ссылки на документацию разработчика