范围查询
/**
* 范围查询range
* @throws IOException
*/
@Test
public void testRange() throws IOException {
///创建构造器
RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("price");
//指定下限2000，上限3000
rangeQueryBuilder.gte(2000);
rangeQueryBuilder.lte(3000);
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式
searchSourceBuilder.query(rangeQueryBuilder);
//指定搜索构造器的排序方式
searchSourceBuilder.sort("price", SortOrder.ASC);
//指定搜索构造器的分页信息
searchSourceBuilder.from(0);
searchSourceBuilder.size(100);
///创建搜索请求对象searchRequest指定搜索的索引名称goods
SearchRequest searchRequest = new SearchRequest("goods");
//搜索请求对象指定搜索构造器searchSourceBuilder为我们要使用的搜索工具
searchRequest.source(searchSourceBuilder);
///创建搜索返回对象拿到指定搜索请求的搜索结果
SearchResponse searchResponse = client.search(searchRequest,RequestOptions.DEFAULT);
///创建搜索命中数对象从搜索返回对象中拿到命中数
SearchHits searchHits = searchResponse.getHits();
///创建一个集合
List<Goods> goodsList = new ArrayList<>();
//以集合方式获取命中的数据
for (SearchHit searchHit : searchHits) {
//获取json字符串格式的数据
String sourceAsString = searchHit.getSourceAsString();
//字符串转为java对象
Goods goods = JSON.parseObject(sourceAsString,Goods.class);
goodsList.add(goods);
}
///打印一下
for (Goods goods : goodsList) { System.out.println(goods); }
}
查询全部match_all：
查询全部数据，一般不会用这个。
//创建查询构造器queryBuilder来指定查询matchAllQuery
QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();
//创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式为查询构造器queryBuilder指定查询matchAllQuery
searchSourceBuilder.query(queryBuilder);
词条查询/精确查询term：
完全匹配，搜索“小米手机”那么结果必须是“小米手机”这四个字连着，如果搜索“小米iphoneXR”则什么结果都不会返回（除非数据库里有数据真的写的是“小米iphoeneXR”），一般用于选择品牌,高级选项等位置。
//创建查询构造器queryBuilder来指定查询termQuery
//QueryBuilder queryBuilder = QueryBuilders.termQuery("title","小米");
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
boolQueryBuilder.filter(QueryBuilders.termQuery("title","华为"));
//创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式为查询构造器queryBuilder指定查询termQuery
//searchSourceBuilder.query(queryBuilder);
searchSourceBuilder.query(boolQueryBuilder);
分词查询match：
先分词，比如搜索“小米手机”，通过ik分词器分为“小米”和“手机”，“小米”和“手机”有两种逻辑，一种是and，一种是or
如果选择and逻辑：
搜索结果为“xxxx小米xxxxxxxx手机xxxx”，结果较少。
如果选择or逻辑：
搜索结果为“xxxx小米xxxxxxxx手机xxxx”，“xxxxxx小米xxxx”，“xxxxx手机xxxx”，结果较多。
//创建查询构造器其父类MatchQueryBuilder来指定查询*Query
MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("title","小米手机");
//and逻辑，or逻辑在后面改为OR即可
matchQueryBuilder.operator(Operator.AND);
//创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式为查询构造器queryBuilder指定查询*Query
//searchSourceBuilder.query(queryBuilder);
searchSourceBuilder.query(matchQueryBuilder);
模糊查询wildcard:
///创建模糊查询构造器wildcardQueryBuilder来指定查询*Query
WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("title","小*");
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式为模糊查询构造器wildcardQueryBuilder
searchSourceBuilder.query(wildcardQueryBuilder);
正则查询Regexp:
///创建构造器
RegexpQueryBuilder regexpQueryBuilder = QueryBuilders.regexpQuery("title", "\w+(.)*");
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式
searchSourceBuilder.query(regexpQueryBuilder);
前缀查询：
///创建构造器
PrefixQueryBuilder prefixQueryBuilder = QueryBuilders.prefixQuery("brandName","小");
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式
searchSourceBuilder.query(prefixQueryBuilder);
多字段查询queryString:
///创建构造器
QueryStringQueryBuilder queryStringQueryBuilder = QueryBuilders.queryStringQuery("小米手机").field("title").field("categoryName").field("brandName").defaultOperator(AND);
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式
searchSourceBuilder.query(queryStringQueryBuilder);
//指定搜索构造器的排序方式
searchSourceBuilder.sort("price", SortOrder.ASC);
多条件拼接boolQuery:
must筛选并计算分支:
should:
must_not:
filter筛选并不计算分值，效率高，推荐使用：
///创建各个查询条件:品牌brandName
QueryBuilder queryTermBuilder = QueryBuilders.termQuery("brandName","小米");
///创建各个查询条件:标题title
QueryBuilder queryMatchQuery = QueryBuilders.matchQuery("title","手机");
///创建各个查询条件:价格范围priceRange
RangeQueryBuilder priceRangeQueryBuilder = QueryBuilders.rangeQuery("price");
///创建布尔查询构造器
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
boolQueryBuilder.must(queryTermBuilder);
boolQueryBuilder.filter(queryMatchQuery);
boolQueryBuilder.filter(priceRangeQueryBuilder);
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式
searchSourceBuilder.query(boolQueryBuilder);
聚合查询——桶聚合Agg:
public void testAgg() throws IOException {
///创建构造器
MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("title", "手机");
///创建聚合构造器
AggregationBuilder aggregationBuilder = AggregationBuilders.terms("goods_brands").field("brandName").size(100);
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式
searchSourceBuilder.query(matchQueryBuilder);
//指定搜索构造器查询聚合
searchSourceBuilder.aggregation(aggregationBuilder);
//指定搜索构造器的分页信息
searchSourceBuilder.from(0);
searchSourceBuilder.size(100);
///创建搜索请求对象searchRequest指定搜索的索引名称goods
SearchRequest searchRequest = new SearchRequest("goods");
//搜索请求对象指定搜索构造器searchSourceBuilder为我们要使用的搜索工具
searchRequest.source(searchSourceBuilder);
///创建搜索返回对象拿到指定搜索请求的搜索结果
SearchResponse searchResponse = client.search(searchRequest,RequestOptions.DEFAULT);
///创建搜索命中数对象从搜索返回对象中拿到命中数
SearchHits searchHits = searchResponse.getHits();
///创建一个集合
List<Goods> goodsList = new ArrayList<>();
//以集合方式获取命中的数据
for (SearchHit searchHit : searchHits) {
//获取json字符串格式的数据
String sourceAsString = searchHit.getSourceAsString();
//字符串转为java对象
Goods goods = JSON.parseObject(sourceAsString,Goods.class);
goodsList.add(goods);
}
///打印一下
for (Goods goods : goodsList) { System.out.println(goods); }
//获取聚合结果
Aggregations aggregations = searchResponse.getAggregations();
Map<String, Aggregation> aggregationMap = aggregations.asMap();
Terms goods_brands = (Terms)aggregationMap.get("goods_brands");
List<? extends Term.Bucket> buckets = goods_brands.getBuckets();
List brands = new ArrayList();
for (Term.Bucket bucket : buckets) {
Object key = bucket.getKey();
brands.add(key);
}
for (Term.Bucket bucket : buckets) {
System.out.println(brands);
}
}
高亮聚合highlight：
public void testHighlight() throws IOException {
///创建构造器
MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("title","手机");
///创建高亮构造器和设置三要素
HighlightBuilder highlightBuilder = new HighlightBuilder();
highlightBuilder.field("title");
highlightBuilder.preTags("<font color='red'>");
highlightBuilder.postTags("</font>");
///创建搜索构造器searchSourceBuilder
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//指定搜索构造器的查询方式
searchSourceBuilder.query(matchQueryBuilder);
//指定搜索构造器的高亮模式
searchSourceBuilder.highlighter(highlightBuilder);
//指定搜索构造器的分页信息
searchSourceBuilder.from(0);
searchSourceBuilder.size(100);
///创建搜索请求对象searchRequest指定搜索的索引名称goods
SearchRequest searchRequest = new SearchRequest("goods");
//搜索请求对象指定搜索构造器searchSourceBuilder为我们要使用的搜索工具
searchRequest.source(searchSourceBuilder);
///创建搜索返回对象拿到指定搜索请求的搜索结果
SearchResponse searchResponse = client.search(searchRequest,RequestOptions.DEFAULT);
///创建搜索命中数对象从搜索返回对象中拿到命中数
SearchHits searchHits = searchResponse.getHits();
///创建一个集合
List<Goods> goodsList = new ArrayList<>();
//以集合方式获取命中的数据
for (SearchHit searchHit : searchHits) {
//获取json字符串格式的数据
String sourceAsString = searchHit.getSourceAsString();
//字符串转为java对象
Goods goods = JSON.parseObject(sourceAsString,Goods.class);
//获取高亮结果，替换goods中的title
Map<String, HighlightField> highlightFieldMap = searchHit.getHighlightFields();
HighlightField highlightField = highlightFieldMap.get("title");
Text[] fragments = highlightField.fragments();
goods.setTitle(fragments[0].toString());
goodsList.add(goods);
}
///打印一下
for (Goods goods : goodsList) { System.out.println(goods); }
}