Descripción

dblink_connect() establece una conexión a una base de datos remota de PostgreSQL. El servidor y la base de datos a contactar se identifican a través de una cadena de conexión estándar de libpq. Opcionalmente, se le puede asignar un nombre a la conexión. Se pueden tener abiertas varias conexiones nombradas a la vez, pero solo se permite una conexión sin nombre al mismo tiempo. La conexión persistirá hasta que se cierre o hasta que finalice la sesión de la base de datos.

La cadena de conexión también puede ser el nombre de un servidor extranjero existente. Se recomienda utilizar el envoltorio de datos extranjeros (foreign-data wrapper) dblink_fdw al definir el servidor extranjero. Consulta el ejemplo de abajo, así como CREATE SERVER y CREATE USER MAPPING.

Argumentos

Valor de retorno

Devuelve el estado, que siempre es OK (ya que cualquier error hace que la función lance un error en lugar de retornar).

Notas

Si los usuarios no confiables tienen acceso a una base de datos que no ha adoptado un patrón de uso seguro de esquemas, comienza cada sesión eliminando los esquemas con permisos de escritura pública de search_path. Podrías, por ejemplo, añadir options=-csearch_path= a connstr. Esta consideración no es específica de dblink; se aplica a cualquier interfaz para ejecutar comandos SQL arbitrarios.

El envoltorio de datos extranjeros dblink_fdw tiene una opción booleana adicional use_scram_passthrough que controla si dblink utilizará la autenticación SCRAM pass-through para conectarse a la base de datos remota. Con la autenticación SCRAM pass-through, dblink utiliza secretos cifrados con SCRAM en lugar de contraseñas de usuario en texto plano para conectarse al servidor remoto. Esto evita almacenar contraseñas de usuario en texto plano en los catálogos del sistema de PostgreSQL. Consulta la documentación de la opción equivalente use_scram_passthrough de postgres_fdw para obtener más detalles y restricciones.

Solo los superusuarios pueden utilizar dblink_connect para crear conexiones que no utilicen autenticación por contraseña, SCRAM pass-through, ni autenticación GSSAPI. Si los usuarios que no son superusuarios necesitan esta capacidad, utiliza dblink_connect_u en su lugar.

No es aconsejable elegir nombres de conexión que contengan signos de igualdad, ya que esto abre el riesgo de confusión con las cadenas de información de conexión en otras funciones de dblink.

Ejemplos

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)

-- Funcionalidad de FOREIGN DATA WRAPPER
-- Nota: las conexiones locales que no usan SCRAM pass-through requieren autenticación
--       por contraseña para que esto funcione correctamente. De lo contrario, recibirás
--       el siguiente error de 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;