共计 1380 个字符,预计需要花费 4 分钟才能阅读完成。
要查询 Elasticsearch(ES)数据,您可以使用 Java 的 Elasticsearch REST 客户端或 Java 的 Elasticsearch 高级客户端。
使用 Elasticsearch REST 客户端:
- 添加 Elasticsearch REST 客户端的依赖。例如,使用 Maven 添加以下依赖:
org.elasticsearch.client
elasticsearch-rest-client
7.12.1
- 创建 Elasticsearch REST 客户端实例:
RestClient restClient = RestClient.builder(new HttpHost("localhost", 9200, "http")).build();
- 创建一个搜索请求并执行查询:
Request request = new Request("GET", "/your-index/_search");
request.setJsonEntity("{\"query\": {\"match_all\": {}}}");
Response response = restClient.performRequest(request);
- 处理查询结果:
String responseBody = EntityUtils.toString(response.getEntity());
System.out.println(responseBody);
使用 Elasticsearch 高级客户端:
- 添加 Elasticsearch 高级客户端的依赖。例如,使用 Maven 添加以下依赖:
org.elasticsearch.client
elasticsearch-rest-high-level-client
7.12.1
- 创建 Elasticsearch 高级客户端实例:
RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")));
- 创建一个搜索请求并执行查询:
SearchRequest searchRequest = new SearchRequest("your-index");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchAllQuery());
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
- 处理查询结果:
SearchHit[] hits = searchResponse.getHits().getHits();
for (SearchHit hit : hits) {String sourceAsString = hit.getSourceAsString();
System.out.println(sourceAsString);
}
这是查询 ES 数据的基本示例。您可以根据自己的需求进行进一步的查询和结果处理。
丸趣 TV 网 – 提供最优质的资源集合!
正文完
发表至: Java
2023-12-20