Elasticsearch的CRUD

CRUD

动作	API
index	PUT my_index/_doc/1 {“a”:”mike”,”b”,”bb”}
Create	PUT my_index/_create/1 {…}
Read	GET my_index/_doc/1
Update	POST my_index/_update/1 {}
DELETE	DELETE my_index/_doc/1

Create

PUT users/_create/1
{
    "name":"zjj",
    "age":"25"
}

• 支持自动生成文档ID和指定文档ID2种方式
• 调用 POST 动作系统会自动生成document id
• 使用HTTP PUT 创建时，URL中显示指定 _create,如果ID文档存在，操作失败

GET

GET users/_doc/1

• 找到文档，返回http 200
  • 文档元信息
    • _index/_type/
    • 版本信息，同一个ID的文档，即使被删除Version号也会不断真加
    • _souece 中默认包含了文档的所有原始信息
• 找不到文档，返回http 404

Index

PUT users/_doc/1
{
  "age": "30"
}

• index 和 create 不一样的地方是，create如果存在该数据会报错，index会覆盖。

Update

POST users/_update/1
{
  "doc":{
    "name":"zjj"
  }
}

• update 和 index的区别是，index是覆盖操作，update会保留原来的数据

Bulk API

• 在一次API调用中，对不同的索引进行操作
• 支持CUD和INDEX操作
• 单条失败其他不影响
• 返回结果包括了每一条执行

POST _bulk
{ "create":{"_index":"users","_id":"5"}}
{ "name":"dx","age":"25"}
{"update":{"_index":"users","_id":"5"}}
{"name":"dxx"}
{"delete":{"_index":"users","_id":"2"}}

{
  "took" : 61,
  "errors" : false,
  "items" : [
    {
      "create" : {
        "_index" : "users",
        "_type" : "_doc",
        "_id" : "5",
        "_version" : 1,
        "result" : "created",
        "_shards" : {
          "total" : 2,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 14,
        "_primary_term" : 1,
        "status" : 201
      }
    },
    {
      "update" : {
        "_index" : "users",
        "_type" : "_doc",
        "_id" : "5",
        "_version" : 2,
        "result" : "updated",
        "_shards" : {
          "total" : 2,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 15,
        "_primary_term" : 1,
        "status" : 200
      }
    },
    {
      "delete" : {
        "_index" : "users",
        "_type" : "_doc",
        "_id" : "2",
        "_version" : 2,
        "result" : "deleted",
        "_shards" : {
          "total" : 2,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 16,
        "_primary_term" : 1,
        "status" : 200
      }
    }
  ]
}

mget

• 批量按照ID获取数据
• 有一些简洁的写法可以看文档

GET /_mget
{
  "docs":[
    {"_index":"users","_id":"1"},
    {"_index":"users","_id":"2"},
    {"_index":"users","_id":"3"},
    {"_index":"users","_id":"4"},
    {"_index":"users","_id":"5"}
  ]
}

{
  "docs" : [
    {
      "_index" : "users",
      "_type" : "_doc",
      "_id" : "1",
      "_version" : 12,
      "_seq_no" : 11,
      "_primary_term" : 1,
      "found" : true,
      "_source" : {
        "age" : "30",
        "name" : "zjj"
      }
    },
    {
      "_index" : "users",
      "_type" : "_doc",
      "_id" : "2",
      "found" : false
    },
    {
      "_index" : "users",
      "_type" : "_doc",
      "_id" : "3",
      "_version" : 1,
      "_seq_no" : 13,
      "_primary_term" : 1,
      "found" : true,
      "_source" : {
        "name" : "dx",
        "age" : "25"
      }
    },
    {
      "_index" : "users",
      "_type" : "_doc",
      "_id" : "4",
      "found" : false
    },
    {
      "_index" : "users",
      "_type" : "_doc",
      "_id" : "5",
      "_version" : 2,
      "_seq_no" : 15,
      "_primary_term" : 1,
      "found" : true,
      "_source" : {
        "name" : "dxx",
        "age" : "25"
      }
    }
  ]
}

msearch