</listitem>

</varlistentry>

<varlistentry>

<term><option>--include-foreign-data=<replaceable class="parameter">foreignserver</replaceable></option></term>

<listitem>

<para>

Dump the data for any foreign table with a foreign server

matching <replaceable class="parameter">foreignserver</replaceable>

pattern. Multiple foreign servers can be selected by writing multiple

<option>--include-foreign-data</option> switches.

Also, the <replaceable class="parameter">foreignserver</replaceable> parameter is

interpreted as a pattern according to the same rules used by

<application>psql</application>'s <literal>\d</literal> commands (see <xref

linkend="app-psql-patterns" endterm="app-psql-patterns-title"/>),

so multiple foreign servers can also be selected by writing wildcard characters

in the pattern. When using wildcards, be careful to quote the pattern

if needed to prevent the shell from expanding the wildcards; see

<xref linkend="pg-dump-examples" endterm="pg-dump-examples-title"/>.

The only exception is that an empty pattern is disallowed.

</para>

<note>

<para>

When <option>--include-foreign-data</option> is specified,

<application>pg_dump</application> does not check that the foreign

table is writeable. Therefore, there is no guarantee that the

results of a foreign table dump can be successfully restored.

</para>

</note>

</listitem>

</varlistentry>

<varlistentry>

<term><option>--inserts</option></term>

<listitem>

static SimpleOidList table_exclude_oids = {NULL, NULL};

static SimpleStringList tabledata_exclude_patterns = {NULL, NULL};

static SimpleOidList tabledata_exclude_oids = {NULL, NULL};

static SimpleStringList foreign_servers_include_patterns = {NULL, NULL};

static SimpleOidList foreign_servers_include_oids = {NULL, NULL};

/* placeholders for the delimiters for comments */

SimpleStringList *patterns,

SimpleOidList *oids,

bool strict_names);

static void expand_foreign_server_name_patterns(Archive *fout,

SimpleStringList *patterns,

SimpleOidList *oids);

static void expand_table_name_patterns(Archive *fout,

SimpleStringList *patterns,

SimpleOidList *oids,

{"no-sync", no_argument, NULL, 7},

{"on-conflict-do-nothing", no_argument, &dopt.do_nothing, 1},

{"rows-per-insert", required_argument, NULL, 10},

{"include-foreign-data", required_argument, NULL, 11},

{NULL, 0, NULL, 0}

};

dopt.dump_inserts = (int) rowsPerInsert;

break;

case 11:/* include foreign data */

simple_string_list_append(&foreign_servers_include_patterns,

optarg);

break;

default:

fprintf(stderr, _("Try \"%s --help\" for more information.\n"), progname);

exit_nicely(1);

exit_nicely(1);

}

if (dopt.schemaOnly && foreign_servers_include_patterns.head != NULL)

fatal("options -s/--schema-only and --include-foreign-data cannot be used together");

if (numWorkers > 1 && foreign_servers_include_patterns.head != NULL)

fatal("option --include-foreign-data is not supported with parallel backup");

if (dopt.dataOnly && dopt.outputClean)

{

pg_log_error("options -c/--clean and -a/--data-only cannot be used together");

&tabledata_exclude_oids,

false);

expand_foreign_server_name_patterns(fout, &foreign_servers_include_patterns,

&foreign_servers_include_oids);

/* non-matching exclusion patterns aren't an error */

/*

printf(_(" --exclude-table-data=PATTERN do NOT dump data for the specified table(s)\n"));

printf(_(" --extra-float-digits=NUM override default setting for extra_float_digits\n"));

printf(_(" --if-exists use IF EXISTS when dropping objects\n"));

printf(_(" --include-foreign-data=PATTERN\n"

" include data of foreign tables in\n"

" foreign servers matching PATTERN\n"));

printf(_(" --inserts dump data as INSERT commands, rather than COPY\n"));

printf(_(" --load-via-partition-root load partitions via the root table\n"));

printf(_(" --no-comments do not dump comments\n"));

destroyPQExpBuffer(query);

}

/*

* Find the OIDs of all foreign servers matching the given list of patterns,

* and append them to the given OID list.

*/

static void

expand_foreign_server_name_patterns(Archive *fout,

SimpleStringList *patterns,

SimpleOidList *oids)

