Elasticsearch 7 有些新特性，操作与老版本稍有不同

创建mapping

PUT /article_index 
{
  "mappings": {
      "properties": {
        "author":{ "type":"keyword"},
        "title":{ "type":"keyword"},
        "keyword":{ "type":"text"},
        "comments": {
          "type": "nested", 
          "properties": {
            "name":    { "type": "keyword"  },
            "comment": { "type": "text"  },
            "age":     { "type": "short"   },
            "stars":   { "type": "short"   },
            "date":    { "type": "date"    }
          }
        }
      }
    
  }
}

写入数据：

{
  "author": "xxxx",
  "title": "Nest coff",
  "keyword":  "nest kill",
  "comments": [
    {
      "name":    "John Smith",
      "comment": "Great article",
      "age":     28,
      "stars":   4,
      "date":    "2017-09-01"
    },
    {
      "name":    "Alice White",
      "comment": "More like this please",
      "age":     31,
      "stars":   5,
      "date":    "2014-10-22"
    }
  ]
}

PUT /article_index/_doc/2
{
  "author": "xx1xx",
  "title": "Fast road",
  "keyword":  "road kill",
  "comments": [
    {
      "name":    "tom",
      "comment": "Great article",
      "age":     23,
      "stars":   1,
      "date":    "2017-09-01"
    },
    {
      "name":    "Big White",
      "comment": "More like this please",
      "age":     35,
      "stars":   5,
      "date":    "2017-10-22"
    }
  ]
}

查询：

嵌套查询：

GET /article_index/_search
{

"from" : 0, "size" : 20,
  "query": {
    "nested": {
      "path": "comments",
      "query": {
        "bool": {
          "must": [
            {
              "match": {
                "comments.name": "tom"
              }
            },
            {
              "match": {
                "comments.age": 23
              }
            }
          ]
        }
      }
    }
  }
}

import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;

import org.apache.http.HttpHost;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
import org.apache.http.impl.nio.reactor.IOReactorConfig;
import org.apache.lucene.search.TotalHits;
import org.apache.lucene.search.join.ScoreMode;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import com.fasterxml.jackson.databind.ObjectMapper;

/**
 * 
 * @author hsn
 *
 */

public class Es7Test1 {
    public static void main(String[] args) throws IOException {
        // Client
        RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost("192.168.37.139", 9200))
                .setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
                    @Override
                    public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder requestConfigBuilder) {
                        return requestConfigBuilder.setConnectTimeout(5000) // 连接超时（默认为1秒）
                                .setSocketTimeout(60000);// 套接字超时（默认为30秒）
                    }
                })
                // .setMaxRetryTimeoutMillis(60000)//调整最大重试超时时间（默认为30秒）
                .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
                    @Override
                    public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                        return httpClientBuilder
                                .setDefaultIOReactorConfig(IOReactorConfig.custom().setIoThreadCount(1).build());// 线程数
                    }
                });
        RestHighLevelClient client = new RestHighLevelClient(restClientBuilder);

        Article article = new Article();
        Comments comments = new Comments();
        comments.setAge(18);
        comments.setComment("good!!!");
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        // Date date =new Date();
        comments.setDate(new Date());
        comments.setStars(3);
        comments.setName("zhang");
        List<Comments> l = new ArrayList<Comments>();
        l.add(comments);
        article.setComments(l);
        article.setAuthor("xxxx");
        article.setKeyword("hk kill tom new");
        article.setTitle("love me");

        String jsonData = new ObjectMapper().writeValueAsString(article);

        IndexRequest indexRequest = new IndexRequest("article_index").id("13").source(jsonData, XContentType.JSON);

        IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
        String index = indexResponse.getIndex();
        String id = indexResponse.getId();
        long version = indexResponse.getVersion();
        System.out.println(index);
        System.out.println(id);
        System.out.println(version);
        
        
        
        
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); 
        searchSourceBuilder.query(QueryBuilders.matchAllQuery()); 
        searchSourceBuilder.query(QueryBuilders.termQuery("author", "xxxx")); 
        searchSourceBuilder.from(0);//设置from确定结果索引的选项以开始搜索。默认为0
        searchSourceBuilder.size(10);//设置size确定要返回的搜索匹配数的选项。默认为10 
        searchSourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
        
        SearchRequest searchRequest = new SearchRequest(); 
        searchRequest.indices("article_index");
        searchRequest.source(searchSourceBuilder); 
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHits hits = searchResponse.getHits();
        TotalHits totalHits = hits.getTotalHits();
        long numHits = totalHits.value;
        TotalHits.Relation relation = totalHits.relation;
        System.out.println("numHits:"+numHits);
        
        
        
        //嵌套查询
        SearchRequest request = new SearchRequest("article_index")
                .source(new SearchSourceBuilder().query(QueryBuilders.boolQuery()
                    .should(QueryBuilders.matchQuery("author", "xxxx"))
                    .should(QueryBuilders.matchQuery("title", "Nest coff"))
                    .should(QueryBuilders.nestedQuery("comments", QueryBuilders.matchQuery("age", "31"),ScoreMode.Total))));
        
        searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        hits = searchResponse.getHits();
        totalHits = hits.getTotalHits();
        numHits = totalHits.value;
        relation = totalHits.relation;
        System.out.println("numHits----:"+numHits);
        SearchHit [] searchHits = hits.getHits();
        for(SearchHit hit:searchHits){
            //使用SearchHit做一些事情
            index = hit.getIndex();
            id = hit.getId();
            float score = hit.getScore();
            System.out.println(hit.getSourceAsString());
        }
        

        
         // 关闭连接
        client.close();
    }
}
 

代码请参考：https://github.com/hsn999/Elasticsearch_7_springboot_demo