inti_agginitval;

inti_aggminitval;

inti_convertok;

inti_proparallel;

const char *aggtransfn;

const char *aggfinalfn;

const char *aggcombinefn;

const char *agginitval;

const char *aggminitval;

boolconvertok;

const char *proparallel;

/* Skip if not to be dumped */

if (!agginfo->aggfn.dobj.dump || dopt->dataOnly)

"aggmtransspace, aggminitval, "

"true AS convertok, "

"pg_catalog.pg_get_function_arguments(p.oid) AS funcargs, "

"pg_catalog.pg_get_function_identity_arguments(p.oid) AS funciargs "

"pg_catalog.pg_get_function_identity_arguments(p.oid) AS funciargs, "

"p.proparallel "

"FROM pg_catalog.pg_aggregate a, pg_catalog.pg_proc p "

"WHERE a.aggfnoid = p.oid "

"AND p.oid = '%u'::pg_catalog.oid",

i_agginitval = PQfnumber(res, "agginitval");

i_aggminitval = PQfnumber(res, "aggminitval");

i_convertok = PQfnumber(res, "convertok");

i_proparallel = PQfnumber(res, "proparallel");

aggtransfn = PQgetvalue(res, 0, i_aggtransfn);

aggfinalfn = PQgetvalue(res, 0, i_aggfinalfn);

aggsig_tag = format_aggregate_signature(agginfo, fout, false);

if (i_proparallel != -1)

proparallel = PQgetvalue(res, 0, PQfnumber(res, "proparallel"));

else

proparallel = NULL;

if (!convertok)

{

write_msg(NULL, "WARNING: aggregate function %s could not be dumped correctly for this database version; ignored\n",

if (hypothetical)

appendPQExpBufferStr(details, ",\n HYPOTHETICAL");

if (proparallel != NULL && proparallel[0] != PROPARALLEL_UNSAFE)

{

if (proparallel[0] == PROPARALLEL_SAFE)

appendPQExpBufferStr(details, ",\n PARALLEL = safe");

else if (proparallel[0] == PROPARALLEL_RESTRICTED)

appendPQExpBufferStr(details, ",\n PARALLEL = restricted");

else if (proparallel[0] != PROPARALLEL_UNSAFE)

exit_horribly(NULL, "unrecognized proparallel value for function \"%s\"\n",

agginfo->aggfn.dobj.name);

}

/*

* DROP must be fully qualified in case same name appears in pg_catalog

*/