Es7.x使用RestHighLevelClient进行查询操作

数据准备查询操作2.1 match查询2.2 bool查询2.3 constant_score查询2.4 matchPhraseQuery搜索2.5 range范围查询1. 数据准备数据准备：接入方式详见Es7.x使用RestHighLevelClient进行增删改和批量操作PUT test_demoPUT test_demo/_mapping{"properties":{"id":{"type"

qq_duhai

8816人浏览 · 2022-01-27 12:01:02

qq_duhai · 2022-01-27 12:01:02 发布

数据准备
查询操作
2.1 match查询
2.2 bool查询
2.3 constant_score查询
2.4 matchPhraseQuery搜索
2.5 range范围查询

1. 数据准备

数据准备：接入方式详见Es7.x使用RestHighLevelClient进行增删改和批量操作

PUT test_demo
 
PUT test_demo/_mapping
{
  "properties":{
    "id":{
      "type":"long"
    },
    "title":{
      "type":"text",
      "analyzer": "ik_max_word"
    },
    "tag":{
      "type":"keyword"
    },
    "publishTime":{
      "type":"date",
      "format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
    }
  }
}

批量存储数据

    public static void testBatch() {
        List<IndexRequest> indexRequests = new ArrayList<>();
 
        ArrayList<DemoDto> demoDtos = new ArrayList<>();
 
 
        demoDtos.add(new DemoDto(1001L, "英国新冠疫情严重", "疫情", new Date()));
        demoDtos.add(new DemoDto(1002L, "疫情影响毕业生找工作", "疫情", new Date()));
        demoDtos.add(new DemoDto(1003L, "公安子女赴美签证被拒？中方回应", "教育", new Date()));
        demoDtos.add(new DemoDto(1004L, "澳军舰疑撞死两头濒危鲸鱼", "军事", new Date()));
        demoDtos.add(new DemoDto(1005L, "2021全国高校毕业生909万", "教育", new Date()));
        demoDtos.add(new DemoDto(1006L, "英国航母补给舰起火", "军事", new Date()));
 
 
        demoDtos.forEach(e -> {
            IndexRequest request = new IndexRequest("test_demo");
            //填充id
            request.id(e.getId() + "");
            //先不修改id
            request.source(JSON.toJSONString(e), XContentType.JSON);
            request.opType(DocWriteRequest.OpType.CREATE);
            indexRequests.add(request);
        });
        indexRequests.forEach(bulkProcessor::add);
    }

执行结果：

17:33:15.759 [elasticsearch[scheduler][T#1]] INFO com.tellme.Test.EsTest - 1. 【beforeBulk】批次[1] 携带 6 请求数量

17:33:16.083 [I/O dispatcher 1] INFO com.tellme.Test.EsTest - 2. 【afterBulk-成功】批量 [1] 完成在 308 ms

2. 查询操作

es7.x（9）— match query的参数

2.1 match查询

    /**
     * match查询
     */
    public static void testMatch() throws Exception {
        RestHighLevelClient restHighLevelClient = EsUtil.getRestHighLevelClient();
        SearchRequest searchRequest = new SearchRequest();
        searchRequest.indices("test_demo");
 
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("title", "英国");
        //忽略格式错误
        matchQueryBuilder.lenient();
        searchSourceBuilder.query(matchQueryBuilder);
        //放入Request对象中
        log.info("dsl：" + searchSourceBuilder.toString());
 
        //组装语句
        searchRequest.source(searchSourceBuilder);
        SearchResponse response = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
        //获取到结果
        SearchHits hits = response.getHits();
        Iterator<SearchHit> iterator = hits.iterator();
        while (iterator.hasNext()) {
            log.info("输出数据:" + iterator.next().getSourceAsString());
        }
    }

转换后的语句：

GET test_demo/_search
{
    "query":{
        "match":{
            "title":{
                "query":"英国",
                "operator":"OR",
                "prefix_length":0,
                "max_expansions":50,
                "fuzzy_transpositions":true,
                "lenient":false,
                "zero_terms_query":"NONE",
                "auto_generate_synonyms_phrase_query":true,
                "boost":"1.0"
            }
        }
    }
}

2.2 bool查询

   public static void testBool() throws IOException {
        SearchRequest searchRequest=new SearchRequest();
        //构建dsl语句
        SearchSourceBuilder searchSourceBuilder=new SearchSourceBuilder();
        //构建查询条件
        BoolQueryBuilder boolQueryBuilder=new BoolQueryBuilder();
 
        boolQueryBuilder.mustNot(QueryBuilders.matchQuery("title","英国"));
 
        boolQueryBuilder.filter(QueryBuilders.termQuery("title","疫情"));
 
        searchSourceBuilder.query(boolQueryBuilder);
        log.info("dsl:"+searchSourceBuilder.toString());
        //填充到Request对象中
        searchRequest.indices("test_demo");
        searchRequest.source(searchSourceBuilder);
        SearchResponse response = EsUtil.getRestHighLevelClient().search(searchRequest, RequestOptions.DEFAULT);
 
        SearchHits hits = response.getHits();
        Iterator<SearchHit> iterator = hits.iterator();
        while (iterator.hasNext()) {
            log.info("输出数据:" + iterator.next().getSourceAsString());
        }
 
    }

转换后的dsl：

GET test_demo/_search
{
    "query":{
        "bool":{
            "filter":[
                {
                    "term":{
                        "title":{
                            "value":"疫情",
                            "boost":"1.0"
                        }
                    }
                }
            ],
            "must_not":[
                {
                    "match":{
                        "title":{
                            "query":"英国",
                            "operator":"OR",
                            "prefix_length":0,
                            "max_expansions":50,
                            "fuzzy_transpositions":true,
                            "lenient":false,
                            "zero_terms_query":"NONE",
                            "auto_generate_synonyms_phrase_query":true,
                            "boost":"1.0"
                        }
                    }
                }
            ],
            "adjust_pure_negative":true,
            "boost":"1.0"
        }
    }
}

filter和must_not属于Filter Context，不会对_score结果产生影响，但是Es提供了constant_score。对于filter可以设置常量分数。

2.3 constant_score查询

es（2）—复杂的多条件查询(bool查询与constant_score查询)

    public static void testConstantScore() throws IOException {
        SearchRequest searchRequest=new SearchRequest();
        //构建dsl语句
        SearchSourceBuilder searchSourceBuilder=new SearchSourceBuilder();
        //构建查询条件
        BoolQueryBuilder boolQueryBuilder=new BoolQueryBuilder();
 
        boolQueryBuilder.mustNot(QueryBuilders.matchQuery("title","英国"));
        /**
         * 设置constant_score搜索
         */
        ConstantScoreQueryBuilder constantScoreQueryBuilder = QueryBuilders.constantScoreQuery(QueryBuilders.termQuery("title", "疫情"));
        /**
         * 放入bool查询的should中
         */
        boolQueryBuilder.should(constantScoreQueryBuilder);
        /**
         * 将bool查询放入到request对象中
         */
        searchSourceBuilder.query(boolQueryBuilder);
        log.info("dsl:"+searchSourceBuilder.toString());
        //填充到Request对象中
        remoteSearch(searchRequest, searchSourceBuilder);
    }
 
    //远程调用
    private static void remoteSearch(SearchRequest searchRequest, SearchSourceBuilder searchSourceBuilder) throws IOException {
        searchRequest.indices("test_demo");
        searchRequest.source(searchSourceBuilder);
        SearchResponse response = EsUtil.getRestHighLevelClient().search(searchRequest, RequestOptions.DEFAULT);
 
        SearchHits hits = response.getHits();
        Iterator<SearchHit> iterator = hits.iterator();
        while (iterator.hasNext()) {
            SearchHit next = iterator.next();
            log.info("输出分数:" + next.getScore());
            log.info("输出数据:" + next.getSourceAsString());
        }
    }

转换dsl：

{
    "query":{
        "bool":{
            "must_not":[
                {
                    "match":{
                        "title":{
                            "query":"英国",
                            "operator":"OR",
                            "prefix_length":0,
                            "max_expansions":50,
                            "fuzzy_transpositions":true,
                            "lenient":false,
                            "zero_terms_query":"NONE",
                            "auto_generate_synonyms_phrase_query":true,
                            "boost":"1.0"
                        }
                    }
                }
            ],
            "should":[
                {
                    "constant_score":{
                        "filter":{
                            "term":{
                                "title":{
                                    "value":"疫情",
                                    "boost":"1.0"
                                }
                            }
                        },
                        "boost":"1.0"
                    }
                }
            ],
            "adjust_pure_negative":true,
            "boost":"1.0"
        }
    }
}

2.4 matchPhraseQuery搜索

    public static void testMatchPhraseQuery() throws IOException {
        SearchRequest searchRequest=new SearchRequest();
        //构建dsl语句
        SearchSourceBuilder searchSourceBuilder=new SearchSourceBuilder();
        //构建查询条件
        BoolQueryBuilder boolQueryBuilder=new BoolQueryBuilder();
 
        MatchPhraseQueryBuilder matchPhraseQueryBuilder = QueryBuilders.matchPhraseQuery("title", "英国新冠");
        matchPhraseQueryBuilder.slop(0);
        boolQueryBuilder.should(matchPhraseQueryBuilder);
 
        searchSourceBuilder.query(boolQueryBuilder);
        //填充到Request对象中
        remoteSearch(searchRequest, searchSourceBuilder);
    }
 
 
    //远程调用
    private static void remoteSearch(SearchRequest searchRequest, SearchSourceBuilder searchSourceBuilder) throws IOException {
        searchRequest.indices("test_demo");
        searchRequest.source(searchSourceBuilder);
        log.info("dsl:"+searchSourceBuilder.toString());
        SearchResponse response = EsUtil.getRestHighLevelClient().search(searchRequest, RequestOptions.DEFAULT);
 
        SearchHits hits = response.getHits();
        Iterator<SearchHit> iterator = hits.iterator();
        while (iterator.hasNext()) {
            SearchHit next = iterator.next();
            log.info("输出分数:" + next.getScore());
            log.info("输出数据:" + next.getSourceAsString());
        }
    }

2.5 range范围查询

    public static void testRange() throws IOException {
        SearchRequest searchRequest=new SearchRequest();
        //构建dsl语句
        SearchSourceBuilder searchSourceBuilder=new SearchSourceBuilder();
        //构建查询条件
        BoolQueryBuilder boolQueryBuilder=new BoolQueryBuilder();
 
        RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("publishTime");
        rangeQueryBuilder.gt("2021-05-14 11:39:27");
 
        boolQueryBuilder.filter(rangeQueryBuilder);
 
        searchSourceBuilder.query(boolQueryBuilder);
        //填充到Request对象中
        remoteSearch(searchRequest, searchSourceBuilder);
    }
 
 
    //远程调用
    private static void remoteSearch(SearchRequest searchRequest, SearchSourceBuilder searchSourceBuilder) throws IOException {
        searchRequest.indices("test_demo");
        searchRequest.source(searchSourceBuilder);
        log.info("dsl:"+searchSourceBuilder.toString());
        SearchResponse response = EsUtil.getRestHighLevelClient().search(searchRequest, RequestOptions.DEFAULT);
 
        SearchHits hits = response.getHits();
        Iterator<SearchHit> iterator = hits.iterator();
        while (iterator.hasNext()) {
            SearchHit next = iterator.next();
            log.info("输出分数:" + next.getScore());
            log.info("输出数据:" + next.getSourceAsString());
        }
    }

转换后的dsl语句

{
    "query":{
        "bool":{
            "filter":[
                {
                    "range":{
                        "publishTime":{
                            "from":"2021-05-14 11:39:27",
                            "to":null,
                            "include_lower":false,
                            "include_upper":true,
                            "boost":"1.0"
                        }
                    }
                }
            ],
            "adjust_pure_negative":true,
            "boost":"1.0"
        }
    }
}

华为云开发者联盟

为开发者提供学习成长、分享交流、生态实践、资源工具等服务，帮助开发者快速成长。

更多推荐