【ElasticSearch教程】--- Elasticsearch JavaApi 文档查询操作（二十）

Elasticsearch JavaApi 文档查询操作

在前面的restful api测试的过程中，我们使用的大量的参数提交的方式进行文档的查询操作。例如：全量查询，分页查询，模糊查询等等。那java api其实也是提供了对应的查询操作功能的。

全量查询

全量查询就是不提交任何的查询条件直接将ES上有的文档数据一次性的查询出来。查询的核心是要构造一个org.elasticsearch.action.search.SearchRequest;对象，并且使用client.search()方法即可查询。下面是java api查询文档的步骤:

构造Httphost对象。
构造RestClientBuilder对象。
构建客户端对象RestHighLevelClient对象。
构造org.elasticsearch.action.search.SearchRequest.
使用indices（）方法设置要查询文档所在的index。
发起请求得到查询结果响应。
关闭客户端链接
测试代码如下:

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.search.SearchHits;


public class DocQueryAll {

    public static void main(String[] args) throws Exception {
        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 查询数据
        SearchRequest request = new SearchRequest();
        request.indices("teacher");
        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();
    }
}

由于我们将执行后的结果的hits进行了打印。所以程序运行的输出为:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7001",
  "_score" : 1.0,
  "_source" : {
    "name" : "方腊",
    "sex" : "男",
    "age" : "38",
    "title" : "教授"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.0,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7003",
  "_score" : 1.0,
  "_source" : {
    "name" : "花荣",
    "sex" : "男",
    "age" : "25",
    "title" : "助教"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7004",
  "_score" : 1.0,
  "_source" : {
    "name" : "孙二娘",
    "sex" : "女",
    "age" : "28",
    "title" : "副教授"
  }
}

Process finished with exit code 0

从执行的结果可以看出，我们把teacher索引下的内容都正常的请求下来了。java api的全量查询结果其实也是和restful api是基本一致的。

条件查询

条件查询其实就是在全量查询的基础上进行怎么条件内容. 条件的构建分了3步走：

构建一个QueryBuilder,改对象由QueryBuilders来构建，比如，年龄等于35的，QueryBuilder age = QueryBuilders.termQuery("age", 35);
创建一个org.elasticsearch.search.builder.SearchSourceBuilder,直接new就ok。
然后把条件弄进SearchSourceBuilder，弄进去就用query()方法.
把SearchSourceBuilder设置到SearchRequest中request.source(query);。
以上就已经把条件弄到请求里面去了。样例代码如下:

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;


public class DocQueryCondition {

    public static void main(String[] args) throws Exception {
        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 条件查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");
        // 添加条件
        QueryBuilder age = QueryBuilders.termQuery("age", 35);
        SearchSourceBuilder query = new SearchSourceBuilder().query(age);
        request.source(query);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();
    }
}

执行结果:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.0,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  }
}

结果仅匹配到了35岁的宋江大哥.
我们再测试一下

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;


public class DocQueryCondition {

    public static void main(String[] args) throws Exception {
        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 条件查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");
        // 添加条件
        QueryBuilder age = QueryBuilders.termQuery("name", "宋");
        SearchSourceBuilder query = new SearchSourceBuilder().query(age);
        request.source(query);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();
    }

}

这次使用的是name字段,值是宋。
查询结果:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.2613049,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  }
}

分页查询

分页查询就是在条件查询的SearchSourceBuilder设置起查询文档的起始位置。
分页查询代码如下:

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;


public class DocQueryPagination {

    public static void main(String[] args) throws Exception {
        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 添加条件
        QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();//全查
        SearchSourceBuilder query = new SearchSourceBuilder().query(queryBuilder);
        query.from(0);
        query.size(2); //每页显示几条

        request.source(query);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();
    }

}

执行结果:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7001",
  "_score" : 1.0,
  "_source" : {
    "name" : "方腊",
    "sex" : "男",
    "age" : "38",
    "title" : "教授"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.0,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  }
}

