@@ -13959,7 +13959,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
13959
13959
int i_aggmtransspace;
13960
13960
int i_agginitval;
13961
13961
int i_aggminitval;
13962
- int i_convertok;
13963
13962
int i_proparallel;
13964
13963
const char *aggtransfn;
13965
13964
const char *aggfinalfn;
@@ -13982,7 +13981,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
13982
13981
const char *aggmtransspace;
13983
13982
const char *agginitval;
13984
13983
const char *aggminitval;
13985
- bool convertok;
13986
13984
const char *proparallel;
13987
13985
char defaultfinalmodify;
13988
13986
@@ -14008,7 +14006,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14008
14006
"aggkind, "
14009
14007
"aggtransspace, agginitval, "
14010
14008
"aggmtransspace, aggminitval, "
14011
- "true AS convertok, "
14012
14009
"pg_catalog.pg_get_function_arguments(p.oid) AS funcargs, "
14013
14010
"pg_catalog.pg_get_function_identity_arguments(p.oid) AS funciargs, "
14014
14011
"p.proparallel "
@@ -14029,7 +14026,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14029
14026
"aggkind, "
14030
14027
"aggtransspace, agginitval, "
14031
14028
"aggmtransspace, aggminitval, "
14032
- "true AS convertok, "
14033
14029
"pg_catalog.pg_get_function_arguments(p.oid) AS funcargs, "
14034
14030
"pg_catalog.pg_get_function_identity_arguments(p.oid) AS funciargs, "
14035
14031
"p.proparallel "
@@ -14051,7 +14047,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14051
14047
"aggkind, "
14052
14048
"aggtransspace, agginitval, "
14053
14049
"aggmtransspace, aggminitval, "
14054
- "true AS convertok, "
14055
14050
"pg_catalog.pg_get_function_arguments(p.oid) AS funcargs, "
14056
14051
"pg_catalog.pg_get_function_identity_arguments(p.oid) AS funciargs "
14057
14052
"FROM pg_catalog.pg_aggregate a, pg_catalog.pg_proc p "
@@ -14073,7 +14068,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14073
14068
"'n' AS aggkind, "
14074
14069
"0 AS aggtransspace, agginitval, "
14075
14070
"0 AS aggmtransspace, NULL AS aggminitval, "
14076
- "true AS convertok, "
14077
14071
"pg_catalog.pg_get_function_arguments(p.oid) AS funcargs, "
14078
14072
"pg_catalog.pg_get_function_identity_arguments(p.oid) AS funciargs "
14079
14073
"FROM pg_catalog.pg_aggregate a, pg_catalog.pg_proc p "
@@ -14095,7 +14089,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14095
14089
"'n' AS aggkind, "
14096
14090
"0 AS aggtransspace, agginitval, "
14097
14091
"0 AS aggmtransspace, NULL AS aggminitval, "
14098
- "true AS convertok "
14099
14092
"FROM pg_catalog.pg_aggregate a, pg_catalog.pg_proc p "
14100
14093
"WHERE a.aggfnoid = p.oid "
14101
14094
"AND p.oid = '%u'::pg_catalog.oid",
@@ -14115,7 +14108,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14115
14108
"'n' AS aggkind, "
14116
14109
"0 AS aggtransspace, agginitval, "
14117
14110
"0 AS aggmtransspace, NULL AS aggminitval, "
14118
- "true AS convertok "
14119
14111
"FROM pg_catalog.pg_aggregate a, pg_catalog.pg_proc p "
14120
14112
"WHERE a.aggfnoid = p.oid "
14121
14113
"AND p.oid = '%u'::pg_catalog.oid",
@@ -14144,7 +14136,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14144
14136
i_aggmtransspace = PQfnumber(res, "aggmtransspace");
14145
14137
i_agginitval = PQfnumber(res, "agginitval");
14146
14138
i_aggminitval = PQfnumber(res, "aggminitval");
14147
- i_convertok = PQfnumber(res, "convertok");
14148
14139
i_proparallel = PQfnumber(res, "proparallel");
14149
14140
14150
14141
aggtransfn = PQgetvalue(res, 0, i_aggtransfn);
@@ -14167,7 +14158,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14167
14158
aggmtransspace = PQgetvalue(res, 0, i_aggmtransspace);
14168
14159
agginitval = PQgetvalue(res, 0, i_agginitval);
14169
14160
aggminitval = PQgetvalue(res, 0, i_aggminitval);
14170
- convertok = (PQgetvalue(res, 0, i_convertok)[0] == 't');
14171
14161
14172
14162
if (fout->remoteVersion >= 80400)
14173
14163
{
@@ -14191,19 +14181,6 @@ dumpAgg(Archive *fout, AggInfo *agginfo)
14191
14181
else
14192
14182
proparallel = NULL;
14193
14183
14194
- if (!convertok)
14195
- {
14196
- pg_log_warning("aggregate function %s could not be dumped correctly for this database version; ignored",
14197
- aggsig);
14198
-
14199
- if (aggfullsig)
14200
- free(aggfullsig);
14201
-
14202
- free(aggsig);
14203
-
14204
- return;
14205
- }
14206
-
14207
14184
/* identify default modify flag for aggkind (must match DefineAggregate) */
14208
14185
defaultfinalmodify = (aggkind == AGGKIND_NORMAL) ? AGGMODIFY_READ_ONLY : AGGMODIFY_READ_WRITE;
14209
14186
/* replace omitted flags for old versions */
0 commit comments