Elasticsearch keyword类型搜索失效问题（Java Rest Client 6.1）

我来帮你排查这个问题——你用SpanOrQueryBuilder来实现单字段多值匹配，这其实用错了查询类型，这就是为什么你拿不到结果的核心原因。

问题分析 #

SpanOrQueryBuilder属于跨度查询（Span Queries），这类查询的设计目的是处理文本中词项的位置关系（比如某个词必须出现在另一个词的前后N个位置），而不是用来做简单的"字段值属于某个集合"的匹配。用它来做多值匹配，不仅不符合设计意图，还会因为Span查询对分词和字段映射的特殊要求，导致查询不到预期结果。

正确的解决方案 #

针对单字段多值匹配的场景，有两种更合适的实现方式：

方案1：使用termsQuery（推荐，简洁高效）

termsQuery是Elasticsearch专门为"字段值在指定列表中"的场景设计的查询，直接传入字段名和值列表即可：

@Override
public SearchResponse findLogsByValues(ElasticSearchLogRequest esLogRequest, Pageable pageable) {
    SearchRequest searchRequest = new SearchRequest("portal-logs-*");
    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
    BoolQueryBuilder bqb = QueryBuilders.boolQuery();

    if (esLogRequest.getLevels() != null && !esLogRequest.getLevels().isEmpty()) {
        // 将levels转成小写列表
        List<String> lowerCaseLevels = esLogRequest.getLevels().stream()
                .map(String::toLowerCase)
                .collect(Collectors.toList());
        // 使用termsQuery实现多值匹配
        bqb.must(QueryBuilders.termsQuery("level", lowerCaseLevels));
    }

    // 分页设置
    sourceBuilder.from(pageable.getPageNumber() * pageable.getPageSize());
    sourceBuilder.size(pageable.getPageSize());
    sourceBuilder.query(bqb);

    searchRequest.source(sourceBuilder);
    try {
        return restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
    } catch (IOException e) {
        // 异常处理
        throw new RuntimeException("查询日志失败", e);
    }
}

方案2：使用BoolQuery的should子句（适合需要额外条件的场景）

如果需要对每个值添加额外的匹配逻辑（比如权重），可以用BoolQuery的should子句，每个值对应一个term查询：

@Override
public SearchResponse findLogsByValues(ElasticSearchLogRequest esLogRequest, Pageable pageable) {
    SearchRequest searchRequest = new SearchRequest("portal-logs-*");
    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
    BoolQueryBuilder bqb = QueryBuilders.boolQuery();

    if (esLogRequest.getLevels() != null && !esLogRequest.getLevels().isEmpty()) {
        BoolQueryBuilder levelBoolQuery = QueryBuilders.boolQuery();
        for (String level : esLogRequest.getLevels()) {
            // 每个level添加一个should子句
            levelBoolQuery.should(QueryBuilders.termQuery("level", level.toLowerCase()));
        }
        // 设置至少匹配一个值
        levelBoolQuery.minimumShouldMatch(1);
        bqb.must(levelBoolQuery);
    }

    // 分页设置
    sourceBuilder.from(pageable.getPageNumber() * pageable.getPageSize());
    sourceBuilder.size(pageable.getPageSize());
    sourceBuilder.query(bqb);

    searchRequest.source(sourceBuilder);
    try {
        return restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
    } catch (IOException e) {
        throw new RuntimeException("查询日志失败", e);
    }
}

额外注意事项 #

• 确认level字段的映射类型：如果是text类型，要确保索引时的分词规则和查询时一致（比如都转成小写），或者直接使用level.keyword子字段（如果有设置）来做精确匹配，避免分词导致的不匹配。
• 分页逻辑：代码中补充了标准的分页设置，确保符合Pageable的要求。

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