Spring Data Elasticsearch组合ID与prefixQuery查询返回空问题

问题复现代码 #

• 实体类定义

@Document(indexName = "product", createIndex = false)
public class ProductDocument implements Serializable {

    @Id
    private String id;

    @NotNull
    private String name;
}

• 初始自定义查询实现

@Override
public List<ProductDocument> findByIdsAndName(List<String> productIds, String name) {
    Query query = new NativeSearchQueryBuilder()
            .withIds(productIds)
            .withQuery(QueryBuilders.prefixQuery("name", name))
            .build();

    return operations.search(query, clazz, indexCoordinates)
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
}

• 测试逻辑
  插入测试数据：

productRepository.saveAll(Arrays.asList(
                ProductDocument.builder().id("1").name("Pikachu1").build(),
                ProductDocument.builder().id("2").name("Pikachu2").build(),
                ProductDocument.builder().id("3").name("Pikachu3").build(),
                ProductDocument.builder().id("4").name("Pikachu4").build(),
                ProductDocument.builder().id("5").name("Pikachu5").build()
        )
);

执行校验断言：

assertThat(productRepository.findByIdsAndName(List.of("1", "2"), "Pika")).hasSize(2);

预期返回ID为1、2的2条数据，实际返回空列表。后续尝试将ID条件移入filter上下文，依然查询失败：

Query query = new NativeSearchQueryBuilder()
        .withFilter(QueryBuilders.idsQuery().addIds(productIds.toArray(String[]::new)))
        .withQuery(QueryBuilders.prefixQuery("name", name))
        .build();

测试确认：移除prefixQuery条件后，ID查询可正常返回结果，问题集中在前缀查询逻辑上。

错误根因 #

两个问题叠加导致查询失效：

• prefix查询匹配逻辑和字段分词规则不匹配
  配置createIndex = false意味着索引不由Spring Data Elasticsearch自动自动创建，默认映射下name字段为text类型，使用standard标准分词器：写入数据时，"Pikachu1"等值会被分词为全小写的term pikachu1存入倒排索引。
  prefixQuery属于term级别查询，不会对传入的查询字符串做分词处理，直接拿传入值匹配倒排索引中的term前缀。传入的查询值是首字母大写的Pika，和倒排索引中全小写的pikachu* term无法匹配，前缀查询命中数为0，最终整个查询返回空。
  这也和测试现象完全吻合：移除prefixQuery后，仅靠ID条件（_id字段默认为keyword类型、不分词）即可正常返回结果。
• 初始写法存在查询覆盖问题
  旧版本Spring Data Elasticsearch的NativeSearchQueryBuilder中，withIds()方法本质是在query上下文添加ids查询，后续调用withQuery()会直接覆盖之前设置的ids查询，属于第一版写法的逻辑漏洞。第二版将ids查询移入filter上下文的写法已经避开了这个问题。

正确实现 #

根据业务场景二选一即可：

• 方案1：精确匹配原始值前缀（大小写敏感）
  给name字段添加keyword类型子字段（不对文本分词，保留原始写入的大小写和完整值），前缀查询直接命中keyword子字段。
  首先修正索引映射，给name字段添加keyword子字段：

"mappings": {
  "properties": {
    "name": {
      "type": "text",
      "fields": {
        "keyword": {
          "type": "keyword"
        }
      }
    }
  }
}

修改查询逻辑，用bool查询组合ID条件和前缀条件，避免查询覆盖：

@Override
public List<ProductDocument> findByIdsAndName(List<String> productIds, String name) {
    BoolQueryBuilder boolQuery = QueryBuilders.boolQuery()
            // 前缀查询命中name.keyword字段，匹配原始值前缀
            .must(QueryBuilders.prefixQuery("name.keyword", name))
            // ID条件放在filter上下文，不参与算分、支持缓存
            .filter(QueryBuilders.idsQuery().addIds(productIds.toArray(String[]::new)));

    Query query = new NativeSearchQueryBuilder()
            .withQuery(boolQuery)
            .build();

    return operations.search(query, clazz, indexCoordinates)
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
}

• 方案2：大小写不敏感的分词前缀匹配
  如果业务不需要大小写敏感，直接将传入prefixQuery的参数转全小写，匹配分词后的小写term即可，无需修改索引映射：

@Override
public List<ProductDocument> findByIdsAndName(List<String> productIds, String name) {
    BoolQueryBuilder boolQuery = QueryBuilders.boolQuery()
            // 入参转小写，匹配standard分词器生成的小写term
            .must(QueryBuilders.prefixQuery("name", name.toLowerCase()))
            .filter(QueryBuilders.idsQuery().addIds(productIds.toArray(String[]::new)));

    Query query = new NativeSearchQueryBuilder()
            .withQuery(boolQuery)
            .build();

    return operations.search(query, clazz, indexCoordinates)
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
}

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