Elasticsearch 8.6动态路径查询country字段及Spring Data实现

一、Elasticsearch原生查询方案 #

要匹配所有层级路径下country字段值为USA的文档，无需指定具体路径，可以使用通配符字段路径结合query_string或multi_match查询，两种方式效果一致：

方式1：使用query_string查询 #

POST /index_name/_search
{
  "query": {
    "query_string": {
      "query": "USA",
      "fields": ["**.country"]
    }
  }
}

方式2：使用multi_match查询 #

POST /index_name/_search
{
  "query": {
    "multi_match": {
      "query": "USA",
      "fields": ["**.country"]
    }
  }
}

关键说明

• **.country是Elasticsearch的路径通配符：**匹配任意层级的嵌套结构，确保所有路径下的country字段都会被匹配（比如data.country、data.Location.country等）。
• 如果索引中存在nested类型字段，该通配符会自动识别嵌套字段的完整路径，无需额外编写nested查询。
• 性能提示：如果数据量较大，通配符查询可能会有性能损耗。建议提前在映射中使用copy_to参数，将所有country字段的值复制到一个统一的字段（比如unified_country），后续直接查询该字段可获得更好的性能。

二、Spring Data Elasticsearch实现方案 #

方式1：使用@Query注解（原生查询） #

在自定义的Repository接口中，通过@Query直接注入原生Elasticsearch查询语句：

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.data.elasticsearch.annotations.Query;
import java.util.List;

public interface DocumentRepository extends ElasticsearchRepository<YourDocumentEntity, String> {

    @Query("{\"query_string\": {\"query\": \"?0\", \"fields\": [\"**.country\"]}}")
    List<YourDocumentEntity> findByCountry(String countryValue);
}

方式2：使用ElasticsearchOperations构建查询（类型安全） #

通过ElasticsearchOperations的Criteria构建器，避免编写原生JSON：

import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
import org.springframework.data.elasticsearch.core.query.Criteria;
import org.springframework.data.elasticsearch.core.query.CriteriaQuery;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class DocumentService {

    private final ElasticsearchOperations elasticsearchOperations;

    public DocumentService(ElasticsearchOperations elasticsearchOperations) {
        this.elasticsearchOperations = elasticsearchOperations;
    }

    public List<YourDocumentEntity> findAllByCountry(String countryValue) {
        // 构建匹配任意路径下country字段的条件
        Criteria criteria = new Criteria("**.country").is(countryValue);
        CriteriaQuery query = new CriteriaQuery(criteria);
        
        // 执行查询并转换为实体列表
        return elasticsearchOperations.search(query, YourDocumentEntity.class)
                .stream()
                .map(result -> result.getContent())
                .collect(Collectors.toList());
    }
}

注意事项

• 确保YourDocumentEntity的字段映射与Elasticsearch索引的结构一致，Spring Data会自动完成文档与实体的转换。
• 请使用与Elasticsearch 8.6兼容的Spring Data Elasticsearch版本（建议4.4.x及以上）。

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