Java中如何用Spring Data Elasticsearch获取索引字段mapping

你要实现的逻辑对应原生ES请求GET /my-index-000001/_mapping/field/user，可以直接通过Spring Data Elasticsearch封装的索引操作接口实现，不需要手动构造HTTP请求。

依赖前提 #

确保项目中已经引入Spring Data Elasticsearch依赖，且已经正确注入ElasticsearchOperations实例。

标准实现（Spring Data Elasticsearch 4.x+ 版本） #

直接使用IndexOperations提供的getFieldMapping方法，和原生请求逻辑完全对齐：

import jakarta.annotation.Resource;
import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
import org.springframework.data.elasticsearch.core.index.FieldMapping;
import org.springframework.stereotype.Component;

@Component
public class EsMappingQuery {

    @Resource
    private ElasticsearchOperations elasticsearchOperations;

    /**
     * 查询指定索引下单个字段的Mapping配置
     * @param indexName 目标索引名 示例值：my-index-000001
     * @param fieldName 目标字段名 示例值：user
     * @return 字段映射信息，包含类型、分词器、索引配置等属性
     */
    public FieldMapping getSpecifiedFieldMapping(String indexName, String fieldName) {
        return elasticsearchOperations
                .indexOps(elasticsearchOperations.getIndexCoordinatesFor(indexName))
                .getFieldMapping(fieldName);
    }
}

返回的FieldMapping对象可以直接通过getType()、getAnalyzer()、isSearchable()等方法拿到对应映射配置，不需要自己解析JSON。

全量Mapping过滤实现 #

如果业务场景需要同时获取多个字段的映射，可以先拉取索引全量Mapping再自行过滤：

import org.springframework.data.elasticsearch.core.document.Document;
import org.springframework.data.elasticsearch.core.IndexCoordinates;
import java.util.Map;

public Map<String, Object> getFieldFromFullMapping(String indexName, String fieldName) {
    Document fullMapping = elasticsearchOperations.indexOps(IndexCoordinates.of(indexName)).getMapping();
    Map<String, Object> propertiesNode = (Map<String, Object>) fullMapping.get("properties");
    return (Map<String, Object>) propertiesNode.get(fieldName);
}

注意：如果是多层嵌套字段（比如user.address.city），需要逐层遍历properties节点获取，不能直接用点分路径单次取值。

低版本兼容实现（3.x及更早版本） #

3.x版本没有封装单字段Mapping查询接口，可以直接调用底层RestHighLevelClient的原生方法实现：

import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.GetFieldMappingsRequest;
import org.elasticsearch.client.indices.GetFieldMappingsResponse;
import jakarta.annotation.Resource;
import java.io.IOException;

@Resource
private RestHighLevelClient restHighLevelClient;

public GetFieldMappingsResponse getFieldMappingForOldVersion(String indexName, String fieldName) throws IOException {
    GetFieldMappingsRequest request = new GetFieldMappingsRequest()
            .indices(indexName)
            .fields(fieldName);
    return restHighLevelClient.indices().getFieldMapping(request, RequestOptions.DEFAULT);
}

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