char* recycleObject = NULL;
    char* f = "f";

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query,
        "SELECT pg_catalog.gs_is_recycle_obj(%u, %u, NULL)",
        classid,
        objid);
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    colNum = PQfnumber(res, "gs_is_recycle_obj");
    recycleObject = gs_strdup(PQgetvalue(res, tupNum, colNum));
    if (strcmp(recycleObject, f) == 0) {
        isRecycleObj = false;
    } else {
        isRecycleObj = true;
    }

static void selectSourceSchema(Archive* fout, const char* schemaName)
{
    static char* curSchemaName = NULL;
    PQExpBuffer query;

    /* Not relevant if fetching from pre-7.3 DB */
    if (fout->remoteVersion < 70300)
        return;
    /* Ignore null schema names */
    if (schemaName == NULL || *schemaName == '\0')
        return;
    /* Optimize away repeated selection of same schema */
    if ((curSchemaName != NULL) && strcmp(curSchemaName, schemaName) == 0)
        return;

    query = createPQExpBuffer();
    /*
     * It is invalid to set pg_temp or pg_catalog behind other schemas in search path explicitly.
     * The priority order is pg_temp, pg_catalog and other schemas.
     */
    appendPQExpBuffer(query, "SET search_path = %s", fmtId(schemaName));
    ExecuteSqlStatement(fout, query->data);

    destroyPQExpBuffer(query);
    if (curSchemaName != NULL) {
        free(curSchemaName);
        curSchemaName = NULL;
    }
    curSchemaName = gs_strdup(schemaName);
}

void ExecuteSqlStatement(Archive* AHX, const char* query)
{
    ArchiveHandle* AH = (ArchiveHandle*)AHX;
    PGresult* res = NULL;

    res = PQexec(AH->connection, query);
    if (PQresultStatus(res) != PGRES_COMMAND_OK)
        die_on_query_failure(AH, modulename, query);
    PQclear(res);
}