Elasticsearch原生restful接口使用

系统管理员 2022-11-08 14:15 150阅读 0赞

**目录**

创建索引index和映射mapping

为一个新创建的索引设置Mapping

删除索引

新增数据(document)

根据id删除document

根据id修改document

查询Document

1.根据id查询document

2.term查询

3.querystring查询document

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

Elasticsearch提供了PUT，POST，GET4，DELETE几种方式的RestFul接口，可以通过HTTP接口进行索引创建，数据添加，修改，删除，查询等操作。

> **启动Elasticsearch服务，HTTP端口为9200，下面进行接口调用操作。**

## **创建索引****index****和映射****mapping** ##

**URL格式：/\{索引名称\}**

> **创建一个名称为blog的索引并设置mapping信息（指定type为article并指定字段信息）**
> 
> 请求方式**：PUT**   
> 
> URL：**[http://192.168.253.131:9200/blog][http_192.168.253.131_9200_blog]**

**请求体body参数： ** （**如果不加参数，那创建的索引的mapping为空**）

{
        "mappings": {
            "article": {
                "properties": {
                    "id": {
                        "type": "long",
                        "store": true
                    },
                    "title": {
                        "type": "text",
                        "store": true
                    },
                    "content": {
                        "type": "text",
                        "store": true
                    }
                }
            }
        }
    }

## **为一个新创建的索引设置****Mapping**  ##

**URL格式： \{索引名称\}/\{type名称\}/\_mapping,参数为type和properties字段信息。**

> **为名称为initblog的索引设置type为hello的mapping信息。**
> 
> **请求方式：PUT**
> 
> **URL：**[http://192.168.253.131:9200/initblog/hello/\_mapping][http_192.168.253.131_9200_initblog_hello_mapping]

**请求体body参数： **

{
        "hello": {
            "properties": {
                "id": {
                    "type": "long",
                    "store": true
                },
                "title": {
                    "type": "text",
                    "store": true
                },
                "content": {
                    "type": "text",
                    "store": true
                }
            }
        }
    }

## **删除索引** ##

**URL格式：  / \{索引名称\}**

> **删除名称为blog的索引**
> 
> 请求方式：DELETE
> 
> URL：[http://192.168.253.131:9200/blog][http_192.168.253.131_9200_blog 1]

## 新增数据(document) ##

**URL格式**： / \{索引名称\} / \{type名称\} / \{id\}

**注意新增接口的 id 指的是在新增的document在当前索引当前类型下的一个id标识，与document内容中的id不是同一回事，****如果URL中不设置id，ES会随机生成一个id作为标识**

> **在 blog索引的 article类型下 创建 id为1 的document**
> 
> **请求方式：POST**
> 
> **URL：**[http://192.168.253.131:9201/blog/article/1][http_192.168.253.131_9201_blog_article_1]

**请求体body参数： **

{
        "id": 1,
        "title": "【新增】redis是一个分布式缓存中间件",
        "content": "redis是一个分布式缓存中间件,是基于内存进行存储的，性能非常好"
    }

**一般为了方便根据id查询document，新增document的id值可以设置与document内容中的id一样**

![20210313204146711.png][]

## 根据id删除document ##

URL格式：  / \{索引名称\} / \{type名称\} / \{id\}

> **删除[blog][]索引下的[article][blog]类型的 id为[1][blog]的document**
> 
> **请求方式： DELETE**
> 
> **URL：    [http://192.168.253.131:9200/blog/article/1][blog]**

## 根据id修改document ##

**ES中的修改本质上是删除旧的document，新增一个修改后的document。****因此修改接口与新增document一致，保证修改传参中的doc的id和被修改的doc的id一直就可以。**

**URL格式**： / \{索引名称\} / \{type名称\} / \{id\}

> 修改[blog][http_192.168.253.131_9201_blog_article_1]索引下的[article][http_192.168.253.131_9201_blog_article_1]类型下的 id为[1][http_192.168.253.131_9201_blog_article_1] 的document
> 
> 请求方式：POST
> 
> URL：    [http://192.168.253.131:9201/blog/article/1][http_192.168.253.131_9201_blog_article_1]

**请求体body参数： （title字段更改，其他字段不更改）**

{
        "id": 1,
        "title": "【修改】redis是一个分布式缓存中间件",
        "content": "redis是一个分布式缓存中间件,是基于内存进行存储的，性能非常好"
    }

## 查询Document ##

### 1.根据id查询document ###

URL格式： / \{索引名称\} / \{type名称\} / \{id\}

> **查询[blog][blog 1]索引下的 [article][blog 1]类型下的  id为1的document**
> 
> **请求方式：GET**
> 
> **URL：  [http://192.168.253.131:9201/blog/article/][blog 1]1**

**返回结果**：

{
        "_index": "blog",
        "_type": "article",
        "_id": "1",
        "_version": 1,
        "found": true,
        "_source": {
            "id": 1,
            "title": "id为【1】的记录标题",
            "content": "id为【1】的记录的内容"
        }
    }

### 2.**term****查询** ###

**term查询是以 输入的参数值作为一个关键词 并 按照参数中指定的document的某个字段做查询。**

> **以 ''是'' 做关键词匹配 title 字段，查询[blog][blog 2]索引下的[article][blog 2]类型下的符合条件的document**
> 
> **请求方式： POST**
> 
> **URL：   [http://192.168.253.131:9201/blog/article/\_search][blog 2]**

### 3.**querystring****查询document** ###

**querystring查询是带分词的查询，也就是先把输入的参数做分词，然后按拆分后的词去查询。**

URL格式： / \{索引名称\} / \{类型\} / **\_search**

> 以"搜索服务器" **做分词（可能分为搜索，服务器两个关键词）** 后分别做为查询条件 去匹配 title字段，查询[blog][blog 2]索引下的[article][blog 2]类型下符合条件的document。
> 
> 请求方式：POST
> 
> URL： [http://192.168.253.131:9201/blog/article/\_search][blog 2]

**请求参数：**

{
        "query": {
            "query_string": {
                "default_field": "title",
                "query": "搜索服务器"
            }
        }
    }

[http_192.168.253.131_9200_blog]: http://192.168.253.131:9200/blog
[http_192.168.253.131_9200_initblog_hello_mapping]: http://192.168.253.131:9200/initblog/hello/_mapping
[http_192.168.253.131_9200_blog 1]: http://192.168.253.131:9200/blog111
[http_192.168.253.131_9201_blog_article_1]: http://192.168.253.131:9201/blog/article/1
[20210313204146711.png]: /images/20221023/4db7ee3ec9ad4da8850ebbc1aa104668.png
[blog]: http://192.168.253.131:9200/blog/article/1
[blog 1]: http://192.168.253.131:9201/blog/article/6
[blog 2]: http://192.168.253.131:9201/blog/article/_search