Elasticsearch入门指南(二)-EW帮帮网

一、RestClient操作索引库

什么是RestClient？
ES官方提供了各种不同语言的客户端，用来操作ES。这些客户端的本质就是组装DSL语句，通过http请求发送给ES。官方文档地址： https://www.elastic.co/guide/en/elasticsearch/client/index.html

案例：利用 JavaRestClient 实现创建、删除索引库，判断索引库是否存在
根据课前资料提供的酒店数据创建索引库，索引库名为hotel，mapping属性根据数据库结构定义。

准备步骤如下：

导入课前资料Demo
分析数据结构，定义mapping属性
小提示
ES中支持两种地理坐标数据类型：

geo_point：由纬度(latitude) 和经度(longitude)确定的一个点。例如：“32.8752345, 120.2981576”
geo_shape：有多个geo_point组成的复杂几何图形。例如一条直线，“LINESTRING (-77.03653 38.897676, -77.009051 38.889939)”

字段拷贝可以使用copy_to属性将当前字段拷贝到指定字段。示例：

"all": {
    "type": "text",
    "analyzer": "ik_max_word"
},
"brand": {
    "type": "keyword"，
    "copy_to": "all"
}

在这里插入图片描述 3. 初始化JavaRestClient

实际步骤
1.引入es的RestHighLevelClient依赖：

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
</dependency>

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

<properties>
    <java.version>1.8</java.version>
    <elasticsearch.version>7.12.1</elasticsearch.version>
</properties>

初始化RestHighLevelClient：

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

在这里插入图片描述
4. 利用JavaRestClient创建索引库

5. 利用JavaRestClient删除索引库

@Test
void testDeleteIndex() throws IOException {
    // 1.准备Request
    DeleteIndexRequest request = new DeleteIndexRequest("hotel");
    // 2.发送请求
    client.indices().delete(request, RequestOptions.DEFAULT);
}

6.利用JavaRestClient判断索引库是否存在

@Test
void testExistsIndex() throws IOException {
    // 1.准备Request
    GetIndexRequest request = new GetIndexRequest("hotel");
    // 2.发送请求
    boolean isExists = client.indices().exists(request, RequestOptions.DEFAULT);
    System.out.println(isExists ? "存在" : "不存在");
}

二、RestClient操作文档

案例1：利用JavaRestClient实现文档的CRUD

去数据库查询酒店数据，导入到hotel索引库，实现酒店数据的CRUD。
基本步骤如下：

初始化JavaRestClient
利用JavaRestClient 新增酒店数据
3. 利用JavaRestClient 根据id查询酒店数据
利用JavaRestClient 删除酒店数据

@Test
void testDeleteDocumentById() throws IOException {
    // 1.准备Request      // DELETE /hotel/_doc/{id}
    DeleteRequest request = new DeleteRequest("hotel", "61083");
    // 2.发送请求
    client.delete(request, RequestOptions.DEFAULT);
}

利用JavaRestClient 修改酒店数据

案例2：利用JavaRestClient批量导入酒店数据到ES

需求：批量查询酒店数据，然后批量导入索引库中
思路：

利用mybatis-plus查询酒店数据
将查询到的酒店数据(Hotel) 转换为文档类型数据(HotelDoc)
利用JavaRestClient中的Bulk批处理，实现批量新增文档，示例代码如下

@Test
void testBulkRequest() throws IOException {
    // 查询所有的酒店数据
    List<Hotel> list = hotelService.list();

    // 1.准备Request
    BulkRequest request = new BulkRequest();
    // 2.准备参数
    for (Hotel hotel : list) {
        // 2.1.转为HotelDoc
        HotelDoc hotelDoc = new HotelDoc(hotel);
        // 2.2.转json
        String json = JSON.toJSONString(hotelDoc);
        // 2.3.添加请求
        request.add(new IndexRequest("hotel").id(hotel.getId().toString()).source(json, XContentType.JSON));
    }
 
    // 3.发送请求
    client.bulk(request, RequestOptions.DEFAULT);
}

三、DSL查询

查询语法

GET /hotel/_search
{
  "query": {
      "match_all": {}  
  },
   "from": 10, #默认0
   "size": 20, #默认10
   "sort": {
      "price": "asc"  
   },
   "highlight": {
      "fields": {
         "name": {
           "require_field_match": "false",
           "pre_tags": "<en>",
           "post_tags": "</en>"
        }
      }
   },
   "aggs": {
      "brandAgg":{
          "terms": {
            "field": "brand",
            "order": {
              "_count": "asc"
            }, 
            "size": 20
          }
      }
  }
}

DSL Query的分类

查询基本语法如下：
在这里插入图片描述

Elasticsearch提供了基于JSON的DSL (Domain Specific Language)来定义查询。常见的查询类型包括：

查询所有：查询出所有数据，一般测试用。例如： match_all
全文检索(full text)查询：利用分词器对用户输入内容分词，然后去倒排索引库中匹配。例如：
- match_query
- multi_match_query
精确查询：根据精确词条值查找数据，一般是查找 keyword、数值、日期、boolean等类型字段。例如：
- ids
- range
- term
地理(geo)查询：根据经纬度查询。例如：
- geo_distance
- geo_bounding_box
复合(compound)查询：复合查询可以将上述各种查询条件组合起来，合并查询条件。例如：
- bool
- function_score

查询所有 match_all

查询所有不用写条件
查询出的结果不会列出所有数据，默认只显示前10条

全文检索查询 match/multi_match

在这里插入图片描述

match和multi_match的区别是什么?

match：根据一个字段查询
multi_match：根据多个字段查询，参与查询字段越多，查询性能越差

精确查询： term/range

精确查询不会对搜索条件分词
精确查询常见的有哪些?

term查询：根据词条精确匹配，一般搜索keyword类型、数值类型、布尔类型、日期类型字段
range查询：根据数值范围查询，可以是数值、日期的范围。可以写gt（大于、gte（大于等于、lt（小于、lte（小于等于

示例：查询品牌是【如家】和价格区间在【2000-3000】内的酒店