diff options
| -rw-r--r-- | contrib/dblink/dblink.c | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/contrib/dblink/dblink.c b/contrib/dblink/dblink.c index 18271b24f76..0bea6487ec3 100644 --- a/contrib/dblink/dblink.c +++ b/contrib/dblink/dblink.c @@ -1980,9 +1980,14 @@ createNewConnection(const char *name, remoteConn * con) errmsg("out of memory"))); if (found) + { + PQfinish(rconn->conn); + pfree(rconn); + ereport(ERROR, (errcode(ERRCODE_DUPLICATE_OBJECT), errmsg("duplicate connection name"))); + } hentry->rcon = con; strncpy(hentry->name, name, NAMEDATALEN - 1); |