如何使用Spring Data Elasticsearch实现精确文本/短语搜索？

核心问题分析 #

你的text字段被标准分析器分词，导致无法直接基于原始完整文本实现精确的前缀、包含、后缀匹配。必须基于字段的原始值进行匹配，最佳方式是使用字段的keyword子字段（存储未分词的完整文本）。

实现方案 #

1. 前提：确保字段有keyword子字段 #

如果你的索引映射中，FIELD_1、FIELD_2、FIELD_3已经定义了keyword子字段（默认命名为字段名.keyword），直接用以下查询代码；如果没有，先修改映射并重新索引数据。

修改映射添加keyword子字段（若未存在）

PUT /你的索引名/_mapping
{
  "properties": {
    "FIELD_1": {
      "type": "text",
      "fields": {
        "keyword": {
          "type": "keyword",
          "ignore_above": 256 // 根据文本长度调整阈值
        }
      }
    },
    "FIELD_2": {
      "type": "text",
      "fields": {
        "keyword": {
          "type": "keyword",
          "ignore_above": 256
        }
      }
    },
    "FIELD_3": {
      "type": "text",
      "fields": {
        "keyword": {
          "type": "keyword",
          "ignore_above": 256
        }
      }
    }
  }
}

2. 构造查询代码 #

import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import java.util.Arrays;
import java.util.List;

// 初始化参数
String filterText = "你的精确匹配文本";
List<String> targetFields = Arrays.asList("FIELD_1", "FIELD_2", "FIELD_3");
String staticFieldValue = "静态条件值";

// 主查询构造
BoolQueryBuilder mainQuery = new BoolQueryBuilder();

// 添加静态必须条件
mainQuery.must(QueryBuilders.termQuery("FIELD_X", staticFieldValue));

// 构造匹配条件：前缀、包含、后缀三选一，匹配任意目标字段
BoolQueryBuilder matchConditions = new BoolQueryBuilder();
for (String field : targetFields) {
    String keywordField = field + ".keyword";
    // 前缀匹配：以filterText开头（性能优于wildcard前缀查询）
    matchConditions.should(QueryBuilders.prefixQuery(keywordField, filterText));
    // 包含匹配：任意位置包含filterText（转义特殊字符避免语法错误）
    matchConditions.should(QueryBuilders.wildcardQuery(keywordField, "*" + QueryParser.escape(filterText) + "*"));
    // 后缀匹配：以filterText结尾
    matchConditions.should(QueryBuilders.wildcardQuery(keywordField, "*" + QueryParser.escape(filterText)));
}
// 至少满足一个匹配条件
matchConditions.minimumShouldMatch(1);

mainQuery.must(matchConditions);

// 构建并执行查询
var nativeQuery = new NativeSearchQueryBuilder()
    .withQuery(mainQuery)
    .withPageable(pageable)
    .build();
elasticsearchOperations.search(nativeQuery, MyEntity.class);

方案说明 #

• 使用keyword子字段：确保基于原始完整文本匹配，彻底避免分词干扰。
• prefixQuery性能优于*xxx格式的wildcard查询，优先用于前缀匹配场景。
• QueryParser.escape(filterText)：转义Elasticsearch通配符中的特殊字符（如*、?），防止查询语法错误。
• 原方案失效原因：
  • queryStringQuery基于分词后的term匹配，无法实现原始文本的精确通配。
  • matchPhraseQuery仅匹配连续的分词序列，无法覆盖前缀/后缀/任意位置包含的场景。
  • 强制text字段用keyword analyzer无效：text字段默认存储分词结果，无法还原原始文本，必须依赖keyword子字段存储完整值。

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