SpringBoot 联表查询：使用 Elasticsearch 关联门店和商品索引，按门店位置排序

在 Spring Boot 环境下，使用 RestHighLevelClient 将门店索引和商品索引进行联表查询，并按门店位置排序，可以按照以下步骤进行操作：

1. 首先，确保你的项目中已经添加了 Elasticsearch 的依赖，可以在 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

2. 创建门店索引和商品索引的实体类，分别命名为 Store 和 Product。这两个实体类需要使用@Document注解进行标记，并且指定索引的名称和类型。

@Document(indexName = 'store_index', type = 'store')
public class Store {

    @Id
    private String id;
    private String name;
    private String location;
    // 其他属性和对应的Getter/Setter方法
}

@Document(indexName = 'product_index', type = 'product')
public class Product {

    @Id
    private String id;
    private String name;
    private String merchantId;
    // 其他属性和对应的Getter/Setter方法
}

3. 创建一个自定义的 Repository 接口，用于执行联表查询操作。在该接口中，使用@Query注解定义一个自定义的查询方法。

public interface StoreProductRepository extends ElasticsearchRepository<Store, String> {

    @Query('{"bool" : {"must" : {"match" : {"name" : "?0"}}}}')
    SearchHits<Store> findStoresByProductName(String productName);
}

4. 在需要进行联表查询的地方，注入 StoreProductRepository 并使用 RestHighLevelClient 执行查询操作。在这里，我们使用SearchRequest和SearchSourceBuilder来构建查询请求和查询条件。

@Autowired
private StoreProductRepository storeProductRepository;

@Autowired
private RestHighLevelClient restHighLevelClient;

public List<Store> getStoresByProductName(String productName, int page, int size) throws IOException {

    SearchRequest searchRequest = new SearchRequest('product_index');
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

    // 构建查询条件
    QueryBuilder queryBuilder = QueryBuilders.matchQuery('name', productName);
    searchSourceBuilder.query(queryBuilder);

    // 分页查询
    searchSourceBuilder.from(page * size);
    searchSourceBuilder.size(size);

    // 按门店位置进行排序
    searchSourceBuilder.sort('location', SortOrder.ASC);

    searchRequest.source(searchSourceBuilder);

    // 执行查询操作
    SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);

    // 解析查询结果
    SearchHits<Store> searchHits = storeProductRepository.findStoresByProductName(productName);
    List<Store> stores = new ArrayList<>();
    for (SearchHit<Store> searchHit : searchHits) {
        stores.add(searchHit.getContent());
    }

    return stores;
}

这样，就可以通过商品名称在门店索引和商品索引上进行联表查询，分页返回门店商品集合，并按门店位置进行排序。