Spring data elasticsearch如何为关键字字段创建存储库方法

Question

假设我有这样的映射，并且我想通过“requestId.keyword”字段进行搜索以获取完全匹配的请求。如何在不使用 @Query 注解的情况下使用 Spring Data Elasticsearch 存储库实现它？

 "requestId": {
      "type": "text",
      "analyzer": "1_to_15_analyzer_without_space",
      "search_analyzer": "all_symbols_and_fold_analyzer",
      "fields": {
        "keyword": {
          "type": "keyword"
        }
      }
    }

Answer 1

对于通过内省方法名称来构建查询的机制来说，这是不可能的。第一个想法是有类似的东西（我在这里使用 Foo 实体）：

SearchHits<Foo> searchByRequestId_Keyword(String keyword);

方法名称的分析是在 spring-data-common 模块中完成的，该模块仅使用 Java 的属性名称实体的属性（可能是嵌套的）。但是 keyword 子字段仅存在于 Elasticsearch 中，并且（如果不是自动创建）存在于 @MultiField 注释中。但是解析方法名的代码不使用特定于商店的信息，因此这样的方法将不起作用并失败，并出现 keyword 不是 text 的属性的错误- 这对于 Java 对象来说是正确的。

您可以做的是首先添加一个自定义存储库片段接口：

public interface FooKeywordRepository {
    SearchHits<Foo> searchByRequestIdKeyword(String keyword);
}

并提供一个实现，该实现的命名必须类似于以 Impl 作为后缀的接口：

import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
import org.springframework.data.elasticsearch.core.SearchHits;
import org.springframework.data.elasticsearch.core.query.Criteria;
import org.springframework.data.elasticsearch.core.query.CriteriaQuery;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.Query;

public class FooKeywordRepositoryImpl implements FooKeywordRepository {

    private final ElasticsearchOperations operations;

    public FooKeywordRepositoryImpl(ElasticsearchOperations operations) {
        this.operations = operations;
    }

    @Override
    public SearchHits<Foo> searchByRequestIdKeyword(String keyword) {

        Query query1 = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.termQuery("requestId.keyword", keyword))
            .build();

        Query query2 = new CriteriaQuery(Criteria.where("requestId.keyword").is(keyword));

        return operations.search(query1, Foo.class); // could be query2 as well
    }
}

您注入了一个 ElasticsearchOperations 并使用它来执行您构建的查询。我采用了两种方法来构建查询，两种方法都有效。

您要使用的存储库定义将是：

public interface FooRepository extends ElasticsearchRepository<Foo, String>, FooKeywordRepository {
    // other custom methods if needed
}