inti_is_identity_sequence;

inti_relacl;

inti_acldefault;

inti_partkeydef;

inti_ispartition;

inti_partbound;

/*

* Find all the tables and table-like objects.

*

* We must fetch all tables in this phase because otherwise we cannot

* correctly identify inherited columns, owned sequences, etc.

*

* We include system catalogs, so that we can work if a user table is

* defined to inherit from a system catalog (pretty weird, but...)

*

* Note: in this phase we should collect only a minimal amount of

* information about each table, basically just enough to decide if it is

* interesting. We must fetch all tables in this phase because otherwise

* we cannot correctly identify inherited columns, owned sequences, etc.

* interesting. In particular, since we do not yet have lock on any user

* table, we MUST NOT invoke any server-side data collection functions

* (for instance, pg_get_partkeydef()). Those are likely to fail or give

* wrong answers if any concurrent DDL is happening.

*/

appendPQExpBuffer(query,

if (fout->remoteVersion >= 90000)

appendPQExpBufferStr(query,

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

"c.reloftype, ");

else

appendPQExpBufferStr(query,

"NULL AS reloftype, ");

"0 AS reloftype, ");

if (fout->remoteVersion >= 90100)

appendPQExpBufferStr(query,

if (fout->remoteVersion >= 100000)

appendPQExpBufferStr(query,

"pg_get_partkeydef(c.oid) AS partkeydef, "

"c.relispartition AS ispartition, "

"pg_get_expr(c.relpartbound, c.oid) AS partbound ");

"c.relispartition AS ispartition ");

else

appendPQExpBufferStr(query,

"NULL AS partkeydef, "

"false AS ispartition, "

"NULL AS partbound ");

"false AS ispartition ");

/*

* Left join to pg_depend to pick up dependency info linking sequences to

i_is_identity_sequence = PQfnumber(res, "is_identity_sequence");

i_relacl = PQfnumber(res, "relacl");

i_acldefault = PQfnumber(res, "acldefault");

i_partkeydef = PQfnumber(res, "partkeydef");

i_ispartition = PQfnumber(res, "ispartition");

i_partbound = PQfnumber(res, "partbound");

if (dopt->lockWaitTimeout)

{

else

tblinfo[i].checkoption = pg_strdup(PQgetvalue(res, i, i_checkoption));

tblinfo[i].toast_reloptions = pg_strdup(PQgetvalue(res, i, i_toastreloptions));

if (PQgetisnull(res, i, i_reloftype))

tblinfo[i].reloftype = NULL;

else

tblinfo[i].reloftype = pg_strdup(PQgetvalue(res, i, i_reloftype));

tblinfo[i].reloftype = atooid(PQgetvalue(res, i, i_reloftype));

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

if (PQgetisnull(res, i, i_amname))

tblinfo[i].amname = NULL;

else

tblinfo[i].amname = pg_strdup(PQgetvalue(res, i, i_amname));

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

tblinfo[i].partkeydef = pg_strdup(PQgetvalue(res, i, i_partkeydef));

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

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

/* other fields were zeroed above */

}

else

