西部数码网站管理助手破解版,wordpress安装2个网站吗,wordpress自动发现,做外贸网站需要注意什么提示#xff1a;文章写完后#xff0c;目录可以自动生成#xff0c;如何生成可参考右边的帮助文档 文章目录 JavaAPI-文档1.新增 Insert2.修改 Update3.查询 Get4.删除 Delete5.批量操作 BulkRequest批量新增批量删除 高级查询1.查询所有索引数据2.条件查询3.分页查询4.查询… 提示文章写完后目录可以自动生成如何生成可参考右边的帮助文档 文章目录 JavaAPI-文档1.新增 Insert2.修改 Update3.查询 Get4.删除 Delete5.批量操作 BulkRequest批量新增批量删除 高级查询1.查询所有索引数据2.条件查询3.分页查询4.查询排序5.组合查询6.范围查询7.模糊查询8.高亮查询9.最大值查询10.分组查询 JavaAPI-文档 1.新增 Insert
package com.atguigu.es.test;import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.HttpHost;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.client.indices.GetIndexResponse;
import org.elasticsearch.common.xcontent.XContentType;public class ESTest_Doc_Insert {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 插入数据IndexRequest request new IndexRequest();request.index(user).id(1001);User user new User();user.setName(zhangsan);user.setAge(30);user.setSex(男);// 向ES插入数据必须将数据转换位JSON格式ObjectMapper mapper new ObjectMapper();String userJson mapper.writeValueAsString(user);request.source(userJson, XContentType.JSON);IndexResponse response esClient.index(request, RequestOptions.DEFAULT);System.out.println(response.getResult());esClient.close();}
} 2.修改 Update
package com.atguigu.es.test;import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.HttpHost;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;public class ESTest_Doc_Update {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 修改数据UpdateRequest request new UpdateRequest();request.index(user).id(1001);request.doc(XContentType.JSON, sex, 女);UpdateResponse response esClient.update(request, RequestOptions.DEFAULT);System.out.println(response.getResult());esClient.close();}
} 3.查询 Get
package com.atguigu.es.test;import org.apache.http.HttpHost;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;public class ESTest_Doc_Get {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 查询数据GetRequest request new GetRequest();request.index(user).id(1001);GetResponse response esClient.get(request, RequestOptions.DEFAULT);System.out.println(response.getSourceAsString());esClient.close();}
} 4.删除 Delete
package com.atguigu.es.test;import org.apache.http.HttpHost;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;public class ESTest_Doc_Delete {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));DeleteRequest request new DeleteRequest();request.index(user).id(1001);DeleteResponse response esClient.delete(request, RequestOptions.DEFAULT);System.out.println(response.toString());esClient.close();}
} 5.批量操作 BulkRequest
批量新增
package com.atguigu.es.test;import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.HttpHost;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;public class ESTest_Doc_Insert_Batch {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 批量插入数据BulkRequest request new BulkRequest();// request.add(new IndexRequest().index(user).id(1001).source(XContentType.JSON, name, zhangsan, age,30,sex,男));
// request.add(new IndexRequest().index(user).id(1002).source(XContentType.JSON, name, lisi, age,30,sex,女));
// request.add(new IndexRequest().index(user).id(1003).source(XContentType.JSON, name, wangwu, age,40,sex,男));
// request.add(new IndexRequest().index(user).id(1004).source(XContentType.JSON, name, wangwu1, age,40,sex,女));
// request.add(new IndexRequest().index(user).id(1005).source(XContentType.JSON, name, wangwu2, age,50,sex,男));
// request.add(new IndexRequest().index(user).id(1006).source(XContentType.JSON, name, wangwu3, age,50,sex,男));//request.add(new IndexRequest().index(user).id(1007).source(XContentType.JSON, name, wangwu44, age,60,sex,男));//request.add(new IndexRequest().index(user).id(1008).source(XContentType.JSON, name, wangwu555, age,60,sex,男));request.add(new IndexRequest().index(user).id(1009).source(XContentType.JSON, name, wangwu66666, age,60,sex,男));BulkResponse response esClient.bulk(request, RequestOptions.DEFAULT);System.out.println(response.getTook());System.out.println(response.getItems());esClient.close();}
}
批量删除
package com.atguigu.es.test;import org.apache.http.HttpHost;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;public class ESTest_Doc_Delete_Batch {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 批量删除数据BulkRequest request new BulkRequest();request.add(new DeleteRequest().index(user).id(1001));request.add(new DeleteRequest().index(user).id(1002));request.add(new DeleteRequest().index(user).id(1003));BulkResponse response esClient.bulk(request, RequestOptions.DEFAULT);System.out.println(response.getTook());System.out.println(response.getItems());esClient.close();}
} 高级查询
先批量增加数据
package com.atguigu.es.test;import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.HttpHost;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;public class ESTest_Doc_Insert_Batch {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 批量插入数据BulkRequest request new BulkRequest();request.add(new IndexRequest().index(user).id(1001).source(XContentType.JSON, name, zhangsan, age, 10, sex,女));request.add(new IndexRequest().index(user).id(1002).source(XContentType.JSON, name, lisi, age, 30, sex,女));request.add(new IndexRequest().index(user).id(1003).source(XContentType.JSON, name, wangwu1, age, 40, sex,男));request.add(new IndexRequest().index(user).id(1004).source(XContentType.JSON, name, wangwu2, age, 20, sex,女));request.add(new IndexRequest().index(user).id(1005).source(XContentType.JSON, name, wangwu3, age, 50, sex,男));request.add(new IndexRequest().index(user).id(1006).source(XContentType.JSON, name, wangwu4, age, 20, sex,男));BulkResponse response esClient.bulk(request, RequestOptions.DEFAULT);System.out.println(response.getTook());System.out.println(response.getItems());esClient.close();}
}
1.查询所有索引数据
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建搜索请求对象SearchRequest request new SearchRequest();request.indices(user);// 构建查询的请求体SearchSourceBuilder sourceBuilder new SearchSourceBuilder();// 查询所有数据sourceBuilder.query(QueryBuilders.matchAllQuery());request.source(sourceBuilder);SearchResponse response client.search(request, RequestOptions.DEFAULT);// 查询匹配SearchHits hits response.getHits();System.out.println(took: response.getTook());System.out.println(timeout: response.isTimedOut());System.out.println(total: hits.getTotalHits());System.out.println(MaxScore: hits.getMaxScore());System.out.println(hits);for (SearchHit hit : hits) {//输出每条查询的结果信息System.out.println(hit.getSourceAsString());}System.out.println();} 2.条件查询
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建搜索请求对象SearchRequest request new SearchRequest();request.indices(user);// 构建查询的请求体SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.query(QueryBuilders.termQuery(age, 30));request.source(sourceBuilder);SearchResponse response client.search(request, RequestOptions.DEFAULT);// 查询匹配SearchHits hits response.getHits();System.out.println(took: response.getTook());System.out.println(timeout: response.isTimedOut());System.out.println(total: hits.getTotalHits());System.out.println(MaxScore: hits.getMaxScore());System.out.println(hits);for (SearchHit hit : hits) {//输出每条查询的结果信息System.out.println(hit.getSourceAsString());}System.out.println();};
}3.分页查询
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建搜索请求对象SearchRequest request new SearchRequest();request.indices(user);// 构建查询的请求体SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.query(QueryBuilders.matchAllQuery());// 分页查询// 当前页其实索引(第一条数据的顺序号) fromsourceBuilder.from(0);// 每页显示多少条 sizesourceBuilder.size(2);request.source(sourceBuilder);SearchResponse response client.search(request, RequestOptions.DEFAULT);// 查询匹配SearchHits hits response.getHits();System.out.println(took: response.getTook());System.out.println(timeout: response.isTimedOut());System.out.println(total: hits.getTotalHits());System.out.println(MaxScore: hits.getMaxScore());System.out.println(hits);for (SearchHit hit : hits) {//输出每条查询的结果信息System.out.println(hit.getSourceAsString());}System.out.println();};
}4.查询排序
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建搜索请求对象SearchRequest request new SearchRequest();request.indices(user);// 构建查询的请求体SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.query(QueryBuilders.matchAllQuery());// 排序sourceBuilder.sort(age, SortOrder.ASC);request.source(sourceBuilder);SearchResponse response client.search(request, RequestOptions.DEFAULT);// 查询匹配SearchHits hits response.getHits();System.out.println(took: response.getTook());System.out.println(timeout: response.isTimedOut());System.out.println(total: hits.getTotalHits());System.out.println(MaxScore: hits.getMaxScore());System.out.println(hits);for (SearchHit hit : hits) {//输出每条查询的结果信息System.out.println(hit.getSourceAsString());}System.out.println();};
}5.组合查询 import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建搜索请求对象SearchRequest request new SearchRequest();request.indices(user);// 构建查询的请求体SearchSourceBuilder sourceBuilder new SearchSourceBuilder();BoolQueryBuilder boolQueryBuilder QueryBuilders.boolQuery();// 必须包含boolQueryBuilder.must(QueryBuilders.matchQuery(age, 30));// 一定不含boolQueryBuilder.mustNot(QueryBuilders.matchQuery(name, zhangsan));// 可能包含boolQueryBuilder.should(QueryBuilders.matchQuery(sex, 男));sourceBuilder.query(boolQueryBuilder);request.source(sourceBuilder);SearchResponse response client.search(request, RequestOptions.DEFAULT);// 查询匹配SearchHits hits response.getHits();System.out.println(took: response.getTook());System.out.println(timeout: response.isTimedOut());System.out.println(total: hits.getTotalHits());System.out.println(MaxScore: hits.getMaxScore());System.out.println(hits);for (SearchHit hit : hits) {//输出每条查询的结果信息System.out.println(hit.getSourceAsString());}System.out.println();}; 6.范围查询 import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建搜索请求对象SearchRequest request new SearchRequest();request.indices(user);// 构建查询的请求体SearchSourceBuilder sourceBuilder new SearchSourceBuilder();RangeQueryBuilder rangeQuery QueryBuilders.rangeQuery(age);// 大于等于//rangeQuery.gte(30);// 小于等于rangeQuery.lte(40);sourceBuilder.query(rangeQuery);request.source(sourceBuilder);SearchResponse response client.search(request, RequestOptions.DEFAULT);// 查询匹配SearchHits hits response.getHits();System.out.println(took: response.getTook());System.out.println(timeout: response.isTimedOut());System.out.println(total: hits.getTotalHits());System.out.println(MaxScore: hits.getMaxScore());System.out.println(hits);for (SearchHit hit : hits) {//输出每条查询的结果信息System.out.println(hit.getSourceAsString());}System.out.println();};}7.模糊查询 import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建搜索请求对象SearchRequest request new SearchRequest();request.indices(user);// 构建查询的请求体SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.query(QueryBuilders.fuzzyQuery(name,wangwu).fuzziness(Fuzziness.ONE));request.source(sourceBuilder);SearchResponse response client.search(request, RequestOptions.DEFAULT);// 查询匹配SearchHits hits response.getHits();System.out.println(took: response.getTook());System.out.println(timeout: response.isTimedOut());System.out.println(total: hits.getTotalHits());System.out.println(MaxScore: hits.getMaxScore());System.out.println(hits);for (SearchHit hit : hits) {//输出每条查询的结果信息System.out.println(hit.getSourceAsString());}System.out.println();};}8.高亮查询 import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 高亮查询SearchRequest request new SearchRequest().indices(user);//2.创建查询请求体构建器SearchSourceBuilder sourceBuilder new SearchSourceBuilder();//构建查询方式高亮查询TermsQueryBuilder termsQueryBuilder QueryBuilders.termsQuery(name,zhangsan);//设置查询方式sourceBuilder.query(termsQueryBuilder);//构建高亮字段HighlightBuilder highlightBuilder new HighlightBuilder();highlightBuilder.preTags(font colorred);//设置标签前缀highlightBuilder.postTags(/font);//设置标签后缀highlightBuilder.field(name);//设置高亮字段//设置高亮构建对象sourceBuilder.highlighter(highlightBuilder);//设置请求体request.source(sourceBuilder);//3.客户端发送请求获取响应对象SearchResponse response client.search(request, RequestOptions.DEFAULT);//4.打印响应结果SearchHits hits response.getHits();System.out.println(took::response.getTook());System.out.println(time_out::response.isTimedOut());System.out.println(total::hits.getTotalHits());System.out.println(max_score::hits.getMaxScore());System.out.println(hits::::);for (SearchHit hit : hits) {String sourceAsString hit.getSourceAsString();System.out.println(sourceAsString);//打印高亮结果MapString, HighlightField highlightFields hit.getHighlightFields();System.out.println(highlightFields);}System.out.println(::::);};}9.最大值查询 import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));//最大值查询SearchRequest request new SearchRequest().indices(user);SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.aggregation(AggregationBuilders.max(maxAge).field(age));//设置请求体request.source(sourceBuilder);//3.客户端发送请求获取响应对象SearchResponse response client.search(request, RequestOptions.DEFAULT);//4.打印响应结果SearchHits hits response.getHits();System.out.println(response);}后台打印
{took:16,timed_out:false,_shards:{total:1,successful:1,skipped:0,failed:0},hits:{total:{value:6,relation:eq},max_score:1.0,hits:[{_index:user,_type:_doc,_id:1001,_score:1.0,_source:{name:zhangsan,age:10,sex:女}},{_index:user,_type:_doc,_id:1002,_score:1.0,_source:{name:lisi,age:30,sex:女}},{_index:user,_type:_doc,_id:1003,_score:1.0,_source:{name:wangwu1,age:40,sex:男}},{_index:user,_type:_doc,_id:1004,_score:1.0,_source:{name:wangwu2,age:20,sex:女}},{_index:user,_type:_doc,_id:1005,_score:1.0,_source:{name:wangwu3,age:50,sex:男}},{_index:user,_type:_doc,_id:1006,_score:1.0,_source:{name:wangwu4,age:20,sex:男}}]},aggregations:{max#maxAge:{value:50.0}}}Process finished with exit code 0
10.分组查询 import org.elasticsearch.index.query.TermsQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.sort.SortOrder;public class ESTest_Doc_Query {public static void main(String[] args) throws Exception {RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));SearchRequest request new SearchRequest().indices(user);SearchSourceBuilder sourceBuilder new SearchSourceBuilder();sourceBuilder.aggregation(AggregationBuilders.terms(age_groupby).field(age));//设置请求体request.source(sourceBuilder);//3.客户端发送请求获取响应对象SearchResponse response client.search(request, RequestOptions.DEFAULT);//4.打印响应结果SearchHits hits response.getHits();System.out.println(response);}后台打印
{took:10,timed_out:false,_shards:{total:1,successful:1,skipped:0,failed:0},hits:{total:{value:6,relation:eq},max_score:1.0,hits:[{_index:user,_type:_doc,_id:1001,_score:1.0,_source:{name:zhangsan,age:10,sex:女}},{_index:user,_type:_doc,_id:1002,_score:1.0,_source:{name:lisi,age:30,sex:女}},{_index:user,_type:_doc,_id:1003,_score:1.0,_source:{name:wangwu1,age:40,sex:男}},{_index:user,_type:_doc,_id:1004,_score:1.0,_source:{name:wangwu2,age:20,sex:女}},{_index:user,_type:_doc,_id:1005,_score:1.0,_source:{name:wangwu3,age:50,sex:男}},{_index:user,_type:_doc,_id:1006,_score:1.0,_source:{name:wangwu4,age:20,sex:男}}]},aggregations:{lterms#age_groupby:{doc_count_error_upper_bound:0,sum_other_doc_count:0,buckets:[{key:20,doc_count:2},{key:10,doc_count:1},{key:30,doc_count:1},{key:40,doc_count:1},{key:50,doc_count:1}]}}}Process finished with exit code 0