ElasticSearch 交互方式

1.基于 HTTP 协议，以 JSON 为数据交互格式的 RESTful API: GET POST PUT DELETE HEAD

2.Elasticsearch 官方提供了多种程序语言的客户端— java，Javascript，.NET，PHP，Perl，Python，以及 Ruby——还有很多由社区提供的客户端和插件

在测试阶段使用 Kibana 操作 ElasticSearch 是最方便的. 下面学习如何安装和使用 Kibana.

操作 ElasticSearch 中数据的常见场景

查看 ES 中有哪些索引:

GET /_cat/indices?v

health	green(集群完整) yellow(单点正常、集群不完整) red(单点不正常)
status	是否能使用
index	索引名
uuid	索引统一编号
pri	主节点几个
rep	从节点几个
docs.count	文档数
docs.deleted	文档被删了多少
store.size	整体占空间大小
pri.store.size	主节点占

增加索引:

PUT /movie_index

删除索引:

DELETE /movie_index

新增文档:

PUT /movie_index/_doc/1
{ "id":1,
  "name":"operation red sea",
  "doubanScore":8.5,
  "actorList":[  
    {"id":1,"name":"zhang yi"},
    {"id":2,"name":"hai qing"},
    {"id":3,"name":"zhang han yu"}
  ]
}
PUT /movie_index/_doc/2
{
  "id":2,
  "name":"operation meigong river",
  "doubanScore":8.0,
  "actorList":[  
    {"id":3,"name":"zhang han yu"}
  ]
}
 
PUT /movie_index/_doc/3
{
  "id":3,
  "name":"incident red sea",
  "doubanScore":5.0,
  "actorList":[  
    {"id":4,"name":"zhang chen"}
  ]
}

注意: 如果之前没建过 index 或者 type，es 会自动创建。

搜索 type 全部数据:

GET /movie_index/_search

查找指定 id 的 document 数据:

GET /movie_index/1

修改 document:

修改分两种: 整体替换和只修改某个字段

整体替换

和新增文档没有区别

PUT /movie_index/3
{
  "id":"3",
  "name":"incident red sea",
  "doubanScore":"8.0",
  "actorList":[  
    {"id":"1","name":"zhang chen"}
  ]
}

只修改某个字段:

使用post方法

POST /movie_index/3/_update
{
  "doc": {
    "doubanScore":"8.1"
  }
}

删除一个 document:

DELETE /movie_index/3

按条件查询(全部):

GET /movie_index/_search

{
  "query": {
    "match_all": {}
  }
}

按照字段的分词查询:

GET /movie_index/_search
{
  "query": {
    "match": {
      "name": "sea"
    }
  }
}

按照分词子属性查询:

GET /movie_index/_search
{
  "query": {
    "match": {
      "actorList.name": "zhang"
    }
  }
}

按照短语查询:

安装短语查询的意思是指, 匹配某个 field 的整个内容, 不再利用分词技术

GET /movie_index/_search
{
  "query": {
    "match_phrase": {
      "name": "operation red"
    }
  }
}

说明: 把operation red作为一个整体来看待

对比:

下面的表示包含 operation 或者 red 的都会被查找出来

GET /movie_index/_search
{
  "query": {
    "match": {
      "name": "operation red"
    }
  }
}

模糊查询:

校正匹配分词，当一个单词都无法准确匹配，es 通过一种算法对非常接近的单词也给与一定的评分，能够查询出来，但是消耗更多的性能。

GET /movie_index/_search
{
  "query": {
    "fuzzy": {
      "name": "red"
    }
  }
}

过滤(查询后过滤):

GET /movie_index/_search
{
  "query": {
    "match": {
      "name": "red"
    }
  },
  "post_filter": {
    "term": {
      "actorList.id": "3"
    }
  }
}

查询前过滤(推荐使用):

GET movie_index/_search
{
  "query": {
    "bool": {
      "filter": [
        {"term": 
          {"actorList.id": 3}
        },
        {
          "term":
            {"actorList.id": 1}
        }
      ],
      "must": 
        {"match": {
          "name": "zhang"
        }}
      
    }
  }
}

按范围过滤：

GET movie_index/_search
{
  "query": {
    "bool": {
      "filter": {
        "range": {
          "doubanScore": {
         "gt": 5,
            "lt": 9
          }
        }
      }
    }
  }
}

排序：

GET movie_index/_search
{
  "query":{
    "match": {"name":"red operation"}
  }
  , "sort": [
    {
      "doubanScore": {
        "order": "desc"
      }
    }
  ]
}

分页查询：

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

指定查询的字段：

GET movie_index/_search
{
  "query": { "match_all": {} },
  "_source": ["name", "doubanScore"]
}

聚合：

 
{
  “id”:”1”,
  “name”:”operation red sea”,
  “doubanScore”:”8.5”,
  “actorList”:[  
    {“id”:”1”,”name”:”zhangyi”},
    {“id”:”2”,”name”:”haiqing”},
    {“id”:”3”,”name”:”zhanghanyu”}
  ]
}

每个演员参演了多少部电影：

GET movie_index/_search
{
  "aggs": {
    "groupby_actor": {
      "terms": {
        "field": "actorList.name.keyword"
      }
    }
  }
}

每个演员参演电影的平均分是多少，并按评分排序：

GET movie_index/_search
{ 
  "aggs": {
    "groupby_actor_id": {
      "terms": {
        "field": "actorList.name.keyword" ,
        "order": {
          "avg_score": "desc"
          }
      },
      "aggs": {
        "avg_score":{
          "avg": {
            "field": "doubanScore" 
          }
        }
       }
    } 
  }
}