1.增加es使用示例
This commit is contained in:
xuwujing
parent
f870b08731
commit
0e28dfae73
@ -1,9 +1,4 @@
|
||||
package com.pancm.sql.easticsearch;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
package com.pancm.easticsearch;
|
||||
|
||||
import org.apache.http.HttpHost;
|
||||
import org.elasticsearch.action.search.SearchRequest;
|
||||
@ -12,9 +7,11 @@ import org.elasticsearch.action.search.ShardSearchFailure;
|
||||
import org.elasticsearch.action.support.IndicesOptions;
|
||||
import org.elasticsearch.client.RequestOptions;
|
||||
import org.elasticsearch.client.RestClient;
|
||||
import org.elasticsearch.client.RestClientBuilder;
|
||||
import org.elasticsearch.client.RestHighLevelClient;
|
||||
import org.elasticsearch.common.unit.Fuzziness;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.index.query.BoolQueryBuilder;
|
||||
import org.elasticsearch.index.query.MatchQueryBuilder;
|
||||
import org.elasticsearch.index.query.QueryBuilders;
|
||||
import org.elasticsearch.rest.RestStatus;
|
||||
@ -25,6 +22,7 @@ import org.elasticsearch.search.aggregations.Aggregations;
|
||||
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
|
||||
import org.elasticsearch.search.aggregations.bucket.terms.Terms.Bucket;
|
||||
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
|
||||
import org.elasticsearch.search.aggregations.metrics.avg.Avg;
|
||||
import org.elasticsearch.search.builder.SearchSourceBuilder;
|
||||
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
|
||||
import org.elasticsearch.search.suggest.Suggest;
|
||||
@ -35,310 +33,520 @@ import org.elasticsearch.search.suggest.term.TermSuggestion;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
|
||||
/**
|
||||
* @author pancm
|
||||
* @Title: EsHighLevelRestSearchTest
|
||||
* @Description: Java High Level REST Client Es高级客户端查询使用使用教程 (Search查询使用教程)
|
||||
* 官方文档地址:
|
||||
* https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-high.html
|
||||
* 官方文档地址:
|
||||
* https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-high.html
|
||||
* @Version:1.0.0
|
||||
* @author pancm
|
||||
* @date 2019年3月12日
|
||||
*/
|
||||
public class EsHighLevelRestSearchTest {
|
||||
|
||||
private static String elasticIp = "192.169.0.23";
|
||||
private static int elasticPort = 9200;
|
||||
private static String elasticIp = "192.169.2.98";
|
||||
private static int elasticPort = 9200;
|
||||
private static Logger logger = LoggerFactory.getLogger(EsHighLevelRestSearchTest.class);
|
||||
|
||||
private static Logger logger = LoggerFactory.getLogger(EsHighLevelRestSearchTest.class);
|
||||
private static RestHighLevelClient client = null;
|
||||
|
||||
private static RestHighLevelClient client = null;
|
||||
/**
|
||||
* @param args
|
||||
*/
|
||||
public static void main(String[] args) {
|
||||
|
||||
/**
|
||||
* @param args
|
||||
*/
|
||||
public static void main(String[] args) {
|
||||
try {
|
||||
init();
|
||||
allSearch();
|
||||
//普通查询
|
||||
genSearch();
|
||||
orSearch();
|
||||
likeSearch();
|
||||
inSearch();
|
||||
existSearch();
|
||||
rangeSearch();
|
||||
// search();
|
||||
// search2();
|
||||
|
||||
try {
|
||||
init();
|
||||
search();
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
close();
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}finally {
|
||||
close();
|
||||
}
|
||||
/**
|
||||
* p_test
|
||||
*{
|
||||
* "settings" : {
|
||||
* "number_of_shards" : 10,
|
||||
* "refresh_interval" : "1s"
|
||||
* },
|
||||
* "mappings" : {
|
||||
* "_doc" : {
|
||||
* "properties" : {
|
||||
* "uid" : { "type" : "long" },
|
||||
* "phone" : { "type" : "long" },
|
||||
* "userid" : { "type" : "keyword" },
|
||||
* "sendday" : { "type" : "long" },
|
||||
* "message" : { "type" : "keyword" },
|
||||
* "msgcode" : { "type" : "long" },
|
||||
* "price" : { "type" : "double","index": "false" },
|
||||
* "sendtime" : {
|
||||
* "type" : "date",
|
||||
* "format" : "yyyy-MM-dd HH:mm:ss.SSS"
|
||||
* },
|
||||
* "sendtime2" : {
|
||||
* "type" : "date",
|
||||
* "format" : "yyyy-MM-dd HH:mm:ss.SSS"
|
||||
* },
|
||||
* "sendtm" : { "type" : "long" },
|
||||
* "sendtm2" : { "type" : "long" }
|
||||
* }
|
||||
* }
|
||||
* }
|
||||
* }
|
||||
*/
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* 初始化服务
|
||||
*/
|
||||
private static void init() {
|
||||
client = new RestHighLevelClient(RestClient.builder(new HttpHost(elasticIp, elasticPort, "http")));
|
||||
/**
|
||||
* @Author pancm
|
||||
* @Description 范围查询
|
||||
* @Date 2019/9/30
|
||||
* @Param []
|
||||
* @return void
|
||||
**/
|
||||
private static void rangeSearch() throws IOException{
|
||||
// 查询指定的索引库
|
||||
SearchRequest searchRequest = new SearchRequest("user");
|
||||
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
||||
|
||||
}
|
||||
// 设置查询条件
|
||||
sourceBuilder.query(QueryBuilders.rangeQuery("sendtime").gte("2019-01-01 00:00:00.000").lte("2019-12-31 23:59:59.999"));
|
||||
searchRequest.source(sourceBuilder);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
// 结果
|
||||
searchResponse.getHits().forEach(hit -> {
|
||||
Map<String, Object> map = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("范围查询的Map结果:" + map);
|
||||
System.out.println("范围查询的String结果:" + string);
|
||||
});
|
||||
|
||||
/*
|
||||
* 关闭服务
|
||||
*/
|
||||
private static void close() {
|
||||
if (client != null) {
|
||||
try {
|
||||
client.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* search查询使用示例
|
||||
*
|
||||
* @throws IOException
|
||||
*/
|
||||
private static void search() throws IOException {
|
||||
System.out.println("\n=================\n");
|
||||
}
|
||||
|
||||
/*
|
||||
* 查询集群所有的索引
|
||||
*
|
||||
*/
|
||||
SearchRequest searchRequestAll = new SearchRequest();
|
||||
/**
|
||||
* @return void
|
||||
* @Author pancm
|
||||
* @Description exist查询
|
||||
* @Date 2019/9/17
|
||||
* @Param []
|
||||
**/
|
||||
private static void existSearch() throws IOException {
|
||||
// 查询指定的索引库
|
||||
SearchRequest searchRequest = new SearchRequest("user");
|
||||
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
||||
|
||||
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
|
||||
searchSourceBuilder.query(QueryBuilders.matchAllQuery());
|
||||
searchRequestAll.source(searchSourceBuilder);
|
||||
// 设置查询条件
|
||||
sourceBuilder.query(QueryBuilders.existsQuery("uid"));
|
||||
searchRequest.source(sourceBuilder);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
// 结果
|
||||
searchResponse.getHits().forEach(hit -> {
|
||||
Map<String, Object> map = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("存在查询的Map结果:" + map);
|
||||
System.out.println("存在查询的String结果:" + string);
|
||||
});
|
||||
|
||||
// 同步查询
|
||||
SearchResponse searchResponseAll = client.search(searchRequestAll, RequestOptions.DEFAULT);
|
||||
|
||||
System.out.println("所有查询总数:" + searchResponseAll.getHits().getTotalHits());
|
||||
System.out.println("\n=================\n");
|
||||
|
||||
// 查询指定的索引库
|
||||
SearchRequest searchRequest = new SearchRequest("user");
|
||||
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
||||
// 设置查询条件
|
||||
sourceBuilder.query(QueryBuilders.termQuery("user", "pancm"));
|
||||
// 设置起止和结束
|
||||
sourceBuilder.from(0);
|
||||
sourceBuilder.size(5);
|
||||
sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
|
||||
// 设置路由
|
||||
}
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @Author pancm
|
||||
* @Description in查询
|
||||
* @Date 2019/9/16
|
||||
* @Param []
|
||||
**/
|
||||
private static void inSearch() throws IOException {
|
||||
// 查询指定的索引库
|
||||
SearchRequest searchRequest = new SearchRequest("user");
|
||||
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
||||
/**
|
||||
* SELECT * FROM p_test where uid in (1,2)
|
||||
* */
|
||||
// 设置查询条件
|
||||
sourceBuilder.query(QueryBuilders.termsQuery("uid", 1, 2));
|
||||
searchRequest.source(sourceBuilder);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
// 结果
|
||||
searchResponse.getHits().forEach(hit -> {
|
||||
Map<String, Object> map = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("in查询的Map结果:" + map);
|
||||
System.out.println("in查询的String结果:" + string);
|
||||
});
|
||||
|
||||
|
||||
System.out.println("\n=================\n");
|
||||
}
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @Author pancm
|
||||
* @Description 模糊查询
|
||||
* @Date 2019/9/12
|
||||
* @Param []
|
||||
**/
|
||||
private static void likeSearch() throws IOException {
|
||||
SearchRequest searchRequest = new SearchRequest();
|
||||
searchRequest.indices("p_test");
|
||||
searchRequest.types("_doc");
|
||||
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
|
||||
BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
|
||||
/**
|
||||
* SELECT * FROM p_test where message like '%pan%';
|
||||
* */
|
||||
boolQueryBuilder.must(QueryBuilders.wildcardQuery("message", "*pan*"));
|
||||
searchSourceBuilder.query(boolQueryBuilder);
|
||||
|
||||
System.out.println("模糊查询语句:" + searchSourceBuilder.toString());
|
||||
searchRequest.source(searchSourceBuilder);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
searchResponse.getHits().forEach(documentFields -> {
|
||||
System.out.println("查询结果:" + documentFields.getSourceAsMap());
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @Author pancm
|
||||
* @Description 普通查询
|
||||
* @Date 2019/9/12
|
||||
* @Param []
|
||||
**/
|
||||
private static void genSearch() throws IOException {
|
||||
// 查询指定的索引库
|
||||
SearchRequest searchRequest = new SearchRequest("user");
|
||||
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
||||
// 设置查询条件
|
||||
sourceBuilder.query(QueryBuilders.termQuery("user", "pancm"));
|
||||
// 设置起止和结束
|
||||
sourceBuilder.from(0);
|
||||
sourceBuilder.size(5);
|
||||
sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
|
||||
// 设置路由
|
||||
// searchRequest.routing("routing");
|
||||
// 设置索引库表达式
|
||||
searchRequest.indicesOptions(IndicesOptions.lenientExpandOpen());
|
||||
// 查询选择本地分片，默认是集群分片
|
||||
searchRequest.preference("_local");
|
||||
// 设置索引库表达式
|
||||
searchRequest.indicesOptions(IndicesOptions.lenientExpandOpen());
|
||||
// 查询选择本地分片，默认是集群分片
|
||||
searchRequest.preference("_local");
|
||||
|
||||
// 排序
|
||||
// 根据默认值进行降序排序
|
||||
// sourceBuilder.sort(new ScoreSortBuilder().order(SortOrder.DESC));
|
||||
// 根据字段进行升序排序
|
||||
// sourceBuilder.sort(new FieldSortBuilder("id").order(SortOrder.ASC));
|
||||
// 排序
|
||||
// 根据默认值进行降序排序
|
||||
// sourceBuilder.sort(new ScoreSortBuilder().order(SortOrder.DESC));
|
||||
// 根据字段进行升序排序
|
||||
// sourceBuilder.sort(new FieldSortBuilder("id").order(SortOrder.ASC));
|
||||
|
||||
// 关闭suorce查询
|
||||
// 关闭suorce查询
|
||||
// sourceBuilder.fetchSource(false);
|
||||
|
||||
String[] includeFields = new String[] { "title", "user", "innerObject.*" };
|
||||
String[] excludeFields = new String[] { "_type" };
|
||||
// 包含或排除字段
|
||||
String[] includeFields = new String[]{"title", "user", "innerObject.*"};
|
||||
String[] excludeFields = new String[]{"_type"};
|
||||
// 包含或排除字段
|
||||
// sourceBuilder.fetchSource(includeFields, excludeFields);
|
||||
|
||||
searchRequest.source(sourceBuilder);
|
||||
searchRequest.source(sourceBuilder);
|
||||
|
||||
// 同步查询
|
||||
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
|
||||
// HTTP状态代码、执行时间或请求是否提前终止或超时
|
||||
RestStatus status = searchResponse.status();
|
||||
TimeValue took = searchResponse.getTook();
|
||||
Boolean terminatedEarly = searchResponse.isTerminatedEarly();
|
||||
boolean timedOut = searchResponse.isTimedOut();
|
||||
// HTTP状态代码、执行时间或请求是否提前终止或超时
|
||||
RestStatus status = searchResponse.status();
|
||||
TimeValue took = searchResponse.getTook();
|
||||
Boolean terminatedEarly = searchResponse.isTerminatedEarly();
|
||||
boolean timedOut = searchResponse.isTimedOut();
|
||||
|
||||
// 供关于受搜索影响的切分总数的统计信息，以及成功和失败的切分
|
||||
int totalShards = searchResponse.getTotalShards();
|
||||
int successfulShards = searchResponse.getSuccessfulShards();
|
||||
int failedShards = searchResponse.getFailedShards();
|
||||
// 失败的原因
|
||||
for (ShardSearchFailure failure : searchResponse.getShardFailures()) {
|
||||
// failures should be handled here
|
||||
}
|
||||
// 供关于受搜索影响的切分总数的统计信息，以及成功和失败的切分
|
||||
int totalShards = searchResponse.getTotalShards();
|
||||
int successfulShards = searchResponse.getSuccessfulShards();
|
||||
int failedShards = searchResponse.getFailedShards();
|
||||
// 失败的原因
|
||||
for (ShardSearchFailure failure : searchResponse.getShardFailures()) {
|
||||
// failures should be handled here
|
||||
}
|
||||
|
||||
// 结果
|
||||
searchResponse.getHits().forEach(hit -> {
|
||||
Map<String, Object> map = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("普通查询的Map结果:" + map);
|
||||
System.out.println("普通查询的String结果:" + string);
|
||||
});
|
||||
// 结果
|
||||
searchResponse.getHits().forEach(hit -> {
|
||||
Map<String, Object> map = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("普通查询的Map结果:" + map);
|
||||
System.out.println("普通查询的String结果:" + string);
|
||||
});
|
||||
|
||||
|
||||
System.out.println("\n=================\n");
|
||||
|
||||
/*
|
||||
* 全文查询使用示例
|
||||
*/
|
||||
System.out.println("\n=================\n");
|
||||
|
||||
// 搜索字段user为pancm的数据
|
||||
MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("user", "pancm");
|
||||
}
|
||||
|
||||
// 设置模糊查询
|
||||
matchQueryBuilder.fuzziness(Fuzziness.AUTO);
|
||||
// 设置前缀长度
|
||||
matchQueryBuilder.prefixLength(3);
|
||||
// 设置最大扩展选项来控制查询的模糊过程
|
||||
matchQueryBuilder.maxExpansions(10);
|
||||
private static void allSearch() throws IOException {
|
||||
/*
|
||||
* 查询集群所有的索引
|
||||
*
|
||||
*/
|
||||
SearchRequest searchRequestAll = new SearchRequest();
|
||||
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
|
||||
searchSourceBuilder.query(QueryBuilders.matchAllQuery());
|
||||
searchRequestAll.source(searchSourceBuilder);
|
||||
// 同步查询
|
||||
SearchResponse searchResponseAll = client.search(searchRequestAll, RequestOptions.DEFAULT);
|
||||
|
||||
/*
|
||||
* QueryBuilder也可以
|
||||
*/
|
||||
System.out.println("所有查询总数:" + searchResponseAll.getHits().getTotalHits());
|
||||
}
|
||||
|
||||
/**
|
||||
* @return void
|
||||
* @Author pancm
|
||||
* @Description 或查询
|
||||
* @Date 2019/9/6
|
||||
* @Param []
|
||||
**/
|
||||
private static void orSearch() throws IOException {
|
||||
SearchRequest searchRequest = new SearchRequest();
|
||||
searchRequest.indices("p_test");
|
||||
searchRequest.types("_doc");
|
||||
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
|
||||
BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
|
||||
BoolQueryBuilder boolQueryBuilder2 = new BoolQueryBuilder();
|
||||
/**
|
||||
* SELECT * FROM p_test where (uid = 1 or uid =2) and phone = 12345678919
|
||||
* */
|
||||
boolQueryBuilder2.should(QueryBuilders.termQuery("uid", 1));
|
||||
boolQueryBuilder2.should(QueryBuilders.termQuery("uid", 2));
|
||||
boolQueryBuilder.must(boolQueryBuilder2);
|
||||
boolQueryBuilder.must(QueryBuilders.termQuery("phone", "12345678919"));
|
||||
searchSourceBuilder.query(boolQueryBuilder);
|
||||
|
||||
System.out.println("或查询语句:" + searchSourceBuilder.toString());
|
||||
searchRequest.source(searchSourceBuilder);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
|
||||
searchResponse.getHits().forEach(documentFields -> {
|
||||
|
||||
System.out.println("查询结果:" + documentFields.getSourceAsMap());
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
/*
|
||||
* 初始化服务
|
||||
*/
|
||||
private static void init() {
|
||||
RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost(elasticIp, elasticPort));
|
||||
client = new RestHighLevelClient(restClientBuilder);
|
||||
|
||||
}
|
||||
|
||||
/*
|
||||
* 关闭服务
|
||||
*/
|
||||
private static void close() {
|
||||
if (client != null) {
|
||||
try {
|
||||
client.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
client = null;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* search查询使用示例
|
||||
*
|
||||
* @throws IOException
|
||||
*/
|
||||
private static void search() throws IOException {
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 全文查询使用示例
|
||||
*/
|
||||
// 查询指定的索引库
|
||||
SearchRequest searchRequest = new SearchRequest("user");
|
||||
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
|
||||
// 搜索字段user为pancm的数据
|
||||
MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("user", "pancm");
|
||||
|
||||
// 设置模糊查询
|
||||
matchQueryBuilder.fuzziness(Fuzziness.AUTO);
|
||||
// 设置前缀长度
|
||||
matchQueryBuilder.prefixLength(3);
|
||||
// 设置最大扩展选项来控制查询的模糊过程
|
||||
matchQueryBuilder.maxExpansions(10);
|
||||
|
||||
/*
|
||||
* QueryBuilder也可以
|
||||
*/
|
||||
|
||||
// QueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("user", "kimchy")
|
||||
// .fuzziness(Fuzziness.AUTO)
|
||||
// .prefixLength(3)
|
||||
// .maxExpansions(10);
|
||||
|
||||
SearchSourceBuilder searchSourceBuilder2 = new SearchSourceBuilder();
|
||||
searchSourceBuilder2.query(matchQueryBuilder);
|
||||
SearchSourceBuilder searchSourceBuilder2 = new SearchSourceBuilder();
|
||||
searchSourceBuilder2.query(matchQueryBuilder);
|
||||
|
||||
SearchRequest searchRequest2 = new SearchRequest();
|
||||
searchRequest2.source(searchSourceBuilder2);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse2 = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
|
||||
SearchHits hits = searchResponse.getHits();
|
||||
//总条数和分值
|
||||
long totalHits = hits.getTotalHits();
|
||||
float maxScore = hits.getMaxScore();
|
||||
|
||||
|
||||
|
||||
hits.forEach(hit -> {
|
||||
|
||||
String index = hit.getIndex();
|
||||
String type = hit.getType();
|
||||
String id = hit.getId();
|
||||
float score = hit.getScore();
|
||||
|
||||
|
||||
|
||||
Map<String, Object> sourceAsMap = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("Match查询的Map结果:" + sourceAsMap);
|
||||
System.out.println("Match查询的String结果:" + string);
|
||||
|
||||
String documentTitle = (String) sourceAsMap.get("title");
|
||||
SearchRequest searchRequest2 = new SearchRequest();
|
||||
searchRequest2.source(searchSourceBuilder2);
|
||||
// 同步查询
|
||||
SearchResponse searchResponse2 = client.search(searchRequest, RequestOptions.DEFAULT);
|
||||
|
||||
SearchHits hits = searchResponse2.getHits();
|
||||
//总条数和分值
|
||||
long totalHits = hits.getTotalHits();
|
||||
float maxScore = hits.getMaxScore();
|
||||
|
||||
|
||||
hits.forEach(hit -> {
|
||||
|
||||
String index = hit.getIndex();
|
||||
String type = hit.getType();
|
||||
String id = hit.getId();
|
||||
float score = hit.getScore();
|
||||
|
||||
|
||||
Map<String, Object> sourceAsMap = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("Match查询的Map结果:" + sourceAsMap);
|
||||
System.out.println("Match查询的String结果:" + string);
|
||||
|
||||
String documentTitle = (String) sourceAsMap.get("title");
|
||||
// List<Object> users = (List<Object>) sourceAsMap.get("user");
|
||||
Map<String, Object> innerObject =
|
||||
(Map<String, Object>) sourceAsMap.get("innerObject");
|
||||
});
|
||||
Map<String, Object> innerObject =
|
||||
(Map<String, Object>) sourceAsMap.get("innerObject");
|
||||
});
|
||||
|
||||
|
||||
|
||||
|
||||
System.out.println("\n=================\n");
|
||||
|
||||
/*
|
||||
* 高亮查询
|
||||
*/
|
||||
System.out.println("\n=================\n");
|
||||
|
||||
SearchSourceBuilder searchSourceBuilder3 = new SearchSourceBuilder();
|
||||
HighlightBuilder highlightBuilder = new HighlightBuilder();
|
||||
HighlightBuilder.Field highlightTitle = new HighlightBuilder.Field("title");
|
||||
// 设置字段高亮字体
|
||||
highlightTitle.highlighterType("user");
|
||||
highlightBuilder.field(highlightTitle);
|
||||
HighlightBuilder.Field highlightUser = new HighlightBuilder.Field("user");
|
||||
highlightBuilder.field(highlightUser);
|
||||
searchSourceBuilder3.highlighter(highlightBuilder);
|
||||
/*
|
||||
* 高亮查询
|
||||
*/
|
||||
|
||||
SearchRequest searchRequest3 = new SearchRequest();
|
||||
searchRequest3.source(searchSourceBuilder3);
|
||||
SearchSourceBuilder searchSourceBuilder3 = new SearchSourceBuilder();
|
||||
HighlightBuilder highlightBuilder = new HighlightBuilder();
|
||||
HighlightBuilder.Field highlightTitle = new HighlightBuilder.Field("title");
|
||||
// 设置字段高亮字体
|
||||
highlightTitle.highlighterType("user");
|
||||
highlightBuilder.field(highlightTitle);
|
||||
HighlightBuilder.Field highlightUser = new HighlightBuilder.Field("user");
|
||||
highlightBuilder.field(highlightUser);
|
||||
searchSourceBuilder3.highlighter(highlightBuilder);
|
||||
|
||||
// 同步查询
|
||||
SearchResponse searchResponse3 = client.search(searchRequest3, RequestOptions.DEFAULT);
|
||||
SearchRequest searchRequest3 = new SearchRequest();
|
||||
searchRequest3.source(searchSourceBuilder3);
|
||||
|
||||
searchResponse3.getHits().forEach(hit -> {
|
||||
// 同步查询
|
||||
SearchResponse searchResponse3 = client.search(searchRequest3, RequestOptions.DEFAULT);
|
||||
|
||||
Map<String, Object> map = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("Highlight查询的Map结果:" + map);
|
||||
System.out.println("Highlight查询的String结果:" + string);
|
||||
});
|
||||
searchResponse3.getHits().forEach(hit -> {
|
||||
|
||||
System.out.println("\n=================\n");
|
||||
Map<String, Object> map = hit.getSourceAsMap();
|
||||
String string = hit.getSourceAsString();
|
||||
System.out.println("Highlight查询的Map结果:" + map);
|
||||
System.out.println("Highlight查询的String结果:" + string);
|
||||
});
|
||||
|
||||
/**
|
||||
* 聚合查询
|
||||
*/
|
||||
System.out.println("\n=================\n");
|
||||
|
||||
SearchSourceBuilder searchSourceBuilder4 = new SearchSourceBuilder();
|
||||
|
||||
//terms 就是分组统计 根据user进行分组并创建一个新的聚合user_
|
||||
TermsAggregationBuilder aggregation = AggregationBuilders.terms("user_").field("user");
|
||||
aggregation.subAggregation(AggregationBuilders.avg("average_age").field("age"));
|
||||
searchSourceBuilder4.aggregation(aggregation);
|
||||
/**
|
||||
* 聚合查询
|
||||
*/
|
||||
|
||||
SearchRequest searchRequest4 = new SearchRequest();
|
||||
searchRequest4.source(searchSourceBuilder4);
|
||||
SearchSourceBuilder searchSourceBuilder4 = new SearchSourceBuilder();
|
||||
|
||||
// 同步查询
|
||||
SearchResponse searchResponse4 = client.search(searchRequest4, RequestOptions.DEFAULT);
|
||||
//聚合查询返回条件
|
||||
Aggregations aggregations = searchResponse4.getAggregations();
|
||||
List<Aggregation> aggregationList = aggregations.asList();
|
||||
|
||||
for (Aggregation agg : aggregations) {
|
||||
String type = agg.getType();
|
||||
if (type.equals(TermsAggregationBuilder.NAME)) {
|
||||
Bucket elasticBucket = ((Terms) agg).getBucketByKey("Elastic");
|
||||
long numberOfDocs = elasticBucket.getDocCount();
|
||||
System.out.println("条数:"+numberOfDocs);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// Terms byCompanyAggregation = aggregations.get("user_");
|
||||
// Bucket elasticBucket = byCompanyAggregation.getBucketByKey("Elastic");
|
||||
// Avg averageAge = elasticBucket.getAggregations().get("average_age");
|
||||
// double avg = averageAge.getValue();
|
||||
//
|
||||
// System.out.println("聚合查询返回的结果:"+avg);
|
||||
|
||||
|
||||
/*
|
||||
* 建议查询
|
||||
*/
|
||||
SearchSourceBuilder searchSourceBuilder5 = new SearchSourceBuilder();
|
||||
SuggestionBuilder termSuggestionBuilder = SuggestBuilders.termSuggestion("user").text("pancm");
|
||||
SuggestBuilder suggestBuilder = new SuggestBuilder();
|
||||
suggestBuilder.addSuggestion("suggest_user", termSuggestionBuilder);
|
||||
searchSourceBuilder5.suggest(suggestBuilder);
|
||||
|
||||
SearchRequest searchRequest5 = new SearchRequest();
|
||||
searchRequest5.source(searchSourceBuilder5);
|
||||
//terms 就是分组统计 根据user进行分组并创建一个新的聚合user_
|
||||
TermsAggregationBuilder aggregation = AggregationBuilders.terms("user_").field("user");
|
||||
aggregation.subAggregation(AggregationBuilders.avg("average_age").field("age"));
|
||||
searchSourceBuilder4.aggregation(aggregation);
|
||||
|
||||
SearchRequest searchRequest4 = new SearchRequest();
|
||||
searchRequest4.source(searchSourceBuilder4);
|
||||
|
||||
// 同步查询
|
||||
SearchResponse searchResponse4 = client.search(searchRequest4, RequestOptions.DEFAULT);
|
||||
//聚合查询返回条件
|
||||
Aggregations aggregations = searchResponse4.getAggregations();
|
||||
System.out.println("聚合查询");
|
||||
for (Aggregation agg : aggregations) {
|
||||
String type = agg.getType();
|
||||
String name = agg.getName();
|
||||
|
||||
Terms terms = (Terms) aggregations.get(name);
|
||||
for (Bucket bucket : terms.getBuckets()) {
|
||||
System.out.println("条数:" + bucket.getDocCount());
|
||||
System.out.println("key:" + bucket.getKey());
|
||||
System.out.println("num:" + bucket.getKeyAsNumber());
|
||||
Avg avg = bucket.getAggregations().get("average_age");
|
||||
System.out.println("value:" + avg.getValue());
|
||||
}
|
||||
if (type.equals(TermsAggregationBuilder.NAME)) {
|
||||
Bucket elasticBucket = ((Terms) agg).getBucketByKey("average_age");
|
||||
long numberOfDocs = elasticBucket.getDocCount();
|
||||
System.out.println("条数:" + numberOfDocs);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 建议查询
|
||||
*/
|
||||
SearchSourceBuilder searchSourceBuilder5 = new SearchSourceBuilder();
|
||||
SuggestionBuilder termSuggestionBuilder = SuggestBuilders.termSuggestion("user").text("pancm");
|
||||
SuggestBuilder suggestBuilder = new SuggestBuilder();
|
||||
suggestBuilder.addSuggestion("suggest_user", termSuggestionBuilder);
|
||||
searchSourceBuilder5.suggest(suggestBuilder);
|
||||
|
||||
SearchRequest searchRequest5 = new SearchRequest();
|
||||
searchRequest5.source(searchSourceBuilder5);
|
||||
|
||||
// 同步查询
|
||||
SearchResponse searchResponse5 = client.search(searchRequest5, RequestOptions.DEFAULT);
|
||||
|
||||
Suggest suggest = searchResponse5.getSuggest();
|
||||
TermSuggestion termSuggestion = suggest.getSuggestion("suggest_user");
|
||||
for (TermSuggestion.Entry entry : termSuggestion.getEntries()) {
|
||||
for (TermSuggestion.Entry.Option option : entry) {
|
||||
String suggestText = option.getText().string();
|
||||
System.out.println("返回结果:" + suggestText);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
// 同步查询
|
||||
SearchResponse searchResponse5= client.search(searchRequest5, RequestOptions.DEFAULT);
|
||||
|
||||
Suggest suggest = searchResponse5.getSuggest();
|
||||
TermSuggestion termSuggestion = suggest.getSuggestion("suggest_user");
|
||||
for (TermSuggestion.Entry entry : termSuggestion.getEntries()) {
|
||||
for (TermSuggestion.Entry.Option option : entry) {
|
||||
String suggestText = option.getText().string();
|
||||
System.out.println("返回结果:"+suggestText);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user