Java如何获取Elasticsearch全部字段以实现全字段通配符检索

解答 #

Java 可以动态获取 Elasticsearch 指定索引的所有字段名称，以下是具体实现方案：

1. 动态获取索引全部字段 #

你可以通过 Elasticsearch High Level Rest Client 拉取索引的 Mapping 信息，递归解析得到所有字段（包含嵌套字段的完整路径）：

import org.elasticsearch.client.indices.GetMappingsRequest;
import org.elasticsearch.client.indices.GetMappingsResponse;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

// 已初始化RestHighLevelClient实例为client
GetMappingsRequest request = new GetMappingsRequest();
// 替换为你的目标索引名，支持多个索引
request.indices("target_index");
GetMappingsResponse response = client.indices().getMapping(request, RequestOptions.DEFAULT);

// 解析Mapping获取所有字段
Map<String, Object> indexMapping = response.mappings().get("target_index").getSourceAsMap();
Map<String, Object> properties = (Map<String, Object>) indexMapping.get("properties");
List<String> allFields = new ArrayList<>();
// 递归解析字段，支持嵌套字段路径拼接
parseFields(properties, "", allFields);

// 递归解析方法
private void parseFields(Map<String, Object> properties, String parentPath, List<String> allFields) {
    for (Map.Entry<String, Object> entry : properties.entrySet()) {
        String fieldName = entry.getKey();
        Map<String, Object> fieldProps = (Map<String, Object>) entry.getValue();
        String fullFieldName = parentPath.isEmpty() ? fieldName : parentPath + "." + fieldName;
        allFields.add(fullFieldName);
        // 处理子级嵌套字段
        if (fieldProps.containsKey("properties")) {
            Map<String, Object> childProps = (Map<String, Object>) fieldProps.get("properties");
            parseFields(childProps, fullFieldName, allFields);
        }
    }
}

2. 实现全字段通配符检索 #

有两种可选方案，可根据你的场景选择：

• 方案一：基于拿到的字段列表构建多字段正则查询

import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;

BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
for (String field : allFields) {
    boolQuery.should(QueryBuilders.regexpQuery(field, ".*" + queryValue + ".*"));
}
// 要求至少匹配一个字段
boolQuery.minimumShouldMatch(1);

• 方案二：无需提前拉取字段，直接使用ES内置全字段查询
  使用query_string默认匹配所有可检索字段，代码更简洁：

QueryBuilder queryBuilder = QueryBuilders.queryStringQuery("*" + queryValue + "*")
        .defaultOperator(Operator.OR);

注意事项 #

• 以通配符开头的检索会跳过倒排索引优化，数据量较大时查询性能较差，百万级以上数据建议使用ngram分词提前预处理字段优化检索效率
• 嵌套类型字段检索需要单独用nested查询包裹，上述递归方法已经输出了嵌套字段的完整路径，可根据字段属性调整查询逻辑
• ES 7.11+版本可使用wildcard字段类型优化通配符查询性能

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