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 le foreign-data wrapper
dblink_fdw
lors de la définition du serveur distant.
Voir l'exemple ci-dessous ainsi que CREATE SERVER et
CREATE USER MAPPING.
connname
Le nom à utiliser pour la connexion ; en cas d'omission, une connexion sans nom est ouverte, qui remplace toute autre connexion sans nom.
connstr
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 options=-csearch_path=
.
Pour les détails, voir Section 32.1.1.
Sinon, il est possible de donner le nom d'un serveur distant.
Renvoie le statut qui est toujours OK
(puisque toute
erreur amène la fonction à lever une erreur, sans retour).
Si des utilisateurs non dignes de confiance, ont accès à
une base de données qui n'a pas adopté une méthode sécurisée d'usage des
schémas, commencez chaque session en supprimant les schémas
modifiables par tout le monde du paramètre search_path
.
Par exemple, un utilisateur pourrait ajouter
options=-csearch_path=
au
connstr
. Cette considération n'est pas spécifique à
dblink
; elle s'applique à toute interface
permettant d'exécuter des commandes SQL arbitraires.
Le foreign-data wrapper
dblink_fdw
a une option booléenne supplémentaire
use_scram_passthrough
qui contrôle si
dblink
utilisera l'authentification
pass-through SCRAM pour se connecter à la
base distante. Avec cette authentification, dblink
utilise des secrets hachés avec SCRAM plutôt que les mots de passe
enregistrés en clair dans les catalogues systèmes de PostgreSQL. Voir la
documentation de l'option équivalente use_scram_passthrough
de postgres_fdw pour plus de détails.
Seuls les superutilisateurs peuvent utiliser
dblink_connect
pour créer des connexions qui n'utilisent
pas les connexions par mot de passe, ainsi que les connexions par SCRAM ou
GSSAPI. 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 options=-csearch_path='); dblink_connect ---------------- OK (1 row) SELECT dblink_connect('myconn', 'dbname=postgres options=-csearch_path='); dblink_connect ---------------- OK (1 row) -- Fonctionnalité FOREIGN DATA WRAPPER -- Note: les connexions locales qui n'utilisent pas SCRAM nécessitent une -- authentification par mot de passe pour fonctionner correctement. -- Sinon vous recevrez l'erreur suivant 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;