简介

ElasticSearch的文档写入是以不可修改的形式写入的，一条文档记录一旦被写入其本身就不能被修改了。然而，现实中存在修改这些数据的需求，那怎么办呢？当上帝给你关上一扇门的时候，他一定给你留了一个窗口。虽然我们不能直接修改这个文档本身，但是我们可以通过更新一条_id一样的文档，并更新版本号的方式来修改这条记录。我们可以通过三种姿势进行更新。

姿势1，直接index

PUT test1/_doc/1
{
  "name": "bbbb"
}
# Do query
PUT test1/_doc/1
{
  "name": "bbbb",
  "age": 33
}
# Do query
PUT test1/_doc/1
{
  "name": "bbbb"
}
# Do query

按顺序执行上面的三条put操作，然后查询，我们可以看到相应的查询结果是：

  "_version": 1
  "_source" : {
    "name" : "bbbb"
  }
  =========================
  "_version": 2
  "_source" : {
    "name" : "bbbb",
    "age" : 33
  }
  =========================
  "_version": 3
  "_source" : {
    "name" : "bbbb"
  }

可以看到每次put之后，版本号都会递增1位，同时后面的数据会覆盖之前的数据。

如果我并不想每次都通过这样把全部文档内容再输入一次的形式来，而是希望基于前一个版本的文档进行增减或者修改，那又应该怎么做呢。ES为我们提供了update API。

姿势2，使用update API

ES 提供了update API，使我们可以针对某个id的文档，进行局部更新。我们可以使用painless脚本或者直接在update中设置doc字段的参数的形式进行。

考虑以下文档。

PUT test14/_doc/1
{
  "name": "aaaa",
  "age": 15,
  "sex": "male"
}

如果我想修改年龄的话，可以有两种方法来进行：

POST test14/_update/1
{
  "doc": {
    "age": 14
  }
}

POST test14/_update/1
{
  "script": {
    "lang": "painless",
    "source": """
      ctx._source.age = 14
    """
  }
}

两种方法都可以将age修改为14。

如果我们想增加一个属性”weight“该怎么做呢？

POST test14/_update/1
{
  "doc": {
    "weight": 90
  }
}

POST test14/_update/1
{
  "script": {
    "lang": "painless",
    "source": """
      ctx._source.weight = 90
    """
  }
}

如果我们想移除”sex“字段，这种情况下，只能用painless脚本了。

POST test14/_update/1
{
  "script": {
    "lang": "painless",
    "source": """
      ctx._source.remove("sex");
    """
  }
}

这三种情况是最基本的，还有一些其他用法，可以参考update的官方文档。

https://www.elastic.co/guide/en/elasticsearch/reference/7.2/docs-update.html

需要注意，使用update api只能使用ES索引的内置版本号，如果强行指定版本号，update操作会发生错误。

上面两种方法需要指定文档id，ES还提供了基于search的update API，及update_by_query API。

姿势3，使用update_by_query API

update_by_query API的第一种使用方式是什么都不指定，直接使用。

POST twitter/_update_by_query?conflicts=proceed

我一开始看到这种用法，觉得特别疑惑，因为这样做除了更新了版本号，似乎也没有什么变化。后来读了官方文档才了解到这种用法的含义。

在设置索引配置的时候，有一个dynamic属性，如果设置成false的话，如果碰到没有事先映射过的字段，是不会做索引，搜索不到的。需要注意，是搜索不到，但不是没有存储，这个数据还是在的。那怎样能使得这个数据能够被索引到呢，这个时候update_by_query就能排上用场了。我们先更新这个索引的mapping，然后调用update_by_query API。对应的文档会重新索引一次，之前不能搜索的字段就变得能够被搜索到了。

和query API一样，update_by_query也可以拥有一个query块，作为update的条件出现：

POST twitter/_update_by_query
{
  "script": {
    "source": "ctx._source.likes++",
    "lang": "painless"
  },
  "query": {
    "term": {
      "user": "kimchy"
    }
  }
}

同样也可以使用painless进行update操作。

PUT _ingest/pipeline/set-foo
{
  "description" : "sets foo",
  "processors" : [ {
      "set" : {
        "field": "foo",
        "value": "bar"
      }
  } ]
}
POST twitter/_update_by_query?pipeline=set-foo

在进行update_by_query的时候，还可以指定pipeline，使用pipeline的处理器处理文档。

还有一些其他用法，可以参考官方文档：

https://www.elastic.co/guide/en/elasticsearch/reference/7.2/docs-update-by-query.html