{

char *partkeydef = NULL;

char *ftoptions = NULL;

char *srvname = NULL;

char *foreign = "";

/*

* Set reltypename, and collect any relkind-specific data that we

* didn't fetch during getTables().

*/

switch (tbinfo->relkind)

{

case RELKIND_PARTITIONED_TABLE:

{

PQExpBuffer query = createPQExpBuffer();

PGresult *res;

reltypename = "TABLE";

/* retrieve partition key definition */

appendPQExpBuffer(query,

"SELECT pg_get_partkeydef('%u')",

tbinfo->dobj.catId.oid);

res = ExecuteSqlQueryForSingleRow(fout, query->data);

partkeydef = pg_strdup(PQgetvalue(res, 0, 0));

PQclear(res);

destroyPQExpBuffer(query);

break;

}

case RELKIND_FOREIGN_TABLE:

{

PQExpBuffer query = createPQExpBuffer();

break;

default:

reltypename = "TABLE";

break;

}

numParents = tbinfo->numParents;

* Attach to type, if reloftype; except in case of a binary upgrade,

* we dump the table normally and attach it to the type afterward.

*/

if (tbinfo->reloftype && !dopt->binary_upgrade)

appendPQExpBuffer(q, " OF %s", tbinfo->reloftype);

if (OidIsValid(tbinfo->reloftype) && !dopt->binary_upgrade)

appendPQExpBuffer(q, " OF %s",

getFormattedTypeName(fout, tbinfo->reloftype,

zeroIsError));

if (tbinfo->relkind != RELKIND_MATVIEW)

{

* Skip column if fully defined by reloftype, except in

* binary upgrade

*/

if (tbinfo->reloftype && !print_default && !print_notnull &&

if (OidIsValid(tbinfo->reloftype) &&

!print_default && !print_notnull &&

!dopt->binary_upgrade)

continue;

* table ('OF type_name'), but in binary-upgrade mode,

* print it in that case too.

*/

if (dopt->binary_upgrade || !tbinfo->reloftype)

if (dopt->binary_upgrade || !OidIsValid(tbinfo->reloftype))

{

appendPQExpBuffer(q, " %s",

tbinfo->atttypnames[j]);

if (actual_atts)

appendPQExpBufferStr(q, "\n)");

else if (!(tbinfo->reloftype && !dopt->binary_upgrade))

else if (!(OidIsValid(tbinfo->reloftype) && !dopt->binary_upgrade))

{

/*

* No attributes? we must have a parenthesized attribute list,

}

if (tbinfo->relkind == RELKIND_PARTITIONED_TABLE)

appendPQExpBuffer(q, "\nPARTITION BY %s",tbinfo->partkeydef);

appendPQExpBuffer(q, "\nPARTITION BY %s", partkeydef);

if (tbinfo->relkind == RELKIND_FOREIGN_TABLE)

appendPQExpBuffer(q, "\nSERVER %s", fmtId(srvname));

}

}

if (tbinfo->reloftype)

if (OidIsValid(tbinfo->reloftype))

{

appendPQExpBufferStr(q, "\n-- For binary upgrade, set up typed tables this way.\n");

appendPQExpBuffer(q, "ALTER TABLE ONLY %s OF %s;\n",

qualrelname,

tbinfo->reloftype);

getFormattedTypeName(fout, tbinfo->reloftype,

zeroIsError));

}

}

tbinfo->attfdwoptions[j]);

}/* end loop over columns */

if (partkeydef)

free(partkeydef);

if (ftoptions)

free(ftoptions);

if (srvname)

{

DumpOptions *dopt = fout->dopt;

PQExpBuffer q;

PGresult *res;

char *partbound;

/* Do nothing in data-only dump */

if (dopt->dataOnly)

q = createPQExpBuffer();

/*Perform ALTER TABLE ontheparent */

/*Fetchthepartition's partbound */

appendPQExpBuffer(q,

"SELECT pg_get_expr(c.relpartbound, c.oid) "

"FROM pg_class c "

"WHERE c.oid = '%u'",

attachinfo->partitionTbl->dobj.catId.oid);

res = ExecuteSqlQueryForSingleRow(fout, q->data);

partbound = PQgetvalue(res, 0, 0);

/* Perform ALTER TABLE on the parent */

printfPQExpBuffer(q,

"ALTER TABLE ONLY %s ",

fmtQualifiedDumpable(attachinfo->parentTbl));

appendPQExpBuffer(q,

"ATTACH PARTITION %s %s;\n",

fmtQualifiedDumpable(attachinfo->partitionTbl),

attachinfo->partitionTbl->partbound);

partbound);

/*

* There is no point in creating a drop query as the drop is done by table

.section = SECTION_PRE_DATA,

.createStmt = q->data));

PQclear(res);

destroyPQExpBuffer(q);

}

uint32toast_minmxid;/* toast table's relminmxid */

intncheck;/* # of CHECK expressions */

Oidreltype;/* OID of table's composite type, if any */

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

Oidreloftype;/* underlying type for typed table */

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

Oidowning_tab;/* OID of table owning sequence */

bool*inhNotNull;/* true if NOT NULL is inherited */

struct_attrDefInfo**attrdefs;/* DEFAULT expressions */

struct_constraintInfo*checkexprs;/* CHECK constraints */

char*partkeydef;/* partition key definition */

char*partbound;/* partition bound definition */

boolneeds_override;/* has GENERATED ALWAYS AS IDENTITY */

char*amname;/* relation access method */