java怎么查询es数据

132次阅读

共计 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 网 – 提供最优质的资源集合！

正文完