Shulou(Shulou.com)06/02 Report--

This article focuses on "elasticsearchTemplate implementation of aggregate query", interested friends may wish to take a look. The method introduced in this paper is simple, fast and practical. Now let the editor to take you to learn "elasticsearchTemplate implementation of aggregate query" bar!

Go directly to the code:

/ / create a query condition object BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery (); / / concatenate query condition queryBuilder.should (QueryBuilders.termQuery ("field", "value"); / / create aggregate query condition TermsAggregationBuilder agg = AggregationBuilders.terms ("aggregate name, custom, used when fetching") .field ("aggregate field") .size (100) / / size is the number of entries aggregated by the query / / create query object SearchQuery build = new NativeSearchQueryBuilder () .withQuery (queryBuilder) / / add query condition .addAggregation (agg) / / add aggregate condition .withPageable (PageRequest.of (0,1)) / / document pages that meet the query criteria (not aggregated pages) .build () / / execute the query AggregatedPage testEntities = elasticsearchTemplate.queryForPage (build, TestEntity.class); / / fetch the aggregate result Aggregations entitiesAggregations = testEntities.getAggregations (); Terms terms = (Terms) propertyInfoEntities.getAggregation ("aggregate name, previously customized"); / / iterate through the value of the aggregate field column, and the corresponding quantity for (Terms.Bucket bucket: terms.getBuckets ()) {String keyAsString = bucket.getKeyAsString () / / the value of the aggregate field column long docCount = bucket.getDocCount (); / / the corresponding quantity of the aggregate field}

Multi-field aggregation:

/ / create a query condition object BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery (); / / stitch query condition queryBuilder.should (QueryBuilders.termQuery ("field", "value")) / / create aggregate query condition TermsAggregationBuilder agg1 = AggregationBuilders.terms ("aggregate name 2"). Field (aggregate field 2) .size (100) TermsAggregationBuilder agg = AggregationBuilders.terms ("aggregate name 1") .field ("aggregate field 1") .size (100) .subAggregation (agg1) / / create the last aggregate condition on the stitching / / create query object SearchQuery build = new NativeSearchQueryBuilder () .withQuery (queryBuilder) / / Add query condition .addAggregation (agg) / / add aggregate condition .withPageable (PageRequest.of (0) 1)) / / document pagination that meets the query criteria (not aggregated pagination) .build () / / execute query AggregatedPage testEntities = elasticsearchTemplate.queryForPage (build, TestEntity.class); / / fetch aggregate result Aggregations entitiesAggregations = testEntities.getAggregations (); Terms terms = (Terms) propertyInfoEntities.getAggregation ("aggregate name"); / / traverse the outermost aggregate result for (Terms.Bucket bucket: terms.getBuckets ()) {String keyAsString = bucket.getKeyAsString (); / / aggregate field column name long docCount = aggregate () / / the number corresponding to the aggregate field / / get the internal aggregate field information Aggregations aggregations = bucket.getAggregations (); Terms terms2 = aggregations.get ("aggregation name 2"); / / traverse to get the aggregation information of agg1 for (Terms.Bucket bucket1: terms2.getBuckets ()) {String keyAsString2 = bucket.getKeyAsString () / / the name of the aggregate field column long docCount2 = bucket.getDocCount (); / / the quantity corresponding to the aggregate field}}

Multiple fields are aggregated at once:

/ / create a query condition object BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery (); / / stitch query condition queryBuilder.should (QueryBuilders.termQuery ("field", "value")) / / create aggregate query condition String script = "doc ['" + field 1 + "] .values +'/'+ doc ['" + field 2 + "] .values +'/'+ doc ['" + field 3 + "'] .values"; / / write script statement Script script1 = newScript (script); / / create a new script object TermsAggregationBuilder agg = AggregationBuilders.terms ("aggregate name") .script (script1) .size (99999) / / create an aggregate query object SearchQuery build = new NativeSearchQueryBuilder () .withQuery (queryBuilder) / / add query conditions .addAggregation (agg) / / add aggregation conditions .withPageable (PageRequest.of (0,1)) / / document pages that meet the query criteria (not aggregated pages) .build () / / execute query AggregatedPage testEntities = elasticsearchTemplate.queryForPage (build, TestEntity.class); Terms terms = (Terms) shopDbEntities.getAggregation ("aggregate name"); for (Terms.Bucket bucket: terms.getBuckets ()) {/ / Loop fetch the aggregate value String keyAsString = bucket.getKeyAsString (); String [] split = keyAsString.split ("/") / / cut out each field System.out.println ("Field 1" + split [0]); System.out.println ("Field 2" + split [1]); System.out.println ("Field 3" + split [2]);}

More field aggregates according to the above analogy. If you really don't understand the structure, you can print out the query statement. Take the print statement to a query tool such as Kibana to query the structure, or directly Debug to look at the data structure. It is easier to understand.

At this point, I believe you have a deeper understanding of "elasticsearchTemplate aggregate query", might as well come to the actual operation of it! Here is the website, more related content can enter the relevant channels to inquire, follow us, continue to learn!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.