从结果上可以看到，分页查询仅查询到了一页数据。

查询结果排序

查询结果排序就是在SearchSourceBuilder的sort方法进行。
例如:

 SearchSourceBuilder query = new SearchSourceBuilder().query(queryBuilder);
 query.sort("age", SortOrder.DESC);//年龄从大大小

以下是全量查询，以年龄倒序的查询例子.

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.SortOrder;


public class DocQueryOrder {

    public static void main(String[] args) throws Exception {
        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 添加条件
        QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();//全查
        SearchSourceBuilder query = new SearchSourceBuilder().query(queryBuilder);
        query.sort("age", SortOrder.DESC);//年龄从大大小

        request.source(query);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();
    }
}

查询输出结果：

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7001",
  "_score" : null,
  "_source" : {
    "name" : "方腊",
    "sex" : "男",
    "age" : "38",
    "title" : "教授"
  },
  "sort" : [
    38
  ]
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : null,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  },
  "sort" : [
    35
  ]
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7004",
  "_score" : null,
  "_source" : {
    "name" : "孙二娘",
    "sex" : "女",
    "age" : "28",
    "title" : "副教授"
  },
  "sort" : [
    28
  ]
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7003",
  "_score" : null,
  "_source" : {
    "name" : "花荣",
    "sex" : "男",
    "age" : "25",
    "title" : "助教"
  },
  "sort" : [
    25
  ]
}

从输出结果可以看出，结果的顺序是按照年龄从大到小的形式输出。

过滤字段

在我们查询的过程中，我们可能存在只需要部分字段的情况。
下面例子是仅获取，姓名和性别的过滤的例子。

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.SortOrder;


public class DocQueryFieldFilter {

    public static void main(String[] args) throws Exception {

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 添加条件
        QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();//全查
        SearchSourceBuilder query = new SearchSourceBuilder().query(queryBuilder);

//        过滤字段
        query.fetchSource(new String[]{"name", "sex"}, null);
        request.source(query);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();

    }

}

执行查询的结果为:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7001",
  "_score" : 1.0,
  "_source" : {
    "sex" : "男",
    "name" : "方腊"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.0,
  "_source" : {
    "sex" : "男",
    "name" : "宋江"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7003",
  "_score" : 1.0,
  "_source" : {
    "sex" : "男",
    "name" : "花荣"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7004",
  "_score" : 1.0,
  "_source" : {
    "sex" : "女",
    "name" : "孙二娘"
  }
}

从返回的内容可以看出，仅查询了sex和name。

多条件联合查询

多条件查询需要用到BoolQueryBuilder,通过QueryBuilders.boolQuery();获取. 多个条件的满足关系。

必须满足must
必须不满足mustNot
可以满足should
例子，查询年龄必须等于35.性别必须等于男。
样例代码：

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;


public class DocQueryMultCondition {

    public static void main(String[] args) throws Exception {

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 组合条件
        BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();//全查
        queryBuilder.must(QueryBuilders.matchQuery("age", "35"));
        queryBuilder.must(QueryBuilders.matchQuery("sex", "男"));

        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(queryBuilder);
        request.source(searchSourceBuilder);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();

    }
}

由于ES的文档中只有宋江满足。所以查询结果为:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.3566749,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  }
}

范围查询

范围查询在工程实践中也是常常被要求的，比如需要得到30岁到40岁的teacher. 需要用到RangeQueryBuilder。
样例代码：

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.RangeQueryBuilder;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;


public class DocQueryRange {

    public static void main(String[] args) throws Exception {

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 组合条件
        RangeQueryBuilder query = QueryBuilders.rangeQuery("age");
        query.gte(30);
        query.lte(40);

        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(query);
        request.source(searchSourceBuilder);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);
        
        client.close();

    }
}

查询结果:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7001",
  "_score" : 1.0,
  "_source" : {
    "name" : "方腊",
    "sex" : "男",
    "age" : "38",
    "title" : "教授"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.0,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  }
}

