elasticsearch7 嵌套查詢，根據嵌套字段排序--備忘

原理：根據條件查詢參數主文檔信息。然后sort的時候，查詢復合條件的子文檔的最大max\最小min等值來排序。

 

GET wk_bbs_index/_search
{
  "post_filter": {
    "bool": {
      "adjust_pure_negative": true,
      "must": [
        {
          "term": {
            "baseInfo.cityAlias": {
              "boost": 1,
              "value": "sz"
            }
          }
        }
      ],
      "boost": 1
    }
  },
  "query": {
    "bool": {
      "adjust_pure_negative": true,
      "must": [
        {
          "term": {
            "isDisable": {
              "boost": 1,
              "value": "0"
            }
          }
        },
        {
          "nested": {
            "path": "bbsSubjectEsVos",
            "score_mode": "none",
            "query": {
              "term": {
                "bbsSubjectEsVos.subjectId": {
                  "boost": 1,
                  "value": "3021723"
                }
              }
            },
            "boost": 1,
            "ignore_unmapped": false
          }
        }
      ],
      "boost": 1
    }
  },
  "sort": [
    {
      "bbsSubjectEsVos.order": {
        "nested": {
          "filter": {
            "term": {
              "bbsSubjectEsVos.subjectId": {
                "boost": 1,
                "value": "3021723"
              }
            }
          },
          "path": "bbsSubjectEsVos"
        },
        "order": "desc"
      }
    },
    {
      "bbsSalePriceEsVo.price": {
        "order": "asc"
      }
    }
  ],
  "_source": [
    "pkId",
    "name",
    "bbsSalePriceEsVo.price",
    "bbsSubjectEsVos.subjectId",
    "bbsSubjectEsVos.order"
  ]
}

 

需求：嵌套排序，根據主題排序號越大排序越前，然后根據價格排序

    /**
     * 加載查詢條件
     * @param searchVO
     * @return
     */
    public void initQuerySubjectbbsListBuilder(NativeSearchQueryBuilder queryBuilder, SubJectVO searchVO) {
        // 復合查詢
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        {// 數據必須有效
            TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("isDisable", ContantsEnums.DISABLE_0.getIndex());
            boolQueryBuilder.must(termQueryBuilder);
        }
        // 主題相關
//        String fkIdLocationSt;
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("bbsSubjectEsVos.subjectId", searchVO.getSubjectId());
        NestedQueryBuilder nestedQueryBuilder = QueryBuilders.nestedQuery("bbsSubjectEsVos", termQueryBuilder, ScoreMode.None);
        boolQueryBuilder.must(nestedQueryBuilder);
        // 查詢條件
        queryBuilder.withQuery(boolQueryBuilder); // 范圍查詢
    }
    

    /**
     * @desc 設置分頁、排序
     * @date 2020年4月3日 上午10:06:18
     * @param queryBuilder 查詢對象
     * @param searchReq 查詢參數
     */
    public void initQuerySubjectbbsListSort(NativeSearchQueryBuilder queryBuilder, SubJectVO searchVo) {
        // 加載分頁信息
        Pageable pageable =this.initPageTable(searchVo.getPn(), searchVo.getPs(), 0, 15);
        queryBuilder.withPageable(pageable);
        // 根據序號倒序 
        NestedSortBuilder nestedSort = new NestedSortBuilder("bbsSubjectEsVos");
        // 嵌套查詢排序，是在上面查詢的結果中抽取數據排序，所以無需使用NestedQueryBuilder
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("bbsSubjectEsVos.subjectId", searchVo.getSubjectId());
        nestedSort.setFilter(termQueryBuilder);
         SortBuilder<?> sortBuilderOrder = SortBuilders.fieldSort("bbsSubjectEsVos.order").order( SortOrder.DESC).setNestedSort(nestedSort);
         queryBuilder.withSort(sortBuilderOrder);
        // 價格順序
        SortBuilder<?> sortBuilderPrice = SortBuilders.fieldSort("bbsSalePriceEsVo.price").order( SortOrder.ASC);
        queryBuilder.withSort(sortBuilderPrice);
    }

 

生成的代碼查詢語句。