percolate-query.asciidoc 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. [[java-query-percolate-query]]
  2. ==== Percolate Query
  3. See:
  4. * {ref}/query-dsl-percolate-query.html[Percolate Query]
  5. [source,java]
  6. --------------------------------------------------
  7. Settings settings = Settings.builder().put("cluster.name", "elasticsearch").build();
  8. TransportClient client = new PreBuiltTransportClient(settings);
  9. client.addTransportAddress(new TransportAddress(new InetSocketAddress(InetAddresses.forString("127.0.0.1"), 9300)));
  10. --------------------------------------------------
  11. Before the `percolate` query can be used an `percolator` mapping should be added and
  12. a document containing a percolator query should be indexed:
  13. [source,java]
  14. --------------------------------------------------
  15. // create an index with a percolator field with the name 'query':
  16. client.admin().indices().prepareCreate("myIndexName")
  17. .addMapping("_doc", "query", "type=percolator", "content", "type=text")
  18. .get();
  19. //This is the query we're registering in the percolator
  20. QueryBuilder qb = termQuery("content", "amazing");
  21. //Index the query = register it in the percolator
  22. client.prepareIndex("myIndexName", "_doc", "myDesignatedQueryName")
  23. .setSource(jsonBuilder()
  24. .startObject()
  25. .field("query", qb) // Register the query
  26. .endObject())
  27. .setRefreshPolicy(RefreshPolicy.IMMEDIATE) // Needed when the query shall be available immediately
  28. .get();
  29. --------------------------------------------------
  30. This indexes the above term query under the name
  31. *myDesignatedQueryName*.
  32. In order to check a document against the registered queries, use this
  33. code:
  34. [source,java]
  35. --------------------------------------------------
  36. //Build a document to check against the percolator
  37. XContentBuilder docBuilder = XContentFactory.jsonBuilder().startObject();
  38. docBuilder.field("content", "This is amazing!");
  39. docBuilder.endObject(); //End of the JSON root object
  40. PercolateQueryBuilder percolateQuery = new PercolateQueryBuilder("query", "_doc", BytesReference.bytes(docBuilder));
  41. // Percolate, by executing the percolator query in the query dsl:
  42. SearchResponse response = client().prepareSearch("myIndexName")
  43. .setQuery(percolateQuery))
  44. .get();
  45. //Iterate over the results
  46. for(SearchHit hit : response.getHits()) {
  47. // Percolator queries as hit
  48. }
  49. --------------------------------------------------