如何在Elasticsearch中以编程方式创建筛选查询，并在嵌套对象中进行筛选

Question

我正忙于在Java Spring中为ElasttiSearch创建过滤查询。我有以下Elasticsearch映射：

"mappings": {
  "properties": {
    "id": {"type": "keyword"},
    "name": {"type": "text"},
    "city": {"type": "keyword"},
    "cars": {
      "type": "nested",
      "properties": {
        "id": {"type": "long"},
        "brand": {"type": "text"},
        "category": {"type": "text"}
      }
   }
}

Elasticsearch中的数据如下所示：

[
   {
      "id": 1,
      "name": "Car seller 1",
      "city": "Detroit",
      "cars": [
         {"id": 1, "brand": "bmw", "category": "suv"},
         {"id": 2, "brand": "bmw", "category": "sedan"},
         {"id": 3, "brand": "bmw", "category": "hatchback"}
      ]
   },
   {
      "id": 2,
      "name": "Car seller 2",
      "city": "Detroit",
      "cars": [
         {"id": 1, "brand": "vw", "category": "suv"},
         {"id": 2, "brand": "vw", "category": "sedan"},
         {"id": 3, "brand": "vw", "category": "suv"}
      ]
   },
   {
      "id": 3,
      "name": "Car seller 3",
      "city": "Las Vegas",
      "cars": [
         {"id": 1, "brand": "ford", "category": "suv"},
         {"id": 2, "brand": "ford", "category": "sedan"},
         {"id": 3, "brand": "ford", "category": "hatchback"}
      ]
   }
]

 1. city: ["Detroit"]
 2. cars.category: ["suv"]

[
   {
      "id": 1,
      "name": "Car seller 1",
      "city": "Detroit",
      "cars": [
         {"id": 1, "brand": "bmw", "category": "suv"}
      ]
   },
   {
      "id": 2,
      "name": "Car seller 2",
      "city": "Detroit",
      "cars": [
         {"id": 1, "brand": "vw", "category": "suv"},
         {"id": 3, "brand": "vw", "category": "suv"}
      ]
   }
]

    public Flux<Seller> filterSearch(Map<String, List<String>> filters) {

      List<String> listOfFields = new ArrayList<>(filters.keySet());
      BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();

      listOfFields.forEach(field -> {
          BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

          if (field.contains("cars.")) {
              filters.get(field).forEach(value -> boolQueryBuilder.should(QueryBuilders.termQuery(field, value)));
              boolQueryBuilder.minimumShouldMatch(1);
              NestedQueryBuilder nestedQueryBuilder = new NestedQueryBuilder("cars", boolQueryBuilder, NestedQueryBuilder.parseScoreMode("none"));
              nestedQueryBuilder.innerHit(new InnerHitBuilder());
              queryBuilder.must().add(nestedQueryBuilder);
          } else {
              filters.get(field).forEach(value -> boolQueryBuilder.should(QueryBuilders.matchPhraseQuery(field, value)));
              queryBuilder.must().add(boolQueryBuilder);
          }
      });

      return executeSearchQuery(queryBuilder);
   }

Answer 1

我想你应该试试这个：

      if (field.contains("cars.")) {
          ...
      } else {
          filters.get(field).forEach(value -> boolQueryBuilder.should(QueryBuilders.matchPhraseQuery(field, value)).minimumShouldMatch(1));
          queryBuilder.must().add(boolQueryBuilder);
      }