在Spring data elasticsearch中，如何在所有结果上投影或添加计算字段？

Question

我正在使用spring-data-elasticsearch（最新版本）以及elasticsearch（最新版本）的docker实例，我想在查询后从我的存储库返回的所有结果上计算一个字段。我不想在存储库中使用这些信息，因为它有时依赖于查询，有时依赖于环境。例如，如果我们执行查询，我想生成一个URL，其中包含查询词作为URL中的查询参数，我想用它来丰富结果。还有一些其他情况。我尝试创建一个接受整个文档对象的Spring data自定义读取转换器。我可以看到它在应用程序启动时被识别，但从未被调用。如何使用自定义值投影字段，或使用上下文计算的值丰富返回的文档？

Answer 1

我喜欢一种混合的方法，将“ChinHuang”和“PJMeisch”的答案结合起来。这两个答案都有其适用性，这取决于语境或情况。我喜欢黄的建议，比如基于实例的信息，你需要配置值之类的东西。我也同意PJ Meisch的担忧是正确的，即这不会让您访问即时查询，因此我喜欢他在从数据存储返回数据时拦截/映射值的想法。我感谢两人提供的大量信息，因为这两种方法的结合是一种我很满意的解决方案。

我更喜欢尽可能使用存储库接口，因为许多人错误地将业务逻辑混合到他们的存储库中。如果我想要自定义实现，那么我必须真正考虑它，因为我必须创建一个“Impl”类来实现它。这不是最严重的错误，但我总是伴随着存储库的业务服务，该服务负责任何数据梳理，或任何不严格检索或持久化数据的编程操作。

这是我的模块配置的一部分，在这里我创建了自定义的AfterConvertCallback。我在onAfterConvert方法中设置了基本URL：

@Bean
AfterConvertCallback<BookInfo> bookInfoAfterConvertCallback() {
    return new BookInfoAfterConvertCallback(documentUrl);
}

static class BookInfoAfterConvertCallback implements AfterConvertCallback<BookInfo> {

    private final String documentUrl;

    public BookInfoAfterConvertCallback(String documentUrl) {
        this.documentUrl = documentUrl;
    }

    @Override
    public BookInfo onAfterConvert(final BookInfo entity, final Document document, final IndexCoordinates indexCoordinates) {
        entity.setUrl(String.format("%s?id=%d", documentUrl, entity.getId()));
        return entity;
    }
}

在调用存储库查询的数据服务中，我编写了一对函数来创建URL的查询参数部分，以便我可以将其附加到使用自动连接存储库实例的任何适用方法中：

/**
 * Given a term, encode it so that it can be used as a query parameter in a URL
 */
private static final Function<String, String> encodeTerm = term -> {
    try {
        return URLEncoder.encode(term, StandardCharsets.UTF_8.name());
    } catch (UnsupportedEncodingException e) {
        log.warn("Could not encode search term for document URL", e);
        return null;
    }
};

/**
 * Given a list of search terms, transform them into encoded URL query parameters and append
 * them to the given URL.
 */
private static final BiFunction<List<String>, String, String> addEncodedUrlQueryParams = (searchTerms, url) ->
        searchTerms.stream()
                .map(term -> String.format("term=%s", encodeTerm.apply(term)))
                .filter(Objects::nonNull)
                .collect(Collectors.joining("&", url + "&", ""));

这完全可以在存储库实例或其封闭服务中完成。但是，当您想要截取检索到的所有数据，并对其执行非特定于查询的操作时，回调是一个很好的选择，因为它不会产生需要在其应应用的每个数据层方法中引入回调的维护成本。在查询时，当您需要引用仅在查询中可用的信息时，显然需要将此类代码引入数据层（服务或repo）方法。

我添加这一点作为回答，因为即使我在发布问题时没有意识到这一点，但这两个问题是相互独立的，足以保证两种方法都适用。我不想为这个答案索赔，所以我不会选择它作为答案，除非你们都对此发表评论，并告诉我，你希望我这样做。

Answer 2

我首先想到了AfterConvertCallback以及Chin评论，但是在回调中，您没有运行以获取实体的查询的上下文，因此您不能使用查询术语之类的东西来构建某些东西。

我会将属性-让我们在此处将其命名为类型为String的url-添加到实体中，并使用org.springframework.data.annotation.瞬态注释对其进行标记，以防止其被存储。

然后在您进行搜索的方法中，使用Elasticsearch chAction或存储库，对返回的实体进行后处理（代码未测试，只是写在这里）：

SearchHits<Entity> searchHits = repository.findByFoo(String fooValue);
searchHits.getSearchHits().forEach(searchHit -> {
    searchHit.getContent().setUrl(someValueDerivedFromEnvironemtAndQuery);
});

之后继续使用SearchHits。