devbox
菜鸟追梦旅行
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

【ES】JavaAPI学习-08 模糊查询 高亮查询 聚合查询 分组查询_querybuilders模糊查询

作者：菜鸟追梦旅行 | 2024-04-27 22:46:30

赞

踩

querybuilders模糊查询

在这里插入图片描述

前言

本节实现条件查询中的模糊查询，高亮查询， 聚合查询 分组查询

模糊查询 高亮查询

模糊查询：模糊查询允许你查找与给定术语相似但不完全匹配的文档

高亮查询：高亮查询可以突出显示匹配查询条件的部分

实现

ESTest_Doc_Cond_Query_Fuzzy.java

org.elasticsearch.index.query.QueryBuilders：提供构建各种查询条件的方法。

org.elasticsearch.common.unit.Fuzziness：定义模糊匹配的模糊程度。

构建模糊查询请求：
创建一个SearchRequest对象，指定要查询的索引为"users"。
创建一个SearchSourceBuilder对象，用于构建查询条件。
使用QueryBuilders.fuzzyQuery("name", "王五").fuzziness(Fuzziness.ONE)构建一个模糊查询条件，表示查询"name"字段包含与"王五"相似的文档，其中"Fuzziness.ONE"表示最大编辑距离为1（即最多允许有一个字符的差异）。
将模糊查询条件设置到SearchSourceBuilder对象中。
将SearchSourceBuilder对象设置到SearchRequest对象中。

package com.zwy.es;

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.RestHighLevelClient;
import org.elasticsearch.common.unit.Fuzziness;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.RangeQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class ESTest_Doc_Cond_Query_Fuzzy {
    public static void main(String[] args) throws IOException {

        //
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        // 模糊查询数据
        SearchRequest request = new SearchRequest();
        request.indices("users");

        SearchSourceBuilder builer = new SearchSourceBuilder();
        builer.query(QueryBuilders.fuzzyQuery("name", "王五").fuzziness(Fuzziness.ONE));

        request.source(builer);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();

        System.out.println(hits.getTotalHits());  // 打印
        System.out.println(response.getTook());  // 打印

        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        // 关闭ES客户端
        esClient.close();

    }
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50

ESTest_Doc_Cond_Query_Highlight.java

org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder：用于构建高亮显示规则的类。

构建查询和高亮显示请求：
创建一个SearchRequest对象，指定要查询的索引为"users"。
创建一个SearchSourceBuilder对象，用于构建查询条件和高亮显示规则。
使用QueryBuilders.termQuery("name", "张三")构建一个精确匹配查询条件，表示查询"name"字段等于"张三"的文档。
创建一个HighlightBuilder对象，用于定义高亮显示规则。
使用highlightBuilder.preTags("<font color='red'>")和highlightBuilder.postTags("</font>")设置高亮标签的开始和结束标签，这里将匹配的文本用红色字体显示。
使用highlightBuilder.field("name")指定需要高亮显示的字段，这里是"name"字段。
将高亮显示规则设置到SearchSourceBuilder对象中。
将查询条件设置到SearchSourceBuilder对象中。
将SearchSourceBuilder对象设置到SearchRequest对象中。

package com.zwy.es;

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.RestHighLevelClient;
import org.elasticsearch.common.unit.Fuzziness;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;

import java.io.IOException;

public class ESTest_Doc_Cond_Query_Highlight {
    public static void main(String[] args) throws IOException {

        //
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        // 模糊查询数据
        SearchRequest request = new SearchRequest();
        request.indices("users");

        SearchSourceBuilder builer = new SearchSourceBuilder();
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "张三");

        HighlightBuilder highlightBuilder = new HighlightBuilder();
        highlightBuilder.preTags("<font color='red'>");
        highlightBuilder.postTags("</font>");
        highlightBuilder.field("name");

        builer.highlighter(highlightBuilder);
        builer.query(termQueryBuilder);

        request.source(builer);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();

        System.out.println(hits.getTotalHits());  // 打印
        System.out.println(response.getTook());  // 打印

        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        // 关闭ES客户端
        esClient.close();

    }
}



  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60

