inti_aggmtransspace;

inti_agginitval;

inti_aggminitval;

inti_convertok;

inti_proparallel;

const char *aggtransfn;

const char *aggfinalfn;

const char *aggmtransspace;

const char *agginitval;

const char *aggminitval;

boolconvertok;

const char *proparallel;

chardefaultfinalmodify;

"aggkind, "

"aggtransspace, agginitval, "

"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, "

"p.proparallel "

"aggkind, "

"aggtransspace, agginitval, "

"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, "

"p.proparallel "

"aggkind, "

"aggtransspace, agginitval, "

"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 "

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

"'n' AS aggkind, "

"0 AS aggtransspace, agginitval, "

"0 AS aggmtransspace, NULL AS 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 "

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

"'n' AS aggkind, "

"0 AS aggtransspace, agginitval, "

"0 AS aggmtransspace, NULL AS aggminitval, "

"true AS convertok "

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

"WHERE a.aggfnoid = p.oid "

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

"'n' AS aggkind, "

"0 AS aggtransspace, agginitval, "

"0 AS aggmtransspace, NULL AS aggminitval, "

"true AS convertok "

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

"WHERE a.aggfnoid = p.oid "

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

i_aggmtransspace = PQfnumber(res, "aggmtransspace");

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);

aggmtransspace = PQgetvalue(res, 0, i_aggmtransspace);

agginitval = PQgetvalue(res, 0, i_agginitval);

aggminitval = PQgetvalue(res, 0, i_aggminitval);

convertok = (PQgetvalue(res, 0, i_convertok)[0] == 't');

if (fout->remoteVersion >= 80400)

{

else

proparallel = NULL;

if (!convertok)

{

pg_log_warning("aggregate function %s could not be dumped correctly for this database version; ignored",

aggsig);

if (aggfullsig)

free(aggfullsig);

free(aggsig);

return;

}

/* identify default modify flag for aggkind (must match DefineAggregate) */

defaultfinalmodify = (aggkind == AGGKIND_NORMAL) ? AGGMODIFY_READ_ONLY : AGGMODIFY_READ_WRITE;

/* replace omitted flags for old versions */