模糊查询

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.unit.Fuzziness;
import org.elasticsearch.index.query.FuzzyQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.RangeQueryBuilder;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;


public class DocFuzzyQuery {

    public static void main(String[] args) throws Exception {

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 组合条件
        FuzzyQueryBuilder query = QueryBuilders.fuzzyQuery("name", "宋").fuzziness(Fuzziness.ONE);
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(query);
        request.source(searchSourceBuilder);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();

    }

}

高亮查询

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.unit.Fuzziness;
import org.elasticsearch.index.query.FuzzyQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;


public class DocHigLightQuery {

    public static void main(String[] args) throws Exception {

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 组合条件
        TermQueryBuilder query = QueryBuilders.termQuery("name", "宋");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(query);
        request.source(searchSourceBuilder);
        HighlightBuilder highlight = SearchSourceBuilder.highlight();
        highlight.preTags("");
        highlight.field("name");
        searchSourceBuilder.highlighter(highlight);
        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();

    }

}

响应结果:

{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.2613049,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  },
  "highlight" : {
    "name" : [
      "江"
    ]
  }
}

聚合查询

查询最大年龄

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.metrics.ParsedMax;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;


public class DocPolyQuery {

    public static void main(String[] args) throws Exception {

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 组合条件
        AggregationBuilder query = AggregationBuilders.max("maxAge").field("age");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().aggregation(query);
        request.source(searchSourceBuilder);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        System.out.println(((ParsedMax) search.getAggregations().get("maxAge")).getValue());
        System.out.println(search.getAggregations().getAsMap().get("maxAge").getName());
        SearchHits hits = search.getHits();
        hits.forEach(System.out::println);

        client.close();

    }

}

查询输出:

38.0
maxAge
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7001",
  "_score" : 1.0,
  "_source" : {
    "name" : "方腊",
    "sex" : "男",
    "age" : "38",
    "title" : "教授"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7002",
  "_score" : 1.0,
  "_source" : {
    "name" : "宋江",
    "sex" : "男",
    "age" : "35",
    "title" : "副教授"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7003",
  "_score" : 1.0,
  "_source" : {
    "name" : "花荣",
    "sex" : "男",
    "age" : "25",
    "title" : "助教"
  }
}
{
  "_index" : "teacher",
  "_type" : "_doc",
  "_id" : "7004",
  "_score" : 1.0,
  "_source" : {
    "name" : "孙二娘",
    "sex" : "女",
    "age" : "28",
    "title" : "副教授"
  }
}

Process finished with exit code 0

分组查询

分组查询也是聚合查询的一种，他可以按照某个字段进行分组，统计。比如统计个数.

package com.maomao.elastic.search.query;

import org.apache.http.HttpHost;
import org.apache.lucene.queryparser.flexible.standard.builders.GroupQueryNodeBuilder;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.ParsedLongTerms;
import org.elasticsearch.search.aggregations.metrics.ParsedMax;
import org.elasticsearch.search.builder.SearchSourceBuilder;


public class DocGroupQuery {

    public static void main(String[] args) throws Exception {

        HttpHost host = new HttpHost("127.0.0.1", 9200, "http");
        RestClientBuilder builder = RestClient.builder(host);
        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 3. 分页查询
        SearchRequest request = new SearchRequest();
        request.indices("teacher");

        // 分组查询
        AggregationBuilder query = AggregationBuilders.terms("ageGroup").field("age");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().aggregation(query);
        request.source(searchSourceBuilder);

        SearchResponse search = client.search(request, RequestOptions.DEFAULT);
        ((ParsedLongTerms) search.getAggregations().get("ageGroup")).getBuckets().forEach(item -> {
            System.out.println(item.getKey() + "===>>" + item.getDocCount());
        });

        client.close();

    }
}

输出结果’

25===>>1
28===>>1
35===>>1
38===>>1

【ElasticSearch教程】--- Elasticsearch JavaApi 文档查询操作（二十）

Java相关栏目本月热门文章