文件结构

文件结构如下：

在这里插入图片描述

运行

ESTest_Doc_Cond_Query_Fuzzy.java，结果如下：

在这里插入图片描述

成功

ESTest_Doc_Cond_Query_Highlight.java，结果如下：

在这里插入图片描述
可以看到没有命中

聚合查询 分组查询

聚合查询：聚合查询允许你对搜索结果进行统计分析。

分组查询：分组查询通常是指术语聚合，它将文档按某个字段的值进行分组

实现

聚合查询
ESTest_Doc_Cond_Query_Agg.java

org.elasticsearch.index.query.TermQueryBuilder：用于构建精确匹配查询条件的类。
org.elasticsearch.search.aggregations.AggregationBuilders：提供构建各种聚合操作的方法

构建查询和聚合请求：
创建一个SearchRequest对象，指定要查询的索引为"users"。
创建一个SearchSourceBuilder对象，用于构建查询条件和聚合操作。
使用AggregationBuilders.max("maxAge").field("age")构建一个最大值聚合操作，表示计算"name"字段等于"张三"的文档中"age"字段的最大值，并将这个聚合操作命名为"maxAge"。
将聚合操作设置到SearchSourceBuilder对象中。
将SearchSourceBuilder对象设置到SearchRequest对象中。

package com.zwy.es;

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.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
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 java.io.IOException;

public class ESTest_Doc_Cond_Query_Agg {
    public static void main(String[] args) throws IOException {

        //
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        // 聚合查询查询数据
        SearchRequest request = new SearchRequest();
        request.indices("users");

        SearchSourceBuilder builer = new SearchSourceBuilder();
        AggregationBuilder aggregationBuilder = AggregationBuilders.max("maxAge").field("age");

        builer.aggregation(aggregationBuilder);

        request.source(builer);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();

        System.out.println(hits.getTotalHits());  // 打印
        System.out.println(response.getTook());  // 打印

        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        // 关闭ES客户端
        esClient.close();

    }
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54

分组查询
ESTest_Doc_Cond_Query_Group.java

org.elasticsearch.search.aggregations.AggregationBuilders：提供构建各种聚合操作的方法。

构建分组查询请求：
创建一个SearchRequest对象，指定要查询的索引为"users"。
创建一个SearchSourceBuilder对象，用于构建分组查询条件。
使用AggregationBuilders.terms("ageGroup").field("age")构建一个术语聚合操作，表示根据"name"字段等于"张三"的文档中"age"字段的值进行分组，并将这个聚合操作命名为"ageGroup"。
将聚合操作设置到SearchSourceBuilder对象中。
将SearchSourceBuilder对象设置到SearchRequest对象中。

package com.zwy.es;

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.RestHighLevelClient;
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 java.io.IOException;

public class ESTest_Doc_Cond_Query_Group {
    public static void main(String[] args) throws IOException {

        //
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        // 分组查询查询数据
        SearchRequest request = new SearchRequest();
        request.indices("users");

        SearchSourceBuilder builer = new SearchSourceBuilder();
        AggregationBuilder aggregationBuilder = AggregationBuilders.terms("ageGroup").field("age");
        builer.aggregation(aggregationBuilder);

        request.source(builer);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();

        System.out.println(hits.getTotalHits());  // 打印
        System.out.println(response.getTook());  // 打印

        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        // 关闭ES客户端
        esClient.close();

    }
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50

文件结构

文件结构如下：

在这里插入图片描述

运行

运行ESTest_Doc_Cond_Query_Agg.java，结果如下：

在这里插入图片描述
运行ESTest_Doc_Cond_Query_Group.java，结果如下：
在这里插入图片描述

成功！

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/499092
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号