{

PQExpBuffer query;

PGresult *res;

SimpleStringListCell *cell;

inti;

if (patterns->head == NULL)

return;/* nothing to do */

query = createPQExpBuffer();

/*

* The loop below runs multiple SELECTs might sometimes result in

* duplicate entries in the OID list, but we don't care.

*/

for (cell = patterns->head; cell; cell = cell->next)

{

appendPQExpBuffer(query,

"SELECT oid FROM pg_catalog.pg_foreign_server s\n");

processSQLNamePattern(GetConnection(fout), query, cell->val, false,

false, NULL, "s.srvname", NULL, NULL);

res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

if (PQntuples(res) == 0)

fatal("no matching foreign servers were found for pattern \"%s\"", cell->val);

for (i = 0; i < PQntuples(res); i++)

simple_oid_list_append(oids, atooid(PQgetvalue(res, i, 0)));

PQclear(res);

resetPQExpBuffer(query);

}

destroyPQExpBuffer(query);

}

/*

* Find the OIDs of all tables matching the given list of patterns,

* and append them to the given OID list. See also expand_dbname_patterns()

*- this routine is called by the Archiver when it wants the table

* to be dumped.

*/

static int

dumpTableData_copy(Archive *fout, void *dcontext)

{

*/

column_list = fmtCopyColumnList(tbinfo, clistBuf);

if (tdinfo->filtercond)

/*

* Use COPY (SELECT ...) TO when dumping a foreign table's data, and when

* a filter condition was specified. For other cases a simple COPY

* suffices.

*/

if (tdinfo->filtercond || tbinfo->relkind == RELKIND_FOREIGN_TABLE)

{

/* Note: this syntax is only supported in 8.2 and up */

appendPQExpBufferStr(q, "COPY (SELECT ");

}

else

appendPQExpBufferStr(q, "* ");

appendPQExpBuffer(q, "FROM %s %s) TO stdout;",

fmtQualifiedDumpable(tbinfo),

tdinfo->filtercond);

tdinfo->filtercond ? tdinfo->filtercond : "");

}

else

{

/* Skip VIEWs (no data to dump) */

if (tbinfo->relkind == RELKIND_VIEW)

return;

/* Skip FOREIGN TABLEs (no data to dump) */

if (tbinfo->relkind == RELKIND_FOREIGN_TABLE)

/* Skip FOREIGN TABLEs (no data to dump) unless requested explicitly */

if (tbinfo->relkind == RELKIND_FOREIGN_TABLE &&

(foreign_servers_include_oids.head == NULL ||

!simple_oid_list_member(&foreign_servers_include_oids,

tbinfo->foreign_server)))

return;

/* Skip partitioned tables (data in partitions) */

if (tbinfo->relkind == RELKIND_PARTITIONED_TABLE)

inti_toastreloptions;

inti_reloftype;

inti_relpages;

inti_foreignserver;

inti_is_identity_sequence;

inti_changed_acl;

inti_partkeydef;

"tc.relminmxid AS tminmxid, "

"c.relpersistence, c.relispopulated, "

"c.relreplident, c.relpages, am.amname, "

"CASE WHEN c.relkind = 'f' THEN "

"(SELECT ftserver FROM pg_catalog.pg_foreign_table WHERE ftrelid = c.oid) "

"ELSE 0 END AS foreignserver, "

"CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"c.relpersistence, c.relispopulated, "

"c.relreplident, c.relpages, "

"NULL AS amname, "

"CASE WHEN c.relkind = 'f' THEN "

"(SELECT ftserver FROM pg_catalog.pg_foreign_table WHERE ftrelid = c.oid) "

"ELSE 0 END AS foreignserver, "

"CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"c.relpersistence, c.relispopulated, "

"c.relreplident, c.relpages, "

"NULL AS amname, "

"CASE WHEN c.relkind = 'f' THEN "

"(SELECT ftserver FROM pg_catalog.pg_foreign_table WHERE ftrelid = c.oid) "

"ELSE 0 END AS foreignserver, "

"CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"c.relpersistence, c.relispopulated, "

"'d' AS relreplident, c.relpages, "

"NULL AS amname, "

"CASE WHEN c.relkind = 'f' THEN "

"(SELECT ftserver FROM pg_catalog.pg_foreign_table WHERE ftrelid = c.oid) "

"ELSE 0 END AS foreignserver, "

"CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"c.relpersistence, 't' as relispopulated, "

"'d' AS relreplident, c.relpages, "

"NULL AS amname, "

"CASE WHEN c.relkind = 'f' THEN "

"(SELECT ftserver FROM pg_catalog.pg_foreign_table WHERE ftrelid = c.oid) "

"ELSE 0 END AS foreignserver, "

"CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"'p' AS relpersistence, 't' as relispopulated, "

"'d' AS relreplident, c.relpages, "

"NULL AS amname, "

"NULL AS foreignserver, "

"CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"'p' AS relpersistence, 't' as relispopulated, "

"'d' AS relreplident, c.relpages, "

"NULL AS amname, "

"NULL AS foreignserver, "

"NULL AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"'p' AS relpersistence, 't' as relispopulated, "

"'d' AS relreplident, c.relpages, "

"NULL AS amname, "

"NULL AS foreignserver, "

"NULL AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

"'p' AS relpersistence, 't' as relispopulated, "

"'d' AS relreplident, relpages, "

"NULL AS amname, "

"NULL AS foreignserver, "

"NULL AS reloftype, "

"d.refobjid AS owning_tab, "

"d.refobjsubid AS owning_col, "

i_relispopulated = PQfnumber(res, "relispopulated");

i_relreplident = PQfnumber(res, "relreplident");

i_relpages = PQfnumber(res, "relpages");

i_foreignserver = PQfnumber(res, "foreignserver");

i_owning_tab = PQfnumber(res, "owning_tab");

i_owning_col = PQfnumber(res, "owning_col");

i_reltablespace = PQfnumber(res, "reltablespace");

tblinfo[i].ispartition = (strcmp(PQgetvalue(res, i, i_ispartition), "t") == 0);

tblinfo[i].partbound = pg_strdup(PQgetvalue(res, i, i_partbound));

/* foreign server */

tblinfo[i].foreign_server = atooid(PQgetvalue(res, i, i_foreignserver));

/*

* Read-lock target tables to make sure they aren't DROPPED or altered

* in schema before we get around to dumping them.

uint32toast_minmxid;/* toast table's relminmxid */

intncheck;/* # of CHECK expressions */

char*reloftype;/* underlying type for typed table */

Oidforeign_server;/* foreign server oid, if applicable */

Oidowning_tab;/* OID of table owning sequence */

intowning_col;/* attr # of column owning sequence */

use Config;

use PostgresNode;

use TestLib;

use Test::Moretests=>74;

use Test::Moretests=>78;

my$tempdir = TestLib::tempdir;

my$tempdir_short = TestLib::tempdir_short;

);

