dblink_connect

примечание

Эта страница переведена при помощи нейросети GigaChat.

dblink_connect – открывает постоянное соединение с удаленной базой данных.

Синтаксис

dblink_connect(text connstr) returns text
dblink_connect(text connname, text connstr) returns text

Описание

dblink_connect() устанавливает соединение с удаленной базой данных PostgreSQL. Сервер и база данных для связи определяются через стандартную строку подключения libpq. Если требуется, можно присвоить имя соединению. Можно одновременно открыть несколько именованных соединений, но за раз допускается только одно неименованное соединение. Соединение будет сохраняться до тех пор, пока оно не будет закрыто или пока сеанс работы с базой данных не завершится.

Строка подключения также может быть именем существующего внешнего сервера. Рекомендуется использовать внешнюю обертка для данных dblink_fdw при определении внешнего сервера. Подробнее смотрите пример ниже, а также CREATE SERVER и CREATE USER MAPPING.

Аргументы

connname

Имя, которое следует использовать для этого соединения. Если опустить, открывается неподписанное соединение, заменяющее любое существующее неподписанное соединение.

connstr

Строка подключения в стиле libpq, например hostaddr=127.0.0.1 port=5432 dbname=mydb user=postgres password=mypasswd options=-csearch_path=. В качестве альтернативы можно указать имя внешнего сервера.

Возвращаемое значение

Функция всегда возвращает статус, который равен OK (поскольку любая ошибка приводит к тому, что функция вместо возврата значения генерирует ошибку).

Примечания

Если недоверенные пользователи имеют доступ к базе данных, которая не использует безопасный шаблон использования схемы, начинайте каждую сессию с удаления общедоступных схем для записи из search_path. Например, можно добавить options=-csearch_path= к connstr. Это соображение не является специфическим для dblink, оно применяется ко всем интерфейсам для выполнения произвольных команд SQL.

Оболочка внешних данных dblink_fdw имеет дополнительную логическую опцию use_scram_passthrough, которая управляет тем, будет ли dblink использовать сквозную аутентификацию SCRAM для подключения к удаленной базе данных. При сквозной аутентификации SCRAM dblink использует хешированные секреты SCRAM вместо паролей пользователей в открытом виде для подключения к удаленному серверу. Это позволяет избежать хранения паролей пользователей в открытом виде в системных каталогах PostgreSQL.

Только суперпользователи могут использовать dblink_connect для создания соединений, которые не используют аутентификацию по паролю, сквозную передачу SCRAM или аутентификацию GSSAPI. Если пользователям без прав суперпользователей необходима эта возможность, используйте вместо этого dblink_connect_u.

Не рекомендуется выбирать имена соединений, содержащие знаки равенства, поскольку это может привести к путанице со строками информации о соединениях в других функциях dblink.

Примеры

SELECT dblink_connect('dbname=postgres options=-csearch_path=');
 dblink_connect
----------------
 OK
(1 row)

SELECT dblink_connect('myconn', 'dbname=postgres options=-csearch_path=');
 dblink_connect
----------------
 OK
(1 row)

-- FOREIGN DATA WRAPPER functionality
-- Note: local connections that don't use SCRAM pass-through require password
--       authentication for this to work properly. Otherwise, you will receive
--       the following error from dblink_connect():
--       ERROR:  password is required
--       DETAIL:  Non-superuser cannot connect if the server does not request a password.
--       HINT:  Target server's authentication method must be changed.

CREATE SERVER fdtest FOREIGN DATA WRAPPER dblink_fdw OPTIONS (hostaddr '127.0.0.1', dbname 'contrib_regression');

CREATE USER regress_dblink_user WITH PASSWORD 'secret';
CREATE USER MAPPING FOR regress_dblink_user SERVER fdtest OPTIONS (user 'regress_dblink_user', password 'secret');
GRANT USAGE ON FOREIGN SERVER fdtest TO regress_dblink_user;
GRANT SELECT ON TABLE foo TO regress_dblink_user;

\set ORIGINAL_USER :USER
\c - regress_dblink_user
SELECT dblink_connect('myconn', 'fdtest');
 dblink_connect
----------------
 OK
(1 row)

SELECT * FROM dblink('myconn', 'SELECT * FROM foo') AS t(a int, b text, c text[]);
 a  | b |       c
----+---+---------------
  0 | a | {a0,b0,c0}
  1 | b | {a1,b1,c1}
  2 | c | {a2,b2,c2}
  3 | d | {a3,b3,c3}
  4 | e | {a4,b4,c4}
  5 | f | {a5,b5,c5}
  6 | g | {a6,b6,c6}
  7 | h | {a7,b7,c7}
  8 | i | {a8,b8,c8}
  9 | j | {a9,b9,c9}
 10 | k | {a10,b10,c10}
(11 rows)

\c - :ORIGINAL_USER
REVOKE USAGE ON FOREIGN SERVER fdtest FROM regress_dblink_user;
REVOKE SELECT ON TABLE foo FROM regress_dblink_user;
DROP USER MAPPING FOR regress_dblink_user SERVER fdtest;
DROP USER regress_dblink_user;
DROP SERVER fdtest;