- 数据准备
- 查询操作
2.1 match查询
2.2 bool查询
2.3 constant_score查询
2.4 matchPhraseQuery搜索
2.5 range范围查询
Es7.x使用RestHighLevelClient进行增删改和批量操作中，使用RestHighLevelClient完成基本的增删改和批量操作，本文着重进行查询操作api的使用。
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. 查询操作
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"
}
}
}
响应结果.png
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"
}
}
}
image.png
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"
}
}
}
