boolhave_error;/* have any subxacts aborted in this xact? */

boolchanging_xact_state;/* xact state change in process */

boolinvalidated;/* true if reconnect is pending */

boolkeep_connections;/* setting value of keep_connections

Oidserverid;/* foreign server OID used to get server name */

uint32server_hashvalue;/* hash value of foreign server OID */

uint32mapping_hashvalue;/* hash value of user mapping OID */

make_new_connection(ConnCacheEntry*entry,UserMapping*user)

{

ForeignServer*server=GetForeignServer(user->serverid);

ListCell*lc;

Assert(entry->conn==NULL);

ObjectIdGetDatum(user->umid));

memset(&entry->state,0,sizeof(entry->state));

entry->keep_connections= true;

foreach(lc,server->options)

{

DefElem*def= (DefElem*)lfirst(lc);

if (strcmp(def->defname,"keep_connections")==0)

entry->keep_connections=defGetBoolean(def);

}

entry->conn=connect_pg_server(server,user);

entry->xact_depth=0;

if (PQstatus(entry->conn)!=CONNECTION_OK||

PQtransactionStatus(entry->conn)!=PQTRANS_IDLE||

entry->invalidated)

!entry->keep_connections)

{

elog(DEBUG3,"discarding connection %p",entry->conn);

disconnect_pg_server(entry);

END;

$d$;

ERROR: invalid option "password"

HINT: Valid options in this context are: service, passfile, channel_binding, connect_timeout, dbname, host, hostaddr, port, options, application_name, keepalives, keepalives_idle, keepalives_interval, keepalives_count, tcp_user_timeout, sslmode, sslcompression, sslcert, sslkey, sslrootcert, sslcrl, sslcrldir, requirepeer, ssl_min_protocol_version, ssl_max_protocol_version, gssencmode, krbsrvname, gsslib, target_session_attrs, use_remote_estimate, fdw_startup_cost, fdw_tuple_cost, extensions, updatable, fetch_size, batch_size, async_capable

HINT: Valid options in this context are: service, passfile, channel_binding, connect_timeout, dbname, host, hostaddr, port, options, application_name, keepalives, keepalives_idle, keepalives_interval, keepalives_count, tcp_user_timeout, sslmode, sslcompression, sslcert, sslkey, sslrootcert, sslcrl, sslcrldir, requirepeer, ssl_min_protocol_version, ssl_max_protocol_version, gssencmode, krbsrvname, gsslib, target_session_attrs, use_remote_estimate, fdw_startup_cost, fdw_tuple_cost, extensions, updatable, fetch_size, batch_size, async_capable, keep_connections

CONTEXT: SQL statement "ALTER SERVER loopback_nopw OPTIONS (ADD password 'dummypw')"

PL/pgSQL function inline_code_block line 3 at EXECUTE

-- If we add a password for our user mapping instead, we should get a different

DROP ROLE regress_multi_conn_user1;

DROP ROLE regress_multi_conn_user2;

-- ===================================================================

-- Test foreign server level option keep_connections

-- ===================================================================

-- By default, the connections associated with foreign server are cached i.e.

-- keep_connections option is on. Set it to off.

ALTER SERVER loopback OPTIONS (keep_connections 'off');

-- connection to loopback server is closed at the end of xact

-- as keep_connections was set to off.

SELECT 1 FROM ft1 LIMIT 1;

?column?

----------

1

(1 row)

-- No cached connections, so no records should be output.

SELECT server_name FROM postgres_fdw_get_connections() ORDER BY 1;

server_name

-------------

(0 rows)

ALTER SERVER loopback OPTIONS (SET keep_connections 'on');

-- ===================================================================

-- batch insert

-- ===================================================================

BEGIN;

if (strcmp(def->defname,"use_remote_estimate")==0||

strcmp(def->defname,"updatable")==0||

strcmp(def->defname,"async_capable")==0)

strcmp(def->defname,"async_capable")==0||

strcmp(def->defname,"keep_connections")==0)

{

(void)defGetBoolean(def);

{"async_capable",ForeignServerRelationId, false},

{"async_capable",ForeignTableRelationId, false},

{"keep_connections",ForeignServerRelationId, false},

{"password_required",UserMappingRelationId, false},

DROP ROLE regress_multi_conn_user1;

DROP ROLE regress_multi_conn_user2;

ALTER SERVER loopback OPTIONS (keep_connections'off');

SELECT1FROM ft1LIMIT1;

SELECT server_nameFROM postgres_fdw_get_connections()ORDER BY1;

ALTER SERVER loopback OPTIONS (SET keep_connections'on');

</para>

</sect3>

<sect3>

<title>Connection Management Options</title>

<para>

By default all the open connections that <filename>postgres_fdw</filename>

established to the foreign servers are kept in local session for re-use.

</para>

<variablelist>

<varlistentry>

<term><literal>keep_connections</literal></term>

<listitem>

<para>

This option controls whether <filename>postgres_fdw</filename> keeps

the connections to the foreign server open so that the subsequent

queries can re-use them. It can only be specified for a foreign server.

The default is <literal>on</literal>. If set to <literal>off</literal>,

all connections to this foreign server will be discarded at the end of

transaction.

</para>

</listitem>

</varlistentry>

</variablelist>

</sect3>

</sect2>

<sect2>

<para>

<filename>postgres_fdw</filename> establishes a connection to a

foreign server during the first query that uses a foreign table

associated with the foreign server. This connection is kept and

re-used for subsequent queries in the same session. However, if

associated with the foreign server. By default this connection

is kept and re-used for subsequent queries in the same session.

This behavior can be controlled using

<literal>keep_connections</literal> option for a foreign server. If

multiple user identities (user mappings) are used to access the foreign

server, a connection is established for each user mapping.

</para>

<para>

Once a connection to a foreign server has been established,

it'susually kept until the local or corresponding remote

it'sby default kept until the local or corresponding remote

session exits. To disconnect a connection explicitly,

<literal>keep_connections</literal> option for a foreign server

may be disabled, or

<function>postgres_fdw_disconnect</function> and

<function>postgres_fdw_disconnect_all</function> functions

may be used. For example, these are useful to close