如何用Java Elasticsearch DSL实现多术语全匹配过滤员工数据

需要根据C、C++、Java等编程语言技能过滤员工列表，使用Java Elasticsearch DSL实现所有术语全匹配查询。

termsQuery默认返回匹配任意一个术语的数据（即至少匹配一个就会被选中），不符合全匹配需求。

尝试过以下方法但均未成功：

1. 给boolQuery设置minimum_should_match为tags.length：

QueryBuilder query = QueryBuilders
            .boolQuery()
            .must(
                    QueryBuilders
                            .termsQuery("tags",tags)
            )
            .minimumShouldMatch(tags.length);

2. 使用TermsSetQueryBuilder但抛出minimum_should_match_field未设置的异常：

QueryBuilder query =
            QueryBuilders
                    .boolQuery()
                    .should(
                            new TermsSetQueryBuilder("tags", tags)
                    )
                    .minimumShouldMatch(tags.size());

3. 尝试给TermsSetQuery设置minimum_should_match_field，但该参数仅接受字符串类型，尝试设置数值字符串、百分比字符串甚至脚本都未生效：

QueryBuilder query =
            QueryBuilders
                    .boolQuery()
                    .should(
                            new TermsSetQueryBuilder("tags", tags)
                                    .setMinimumShouldMatchField(tags.size())
                    )
                    .minimumShouldMatch(tags.size());

更新后的代码：

public List<Employee> getEmployeesByFilters(List<String> terms) {

    int required_matches = terms.size();
    QueryBuilder query =
            QueryBuilders
                    .boolQuery()
                    .must(
                            new TermsSetQueryBuilder(
                                    "filters", terms)
                                    .setMinimumShouldMatchField("required_matches")
                    );

    NativeSearchQuery nativeSearchQuery = new NativeSearchQueryBuilder()
            .withQuery(query)
            .build();

    List<Employee> employees = elasticsearchRestTemplate
    .search(nativeSearchQuery, Employee.class)
    .stream().map(SearchHit -> SearchHit.getContent())
    .collect(Collectors.toList());

    return employees;
}

请问如何针对“tags”字段实现多个术语（如["JAVA", "C"]）的全匹配过滤？

方法一：多个termQuery放入boolQuery的must中 #

这是最直观的实现方式，把每个术语单独做成termQuery，全部放入must集合里，只有同时匹配所有术语的文档才会被返回。

示例代码：

public List<Employee> getEmployeesByFilters(List<String> terms) {
    BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
    
    // 为每个术语添加必须匹配的条件
    for (String term : terms) {
        boolQuery.must(QueryBuilders.termQuery("tags", term));
    }

    NativeSearchQuery nativeSearchQuery = new NativeSearchQueryBuilder()
            .withQuery(boolQuery)
            .build();

    return elasticsearchRestTemplate.search(nativeSearchQuery, Employee.class)
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
}

这种方式逻辑清晰，易维护，适合术语数量不多的场景。

方法二：正确使用TermsSetQueryBuilder #

你之前的TermsSetQuery用法有误：minimum_should_match_field需要指向文档中存储的数值字段，而非直接传入数值。如果你的文档没有这类字段，应该用脚本方式指定需要匹配的术语数量：

示例代码：

public List<Employee> getEmployeesByFilters(List<String> terms) {
    int requiredMatches = terms.size();
    
    // 通过脚本设置必须匹配的术语总数
    TermsSetQueryBuilder termsSetQuery = QueryBuilders.termsSetQuery("tags", terms)
            .setMinimumShouldMatchScript(new Script(String.valueOf(requiredMatches)));

    NativeSearchQuery nativeSearchQuery = new NativeSearchQueryBuilder()
            .withQuery(termsSetQuery)
            .build();

    return elasticsearchRestTemplate.search(nativeSearchQuery, Employee.class)
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
}

只有当员工文档中存在类似required_skill_count这类存储需要匹配技能数量的字段时，才需要用setMinimumShouldMatchField指向该字段；否则直接用脚本指定固定数量即可。

方法三：match_all结合多条件过滤（可选） #

如果需要结合其他过滤逻辑，可将多个termQuery放入boolQuery的filter中，效果和must类似，但不会影响文档评分：

public List<Employee> getEmployeesByFilters(List<String> terms) {
    BoolQueryBuilder filterQuery = QueryBuilders.boolQuery();
    
    for (String term : terms) {
        filterQuery.filter(QueryBuilders.termQuery("tags", term));
    }

    NativeSearchQuery nativeSearchQuery = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.matchAllQuery())
            .withFilter(filterQuery)
            .build();

    return elasticsearchRestTemplate.search(nativeSearchQuery, Employee.class)
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
}

内容的提问来源于stack exchange，提问作者Pranta Palit