else
{
DBLINK_RES_ERROR_AS_NOTICE("sql error");
- PQclear(res);
PG_RETURN_TEXT_P(GET_TEXT("ERROR"));
}
}
else
{
DBLINK_RES_ERROR_AS_NOTICE("sql error");
- PQclear(res);
PG_RETURN_TEXT_P(GET_TEXT("ERROR"));
}
}
DBLINK_RES_ERROR("sql error");
else
{
- if (res)
- PQclear(res);
DBLINK_RES_ERROR_AS_NOTICE("sql error");
SRF_RETURN_DONE(funcctx);
}
DBLINK_RES_ERROR("sql error");
else
{
- if (res)
- PQclear(res);
+ DBLINK_RES_ERROR_AS_NOTICE("sql error");
if (freeconn)
PQfinish(conn);
- DBLINK_RES_ERROR_AS_NOTICE("sql error");
SRF_RETURN_DONE(funcctx);
}
}
* result tuple
*/
sql_cmd_status = GET_TEXT(PQcmdStatus(res));
+ PQclear(res);
}
else
+ {
+ PQclear(res);
ereport(ERROR,
(errcode(ERRCODE_S_R_E_PROHIBITED_SQL_STATEMENT_ATTEMPTED),
errmsg("statement returning results not allowed")));
-
- PQclear(res);
+ }
/* if needed, close the connection to the database and cleanup */
if (freeconn)