devbox
很楠不爱3
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

RestClient 访问elasticsearch_highlevelrestclient访问es

作者：很楠不爱3 | 2024-04-28 10:32:03

赞

踩

highlevelrestclient访问es

1。引入依赖

1）引入es的RestHighLevelClient依赖：

  1. <dependency>
  2.     <groupId>org.elasticsearch.client</groupId>
  3.     <artifactId>elasticsearch-rest-high-level-client</artifactId>
  4. </dependency>

2）因为SpringBoot默认的ES版本是7.6.2，所以我们需要覆盖默认的ES版本：

  1. <properties>
  2.     <java.version>1.8</java.version>
  3.     <elasticsearch.version>7.12.1</elasticsearch.version>
  4. </properties>

3）初始化RestHighLevelClient：

初始化的代码如下：

  1. RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(
  2.         HttpHost.create("http://192.168.150.101:9200")
  3. ));

2.创建索引库和删除索引库

存储的是新增索引库的语句

  1. package cn.itcast.hotel;
  2.  
  3. public class HotelConstants {
  4.     public static final String MAPPING_TEMPLATE = "{\n" +
  5.             "  \"mappings\": {\n" +
  6.             "    \"properties\": {\n" +
  7.             "      \"id\": {\n" +
  8.             "        \"type\": \"keyword\"\n" +
  9.             "      },\n" +
  10.             "      \"name\":{\n" +
  11.             "        \"type\": \"text\",\n" +
  12.             "        \"analyzer\": \"ik_max_word\",\n" +
  13.             "        \"copy_to\": \"all\"\n" +
  14.             "      },\n" +
  15.             "      \"address\":{\n" +
  16.             "        \"type\": \"keyword\",\n" +
  17.             "        \"index\": false\n" +
  18.             "      },\n" +
  19.             "      \"price\":{\n" +
  20.             "        \"type\": \"integer\"\n" +
  21.             "      },\n" +
  22.             "      \"score\":{\n" +
  23.             "        \"type\": \"integer\"\n" +
  24.             "      },\n" +
  25.             "      \"brand\":{\n" +
  26.             "        \"type\": \"keyword\",\n" +
  27.             "        \"copy_to\": \"all\"\n" +
  28.             "      },\n" +
  29.             "      \"city\":{\n" +
  30.             "        \"type\": \"keyword\",\n" +
  31.             "        \"copy_to\": \"all\"\n" +
  32.             "      },\n" +
  33.             "      \"starName\":{\n" +
  34.             "        \"type\": \"keyword\"\n" +
  35.             "      },\n" +
  36.             "      \"business\":{\n" +
  37.             "        \"type\": \"keyword\"\n" +
  38.             "      },\n" +
  39.             "      \"location\":{\n" +
  40.             "        \"type\": \"geo_point\"\n" +
  41.             "      },\n" +
  42.             "      \"pic\":{\n" +
  43.             "        \"type\": \"keyword\",\n" +
  44.             "        \"index\": false\n" +
  45.             "      },\n" +
  46.             "      \"all\":{\n" +
  47.             "        \"type\": \"text\",\n" +
  48.             "        \"analyzer\": \"ik_max_word\"\n" +
  49.             "      }\n" +
  50.             "    }\n" +
  51.             "  }\n" +
  52.             "}";
  53. }

