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