ElasticSearch常用搜索命令整理（长期更新...）

末蓝、 2022-05-31 09:19 188阅读 0赞

*  基础入门版
    
     *  快速检查集群的健康状况
     *  快速查看集群中有哪些索引
     *  索引的CRUD操作以商品为例
        
         *  新增商品建立索引
         *  查询商品参见查询专题详解
         *  修改商品name
         *  删除商品
 *  查询专题版
    
     *  query string search不常用
     *  query DSLDomain Specified Language特定领域的语言
     *  query filter
     *  full-text search全文检索
     *  phrase search短语搜索
     *  highlight search高亮搜索结果
 *  批量操作
    
     *  批量查询mget
     *  批量操作bulk

# 基础入门版 #

## 快速检查集群的健康状况 ##

GET /_cat/health?v

*说明：如何快速了解集群的健康状况？green、yellow、red？*  
*green：每个索引的primary shard和replica shard都是active状态的*  
*yellow：每个索引的primary shard都是active状态的，但是部分replica shard不是active状态，处于不可用的状态*  
*red：不是所有索引的primary shard都是active状态的，部分索引有数据丢失了*

## 快速查看集群中有哪些索引 ##

GET /_cat/indices?v

## 索引的CRUD操作，以商品为例 ##

### 新增商品（建立索引） ###

（1）手动指定document id（用于其他库倒进来时本身就含有id的情况）

PUT /ecommerce/product/1
    {
        "name" : "gaolujie yagao",
        "desc" : "gaoxiao meibai",
        "price" : 30,
        "producer" : "gaolujie producer",
        "tags": [ "meibai", "fangzhu" ]
    }

*说明：若已经有/ecommerce/product/1该数据，此时“新增”操作变成“全量替换”，旧数据被deleted。因此如果我们要需要创建，而不允许替换数据（逻辑：若已经有该条数据，则不进行任何操作（报错回滚））*

（2）自动生成document id（自动生成的id，长度为20个字符，URL安全，base64编码，GUID，分布式系统并行生成时不可能会发生冲突）

POST /ecommerce/product
    {
        "name" : "gaolujie yagao",
        "desc" : "gaoxiao meibai",
        "price" : 30,
        "producer" : "gaolujie producer",
        "tags": [ "meibai", "fangzhu" ]
    }

### 查询商品（参见查询专题详解） ###

GET /ecommerce/product/1

### 修改商品name ###

全量替换：

PUT /ecommerce/product/1
    {
        "name" : "jiaqiangban gaolujie yagao",
        "desc" : "gaoxiao meibai",
        "price" : 30,
        "producer" : "gaolujie producer",
        "tags": [ "meibai", "fangzhu" ]
    }

部分修改：

POST /ecommerce/product/1/_update
    {
      "doc": {
        "name": "jiaqiangban gaolujie yagao"
      }
    }

### 删除商品 ###

DELETE /ecommerce/product/1

*说明：不会理解物理删除，只会将其标记为deleted，当数据越来越多的时候，在后台自动删除*

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

# 查询专题版 #

## query string search（不常用） ##

1、搜索全部商品：

GET /ecommerce/product/_search

*查询结果部分字段说明：*  
*took：耗费了几毫秒。*  
*timed\_out：是否超时，这里是没有。*  
*\_shards：数据拆成了5个分片，所以对于搜索请求，会打到所有的primary shard（或者是它的某个replica shard也可以）。*  
*hits.total：查询结果的数量，3个document。*  
*hits.max\_score：score的含义，就是document对于一个search的相关度的匹配分数，越相关，就越匹配，分数也高。*  
*hits.hits：包含了匹配搜索的document的详细数据。*

2、搜索商品名称中包含yagao的商品，而且按照售价降序排序

GET /ecommerce/product/_search?q=name:yagao&sort=price:desc

3、指定要查询出来商品的名称和价格

GET /ecommerce/product/_search?_source=name,price

## query DSL（Domain Specified Language，特定领域的语言） ##

1、查询所有的商品（match\_all）

GET /ecommerce/product/_search
    {
      "query": { "match_all": {} }
    }

2、查询名称包含yagao的商品，同时按照价格降序排序（sort）

GET /ecommerce/product/_search
    {
        "query" : {
            "match" : {
                "name" : "yagao"
            }
        },
        "sort": [
            { "price": "desc" }
        ]
    }

3、分页查询商品（from，size）  
例如：总共3条商品，假设每页就显示1条商品，现在显示第2页，所以就查出来第2个商品

GET /ecommerce/product/_search
    {
      "query": { "match_all": {} },
      "from": 1,
      "size": 1
    }

4、指定要查询出来商品的名称和价格（source）

