elasticsearch【更新】操作

基于上一篇博文基础上，进行es的操作，document的新增比较简单，就不说了，这里主要说说更新操作。

 

更新操作，有两大类，一个是Replace，一个是Update，就是说一个是替换，一个是更新。 替换，就是全文档更换，而更新可以只针对文档的局部字段。

 

1. 这里先说简单的Replace的操作。

先创建一个document，索引名为gengxin，文档类型为replace。

 1 [water@CloudGame ES]$ curl -XPUT 'localhost:9200/gengxin/replace/1?pretty' -d '
 2 { 
 3   "name": "shihuc",
 4   "job": "System Software Dev Manager",
 5   "date": "2016-10-19"
 6 }'
 7 {
 8   "_index" : "gengxin",
 9   "_type" : "replace",
10   "_id" : "1",
11   "_version" : 1,                   
12   "_shards" : {
13     "total" : 2,
14     "successful" : 1,
15     "failed" : 0
16   },
17   "created" : true                  #注意，这里的信息状态是true
18 }

查询看看创建的结果：

 1 [water@CloudGame ES]$ curl "localhost:9200/gengxin/replace/1?pretty"
 2 {
 3   "_index" : "gengxin",
 4   "_type" : "replace",
 5   "_id" : "1",
 6   "_version" : 1,
 7   "found" : true,
 8   "_source" : {
 9     "name" : "shihuc",
10     "job" : "System Software Dev Manager",
11     "date" : "2016-10-19"
12   }
13 }

没有什么问题。 然后我们对这个id为1的document进行replace操作：

 1 [water@CloudGame ES]$ curl -XPUT 'localhost:9200/gengxin/replace/1?pretty' -d '
 2 { 
 3   "name": "wdn",
 4   "job": "TK CEO"
 5 }'
 6 {
 7   "_index" : "gengxin",
 8   "_type" : "replace",
 9   "_id" : "1",
10   "_version" : 2,
11   "_shards" : {
12     "total" : 2,
13     "successful" : 1,
14     "failed" : 0
15   },
16   "created" : false           #注意，这里的状态是false哟，表示没有新建一个
17 }

再查看一下，这个被replace了的document内容：

 1 [water@CloudGame ES]$ curl "localhost:9200/gengxin/replace/1?pretty"
 2 {
 3   "_index" : "gengxin",
 4   "_type" : "replace",
 5   "_id" : "1",
 6   "_version" : 2,
 7   "found" : true,
 8   "_source" : {
 9     "name" : "wdn",
10     "job" : "TK CEO"
11   }
12 }

发现没有，这个被Replace后的数据，与新建的时候字段数量都不一样了，就和一个新建很类似。内容完全被替换了。

 

2. 下面看看Update更新操作，其实，这个操作是针对已经建立的document修改field的内容，字段field的名字和数量是不能被修改的，是不是差别出来了？？？对的，就是这个差别。

 1 [water@CloudGame ES]$ curl -XPUT 'localhost:9200/gengxin/update/1?pretty' -d '
 2 { 
 3   "name": "water",
 4   "job": "跑龙套的宝宝",
 5   "date": "2016-10-19"
 6 }'
 7 {
 8   "_index" : "gengxin",
 9   "_type" : "update",
10   "_id" : "1",
11   "_version" : 1,
12   "_shards" : {
13     "total" : 2,
14     "successful" : 1,
15     "failed" : 0
16   },
17   "created" : true
18 }

查看返回值：

 1 [water@CloudGame ES]$ curl "localhost:9200/gengxin/update/1?pretty"
 2 {
 3   "_index" : "gengxin",
 4   "_type" : "update",
 5   "_id" : "1",
 6   "_version" : 1,
 7   "found" : true,
 8   "_source" : {
 9     "name" : "water",
10     "job" : "跑龙套的宝宝",
11     "date" : "2016-10-19"
12   }
13 }

再来看看Update的操作：

 1 [water@CloudGame ES]$ curl -XPOST "localhost:9200/gengxin/update/1/_update?pretty" -d '
 2 {
 3   "doc": {"job": "奋斗者"}
 4 }'
 5 {
 6   "_index" : "gengxin",
 7   "_type" : "update",
 8   "_id" : "1",
 9   "_version" : 5,
10   "_shards" : {
11     "total" : 2,
12     "successful" : 1,
13     "failed" : 0
14   }
15 }

查看Update的结果：

 1 [water@CloudGame ES]$ curl "localhost:9200/gengxin/update/1?pretty"
 2 {
 3   "_index" : "gengxin",
 4   "_type" : "update",
 5   "_id" : "1",
 6   "_version" : 5,
 7   "found" : true,
 8   "_source" : {
 9     "name" : "water",
10     "job" : "奋斗者",
11     "date" : "2016-10-19"
12   }
13 }