新增和删除索引库操作 

  1. import org.apache.http.HttpHost;
  2. import org.apache.http.client.methods.HttpPost;
  3. import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
  4. import org.elasticsearch.client.RequestOptions;
  5. import org.elasticsearch.client.RestClient;
  6. import org.elasticsearch.client.RestHighLevelClient;
  7. import org.elasticsearch.client.indices.CreateIndexRequest;
  8. import org.elasticsearch.common.xcontent.XContentType;
  9. import org.junit.jupiter.api.AfterEach;
  10. import org.junit.jupiter.api.BeforeEach;
  11. import org.junit.jupiter.api.Test;
  12. import org.springframework.boot.test.context.SpringBootTest;
  13.  
  14. import java.io.IOException;
  15.  
  16. @SpringBootTest
  17. class HotelSuoYinTest {
  18.     private RestHighLevelClient client;
  19.  
  20.     @BeforeEach
  21.     void setup() {
  22.         this.client =
  23.                 new RestHighLevelClient(
  24.                         RestClient.builder(
  25.                                 HttpHost.create("http://101.43.94.150:9200")
  26.                         ));
  27.     }
  28.  
  29.     @AfterEach
  30.     void shutdown() throws IOException {
  31.         this.client.close();
  32.     }
  33. //    indices()  有这个，就是索引库的操作
  34.     @Test
  35.     void test() throws IOException {
  36. //        创建request对象
  37.         CreateIndexRequest request = new CreateIndexRequest("hotel");
  38. //        准备请求的参数 dsl语句
  39.         request.source(HotelConstants.MAPPING_TEMPLATE, XContentType.JSON);
  40. //        发送请求
  41.         client.indices().create(request, RequestOptions.DEFAULT);
  42.     }
  43.  
  44.     @Test
  45.     void deltest() throws IOException {
  46. //        创建request对象
  47.         DeleteIndexRequest request = new DeleteIndexRequest("hotel");
  48. //        发送请求
  49.         client.indices().delete(request, RequestOptions.DEFAULT);
  50.     }
  51. }

判断索引库是不是存在 

  1. @Test
  2. void testExistsHotelIndex() throws IOException {
  3.     // 1.创建Request对象
  4.     GetIndexRequest request = new GetIndexRequest("hotel");
  5.     // 2.发送请求
  6.     boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
  7.     // 3.输出
  8.     System.err.println(exists ? "索引库已经存在！" : "索引库不存在！");
  9. }

索引库操作的基本步骤：

  • 初始化RestHighLevelClient

  • 创建XxxIndexRequest。XXX是Create、Get、Delete

  • 准备DSL（ Create时需要，其它是无参）

  • 发送请求。调用RestHighLevelClient#indices().xxx()方法，xxx是create、exists、delete

3.删除文档 修改文档 新增文档 批量添加文档

因为mysql查询出来的hotel信息经纬度信息是分开的，但是eleasticsearch的地理坐标要求是一个String类型，中间用逗号分开，所以要转为hotelDoc

  1.  
  2. //文档，相当于mysql中的行
  3. //#查询一条文档（记录）的 dsl语句
  4. //        GET /heima/_doc/1
  5. @SpringBootTest
  6. public class DocumentTest {
  7.     private RestHighLevelClient client;
  8.     @Autowired
  9.     HotelService hotelService;
  10.  
  11.     //    插入新数据
  12.     @Test
  13.     public void testadd() throws IOException {
  14.         Hotel hotel = hotelService.getById(61083L);
  15.         HotelDoc hotelDoc = new HotelDoc(hotel);
  16. //        创建request，并指明要处理的索引是hotel,记录号是 hotelDoc.getId()
  17.         IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
  18.         request.source(JSON.toJSONString(hotelDoc), XContentType.JSON);
  19.         client.index(request, RequestOptions.DEFAULT);
  20.     }
  21.  
  22.     //    查询某条数据
  23.     @Test
  24.     public void testquery() throws IOException {
  25.         GetRequest request = new GetRequest("hotel", "61083");
  26.         GetResponse response = client.get(request, RequestOptions.DEFAULT);
  27.         String json = response.getSourceAsString();
  28.         HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
  29.         System.out.println(hotelDoc);
  30.     }
  31.  
  32.     //更新某条数据
  33.     @Test
  34.     public void testupdate() throws IOException {
  35.         Hotel hotel = hotelService.getById(61083L);
  36.         HotelDoc hotelDoc = new HotelDoc(hotel);
  37.         UpdateRequest request = new UpdateRequest("hotel", "61083");
  38.         request.doc("price", "952");
  39.         request.doc("address", "北京饭店");
  40.         client.update(request, RequestOptions.DEFAULT);
  41.     }
  42.  
  43.     //   删除某条数据
  44.     @Test
  45.     void testDeleteDocument() throws IOException {
  46.         // 1.准备Request
  47.         DeleteRequest request = new DeleteRequest("hotel", "61083");
  48.         // 2.发送请求
  49.         client.delete(request, RequestOptions.DEFAULT);
  50.     }
  51.  
  52.     @Test
  53.     void testpiliangadd() throws IOException {
  54.         List<Hotel> hotels = hotelService.list();
  55.         BulkRequest request = new BulkRequest();
  56.         for (Hotel hotel : hotels) {
  57.             HotelDoc hotelDoc = new HotelDoc(hotel);
  58.             request.add(new IndexRequest("hotel")
  59.                     .id(hotelDoc.getId() + "")
  60.                     .source(JSON.toJSONString(hotelDoc)
  61.                             , XContentType.JSON));
  62.         }
  63.         client.bulk(request, RequestOptions.DEFAULT);
  64.     }
  65.  
  66.     @BeforeEach
  67.     void setup() {
  68.         this.client =
  69.                 new RestHighLevelClient(
  70.                         RestClient.builder(
  71.                                 HttpHost.create("http://101.43.94.150:9200")
  72.                         ));
  73.     }
  74.  
  75.     @AfterEach
  76.     void shutdown() throws IOException {
  77.         this.client.close();
  78.     }
  79. }