GET /ecommerce/product/_search
    {
      "query": { "match_all": {} },
      "_source": ["name", "price"]
    }

5、查询name和desc都含yagao的商品（multi\_match）

GET /ecommerce/product/_search
    {
      "query": {
        "multi_match": {
          "query": "yagao",
          "fields": ["name", "desc"]
        }
      }
    }

6、查询价格大于等于30的商品（range）

GET /ecommerce/product/_search 
    {
      "query": {
        "range": {
          "price": {
            "gte": 30
          }
        }
      }
    }

7、查询name是yagao的商品（term 或者 terms数组指定多个）

GET /test_index/test_type/_search 
    {
      "query": {
        "term": {
          "name ": "yagao"
        }
      }
    }

*说明：不常用。若想用term查询，则被查询的字段需要定义为不分词。*

## query filter ##

1、搜索商品名称包含yagao，而且售价大于25元的商品

GET /ecommerce/product/_search
    {
        "query" : {
            "bool" : {
                "must" : {
                    "match" : {
                        "name" : "yagao" 
                    }
                },
                "filter" : {
                    "range" : {
                        "price" : { "gt" : 25 } 
                    }
                }
            }
        }
    }

*说明：bool 多条件查询，含以下参数：*  
*must：返回的doc必须满足must子句的条件，并且参与计算score*  
*must\_not：返回的文档必须不满足must\_not定义的条件*  
*should：返回的文档可能满足should子句的条件。在一个Bool查询中，如果没有must或者filter，有一个或者多个should子句，那么只要满足一个就可以返回。minimum\_should\_match参数定义了至少满足几个子句。*  
*filter：返回的doc必须满足filter子句的条件，不参与计算sorce*

## full-text search（全文检索） ##

GET /ecommerce/product/_search
    {
        "query" : {
            "match" : {
                "producer" : "yagao producer"
            }
        }
    }

## phrase search（短语搜索） ##

跟全文检索相对应，相反，全文检索会将输入的搜索串拆解开来，去倒排索引里面去一一匹配，只要能匹配上任意一个拆解后的单词，就可以作为结果返回。

phrase search，要求输入的搜索串，必须在指定的字段文本中，完全包含一模一样的，才可以算匹配，才能作为结果返回。

GET /ecommerce/product/_search
    {
        "query" : {
            "match_phrase" : {
                "producer" : "yagao producer"
            }
        }
    }

## highlight search（高亮搜索结果） ##

GET /ecommerce/product/_search
    {
        "query" : {
            "match" : {
                "producer" : "producer"
            }
        },
        "highlight": {
            "fields" : {
                "producer" : {}
            }
        }
    }

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

# 批量操作 #

## 批量查询mget ##

获取商品id为1和2的商品信息（假设在同一个index和type下）

GET /_mget
    {
       "docs" : [
          {
             "_index" : "ecommerce",
             "_type" : "product",
             "_id" : 1
          },
          {
             "_index" : "ecommerce",
             "_type" : "product",
             "_id" : 2
          }
       ]
    }
    
    或者
    
    GET /ecommerce/_mget
    {
       "docs" : [
          {
             "_type" : "product",
             "_id" : 1
          },
          {
             "_type" : "product",
             "_id" : 2
          }
       ]
    }
    
    或者
    
    GET /ecommerce/product/_mget
    {
       "ids": [1, 2]
    }

## 批量操作bulk ##

需求：  
1、删除id为1的商品  
2、创建id为3的商品（name为“zhonghua yagao”）  
3、修改商品2的name为“replaced zhonghua yagao”（采用全量替换的方式）  
4、修改商品3的name为“bulk zhonghua yagao”（采用部分更新的方式）

POST /_bulk
    { "delete": { "_index": "ecommerce", "_type": "product", "_id": "1" }} { "create": { "_index": "ecommerce", "_type": "product", "_id": "3" }} { "name": "zhonghua yagao" } { "index": { "_index": "ecommerce", "_type": "product", "_id": "2" }} { "name": "replaced zhonghua yagao" } { "update": { "_index": "ecommerce", "_type": "product", "_id": "3", "_retry_on_conflict" : 3} } { "doc" : {"name" : "bulk zhonghua yagao"} }

*说明：*  
*（1）delete：删除一个文档，只要1个json串就可以了*  
*（2）create：PUT /index/type/id/\_create，强制创建*  
*（3）index：普通的put操作，可以是创建文档，也可以是全量替换文档*  
*（4）update：执行的partial update操作*

*bulk api对json的语法，有严格的要求，每个json串不能换行，只能放一行，同时一个json串和一个json串之间，必须有一个换行*

参考：[ElasticSearch教程（龙果学院）][ElasticSearch]

[ElasticSearch]: http://www.roncoo.com/course/list.html?courseName=Elasticsearch