dblink_connect — ouvre une connexion persistante vers une base de données distante.
dblink_connect(text connstr) returns text
dblink_connect(text connname, text connstr) returns text
dblink_connect() établit une connexion à une base de données PostgreSQL™ distante. Le serveur et la base de données à contacter sont identifiées par une chaine de connexion standard de la libpq. Il est possible d'affecter un nom à la connexion. Plusieurs connexions nommées peuvent être ouvertes en une seule fois, mais il ne peut y avoir qu'une seule connexion anonyme à la fois. Toute connexion est maintenue jusqu'à ce qu'elle soit close ou que la session de base de données soit terminée.
La chaîne de connexion peut aussi être le nom d'un serveur distant existant. Il est recommandé d'utiliser postgresql_fdw_validator lors de la définition d'un wrapper de données distantes correspondant. Voir l'exemple ci-dessous, ainsi que : CREATE FOREIGN DATA WRAPPER, CREATE SERVER, CREATE USER MAPPING
Le nom à utiliser pour la connexion ; en cas d'omission, une connexion sans nom est ouverte, qui remplace toute autre connexion sans nom.
Chaîne de connexion au format standard de la libpq, par exemple hostaddr=127.0.0.1 port=5432 dbname=mabase user=postgres password=monmotdepasse. Pour les détails, voir PQconnectdb dans Section 30.1, « Fonctions de contrôle de connexion à la base de données ».
Renvoie le statut qui est toujours OK (puisque toute erreur amène la fonction à lever une erreur, sans retour).
Seuls les super-utilisateurs peuvent utiliser dblink_connect pour créer des connexions authentifiées sans mot de passe. Si des utilisateurs standard ont ce besoin, il faut utiliser la fonction dblink_connect_u à sa place.
Il est déconseillé de choisir des noms de connexion contenant des signes d'égalité car ils peuvent introduire des risques de confusion avec les chaînes de connexion dans les autres fonctions dblink.
select dblink_connect('dbname=postgres');
dblink_connect
----------------
OK
(1 row)
select dblink_connect('myconn', 'dbname=postgres');
dblink_connect
----------------
OK
(1 row)
-- Fonctionnalité FOREIGN DATA WRAPPER
-- Note : la connexion locale nécessite l'authentification password pour que
-- cela fonctionne correctement
-- Sinon, vous recevrez le message d'erreur suivant provenant 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 USER dblink_regression_test WITH PASSWORD 'secret';
CREATE FOREIGN DATA WRAPPER postgresql VALIDATOR postgresql_fdw_validator;
CREATE SERVER fdtest FOREIGN DATA WRAPPER postgresql OPTIONS (hostaddr '127.0.0.1', dbname 'contrib_regression');
CREATE USER MAPPING FOR dblink_regression_test SERVER fdtest OPTIONS (user 'dblink_regression_test', password 'secret');
GRANT USAGE ON FOREIGN SERVER fdtest TO dblink_regression_test;
GRANT SELECT ON TABLE foo TO dblink_regression_test;
\set ORIGINAL_USER :USER
\c - dblink_regression_test
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 dblink_regression_test;
REVOKE SELECT ON TABLE foo FROM dblink_regression_test;
DROP USER MAPPING FOR dblink_regression_test SERVER fdtest;
DROP USER dblink_regression_test;
DROP SERVER fdtest;
DROP FOREIGN DATA WRAPPER postgresql;
dblink