4.查询文档

  1. package cn.itcast.hotel;
  2.  
  3. import cn.itcast.hotel.pojo.HotelDoc;
  4. import com.alibaba.fastjson.JSON;
  5. import org.apache.http.HttpHost;
  6. import org.elasticsearch.action.search.SearchRequest;
  7. import org.elasticsearch.action.search.SearchResponse;
  8. import org.elasticsearch.client.RequestOptions;
  9. import org.elasticsearch.client.RestClient;
  10. import org.elasticsearch.client.RestHighLevelClient;
  11. import org.elasticsearch.index.query.BoolQueryBuilder;
  12. import org.elasticsearch.index.query.QueryBuilder;
  13. import org.elasticsearch.index.query.QueryBuilders;
  14. import org.elasticsearch.search.SearchHit;
  15. import org.elasticsearch.search.SearchHits;
  16. import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
  17. import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
  18. import org.elasticsearch.search.sort.SortOrder;
  19. import org.junit.jupiter.api.AfterEach;
  20. import org.junit.jupiter.api.BeforeEach;
  21. import org.junit.jupiter.api.Test;
  22. import org.springframework.boot.test.context.SpringBootTest;
  23.  
  24. import java.io.IOException;
  25. import java.util.Map;
  26.  
  27. @SpringBootTest
  28. public class QueryTest {
  29.     private RestHighLevelClient client;
  30.  
  31.     //查询全部文档
  32.     @Test
  33.     void testmatchall() throws IOException {
  34. //       1. 准备request
  35.         SearchRequest request = new SearchRequest("hotel");
  36. //       2. 准备dsl
  37.         request.source().query(QueryBuilders.matchAllQuery());
  38. //        3.发送请求
  39.         SearchResponse response = client.search(request, RequestOptions.DEFAULT);
  40.         handleResponse(response);
  41.     }
  42.  
  43.     //全文检索查询
  44.     @Test
  45.     void testquerycheck() throws IOException {
  46. //       1. 准备request
  47.         SearchRequest request = new SearchRequest("hotel");
  48.  
  49. //       2. 准备dsl
  50.         request.source().query(QueryBuilders.matchQuery("all", "如家"));
  51. //        3.发送请求
  52.         SearchResponse response = client.search(request, RequestOptions.DEFAULT);
  53.         handleResponse(response);
  54.     }
  55.  
  56.     //boolean复合查询
  57.     @Test
  58.     void testBool() throws IOException {
  59.         // 1.准备Request
  60.         SearchRequest request = new SearchRequest("hotel");
  61.         // 2.准备DSL
  62.         // 2.1.准备BooleanQuery
  63.         BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
  64.         // 2.2.添加term
  65.         boolQuery.must(QueryBuilders.termQuery("city", "上海"));
  66.         // 2.3.添加range
  67.         boolQuery.filter(QueryBuilders.rangeQuery("price").lte(250));
  68. //        关联查询条件
  69.         request.source().query(boolQuery);
  70.         // 3.发送请求
  71.         SearchResponse response = client.search(request, RequestOptions.DEFAULT);
  72.         // 4.解析响应
  73.         handleResponse(response);
  74.     }
  75.  
  76.     //查询后排序和按页查询  el的分页查询是查询所有结果之后再分页。
  77.     @Test
  78.     void testpageandsort() throws IOException {
  79. //        页码，每页大小
  80.         int pagenum = 1, pagesize = 5;
  81.         // 1.准备Request
  82.         SearchRequest request = new SearchRequest("hotel");
  83.         request.source().query(QueryBuilders.matchAllQuery());
  84.         request.source().sort("price", SortOrder.ASC);
  85. //       前端传过来的是页码和每页大小 ，算一下从第多少条后开始分页
  86.         request.source().from((pagenum - 1) * pagesize);
  87. //        页大小
  88.         request.source().size(pagesize);
  89.         // 3.发送请求
  90.         SearchResponse response = client.search(request, RequestOptions.DEFAULT);
  91.         // 4.解析响应
  92.         handleResponse(response);
  93.     }
  94.  
  95.     //查询后高亮显示
  96.     @Test
  97.     void testhightlight() throws IOException {
  98.         // 1.准备Request
  99.         SearchRequest request = new SearchRequest("hotel");
  100.         request.source().query(QueryBuilders.matchQuery("brand", "如家"));
  101. //        requireFieldMatch(false) 搜索条件brand和高亮的属性name设为不一致
  102.         request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));
  103.         // 3.发送请求
  104.         SearchResponse response = client.search(request, RequestOptions.DEFAULT);
  105.         handleHeightLightResponse(response);
  106.     }
  107.     
  108. //    高亮查询
  109.     private void handleHeightLightResponse(SearchResponse response) {
  110.         // 4.解析响应
  111.         SearchHits searchHits = response.getHits();
  112.         // 4.1.获取总条数
  113.         long total = searchHits.getTotalHits().value;
  114.         System.out.println("共搜索到" + total + "条数据");
  115.         // 4.2.文档数组
  116.         SearchHit[] hits = searchHits.getHits();
  117.         // 4.3.遍历
  118.         for (SearchHit hit : hits) {
  119.             // 获取文档source
  120.             String json = hit.getSourceAsString();
  121.             // 反序列化
  122.             HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
  123. //             获取高亮
  124.             Map<String, HighlightField> highlightFields = hit.getHighlightFields();
  125.             HighlightField highlightField = highlightFields.get("name");
  126.             String name = highlightField.getFragments()[0].toString();
  127.             hotelDoc.setName(name);
  128.             System.out.println(hotelDoc);
  129.         }
  130.     }
  131. // 解析响应函数
  132.     private void handleResponse(SearchResponse response) {
  133.         // 4.解析响应
  134.         SearchHits searchHits = response.getHits();
  135.         // 4.1.获取总条数
  136.         long total = searchHits.getTotalHits().value;
  137.         System.out.println("共搜索到" + total + "条数据");
  138.         // 4.2.文档数组
  139.         SearchHit[] hits = searchHits.getHits();
  140.         // 4.3.遍历
  141.         for (SearchHit hit : hits) {
  142.             // 获取文档source
  143.             String json = hit.getSourceAsString();
  144.             // 反序列化
  145.             HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
  146. //            System.out.println("hotelDoc = " + hotelDoc);
  147.         }
  148.     }
  149.  
  150.     @BeforeEach
  151.     void setup() {
  152.         this.client =
  153.                 new RestHighLevelClient(
  154.                         RestClient.builder(
  155.                                 HttpHost.create("http://101.43.94.150:9200")
  156.                         ));
  157.     }
  158.  
  159.     @AfterEach
  160.     void shutdown() throws IOException {
  161.         this.client.close();
  162.     }
  163. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/很楠不爱3/article/detail/501814
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号