percolate-query.asciidoc 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  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("query", "query", "type=percolator")
  18. .addMapping("docs", "content", "type=text")
  19. .get();
  20. //This is the query we're registering in the percolator
  21. QueryBuilder qb = termQuery("content", "amazing");
  22. //Index the query = register it in the percolator
  23. client.prepareIndex("myIndexName", "query", "myDesignatedQueryName")
  24. .setSource(jsonBuilder()
  25. .startObject()
  26. .field("query", qb) // Register the query
  27. .endObject())
  28. .setRefreshPolicy(RefreshPolicy.IMMEDIATE) // Needed when the query shall be available immediately
  29. .get();
  30. --------------------------------------------------
  31. This indexes the above term query under the name
  32. *myDesignatedQueryName*.
  33. In order to check a document against the registered queries, use this
  34. code:
  35. [source,java]
  36. --------------------------------------------------
  37. //Build a document to check against the percolator
  38. XContentBuilder docBuilder = XContentFactory.jsonBuilder().startObject();
  39. docBuilder.field("content", "This is amazing!");
  40. docBuilder.endObject(); //End of the JSON root object
  41. PercolateQueryBuilder percolateQuery = new PercolateQueryBuilder("query", "docs", BytesReference.bytes(docBuilder));
  42. // Percolate, by executing the percolator query in the query dsl:
  43. SearchResponse response = client().prepareSearch("myIndexName")
  44. .setQuery(percolateQuery))
  45. .get();
  46. //Iterate over the results
  47. for(SearchHit hit : response.getHits()) {
  48. // Percolator queries as hit
  49. }
  50. --------------------------------------------------