如何用Java Jest在Elasticsearch中按ID查询文档并附加字段存在过滤

问题描述 #

我正在使用Jest Java API按ID获取Elasticsearch中的User文档，User对象包含id、firstname、lastname字段。现在的需求是：如果索引中的文档完全没有firstname元素，就把它过滤掉，不返回给调用方。

目前我的实现是先获取文档，再在内存中检查firstname是否存在，代码如下：

public Optional<User> findById(long id) {
    try {
        Get action = new Get.Builder(INDEX_ALIAS, String.valueOf(id)).build();
        User user= execute(action).getSourceAsObject(User.class);
        if (user!= null && user.getFirstName()!=null) {
            return Optional.ofNullable(user);
        } else {
            return Optional.empty();
        }
    } catch (NoSuchElementException ex) {
        return Optional.empty();
    }
}

我想知道有没有更好的方法，能把这个检查逻辑直接整合到查询本身中，不用在获取后再做判断？

解决方案 #

当然有办法！不过要注意：Jest的Get请求本身是针对单个ID的精确获取操作，它不支持附加查询过滤条件。所以我们需要换个思路，用Search请求来实现——既可以指定要查询的ID，又能添加字段存在性的过滤条件。

具体来说，我们可以结合IdsQueryBuilder（指定目标ID）和ExistsQueryBuilder（检查firstname字段是否存在）来构建搜索请求，这样Elasticsearch会直接帮我们过滤掉缺少firstname的文档，无需在内存中二次判断。

改造后的代码示例如下：

import io.searchbox.core.Search;
import io.searchbox.core.SearchResult;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;

public Optional<User> findById(long id) {
    try {
        // 构建查询：指定ID + 检查firstname字段存在
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder()
               .query(QueryBuilders.boolQuery()
                       .must(QueryBuilders.idsQuery().addIds(String.valueOf(id)))
                       .must(QueryBuilders.existsQuery("firstname")));

        Search searchAction = new Search.Builder(sourceBuilder.toString())
               .addIndex(INDEX_ALIAS)
               .build();

        SearchResult result = execute(searchAction);

        // 处理搜索结果：如果有匹配的文档，返回第一个
        if (result.getTotal() > 0) {
            User user = result.getSourceAsObject(User.class, 0);
            return Optional.ofNullable(user);
        } else {
            return Optional.empty();
        }
    } catch (Exception ex) {
        return Optional.empty();
    }
}

为什么这个方案更好？

• 逻辑内聚：把过滤逻辑交给Elasticsearch处理，避免了应用层的额外判断，代码更简洁。
• 性能优化：减少了不必要的数据传输——如果文档缺少firstname，Elasticsearch不会把它返回给应用，节省了网络带宽和内存开销。
• 语义更清晰：查询语句直接表达了"获取ID为X且存在firstname字段的User文档"的需求，可读性更强。

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