spring-Data-ElasticSearch通过不同的enttity/indicies进行搜索

Question

我有一个要求，以提供功能，将允许用户搜索通过许多不同的领域元素，并看到结果作为组合列表。所以在UI中，他只需要填充一个文本字段，然后检索结果。

为了可视化，假设我在域中有3个实体：

@Document(indexName="car") 
public class Car { 
  private int id;
  private String type;
} 
@Document(indexName="garage")
public class Garage{ 
  private int id;
  private String address;
} 
@Document(indexName="shop")
public class Shop{ 
  private int id;
  private String name;
}

现在我想我可以达到这样的要求：

...
@Inject
    private ElasticsearchTemplate elasticsearchTemplate;
...    
@RequestMapping(value = "/_search/all/{query}",
        method = RequestMethod.GET,
        produces = MediaType.APPLICATION_JSON_VALUE)
@Timed
public List<?> search(@PathVariable String query) {
     SearchQuery searchQuery = new NativeSearchQueryBuilder()
       .withQuery(queryString(query))
       .withIndices("car", "garage", "shop")
       .build();

    //THIS WORKS
    elasticsearchTemplate.queryForIds(searchQuery);

    //THIS THROWS ERROR ABOUT WRONG INDEXES
    return elasticsearchTemplate.queryForPage(searchQuery, GlobalSearchDTO.class, new GlobalSearchResultMapper()).getContent();
    }
...
    class GlobalSearchDTO {
        public Long id;
        public String type;
        public Object obj;
    }
 ...  

但是当调用第二个函数--负责返回实际文档的函数时，会引发以下异常：

无法标识索引名称。GlobalSearchDTO不是文档。确保document类被@document(indexname=“foo”）注释

我尝试将任何域实体作为类参数传递，但我只是从相应的索引中检索元素，而不是全部。例如调用：

return elasticsearchTemplate.queryForPage(searchQuery, Shop.class, new GlobalSearchResultMapper()).getContent();

仅从“shop”索引检索元素的结果。由于某种原因，似乎没有使用动态提供的指数。

所以问题是：这样检索数据有可能吗？为什么指定'.withindees（“car”、“garage”、“shop”）‘是不够的？

也许我应该考虑其他的解决方案，比如：

>

在循环中搜索索引（一个比一个），连接结果并按分数排序

创建具有“GlobalSearch”索引
并在其中重复数据的单独GlobalSearch实体

提前道谢！

克日什托夫

Answer 1

我已设法为我的问题找到了合适的解决办法。结果表明，当使用“滚动”和“扫描”功能时，会使用动态提供的索引，这意味着查询按预期工作。解决方案代码：

 @RequestMapping(value = "/_search/all/{query}",
        method = RequestMethod.GET,
        produces = MediaType.APPLICATION_JSON_VALUE)
    @Timed
    public List<?> search(@PathVariable String query) {
       SearchQuery searchQuery = new NativeSearchQueryBuilder()
         .withQuery(queryString(query))
         .withIndices("car", "garage", "shop")
         .withPageable(new PageRequest(0,1))
         .build();

         String scrollId = elasticsearchTemplate.scan(searchQuery, 1000, false);
         List<GlobalSearchDTO> sampleEntities = new ArrayList<GlobalSearchDTO>();
         boolean hasRecords = true;
         while (hasRecords){
             Page<GlobalSearchDTO> page = elasticsearchTemplate.scroll(scrollId, 5000L , new ResultMapper());
             if(page != null) {
                 sampleEntities.addAll(page.getContent());
                 hasRecords = page.hasNext();
             }
             else{
                 hasRecords = false;
             }
         }
         return sampleEntities;
    }

}

并且在ResultMapper类中：

...
for (SearchHit hit : response.getHits()) { 
    switch(hit.getIndex()) {
                case "car": //map to DTO
                case "shop": //map to DTO
                case "garage": //map to DTO
                }
}   
...