关于elasticsearch:elasticsearch笔记006文档APICRUD单文档更新操作

[toc]

1. 单文档 Update API

update API 依据提供的 script 更新文档; 从索引中获取 document, 执行脚本, 并对新的后果进行索引.

如何确保 get 和 reindex 期间没有产生更新? –> 应用版本控制;

这种操作依然意味着对文档进行残缺的从新索引, 它只是移除了一些网络往返损耗，并缩小了 get 和索引之间版本抵触的机会.

1. script 更新: 数值计算

示例: 新建一个 document 到 test 索引, 而后批改 counter=counter+4; 而后为 tags 新增一个 blue 的色彩:

#1. 新建一个 document 到 test 索引
PUT test/_doc/1
{
    "counter" : 1,
    "tags" : ["red"]
}

将 “counter” 的值加上给定的参数:

POST test/_update/1
{
    "script" : {
        "source": "ctx._source.counter += params.count",
        "lang": "painless",
        "params" : {"count" : 4}
    }
}

查看以后: GET test/_source/1

{
    "counter" : 5,
    "tags" : ["red"]
}

同理: counter=counter*2:

POST test/_update/1
{
  "script": {
    "source": "ctx._source.counter *= params.val",
    "params": {"val": 2}
  }
}

2. script 更新: 数组 (汇合) 减少 / 删除

2.1 减少一个 yellow:

POST test/_update/1
{
  "script": {"source": "ctx._source.tags.add(params.clr)",
    "params": {"clr": "yellow"}
  }
}

output:

{
    "counter" : 10,
    "tags" : [
      "red",
      "yellow"
    ]
}

2.2 删除(留神是索引)

理论是 ArrayList 的办法!

POST test/_update/1
{
  "script": {"source": "ctx._source.tags.remove(params.val)",
    "params": {"val": 0}
  }
}

{
    "counter" : 10,
    "tags" : ["yellow"]
}

2.3 clear()清空

同理, 能够调用 ArrayList的其余办法: 比方 :

POST test/_update/1
{
  "script": {"source": "ctx._source.tags.clear()"
  }
}

2.4 如何删除匹配的内容

如果当初 tags = [“yello”, “red”, “blue”], 要删除 “red”, 依据内容而非索引:

POST test/_update/1
{
  "script": {"source": "if (ctx._source.tags.contains(params.val)) {ctx._source.tags.remove(ctx._source.tags.indexOf(params.val));}",
    "params": {"val": "red"}
  }
}

GET test/_source/1 output:

{
    "counter" : 10,
    "tags" : [
      "yellow",
      "blue"
    ]
}

留神: script.source 里的 ”;” 能够不要的;

2.5 script 更新: ctx 的其余内置变量

除了 _source 之外，ctx 映射还提供了以下变量: _index、_type、_id、_version、_routing和 _now(以后工夫戳)。

2.6 script 更新: 减少 / 删除字段 entry

咱们给 test 索引中的 文档 1 新增一个字段: “addr”: “beijing”:

# update 减少字段 entry
POST test/_update/1
{
  "script": {"source": "ctx._source.addr='beijing'"}
}
# 再减少一条
POST test/_update/1
{
  "script": {"source": "ctx._source.location='yizhuang'"}
}

GET test/_source/1

{
  "counter" : 10,
  "tags" : ["yellow"],
  "addr" : "beijing",
  "location" : "yizhuang"
}

删除:

# update 删除字段
POST test/_update/1
{
  "script": {"source": "ctx._source.remove('location')"
  }
}

GET test/_source/1 :

{
  "counter" : 10,
  "tags" : ["yellow"],
  "addr" : "beijing"
}

3. doc 新增字段:

除了应用 script 外, 也能够应用 doc 来新增字段; 如果二者皆有, 会报错!

POST test/_update/1
{
    "doc" : {"loc" : "yz"}
}

{
  "counter" : 10,
  "tags" : ["yellow"],
  "addr" : "beijing",
  "loc" : "yz"
}

如果指定了 doc，那么它的值将与现有的_source 合并; 如果 doc 执行了屡次, 数据并没有变动, \_version 和 \_seq\_no 都不会更新! "result" : "noop"

4. upsert 更新 + 插入

4.1 script+upsert 形式

如果文档还不存在，那么 upsert 元素的内容将作为新文档插入。如果该文档存在，则执行脚本:

DELETE test/_doc/2 咱们先执行此操作删除 id= 2 的 document; 而后执行上面 upsert 操作:

POST test/_update/2
{
    "script" : {
        "source": "ctx._source.counter += params.count",
        "lang": "painless",
        "params" : {"count" : 4}
    },
    "upsert" : {
        "counter" : 2,
        "name": "ifnotexists"
    }
}

因为此刻没有 id= 2 的文档, 所以默认 += 操作时是不会有的; 这样的话, upsert 中的内容就会作为文档的内容保留;

这是 反复下面的 upsert 操作一次!! 再查后果: GET test/_source/2

{
  "counter" : 6,
  "name" : "ifnotexists"
}

能够看到, counter 就是 2+ 4 了;

4.2 doc 形式的 upsert

doc 形式也能够实现 upsert: 如下: 如果单纯是在下面有 id= 2 的 document 的根底上执行上面:

POST test/_update/2
{
  "doc": {"gender": "male"},
  "doc_as_upsert": true
}

只是减少了一个 gender 的字段!

{
  "counter" : 6,
  "name" : "ifnotexists",
  "gender" : "male"
}

当初删掉 document: DELETE test/_doc/2 , 就会体现为 upsert 的性能了, 此时 GET test/_source/2:

{"gender" : "male"}

5. update 的其余参数

timeout/wait_for_active_shards/version, 以及 if_seq_no + if_primary_term

5.1 if_seq_no+if_primary_term

POST test/_update/2?if_seq_no=31&if_primary_term=1
{
  "script": {
    "source": "ctx._source.counter=params.val",
    "params": {"val": 3}
  }
}

如果 _seq_no 和 _primary_term匹配, 才执行更新, 否则报错!

2. TODO: Update By Query API