【ElasticSearch系列-02】ElasticSearch的概念和基本操作

迷南。 2024-02-20 10:46 49阅读 0赞

ElasticSearch系列整体栏目

--------------------

<table> 
 <thead> 
  <tr> 
   <th align="left">内容</th> 
   <th>链接地址</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left"><font>【一】ElasticSearch下载和安装</font></td> 
   <td><a href="https://zhenghuisheng.blog.csdn.net/article/details/129260827" rel="nofollow">https://zhenghuisheng.blog.csdn.net/article/details/129260827</a></td> 
  </tr> 
  <tr> 
   <td align="left"><font>【二】ElasticSearch概念和基本操作</font></td> 
   <td><a href="https://blog.csdn.net/zhenghuishengq/article/details/134121631" rel="nofollow">https://blog.csdn.net/zhenghuishengq/article/details/134121631</a></td> 
  </tr> 
 </tbody> 
</table>

--------------------

#### 深入理解ElasticSearch概念和基本操作 ####

*   *  1，ES的基本概念
     *  2，ES的基本操作
     *   *  2.1，索引的创建和删除
         *  2.2，文档的增删改查
     *  3，mapping
     *   *  3.1，静态映射和动态映射
         *  3.2，reindex重建索引
         *  3.3，常用mapping参数设置

### 1，ES的基本概念 ###

在上一篇中，讲解了ElasticSearch的搭建以及Kibana的搭建，接下来就可以去了解其内部原理了，从es的官网上可以看到，ElasticSearch主要的一些应用，如做系统日志，大数据分析，搜索引擎，性能监控等等

![在这里插入图片描述][d440970e42434ef188ac455d721ead53.png]

ElasticSearch同时也支持RestFulf风格，这样就可以通过HTTP来操作ES中的数据，可以达到实时搜索，稳定，可靠等强大性能，同时也支持多种客户端语言，其生态圈也相当友好，版本还在一直迭代更新。

在关系型数据库中，如mysql，内部有库、表、行列等，在ElasticSearch中，也存在着和其一样概念的类型数据，如下图，Index对应的就是数据库，Type类型对应的就是表，Document文档对应的就是行，Field字段对应的就是列。在7.0开始后，一个索引库中只能存在一种类型。

![在这里插入图片描述][f47c05906e794c94ba4fad2fd16725a1.png]

### 2，ES的基本操作 ###

#### 2.1，索引的创建和删除 ####

索引的创建方式如下，需要注意的是，索引的名称必须全部小写，否则会报错

PUT /zhs_db

接下来查看索引的信息，直接通过GET命令即可

GET /zhs_db

在使用GET命令后，在控制台会出现以下数据，一些别名，创建时间，索引的分片数，副本数据等

{
        
      "zhs_db" : {
        
        "aliases" : {
         },
        "mappings" : {
         },							//映射关系，每个字段的数据和类型
        "settings" : {
        
          "index" : {
        
            "creation_date" : "1695018423771",		//创建索引的时间
            "number_of_shards" : "1",				//分片数
            "number_of_replicas" : "1",				//副本数
            "uuid" : "eHD7DY1eR7Ki4zm1QKXzrg",		//uuid
            "version" : {
        							//版本号
              "created" : "7070099"
            },
            "provided_name" : "es_db"
          }
        }
      }
    }

删除索引库的方式如下，可以直接通过DELETE的方式直接删除

DELETE /zhs_db

#### 2.2，文档的增删改查 ####

在ES中，文档就是相当于mysql表中的一条数据，只不过ES是通过序列化后的JSON的方式保存，JSON数据中支持层层嵌套，接下来举一个例子来说明文档的含义

首先**创建**一个索引库，并设置分词器为IK分词器，粒度设置为细粒度。

PUT /zhs_db
    {
        
        "settings" : {
        
            "index" : {
        
                "analysis.analyzer.default.type": "ik_max_word"
            }
        }
    }

由于本人使用的是7.7.0的版本，因此type类型可以不需处理。随后往文档中**插入**几条数据，其数据如下

PUT /zhs_db/_doc/1
    {
        
    "name": "zhenghuisheng",
    "sex": 1,
    "age": 18,
    "dept": "团长",
    "remark": "tz"
    }
    
    PUT /zhs_db/_doc/2
    {
        
    "name": "xiaozheng",
    "sex": 1,
    "age": 19,
    "dept": "连长",
    "remark": "lz"
    }
    
    PUT /zhs_db/_doc/3
    {
        
    "name": "郑跟班",
    "sex": 0,
    "age": 20,
    "dept": "班长",
    "remark": "bz"
    }

添加文档除了使用这个PUT请求之外，还可以使用POST请求。PUT请求需要手动的指定一个id才能操作，而POST请求如果在没指定id的情况下，ES内部会自动的生成一个id，如果指定了，就用指定的id。如下图，ES内部自动的生成了一个id

![在这里插入图片描述][678a59484c8e4dad82bb451cb9c78049.png]

并且无论是PUT请求还是POST请求，在重复进行数据的插入时，会出现数据覆盖的情况，类似于**先删除后覆盖。**

也存在直接创建完，不需要进行更新和删除操作的，就是需要用到create的语法，如果已经存在这个id对应的文档，那么就会直接抛异常

PUT /zhs_db/_created/1

在通过id获取某条文档数据的时候比较简单，只需要索引库 + \_doc + 文档对应的id即可

GET /zhs_db/_doc/1

在获取这个zhs\_db索引库的时候，其结果如下。每个字段中可以包含数值、字符串、布尔类型、日期、二进制等

![在这里插入图片描述][ec68b2fefe4044289e6147e46a0f18a4.png]