到此，是不是发现Replace操作和Update操作的不同了？

1. 指令不同，replace前后都是PUT指令，其实，用POST也可以实现replace，比如上面的replace操作的时候，将PUT换成POST也可以的。但是最好还是用PUT, http指令中POST是用来更新数据的，PUT是用来新增数据用的，虽然两个没有严格的限制。还有，在做Update操作时，指令中含有关键字_update.

2. replace操作时，指令的-d的内容就是最后的数据的内容，也就是查询结果中_source中的内容，但是Update的操作，修改的只是_source中的某些字段的内容。

 

另外，补充一下Update的操作，其实除了通过doc来修改指定的字段内容，还可以通过script来实现字段内容的修改。script的东西就比较多了，这里简单的演示一个inline的脚本处理，作为引子简单介绍下！

A. 创建一个文档，并查看结果， 文档的内容是说wangbaoqiang有几顶绿帽子，开始创建的时候写的是2个，后来发现其实只有马rong个jian人一个，于是乎要修改。。。

 1 [water@CloudGame ES]$ curl -XPUT "localhost:9200/gengxin/update/2?pretty" -d '{
 2 > "name": "wangbaoqiang",
 3 > "green_hat": "2"
 4 > }'
 5 {
 6   "_index" : "gengxin",
 7   "_type" : "update",
 8   "_id" : "2",
 9   "_version" : 1,
10   "_shards" : {
11     "total" : 2,
12     "successful" : 1,
13     "failed" : 0
14   },
15   "created" : true
16 }
17 [water@CloudGame ES]$ 
18 [water@CloudGame ES]$ curl "localhost:9200/gengxin/update/2?pretty"
19 {
20   "_index" : "gengxin",
21   "_type" : "update",
22   "_id" : "2",
23   "_version" : 1,
24   "found" : true,
25   "_source" : {
26     "name" : "wangbaoqiang",
27     "green_hat" : "2"
28   }
29 }

好吧，进行修改吧（行内脚本的方式实现）：

 1 [water@CloudGame ES]$ curl -XPOST "localhost:9200/gengxin/update/2/_update?pretty" -d '{
 2 > "script": "ctx._source.green_hat = count",
 3 > "inline": {
 4 >    "params" : {
 5 >      "count" : 1
 6 >    }
 7 >  }
 8 > }'
 9 {
10   "error" : {
11     "root_cause" : [ {
12       "type" : "remote_transport_exception",
13       "reason" : "[node-1][10.90.6.172:9300][indices:data/write/update[s]]"
14     } ],
15     "type" : "illegal_argument_exception",
16     "reason" : "failed to execute script",
17     "caused_by" : {
18       "type" : "script_exception",
19       "reason" : "scripts of type [inline], operation [update] and lang [groovy] are disabled"
20     }
21   },
22   "status" : 400
23 }

报错了，意思是说行内脚本通过groovy语言执行update操作是被禁用了的。 查看帮助文档吧，发现script章节有介绍，需要修改elasticsearch.yml配置文件，再其最后，加入下面的内容，重新启动es：

1  script.inline: true
2  script.indexed: true
3  script.engine.groovy.inline.aggs: true

 

重启ES后，再次操作上述script方式的update指令：

 1 [water@CloudGame ES]$ curl -XPOST "localhost:9200/gengxin/update/2/_update?pretty" -d '{
 2 "script": "ctx._source.green_hat = count",
 3 "inline": {
 4    "params" : {
 5      "count" : 1
 6    }
 7  }
 8 }'
 9 {
10   "_index" : "gengxin",
11   "_type" : "update",
12   "_id" : "2",
13   "_version" : 4,
14   "_shards" : {
15     "total" : 2,
16     "successful" : 1,
17     "failed" : 0
18   }
19 }
20 [water@CloudGame ES]$ 
21 [water@CloudGame ES]$ curl "localhost:9200/gengxin/update/2?pretty"
22 {
23   "_index" : "gengxin",
24   "_type" : "update",
25   "_id" : "2",
26   "_version" : 4,
27   "found" : true,
28   "_source" : {
29     "name" : "wangbaoqiang",
30     "green_hat" : 1
31   }
32 }

是不是也还不错，比较容易实现。

补充一点tip，若update操作中doc和script关键字都出现了，那么doc将被忽略！

 

 

elasticsearch中给类型增加新字段                         

 

For instance, let’s add a new field to my_index:

PUT /my_index/_mapping/my_type
{
    "my_type": {
        "properties": {
            "english_title": {
                "type":     "string",
                "analyzer": "english"
            }
        }
    }
}