2016-04-19 09:59:09 -04:00
|
|
|
[[java-query-percolate-query]]
|
|
|
|
==== Percolate query
|
2013-08-28 19:24:34 -04:00
|
|
|
|
2016-05-20 17:53:51 -04:00
|
|
|
See: {ref}/query-dsl-percolate-query.html[Percolate Query]
|
|
|
|
|
|
|
|
In order to use the `percolate` query from the Java API your
|
|
|
|
the percolator module dependency should be on the classpath and
|
|
|
|
the transport client should be loaded with the percolator plugin:
|
|
|
|
|
|
|
|
[source,java]
|
|
|
|
--------------------------------------------------
|
|
|
|
TransportClient transportClient = TransportClient.builder()
|
|
|
|
.settings(Settings.builder().put("node.name", "node"))
|
|
|
|
.addPlugin(PercolatorPlugin.class)
|
|
|
|
.build();
|
|
|
|
transportClient.addTransportAddress(
|
|
|
|
new InetSocketTransportAddress(new InetSocketAddress(InetAddresses.forString("127.0.0.1"), 9300))
|
|
|
|
);
|
|
|
|
--------------------------------------------------
|
|
|
|
|
|
|
|
Before the `percolate` query can be used an `percolator` mapping should be added and
|
|
|
|
a document containing a percolator query should be indexed:
|
2013-08-28 19:24:34 -04:00
|
|
|
|
|
|
|
[source,java]
|
|
|
|
--------------------------------------------------
|
2016-04-19 09:59:09 -04:00
|
|
|
// create an index with a percolator field with the name 'query':
|
|
|
|
client.admin().indices().prepareCreate("myIndexName")
|
|
|
|
.addMapping("query", "query", "type=percolator")
|
|
|
|
.get();
|
|
|
|
|
2013-08-28 19:24:34 -04:00
|
|
|
//This is the query we're registering in the percolator
|
|
|
|
QueryBuilder qb = termQuery("content", "amazing");
|
|
|
|
|
|
|
|
//Index the query = register it in the percolator
|
2016-04-19 09:59:09 -04:00
|
|
|
client.prepareIndex("myIndexName", "query", "myDesignatedQueryName")
|
2013-08-28 19:24:34 -04:00
|
|
|
.setSource(jsonBuilder()
|
|
|
|
.startObject()
|
|
|
|
.field("query", qb) // Register the query
|
|
|
|
.endObject())
|
|
|
|
.setRefresh(true) // Needed when the query shall be available immediately
|
2016-04-19 09:59:09 -04:00
|
|
|
.get();
|
2013-08-28 19:24:34 -04:00
|
|
|
--------------------------------------------------
|
|
|
|
|
|
|
|
This indexes the above term query under the name
|
|
|
|
*myDesignatedQueryName*.
|
|
|
|
|
|
|
|
In order to check a document against the registered queries, use this
|
|
|
|
code:
|
|
|
|
|
|
|
|
[source,java]
|
|
|
|
--------------------------------------------------
|
|
|
|
//Build a document to check against the percolator
|
|
|
|
XContentBuilder docBuilder = XContentFactory.jsonBuilder().startObject();
|
|
|
|
docBuilder.field("doc").startObject(); //This is needed to designate the document
|
|
|
|
docBuilder.field("content", "This is amazing!");
|
|
|
|
docBuilder.endObject(); //End of the doc field
|
|
|
|
docBuilder.endObject(); //End of the JSON root object
|
2016-03-15 10:07:53 -04:00
|
|
|
// Percolate, by executing the percolator query in the query dsl:
|
|
|
|
SearchResponse response = client().prepareSearch("myIndexName")
|
2016-04-19 09:59:09 -04:00
|
|
|
.setQuery(QueryBuilders.percolateQuery("query", ""myDocumentType", docBuilder.bytes()))
|
2016-03-15 10:07:53 -04:00
|
|
|
.get();
|
2013-08-28 19:24:34 -04:00
|
|
|
//Iterate over the results
|
2016-03-15 10:07:53 -04:00
|
|
|
for(SearchHit hit : response.getHits()) {
|
|
|
|
// Percolator queries as hit
|
2013-08-28 19:24:34 -04:00
|
|
|
}
|
|
|
|
--------------------------------------------------
|