Subversion Repositories SmartDukaan

package com.spice.profitmandi.common.solr;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.HttpClients;
import org.springframework.web.util.UriComponentsBuilder;

public class SolrService {
        public static void main(String[] args) throws Throwable {
                //System.out.println(String.format("{!parent which=\"id:catalog*\"}tagId_i:%s", StringUtils.join(elements)));
                /*RestClient rc  = new RestClient(SchemeType.HTTP, "dtr", 8984);
                Map<String, String> params = new HashMap<>();
                Map<String, String> headers = new HashMap<>();
                params.put("q", "{!parent which=\"id:catalog*\"}tagId_i:4");
                params.put("fl", "*, [child parentFilter=id:catalog*]");
                params.put("sort", "rank_i asc");
                params.put("start", String.valueOf(0));
                params.put("rows", String.valueOf(10));
                params.put("wt", "json");
                String response  =rc.get("solr/demo/select", params);
                JSONObject solrResponseJSONObj = new JSONObject(response);*/

                /*rc.e
        SolrQuery query = new SolrQuery();
        query.setQuery("{!parent which=\"id:catalog*\"}tagId_i:4");
        query.setFields("*, [child parentFilter=id:catalog*]");
        query.addSort("rank_i", ORDER.asc);
        query.setStart(0);

        QueryResponse response = client.query(query);
        System.out.println(response.toString());
        SolrDocumentList results = response.getResults();
        for (int i = 0; i < results.size(); ++i) {
            System.out.println(results.get(i));
        }*/
                
                UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl("http://dtr:8984/solr/demo/select");
                        builder.queryParam("q", "+brand_s:Samsung +{!parent which=\"id:catalog*\"}");
                        builder.queryParam("fl", "*, [child parentFilter=id:catalog*]");
                        builder.queryParam("wt", "json");
                HttpGet request = new HttpGet(builder.build().encode().toUri());
                System.out.println(toString(HttpClients.createDefault().execute(request).getEntity().getContent()));
    }
        
        private static String toString(InputStream inputStream){
                BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
                StringBuilder responseString = new StringBuilder();
                String line = null;
                try {
                        while((line = reader.readLine()) != null){
                                responseString.append(line);
                        }
                        inputStream.close();
                } catch (IOException e) {
                        throw new RuntimeException();
                }
                return responseString.toString();
        }
}