java中如何查询es数据

104次阅读

共计 1436 个字符，预计需要花费 4 分钟才能阅读完成。

在 Java 中查询 Elasticsearch（ES）数据，可以使用 Elasticsearch 的 Java 客户端进行操作。以下是一个简单的查询 ES 数据的示例：

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class ESQueryExample {public static void main(String[] args) {RestHighLevelClient client = new RestHighLevelClient(RestClient.builder("localhost:9200"));

        try {SearchRequest searchRequest = new SearchRequest("your_index_name");
            SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
            searchSourceBuilder.query(QueryBuilders.matchQuery("your_field_name", "your_search_term"));
            searchRequest.source(searchSourceBuilder);

            SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
            
            // 处理搜索结果
            // ...

        } catch (IOException e) {e.printStackTrace();
        }

        // 关闭客户端连接
        try {client.close();
        } catch (IOException e) {e.printStackTrace();
        }
    }
}

在上面的代码中，首先创建一个 RestHighLevelClient 实例，然后创建一个 SearchRequest 对象，指定要查询的索引名称。通过 SearchSourceBuilder 可以构建查询条件，这里使用 QueryBuilders.matchQuery() 方法创建一个匹配查询，指定要匹配的字段名和搜索词。将 SearchSourceBuilder 对象设置到 SearchRequest 中，然后使用 client.search() 方法执行查询操作。最后，可以根据查询结果进行相应的处理。

注意，上述示例中的连接地址为 localhost:9200，你需要根据自己的 ES 部署情况修改为正确的地址。另外，your_index_name 和your_field_name需要替换为你实际的索引名称和字段名。

丸趣 TV 网 – 提供最优质的资源集合！

正文完