elasticsearch学习笔记之二（CURD）

ゝ一世哀愁。 2022-04-23 11:38 282阅读 0赞

> 本文介绍elasticsearch的概念和CURD

### 文章目录 ###

*   *   *  1. 基本概念
         *  2. 增删改查
         *   *  2.1 数据库操作（indexes）
             *   *  2.1.1 创建数据库
                 *  2.1.2 删除数据库
             *  2.2 创建文档（表和记录）
             *  2.3 更新文档
             *  2.4 删除文档
             *  2.5 查询文档
             *  2.6 删除类型(表)

### 1. 基本概念 ###

[http://localhost:9200/\{\_index\}/\{\_type\}/\{\_id\}][http_localhost_9200_index_type_id]

例如：  
[http://localhost:9200/blog/user/1][http_localhost_9200_blog_user_1]

<table> 
 <thead> 
  <tr> 
   <th>关系型数据库</th> 
   <th>elasticsearch</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>数据库 blog</td> 
   <td>_index</td> 
  </tr> 
  <tr> 
   <td>表 user</td> 
   <td>_type</td> 
  </tr> 
  <tr> 
   <td>行(id为1)</td> 
   <td>Document</td> 
  </tr> 
  <tr> 
   <td>列(比如name)</td> 
   <td>fields</td> 
  </tr> 
 </tbody> 
</table>

### 2. 增删改查 ###

> elasticsearch 是遵循restful风格提供API接口的，所以对应的增删改查方式对应如下

<table> 
 <thead> 
  <tr> 
   <th>请求方法</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>POST</td> 
   <td>创建 /db</td> 
  </tr> 
  <tr> 
   <td>GET</td> 
   <td>查询 /db/table/id</td> 
  </tr> 
  <tr> 
   <td>PUT</td> 
   <td>更新或创建 /db/table/id</td> 
  </tr> 
  <tr> 
   <td>DELETE</td> 
   <td>删除 /db/table/id</td> 
  </tr> 
 </tbody> 
</table>

#### 2.1 数据库操作（indexes） ####

##### 2.1.1 创建数据库 #####

curl -X PUT 'localhost:9200/blog'

返回结果：

{ 
    "acknowledged": true,
    "shards_acknowledged": true,
    "index": "blog"
    }

##### 2.1.2 删除数据库 #####

curl -X DELETE 'localhost:9200/blog'

返回结果:

{ 
    "acknowledged": true
    }

> 注意删除后的indexes 不是真的删除了，而是内部改变了状态后查询不到了，所以不能重新使用 `POST` 方法进行创建，需要使用 `PUT` 方法。  
> `POST` 会出现 405, `GET` 会出现 404

#### 2.2 创建文档（表和记录） ####

> elasticsearch 是以json文档形式存储数据的，使用\_type 来区分文档归属，即所属表，所以创建文档的时候  
> 添加分类\_type 可以直接创建表同时加入记录

curl -X POST 'localhost:9200/blog/user -d '
    {
    	"id": 1,
    	"name": "zhangsan",
    	"score": 78.5,
    	"age": 25,
    	"gender": "F"
    }'

在未指定`_id`的情况下，使用POST方法来创建一条记录，如果使用`PUT` 会出现 405

创建成功，返回结果：

{ 
    "_index": "blog",
    "_type": "user",
    "_id": "chGm_mgB1Lja9i2Q0fSA",
    "_version": 1,
    "result": "created",
    "_shards": { 
    	"total": 2,
    	"successful": 1,
    	"failed": 0
    },
    "_seq_no": 0,
    "_primary_term": 1
    }

#### 2.3 更新文档 ####

curl -X PUT 'localhost:9200/blog/user/chGm_mgB1Lja9i2Q0fSA -d '
    {
    	"id": 1,
    	"name": "zhangsan",
    	"score": 80.5,
    	"age": 26,
    	"gender": "F"
    }'

打印结果：

{ 
    "_index": "blog",
    "_type": "user",
    "_id": "chGm_mgB1Lja9i2Q0fSA",
    "_version": 2,
    "result": "updated",
    "_shards": { 
    	"total": 2,
    	"successful": 1,
    	"failed": 0
    },
    "_seq_no": 1,
    "_primary_term": 1
    }

> 可以看到更新一次，版本号`_version`会自动加 1

#### 2.4 删除文档 ####

curl -X DELETE 'localhost:9200/blog/user/chGm_mgB1Lja9i2Q0fSA'

打印结果：

{ 
    "_index": "blog",
    "_type": "user",
    "_id": "chGm_mgB1Lja9i2Q0fSA",
    "_version": 3,
    "result": "deleted",
    "_shards": { 
    	"total": 2,
    	"successful": 1,
    	"failed": 0
    },
    "_seq_no": 2,
    "_primary_term": 1
    }

#### 2.5 查询文档 ####

curl -X GET 'localhost:9200/blog/user/chGm_mgB1Lja9i2Q0fSA'

打印结果：

{ 
    "_index": "blog",
    "_type": "user",
    "_id": "chGm_mgB1Lja9i2Q0fSA",
    "_version": 2,
    "_seq_no": 1,
    "_primary_term": 1,
    "found": true,
    "_source": { 
    	"id": 1,
    	"name": "zhangsan",
    	"score": 80.5,
    	"age": 26,
    	"gender": "F"
     }
    }

#### 2.6 删除类型(表) ####

POST _indexex/_type/_delete_by_query?conflicts=proceed
    {
      "query": {
        "match_all": {}
      }
    }

[http_localhost_9200_index_type_id]: http://localhost:9200/%7B_index%7D/%7B_type%7D/%7B_id%7D
[http_localhost_9200_blog_user_1]: http://localhost:9200/blog/user/1