在重复执行查询文档数据时，该条文档的version版本号和seq序列号会跟着改变，并且result的 状态会从创建的 **created** 状态变成 **updated** 状态。

"_version" : 23, 	//	版本号
    "_seq_no" : 22,		//	序列号

或者直接通过 **\_search** 的方式将数据查出，这里面也可以写一些SDL语法进行匹配模式

GET /zhs_db/_search

更新可以直接使用POST的方式进行更新操作，只需要通过 **\_update** 就可以实现更新操作。

POST /zhs_db/_update/1

也可以只更新某个文档中的部分数据，如只更新文档中的某一个字段

POST /zhs_db/_update/1
    {
        
        "name":"王五"
    }

除了这两种方式是属于更新操作之外，上面的重复插入操作也会有更新的效果，如修改序列号等等。

通过id删除文档也比较简单，只需要通过DELETE关键字即可

DELETE /zhs_db/_doc/2

在7.x版本之前，为了保证多线程场景下的线程安全，采用通过version版本号来实现乐观锁，但是在7.x开始，是通过\*\*\_seq\_no\*\* 和 **\_primary\_term** 字段来保证乐观锁的

POST /zhs_db/_update/3?if_seq_no=21&if_primary_term=6
    {
        
      "name": "赵六"
    }

### 3，mapping ###

#### 3.1，静态映射和动态映射 ####

动态映射指的是Es在插入数据时，不需要手动的指定插入字段的数据类型，**es内部会自动的根据对应的数据类型转成相应的数据类型，内部有自动识别机制**

PUT /zhs_db/_doc/1
    {
        
      "age":10,
      "name":"zhenghuisheng"
    }
    GET /zhs_db

其结果如下，可以看到在mapping中的属性age和name给了对应的属性。text类型则表示是可以全文检索的数据类型

![在这里插入图片描述][a7b8ccda68ef486dbe80abbd1569b1fe.png]

静态映射指的是在创建索引时，同时将文档中字段的数据类型也设置好

DELETE /zhs_db
    PUT /zhs_db
    {
        
    	"mappings": {
        
    		"properties": {
        
    			"age": {
        
    				"type": "long"
    			},
    			"name": {
        
    				"type": "text",
    				"analyzer": "ik_smart"
    			}
    		}
    	}
    }

在es的动态映射中，其对应的数据类型如下，有这些对应的字符串类型，布尔类型，浮点型，整型，对象，数组等![img][]

在mapping建立好之后，可能会遇到新增或者删除字段的情况，因此可以直接通过这个dynamic这个属性控制

*  当该属性为true时，一旦有新的文档写入，mapping也会自动更新
 *  当该属性为false时，mapping不会被更新，新增的字段内容无法被索引查询
 *  当该属性为strict时，文档直接写入失败，并且同时抛出异常

PUT /zhs_db/_mapping
    {
        
      "dynamic":true
    }

#### 3.2，reindex重建索引 ####

如果是索引的文档中已经有了数据，那么就不支持修改操作，只能重新的建立索引，然后将原索引的数据迁移到新的索引中。那么就需要通过这个 \_reindex 这个命令，source设置为需要修改的索引，dest设置为新建的索引

POST _reindex
    {
        
    	"source": {
        		//原索引
    		"index": "zhs_db"	
    	},
    	"dest": {
        
    		"index": "zhs_db2"
    	}
    }

并且为了解决接口调用的问题，因为此时索引已经从zhs\_db变成了zhs\_db2，所以可以通过修改别名的方式，减少上层代码的变动，需要先将原索引删除，随后将新索引的别名设置成原索引的名称

DELETE /zhs_db	
    PUT /zhs_db2/_alias/zhs_db

在查这个新的索引 **zhs\_db2** 时，只需要查询原来的 zhs\_db，就能将原数据全部查询出

GET /zhs_db

#### 3.3，常用mapping参数设置 ####

如果不想被索引，可以直接在对应的字段加上index这个属性，并且设置value为false

{
        
      "mappings" : {
        
          "properties" : {
        
           	"name":{
        
         		"type": "text",
      			"index": false
     		}
          }
        }
    }

如果需要在有索引的字段中将为null的值查询出，那么可以设置一个 **null\_value**的属性，并将值设置成null

{
        
      "mappings" : {
        
          "properties" : {
        
             "name":{
        
         		"type": "text",
         		"null_value": "NULL"
     		 }
          }
        }
    }

如果是需要字段合并的场景，如省市区等的合并等，那就需要借助于这个 **copy\_to** 这个属性，可以将这个值全部添加到这个full\_address这个属性中，后续可以直接通过查询这个 **full\_address** 这个属性将需要匹配的值查询出

{
        
      "mappings" : {
        
          "properties" : {
        
            "province" : {
        
              "type" : "keyword",
              "copy_to": "full_address"
            },
            "city" : {
        
              "type" : "text",
              "copy_to": "full_address"
            }
          }
        }
    }

[d440970e42434ef188ac455d721ead53.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/b8d43431a1bc4049a1035fb60c8c58c3.png
[f47c05906e794c94ba4fad2fd16725a1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/50da141d3aeb4a93a7ee50a4b63676eb.png
[678a59484c8e4dad82bb451cb9c78049.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/a87c2915defe4082a74826846a4c2ea9.png
[ec68b2fefe4044289e6147e46a0f18a4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/d22319adbd974a68ae0c2a63d12392c8.png
[a7b8ccda68ef486dbe80abbd1569b1fe.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/aafc11c941ea46e18d3561016a90039f.png
[img]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/10b6708fd99849bb9a92ff62c0e72181.png