Elasticsearch 7 嵌套mapping创建及插入查询操作, 含JAVA操作

一时失言乱红尘 2023-06-11 03:21 5阅读 0赞

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"    \}  
>           \}  
>         \}  
>       \}  
>       
>   \}  
> \}

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70][]

写入数据：

> \{  
>   "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"  
>     \}  
>   \]  
> \}

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70 1][]

查询：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70 2][]

嵌套查询：

> GET /article\_index/\_search  
> \{
> 
> "from" : 0, "size" : 20,  
>   "query": \{  
>     "nested": \{  
>       "path": "comments",  
>       "query": \{  
>         "bool": \{  
>           "must": \[  
>             \{  
>               "match": \{  
>                 "comments.name": "tom"  
>               \}  
>             \},  
>             \{  
>               "match": \{  
>                 "comments.age": 23  
>               \}  
>             \}  
>           \]  
>         \}  
>       \}  
>     \}  
>   \}  
> \}

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70 3][]

> 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][https_github.com_hsn999_Elasticsearch_7_springboot_demo]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70]: /images/20230531/56932dfa0bda4c55ad860d8eb5e5994b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70 1]: /images/20230531/788d205c996c46aab9c5fe644fc45b6c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70 2]: /images/20230531/4b65f775bf9540ebb78f3fc966dcf0c5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfc245OTk5_size_16_color_FFFFFF_t_70 3]: /images/20230531/2346480109e34b7d9001f8d25905f1b2.png
[https_github.com_hsn999_Elasticsearch_7_springboot_demo]: https://github.com/hsn999/Elasticsearch_7_springboot_demo