弹性搜索结果到POJO

Question

我使用的是spring数据elasticsearch（4.0版）。现在，我需要将rest高级客户端的搜索结果转换为POJO对象。

我会使用杰克逊图书馆的ObjectMapper。我相信有更好的方法来做到这一点。

Spring data elasticsearch now（4.0版）使用MappingElasticsearchConverter。不幸的是，我不知道如何做到这一点-我没有看到任何相关文档。

实体

@Document(indexName="addresses")
public class Address {

    @Id
    private String uam;

    @Field
    private String street;

    ....
}

我只需要将SearchHits转换为地址实体

@SpringBootTest
@RunWith(SpringRunner.class)
@ActiveProfiles(profiles = "dev")
public class TestElasticSearch {


    @Autowired
    private RestHighLevelClient highLevelClient;

    @Test
    void convertToPojo() throws Exception {
        SearchRequest searchRequest = new SearchRequest();
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());
        searchRequest.source(searchSourceBuilder);
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

        SearchHit[] hits = searchResponse.getHits().getHits();

        Arrays.stream(hits).map(hit -> hit.toString()).forEach(System.out::println);
    }

Answer 1

我有另一个解决方案，对我来说很好，当你需要一个复杂的查询时，你可以使用

template.getElasticsearchConverter().read(YourPOJOClass.class, DocumentAdapters.from(hit));

其中模板是一个组织。springframework。数据elasticsearch。果心ElasticsearchRestTemplate您可以将其注入到类中。

Answer 2

SearchHits类扩展了Streamable类，因此，如果您使用leiblix所说的ElasticsearchOperations，您甚至不需要对其调用流（）

    public <T> List<T> search(Query query, Class<T> clazz) {
        return elasticsearchOperations.search(query, clazz).map(SearchHit::getContent).toList();
    }

Answer 3

正如P.J.Meisch所提到的，使用ElasticsearchOperations更好

void convertToPojo() {
    SearchHits<Address> hits = operations.search(Query.findAll(), Address.class);
    List<Address> addresses = hits.stream().map(hit -> hit.getContent()).collect(Collectors.toList());
}