如何从QueryString创建Elasticsearch的Query Java对象？

你可以借助Elasticsearch Java客户端自带的JsonpMapper工具，将合法的Query DSL JSON字符串直接解析为Query对象，无需通过Java类逐步构建。

实现getQueryFromString方法 #

import co.elastic.clients.elasticsearch._types.query_dsl.Query;
import co.elastic.clients.json.JsonpMapper;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;

public Query getQueryFromString(String queryString, ElasticsearchClient esClient) throws IOException {
    // 使用客户端自带的JsonpMapper，避免版本兼容性问题
    JsonpMapper mapper = esClient._jsonpMapper();
    InputStream inputStream = new ByteArrayInputStream(queryString.getBytes());
    return mapper.deserialize(inputStream, Query.class);
}

整合到你的现有代码 #

// 示例：合法的Elasticsearch Query DSL JSON字符串
String queryString = "{\"bool\": {\"must\": [{\"match\": {\"content\": \"java\"}}, {\"range\": {\"create_time\": {\"gte\": \"2024-01-01\"}}}]}}";

Query query = null;
co.elastic.clients.elasticsearch.core.SearchResponse searchResponse = null;
try {
    query = getQueryFromString(queryString, esClient);
    
    co.elastic.clients.elasticsearch.core.SearchRequest request = new co.elastic.clients.elasticsearch.core.SearchRequest.Builder()
            .index(indexName)
            .size(pageSize)
            .query(query)
            .build();

    searchResponse = esClient.search(request, Object.class); // 替换为你的实体类，比如YourEntity.class

} catch (Exception ex) {
    log.error("请求Elasticsearch时发生异常", ex);
}

关键注意事项 #

• 确保queryString是符合Elasticsearch Query DSL规范的JSON字符串，否则会抛出解析异常
• 优先使用客户端自带的JsonpMapper（即esClient._jsonpMapper()），避免手动创建JacksonJsonpMapper带来的版本不一致问题
• 若需要动态生成查询字符串，可先通过字符串替换、模板引擎等方式生成合法的DSL JSON后再解析

内容的提问来源于stack exchange，提问作者Indrapreet