RestClient的基本操作2-创新互联

match匹配具体及分词内容

成都创新互联公司是一家专业提供绵阳企业网站建设,专注与成都网站建设、网站制作、H5建站、小程序制作等业务。10年已为绵阳众多企业、政府机构等服务。创新互联专业网站建设公司优惠进行中。

@Test
void testMatch() throws IOException {SearchRequest request = new SearchRequest("hotel");
    request.source().query(QueryBuilders.matchQuery("all","如家"));
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
    //4、解析响应
    handleResponse(response);
}

term具体匹配，不分词

@Test
void testTerm() throws IOException {SearchRequest request = new SearchRequest("hotel");
    request.source().query(QueryBuilders.termQuery("city","上海"));
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    handleResponse(response);
}

range范围查询

@Test
void testRange() throws IOException {SearchRequest request = new SearchRequest("hotel");
    request.source().query(QueryBuilders.rangeQuery("price").gte(100).lte(2000));
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    handleResponse(response);
}

多条件查询

@Test
void testBoolQuery() throws IOException {SearchRequest request = new SearchRequest("hotel");
    //组装bool条件
    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    boolQueryBuilder.must(QueryBuilders.termQuery("city","上海"));
    boolQueryBuilder.must(QueryBuilders.termQuery("brand","如家"));
    boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(250));
    request.source().query(boolQueryBuilder);
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    handleResponse(response);

分页和排序

还记得我们mysql的分页吗？

@Test
void pageAndSort() throws IOException {int page = 1,size = 5;
    SearchRequest request = new SearchRequest("hotel");
    request.source().query(QueryBuilders.matchAllQuery());
    //排序
    request.source().sort("price", SortOrder.ASC);
    //分页
    request.source().from((page-1)*size).size(size);
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    handleResponse(response);
}

被标签包裹会高亮显示

我们这里后端处理，当然前端也可以

@Test
void testHighlight() throws IOException {SearchRequest request = new SearchRequest("hotel");
    request.source().query(QueryBuilders.matchQuery("name","如家"));
    request.source().highlighter(new HighlightBuilder()
            .field("name").requireFieldMatch(false));
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    handleResponse(response);
}

代码冗长，将解析单独封装

我的案例解析皆为此方法

private void handleResponse(SearchResponse response) {SearchHits searchHits = response.getHits();
    //4.1、获取总条数
    long total = searchHits.getTotalHits().value;
    System.out.println("共搜索到" + total + "条");
    //4.2、文档数组
    SearchHit[] hits = searchHits.getHits();
    for (SearchHit hit : hits) {String json = hit.getSourceAsString();
        HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
        //获取高亮结果
        MaphighlightFields = hit.getHighlightFields();
        if(!CollectionUtils.isEmpty(highlightFields)){//根据字段获取高亮结果
            HighlightField highlightField = highlightFields.get("name");
            //获取高亮值
            String name = highlightField.getFragments()[0].string();
            //覆盖非高亮值
            if(name!=null){//判空处理
                hotelDoc.setName(name);
            }
        }
        System.out.println("hotelDoc=>" + hotelDoc);
    }
}

@Test
void testAggregation() throws IOException {//准备request
    SearchRequest request = new SearchRequest("hotel");
    //准备DSL
    //设置size、清除文档数据
    request.source().size(0);
    //聚合
    request.source().aggregation(AggregationBuilders
            .terms("brand")
            .size(20)
            .field("brand")) ;
    //发出请求
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    //解析结果
    Aggregations aggregations = response.getAggregations();
    Terms brands = aggregations.get("brand");
    Listbuckets = brands.getBuckets();
    for (Terms.Bucket bucket: buckets){String key = bucket.getKeyAsString();
        System.out.println(key);
    }
}

@Test
void testAggregations() throws IOException {//准备request
    SearchRequest request = new SearchRequest("hotel");
    //准备DSL、限定查询范围
    //设置size、清除文档数据
    request.source().size(0);
    //聚合
    buildAggregation(request);
    //发出请求
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    //解析结果
    Map>map = new HashMap<>();
    Aggregations aggregations = response.getAggregations();
    //根据名称放入品牌结果
    ListbrandList = getAggByName(aggregations,"brand");
    ListcityList = getAggByName(aggregations,"city");
    map.put("品牌",brandList);
    map.put("city",cityList);
    System.out.println(map);
}

private void buildAggregation(SearchRequest request) {request.source().aggregation(AggregationBuilders
            .terms("brand")
            .size(200)
            .field("brand")) ;
    request.source().aggregation(AggregationBuilders
            .terms("city")
            .size(200)
            .field("city")) ;
}

private ListgetAggByName(Aggregations aggregations,String aggName) {Terms brands = aggregations.get(aggName);
    Listbuckets = brands.getBuckets();
    ListbrandList = new ArrayList<>();
    for (Terms.Bucket bucket: buckets){String key = bucket.getKeyAsString();
        brandList.add(key);
    }
    return brandList;
}

自动补全需要pinyin分词器，需要在github上自行下载

@Test
void testSuggest() throws IOException {//准备request
    SearchRequest request = new SearchRequest("hotel");
    //准备DSL
    request.source().suggest(new SuggestBuilder().addSuggestion(
            "suggestions",
            //补全的字段
            SuggestBuilders.completionSuggestion("suggestion")
                    .prefix("sh")
                    .skipDuplicates(true)
                    .size(10)
    ));
    //发起请求
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
    //解析结果
    Suggest suggest = response.getSuggest();
    CompletionSuggestion suggestions = suggest.getSuggestion("suggestions");
    Listoptions = suggestions.getOptions();
    for(CompletionSuggestion.Entry.Option option :options){String text = option.getText().toString();
        System.out.println(text);
    }
}

• 准备request
• 准备DSL、query的条件或者聚合分页处理等
• 发出request
• 解析response

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