dblink

Ограничения

1. Функция dblink_connect_se устанавливается в специальную схему pgse_profile.
2. Отличия параметров адреса сервера в аргументе connstr для функций:

   Параметр	dblink_connect	dblink_connect_se
   host	IP-адрес	IP-адрес или FQDN
   hostaddr	IP-адрес	не используется

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

1. Стандартная функция dblink_connect. Создать именованное подключение:
   SELECT dblink_connect('myTest2', 'hostaddr=<IP-адрес> port=5433 dbname=test1 user=user1 password=<password> options=-csearch_path=ext');
   Пример вывода результата:

   Раскрыть type=sql
    dblink_connect
   ----------------
    OK
   (1 row)
   

2. Функция dblink:
   SELECT * FROM dblink('myTest2', 'SELECT * FROM mdt') AS t(a_int int, b_text text, c_time timestamp);
   Пример вывода результата SQL-запроса:

   Раскрыть type=sql
    a_int | b_text |           c_time
   -------+--------+----------------------------
        4 | fourth | 2023-02-21 13:20:57.977069
       11 | first  | 2023-02-21 13:22:30.738639
       22 | second | 2023-02-21 13:22:30.743876
       33 | third  | 2023-02-21 13:22:31.993623
   (4 rows)
   

3. Стандартная функция dblink_connect с использованием параметра host вместо hostaddr в аргументе connstr:
   SELECT dblink_connect('myTest3', 'host=<IP-адрес> port=5433 dbname=test1 user=user1 password=<password> options=-csearch_path=ext');
   Пример вывода результата:

   Раскрыть type=sql
    dblink_connect
   ----------------
    OK
   (1 row)
   

4. Доработанная функция dblink_connect_se. Создать схему pgse_profile:
   CREATE SCHEMA pgse_profile;
   Установить необходимые дополнительные расширения – pg_profile, pg_stat_statements:

   CREATE EXTENSION IF NOT EXISTS pg_stat_statements SCHEMA ext;
   CREATE EXTENSION IF NOT EXISTS pg_profile SCHEMA pgse_profile;
   

   Добавить данные аутентификации пользователя базы данных в шифрованное хранилище паролей:
   pg_auth_config add --host <FQDN_hostname-OR-IPaddress> --port 5433 --database test1 --user user1
   По запросу утилиты ввести интерактивно дважды пароль пользователя.

   Раскрыть type=bash
   enter password:
   *******************
   confirm password:
   *******************
   

   В случае успешного завершения утилита выдает сообщение:

   Going to add auth record for user: "user1", host: "<FQDN_hostname-OR-IPaddress>", port: "5433", database: "test1"
   new record added
   

   Проверка корректности записи в хранилище паролей:
   pg_auth_config check | grep user1
   Успешный результат - OK:
   Connection settings for host: "<FQDN_hostname-OR-IPaddress>", port "5433", database "test1", user "user1" are OK
   Создание подключений dblink функцией dblink_connect_se с использованием хранилища паролей:
   • подключение myTestNew1:
     SELECT pgse_profile.dblink_connect_se('myTestNew1','host=<FQDN_hostname> port=5433 dbname=test1 user=user1');
   • подключение myTestNew2:
     SELECT pgse_profile.dblink_connect_se('myTestNew2','host=<IPaddress> port=5433 dbname=test1 user=user1 options=-csearch_path=ext');
     Успешный результат - OK:

     Раскрыть type=bash
     dblink_connect_se
     -------------------
     OK
     (1 row)
     

5. Функция dblink:
   SELECT * FROM dblink('myTestNew2', 'SELECT * FROM mdt') AS t(a_int int, b_text text, c_time timestamp);
   Пример вывода результата SQL-запроса:

   Раскрыть type=bash
    a_int | b_text |           c_time
   -------+--------+----------------------------
        4 | fourth | 2023-02-21 13:20:57.977069
       11 | first  | 2023-02-21 13:22:30.738639
       22 | second | 2023-02-21 13:22:30.743876
       33 | third  | 2023-02-21 13:22:31.993623
   (4 rows)
   

6. Функция dblink_get_connections выводит имена всех именованных подключений, которые были созданы на данном сервере:
   SELECT dblink_get_connections();
   Пример вывода списка именованных подключений:

   Раскрыть type=bash
     dblink_get_connections
   -------------------------
    {myTestNew1,myTestNew2}
   (1 row)
   

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