如何在Elasticsearch中匹配完整数组项？含DSL及Java客户端方案

要实现你需要的**完全匹配数组元素（顺序无关、元素数量必须完全一致，不能多也不能少）**的需求，我们可以结合Elasticsearch的terms查询和脚本查询来完成，下面分DSL示例和Java High Level REST Client实现两部分说明：

Elasticsearch DSL 查询示例 #

核心思路是两个条件同时满足：

1. 文档的数组字段包含筛选数组的所有元素（顺序无关）
2. 文档数组的长度和筛选数组的长度完全一致

对应的DSL如下：

{
  "query": {
    "bool": {
      "must": [
        {
          "terms": {
            "id": ["a", "b"]
          }
        },
        {
          "script": {
            "script": {
              "source": "doc['id'].size() == params.targetSize",
              "params": {
                "targetSize": 2
              }
            }
          }
        }
      ]
    }
  }
}

逻辑解释 #

• terms查询会自动忽略元素顺序，确保文档的id数组包含所有筛选元素；
• 脚本查询通过对比数组长度，直接排除了元素更少的子集（比如["a"]）和元素更多的超集（比如["a","b","c"]）；
• 两者结合后，就只会返回和筛选数组元素完全一致（顺序无关）的文档。

Java High Level REST Client 实现 #

下面是用Java客户端实现上述查询的代码示例，假设你已经初始化好了RestHighLevelClient实例：

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.ScriptQueryBuilder;
import org.elasticsearch.script.Script;
import org.elasticsearch.script.ScriptType;

import java.io.IOException;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class ExactArrayMatchDemo {
    public static void runExactArraySearch(RestHighLevelClient client) throws IOException {
        // 定义你的筛选数组
        String[] targetIds = {"a", "b"};
        int targetArraySize = targetIds.length;

        // 构建bool查询容器
        BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();

        // 添加terms查询：匹配所有目标元素
        boolQuery.must(QueryBuilders.termsQuery("id", targetIds));

        // 添加脚本查询：确保数组长度一致
        Map<String, Object> scriptParams = new HashMap<>();
        scriptParams.put("targetSize", targetArraySize);
        Script lengthCheckScript = new Script(
                ScriptType.INLINE,
                "painless",
                "doc['id'].size() == params.targetSize",
                scriptParams
        );
        boolQuery.must(new ScriptQueryBuilder(lengthCheckScript));

        // 构建搜索请求，替换为你的索引名
        SearchRequest searchRequest = new SearchRequest("your_target_index");
        searchRequest.source().query(boolQuery);

        // 执行查询并获取结果
        SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);

        // 这里可以添加结果解析逻辑，比如遍历命中的文档
        // SearchHits hits = response.getHits();
        // for (SearchHit hit : hits) {
        //     String source = hit.getSourceAsString();
        //     // 处理文档内容
        // }
    }
}

注意事项 #

• 确保你的id字段是keyword类型（或其他支持精确匹配的类型），否则terms查询可能无法正确匹配元素；
• 如果需要频繁执行这类查询，建议将脚本保存为存储脚本（stored script），这样可以避免每次传输脚本内容，提升性能；
• 如果你的数组存在重复元素的场景（比如筛选数组是["a","a"]），需要额外在脚本中统计每个元素的出现次数，确保和筛选数组完全一致，这时候可以扩展脚本逻辑来实现。

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