D-Net

import org.apache.solr.client.solrj.impl.CloudSolrClient;

import java.util.Arrays;

    private Map<String, CloudSolrClient> clients = new HashMap<String, CloudSolrClient>();

            String[] zkservers= epr.getAddress().split(",");

            CloudSolrClient solrClient;

                solrClient = new CloudSolrClient.Builder().withZkHost(Arrays.asList(zkservers)).build();

            ResultSet<String> solrResultSets = new SolrResultSet(epr, solrClient);

            return solrResultSets;

        logger.debug("NOT HERE!");

import org.apache.solr.client.solrj.SolrClient;

import org.apache.solr.client.solrj.impl.CloudSolrClient;

import java.util.*;

    public SolrClient solrClient = null;

    public SolrResultSet(EPR epr, CloudSolrClient cloudSolrClient) throws IOException, CQLParseException {

        logger.debug("Setting solr client " + cloudSolrClient);

        this.solrClient = cloudSolrClient;

        ((CloudSolrClient)solrClient).setDefaultCollection(mdformat + "-" + layout + "-" + interpretation);

/*

        try {

            logger.debug("!!!!!!!!! !!!!!!! CLOSING !!!!!!!!! !!!!!!!!!! ");

            solrClient.close();

        } catch (IOException e) {

            logger.error("Error closing result set.", e);

        }

*/

                String result = (String) docs.get(i).get("__result");

        } catch (IOException ioe) {

            logger.error("Fail to get results from Solr. ", ioe);

                            logger.debug("faceted values " + Arrays.toString(facetedValues));

                                logger.debug("faceted values [1] " + facetedValues[1]);

                } else { //the old implementation & xml as default

                String result = (String) docs.get(i).get("__result");

                logger.debug("["+ i +"]: " + docs.get(i).get("__result"));

                        logger.debug("1 >>>>>>" + result);

                        logger.debug("2 >>>>>>" + result);

            //logger.debug("refine results " + refineSolrResults);

        } catch (IOException ioe) {

            logger.error("Error calling Solr.", ioe);

        try {

            QueryResponse resp = solrClient.query(SolrParams.toSolrParams(queryOpts));

            while (!cursorMark.equals(nextCursorMark)) {

                resp = solrClient.query(SolrParams.toSolrParams(queryOpts));

                cursorMark = nextCursorMark;

                nextCursorMark = resp.getNextCursorMark();

                for (int i = 0; i < resp.getResults().size(); i++) {

                    if (transformer != null) {

                        String result = null;

                        try {

                            result = transformer.transform((String) resp.getResults().get(i).get("__result"));

                            logger.debug("RESULT " + result);

                        } catch (TransformerException te) {

                            logger.warn("Error transforming " + result, te);

                            continue;

                        }

                        try {

                            os.write(result.getBytes());

                            os.flush();

                        } catch (IOException e) {

                            logger.error("Cursor get... ", e);

                            continue;

                        }

                queryOpts.remove("cursorMark");

                queryOpts.add("cursorMark", nextCursorMark);

                curs++;

        } catch (IOException ioe) {

            logger.error("Error executing solr query. ", ioe);

        //logger.info("deprecated searchNrefine > from: " + page + " to:" + size);

        //logger.debug("Search transformer " + searchTransformer);

        //logger.debug("Refine transformer " + browseTransformer);

        //logger.debug("Search transformer " + searchTransformer);

        //logger.debug("Refine transformer " + refineTransformer);

        logger.info("newSearch > from: " + from + " to:" + to);

        } catch (SolrServerException sse) {

    //TODO: I wish to remove this. This was only made (quick and dirty - only the enhanceFieldQueries(fieldQueries) is missing

    //from newSearch() after a last time request for the portal to show all the publications and the deletedbyinference ones.

    //I did not want to pass a parameter since I do not know if we are going to keep it. This is for a tech meeting showcase.

    //If we want to keep this I need to redesign.

    public SearchResult newSearchWithoutFieldQueries (String text, String locale, List<String> refinefields, List<String> fieldQueries,

                                   int from, int to, String format, Transformer transformer, Transformer oldRefineTransformer,

                                   boolean oldPaging) throws SearchServiceException {

        logger.info("non filtered search for...  > from: " + from + " to:" + to);

        long startTime = System.nanoTime();

        IndexService index = getIndexLocator().getService();

        EPR epr = null;

        ResultSet<String> rs = null;

        List<String> browseResults = null;

        List<String> searchResults = null;

        String query = rewrite(text);

        logger.info("Performing query " + query + "' and fields " + fieldQueries + " and refine " + refinefields);

        try {

            //TODO see parser and maybe delete!

            //query = new CQLParser().parse(query).toCQL();

            String eprQuery = createEprQuery(query, refinefields, fieldQueries);

            epr = index.getBrowsingStatistics(eprQuery, "all", mdFormat, indexLayout);

            if (epr == null) {

                throw new SearchServiceException("Something really strange happened there! Index returned null result set id.");

            }

            //get the locale TODO do we need this?

            //String correctLocale = getCorrectLocale(locale);

            //StringTokenizer tokenizer = new StringTokenizer(correctLocale, "_");

            //Locale requestLocale = new Locale(tokenizer.nextToken(), tokenizer.nextToken());

            rs = rsFactory.createResultSet(epr);

            Map<String, List<String>> list = null;

            if (oldPaging) {

                list = ((SolrResultSet)rs).newGet(from-1, to, format, transformer, oldRefineTransformer);

            } else {

                list = ((SolrResultSet)rs).newGet(from, to, format, transformer, oldRefineTransformer);

            }

            searchResults = list.get("search");

            browseResults = list.get("refine");

        } catch (IndexServiceException ise) {

            logger.error("Error getting refine results.", ise);

            throw new SearchServiceException("Error getting refine results.", ise);

        }

        long estimatedTime = System.nanoTime() - startTime;

        logger.debug("Search time " + estimatedTime/1000000 +  " milliseconds for query " + query +

                " and fields " + fieldQueries + " and refine " + refinefields + " from: "+ from + " and size " + to);

        //logger.info("Returned results for NEW search query '" + query + "' and fields " + fieldQueries + " and refine " + refinefields);;

        rs.close();

        return new SearchResult(query, Locale.getDefault().toString(), rs.size(), from, to, searchResults, browseResults, refinefields);

    }

    //This follows the newSearchWithoutFieldQueries comment. I wish to remove it!!! This was only made

    // (quick and dirty - only the getResponseByEntity version with newSearchWithoutFieldQueries is used

    // after a last time request for the portal to show all the publications and the deletedbyinference ones.

    // I did not want to pass a parameter since I do not know if we are going to keep it. This is for a tech meeting showcase.

    // If we want to keep this I need to redesign.

    @GET

    @Path("/api/deletedByInferencePublications/{publicationid}")

    @Produces({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML})

    public Response fetchDeletedByInferencePublicationsById(@PathParam("publicationid") String publicationid,

                                          @QueryParam("format") final String format,

                                          @QueryParam("fq") final List<String> fieldQueries,

                                          @Context final HttpServletRequest request) {

        return getDeletedByInferenceResponseByEntityId(request, RequestResponseHandler.Entity.PUBLICATION, publicationid, format, fieldQueries);

    }

    //Please see comment above. I wish to remove it.

    private Response getDeletedByInferenceResponseByEntityId(HttpServletRequest request, RequestResponseHandler.Entity entity, String entityId, String format, List<String> fieldQueries) {

        String responseType = extractResponseFormat(format);

        try {

            StringBuilder queryBuilder = new StringBuilder();

            builtEntityIdQuery(queryBuilder, entity, entityId, fieldQueries);

            String fullQuery = queryBuilder.toString();

            if(fullQuery == null || fullQuery.isEmpty()) {

                return Response.status(Response.Status.BAD_REQUEST).

                        entity(APIResponseFormatter.compose400Message(format, "The 'query' parameter is required")).

                        type(responseType).build();

            }

            SearchResult searchResult = searchService.newSearchWithoutFieldQueries(fullQuery, Locale.getDefault().toString(), null, fieldQueries, 0, 1, responseType, null, null, false);

            if (searchResult.getSearchResults() == null || searchResult.getSearchResults().isEmpty() ||

                    searchResult.getSearchResults().size() == 0 || searchResult.getSearchResults().get(0) == null) {

                return Response.status(Response.Status.NOT_FOUND).entity(APIResponseFormatter.compose404Message(responseType, "404 - " + entity +" with id "

                        + entityId + " not found.")).type(responseType).build();

            }

            return Response.status(Response.Status.OK).entity(APIResponseFormatter.createEntityResponse(request, entity, searchResult.getSearchResults().get(0).toString(), responseType)).type(responseType).build();

        } catch (SearchServiceException sse) {

            logger.error("Fail to fetch "+ entity + " with id " + entityId, sse);

            return Response.status(Response.Status.INTERNAL_SERVER_ERROR).entity(APIResponseFormatter.compose500Message(responseType, "Fail to fetch " + entity + " with id " + entityId, sse.getMessage())).build();

        }

    }

    @Autowired

    private SearchServiceImpl searchService = null;

    @Autowired

    private VocabularyManager vocabularyManager = null;

    @Resource

    private String maxResults = null;

    @Resource

    private String maxSize = null;

    private static Logger logger = Logger.getLogger(SearchRequestController.class);

    private static final String XML_CONTENT_TYPE = "application/xml;charset=UTF-8";

    private static final String JSON_CONTENT_TYPE = "application/json;charset=UTF-8;";

    @RequestMapping(value = "/search", method = RequestMethod.GET)

    public void search(HttpServletRequest request, HttpServletResponse response) {

        PrintWriter writer = null;

        FormattedSearchResult formattedSearchResult = null;

        String format = (request.getParameter("format") != null) ? request.getParameter("format") : "xml";

        String locale = request.getParameter("locale");

        if (size > Integer.parseInt(maxSize)) {

            throw new IllegalArgumentException("Size argument have exceeded the maximum allowed number.");

        }

        String sTransformer = request.getParameter("sTransformer");

        String rTransformer = request.getParameter("rTransformer");

        Collection<String> fields = readParameter(request, "fields");

            writer.append(formattedSearchResult.getFormattedResult());

        } catch (Exception e) {

            logger.error("Fail to execute search.", e);

            createXmlErrorPage(writer, e);

        } finally {

        }

    }

    @RequestMapping(value = "/api/publications", method = RequestMethod.GET, produces = {MediaType.APPLICATION_XML_VALUE,MediaType.APPLICATION_JSON_VALUE})

    public void searchPublications(HttpServletRequest request, HttpServletResponse response) throws Exception {

        long time = System.currentTimeMillis();

        } catch (Exception e) {

            logger.error("Fail to execute search.", e);

            throw new Exception("Fail to execute search", e);

        }

    }

    @RequestMapping(value = "/api/datasets", method = RequestMethod.GET, produces = {MediaType.APPLICATION_XML_VALUE,MediaType.APPLICATION_JSON_VALUE})

    public void searchData(HttpServletRequest request, HttpServletResponse response) throws Exception {

        } catch (Exception e) {

    }

    @RequestMapping(value = "/api/projects", method = RequestMethod.GET, produces = {MediaType.APPLICATION_XML_VALUE,MediaType.APPLICATION_JSON_VALUE})

    public void searchProjects(HttpServletRequest request, HttpServletResponse response) throws Exception {

        checkParameters(PROJECT_PARAMETERS, request.getParameterMap());

    }

    if (model!=null && !model.trim().isEmpty()) {

    if (model.equals("openaire")) {

    return null;

    } else if (model.equals("sygma")) {

    return "results_openaire";

    }

    else if (model.equals("dc")) {

    return "dc";

    }

    throw new IllegalArgumentException("model '" + model + "' is not supported.");

    } else {

    return null;

    }

        if (model != null && !model.trim().isEmpty() && format != null && (format.equals("json")||format.equals("xml"))) {

        } else if (format != null && !format.trim().isEmpty()) {

            if (format.equals("rss") || format.equals("csv") || format.equals("tsv") || format.equals("html")) {

                return "results_openaire";

            }

        return null;

        writer.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");

        writer.append("<error>");

        writer.append("<exception>")

                .append(StringEscapeUtils.escapeXml(e.getClass().getName()))

                .append("</exception>");

        if (e.getMessage() != null) {

            writer.append("<message>")

                    .append(StringEscapeUtils.escapeXml(e.getMessage()))

                    .append("</message>");

        }

        if (e.getCause() != null) {

            writer.append("<cause>")

                    .append(StringEscapeUtils.escapeXml(e.getCause()

                            .toString())).append("</cause>");

        }

        StackTraceElement[] trace = e.getStackTrace();

        writer.append("<trace>");

        for (int i = 0; i < trace.length; i++) {

            writer.append(StringEscapeUtils.escapeXml(trace[i].toString()))

                    .append("\n");

        }

        writer.append("</trace>");

        writer.append("</error>");

    }

     * Checks if the requested result size exceeds the maximum allowed numbers of returned results

     * @param page the page parameter

     * @param size the size parameter

     */

    private void checkRequestSize(int page, int size) {

        int total = page*size;

        if (total > Integer.parseInt(maxResults)) {

            throw new IllegalArgumentException("Size and page arguments have exceeded the maximum number of returned results.");

        }

    }

            } else if (format.equalsIgnoreCase("csv")) {

	<version>3.5.0-SNAPSHOT</version>

			<version>7.2.1</version>