Extension du service Query

@RestController
@RequestMapping

1. Appelez la méthode performSearch à partir de SearchServiceFacade fourni dans le cadre de query-api.jar. Consultez par exemple le code suivant.

   package com.samplecompany.search.rest;
   
   import org.springframework.http.ResponseEntity;
   import org.springframework.web.bind.annotation.RequestMapping;
   import org.springframework.web.bind.annotation.RequestParam;
   import org.springframework.web.bind.annotation.RestController;
   
   import com.hcl.commerce.search.expression.SearchCriteria;
   import com.hcl.commerce.search.internal.runtime.SearchServiceFacade;
   
   @RestController
   @RequestMapping("/api/url")
   public class URLResource {
   	
   	@RequestMapping("/id")
   	private ResponseEntity findUrlsByIds(@RequestParam("storeId") Integer iStoreId,
   			@RequestParam("id") String id) throws Exception {
   		
   		ResponseEntity result = null; 
   		SearchCriteria searchCriteria = SearchCriteria.getCriteria();
   		//Set all the necessary control parameters in the searchCriteria. Below is just a sample about how to set parameters.
   		searchCriteria.setControlParameterValue("_wcf.search.profile","Mycompany_customProfile");
   		searchCriteria.setControlParameterValue("_wcf.search.term",id);
   		searchCriteria.setControlParameterValue("_wcf.search.language","-1");
   		result = SearchServiceFacade.getInstance().performSearch(searchCriteria);
   		return result;
   	
   	}
   
   }
   

2. 2. Si vous n'avez pas besoin de l'architecture d'environnement d'exécution des requêtes et que vous souhaitez interroger directement l'index Elasticsearch, vous pouvez le faire à l'aide des API Java fournies par ElasticSearch. Voir, par exemple, l'exemple de fragment de code suivant.

   package com.samplecompany.search.rest;
   
   import java.util.Arrays;
   import java.util.HashMap;
   import java.util.Map;
   
   import org.springframework.http.HttpStatus;
   import org.springframework.http.MediaType;
   import org.springframework.http.ResponseEntity;
   import org.springframework.web.bind.annotation.PathVariable;
   import org.springframework.web.bind.annotation.RequestMapping;
   import org.springframework.web.bind.annotation.RequestMethod;
   import org.springframework.web.bind.annotation.RestController;
   
   
   import org.apache.http.HttpHost;
   import org.elasticsearch.action.search.SearchRequest;
   import org.elasticsearch.action.search.SearchResponse;
   import org.elasticsearch.client.RequestOptions;
   import org.elasticsearch.client.RestClient;
   import org.elasticsearch.client.RestHighLevelClient;
   import org.elasticsearch.index.query.BoolQueryBuilder;
   import org.elasticsearch.index.query.QueryBuilders;
   import org.elasticsearch.index.query.QueryStringQueryBuilder;
   import org.elasticsearch.search.builder.SearchSourceBuilder;
   
   @RestController
   @RequestMapping("/store/{storeId}/attrview")
   public class AttributeResource {
   	
   	private static final String ES_SCHEME = System.getenv("ELASTICSEARCH_SCHEME");
   	private static final String ES_HOST = System.getenv("ELASTICSEARCH_HOST");
   	private static final String ES_PORT = System.getenv("ELASTICSEARCH_PORT");
   	private static final String ENV_TYPE = System.getenv("ENVTYPE");
   
   	private static final String BY_ATTR_ID = "/{attrId}";
   
   	@RequestMapping(value = BY_ATTR_ID, method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
   	public ResponseEntity findAttrById(@PathVariable("storeId") String storeId, @PathVariable("attrId") String attrId) throws Exception {
   
   		ResponseEntity result = null;
   		SearchResponse searchResponse = null;
   		
   		RestHighLevelClient elasticServer = new RestHighLevelClient(RestClient.builder
   				(new HttpHost(ES_HOST, Integer.valueOf(ES_PORT), ES_SCHEME)));
   		
   		String strIndexName = "auth" + "." + storeId + "." + "attribute";
   		SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
   		
   		BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
   		
   		QueryStringQueryBuilder queryStringStore = QueryBuilders.queryStringQuery(attrId.toString());
   		queryStringStore.field("id.attribute");
   		boolQuery.filter(queryStringStore);
   		
   		searchSourceBuilder.query(boolQuery);
   		searchSourceBuilder.fetchSource(false);
   		searchSourceBuilder.storedFields(Arrays.asList("*"));
   		searchSourceBuilder.size(1000);
   		
   		SearchRequest request = new SearchRequest(strIndexName);
   		// Set search source builder in request
   		request.source(searchSourceBuilder);
   		
   		searchResponse = elasticServer.search(request, RequestOptions.DEFAULT);
   		
   		searchResponse.getHits().getAt(0).getId();
   		
   		Map resultMap = new HashMap();
   		
   		resultMap.put("id", searchResponse.getHits().getAt(0).getId());
   		
   		result = new ResponseEntity(resultMap, HttpStatus.OK);
   
   		return result;
   	}
   }
   

public class SearchCustomQueryPreprocessor extends AbstractSearchQueryPreprocessor 
	implements SearchQueryPreprocessor {

	private static final String CLASSNAME = SearchCustomQueryPreprocessor.class.getName();
	private static final Logger LOGGER = LoggerFactory.getLogger(CLASSNAME);

	@Override
	public void invoke(SearchCriteria searchCriteria, Object... queryRequestObjects) throws Exception {
		// your logic here
	}	
}

public class SearchCustomQueryPostprocessor extends AbstractSearchQueryPostprocessor 
implements SearchQueryPostprocessor {

	private static final String CLASSNAME = SearchCustomQueryPostprocessor.class.getName();
	private static final Logger LOGGER = LoggerFactory.getLogger(CLASSNAME);

	@Override
	public void invoke(SearchCriteria searchCriteria, Object... queryResponseObjects) throws Exception {
		// your logic here
	}	
}