command_fails_like(

['pg_dump','-s','--include-foreign-data=xxx' ],

qr/\Qpg_dump: error: options -s\/--schema-only and --include-foreign-data cannot be used together\E/,

);

command_fails_like(

['pg_dump','-j2','--include-foreign-data=xxx' ],

qr/\Qpg_dump: error: option --include-foreign-data is not supported with parallel backup\E/,

);

command_fails_like(

['pg_restore'],

qr{\Qpg_restore: error: one of -d/--dbname and -f/--file must be specified\E},

use strict;

use warnings;

use PostgresNode;

use TestLib;

use Test::Moretests=> 3;

my$tempdir = TestLib::tempdir;

my$tempdir_short = TestLib::tempdir_short;

my$node = get_new_node('main');

my$port =$node->port;

$node->init;

$node->start;

$node->safe_psql('postgres',"CREATE FOREIGN DATA WRAPPER dummy");

$node->safe_psql('postgres',"CREATE SERVER s0 FOREIGN DATA WRAPPER dummy");

$node->safe_psql('postgres',"CREATE SERVER s1 FOREIGN DATA WRAPPER dummy");

$node->safe_psql('postgres',"CREATE SERVER s2 FOREIGN DATA WRAPPER dummy");

$node->safe_psql('postgres',"CREATE FOREIGN TABLE t0 (a int) SERVER s0");

$node->safe_psql('postgres',"CREATE FOREIGN TABLE t1 (a int) SERVER s1");

my ($cmd,$stdout,$stderr,$result);

command_fails_like(

["pg_dump",'-p',$port,'postgres','--include-foreign-data=s0' ],

qr/foreign-data wrapper\"dummy\" has no handler\r?\npg_dump: error: query was:.*t0/,

"correctly fails to dump a foreign table from a dummy FDW");

command_ok(

["pg_dump",'-p',$port,'postgres','-a','--include-foreign-data=s2' ] ,

"dump foreign server with no tables");