REST API (更新删除文档)

Elasticsearch的更新文档API准许通过脚本操作来更新文档。更新操作从索引中获取文档,执行脚本,然后获得返回结果。它使用版本号来控制文档获取或者重建索引。

我们新建一个文档:

请求:PUT http://localhost:9200/test/type1/1?pretty

参数:

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

脚本开启功能

在最新版本的Elasticsearch中,基于安全考虑(如果用不到,请保持禁用),默认禁用了动态脚本功能.如果被禁用,在使用脚本的时候则报以下的错误:

scripts of type [inline], operation [update] and lang [groovy] are disabled

可以用以下方式完全开启动态脚本功能,在config/elasticsearch.yml文件,在最后添加以下代码:

script.inline: on
script.indexed: on
script.file: on

配置后,重启Elasticsearch。

下面我们用脚本来更新此文档。

请求:POST http://localhost:9200/test/type1/1/_update?pretty

参数:

{
    "script" : {
        "inline": "ctx._source.counter += count",
        "params" : {
            "count" : 4
        }
    }
}

执行完后,我们在查询一下文档内容,可以发现counter的值为5:

{
  "_index" : "test",
  "_type" : "type1",
  "_id" : "1",
  "_version" : 5,
  "found" : true,
  "_source" : {
    "counter" : 5,
    "tags" : [ "red" ]
  }
}

在看下面的更新操作:

请求:POST http://localhost:9200/test/type1/1/_update?pretty

参数:

{
    "script" : {
        "inline": "ctx._source.tags += tag",
        "params" : {
            "tag" : "blue"
        }
    }
}

返回的内容为,表示更新成功,我们看一下_version为6,比刚才的值增加了1:

{
  "_index" : "test",
  "_type" : "type1",
  "_id" : "1",
  "_version" : 6,
  "_shards" : {
    "total" : 2,
    "successful" : 1,
    "failed" : 0
  }
}

然后我们在查询一下文档内容:

{
  "_index" : "test",
  "_type" : "type1",
  "_id" : "1",
  "_version" : 6,
  "found" : true,
  "_source" : {
    "counter" : 5,
    "tags" : [ "red", "blue" ]
  }
}

在脚本中除了_source外其他内置参数也可以使用,例如_index, _type, _id, _version, _routing, _parent, _timestamp, _ttl。

下面我们通过脚本增加一列。

请求:POST http://localhost:9200/test/type1/1/_update?pretty

参数:

{
    "script" : "ctx._source.name_of_new_field = \"value_of_new_field\""
}

然后查询此文档:

{
  "_index" : "test",
  "_type" : "type1",
  "_id" : "1",
  "_version" : 7,
  "found" : true,
  "_source" : {
    "counter" : 5,
    "tags" : [ "red", "blue" ],
    "name_of_new_field" : "value_of_new_field"
  }
}

从中可以看出,文档中又增加了一列。

删除一列,请求和刚才的一样,参数变为:

{
    "script" : "ctx._source.remove(\"name_of_new_field\")"
}

甚至可以通过表达式来判断做某些事情,例如:下面的示例将删除的文件如果标签字段包含蓝色,否则什么也不做(空):

请求参数:

{
    "script" : {
        "inline": "ctx._source.tags.contains(tag) ? ctx.op = \"delete\" : ctx.op = \"none\"",
        "params" : {
            "tag" : "blue"
        }
    }
}

部分文档更新:

该更新接口还支持更新部分文档,将文档合并到现有文档中(简单的递归合并、对象的内部合并、替换核心的“键/值”和数组)。例如:

{
    "doc" : {
        "name" : "new_name"
    }
}

更新后,可以发现文档中多了一列name。

{
  "_index" : "test",
  "_type" : "type1",
  "_id" : "1",
  "_version" : 23,
  "found" : true,
  "_source" : {
    "counter" : 5,
    "tags" : [ "red", "blue" ],
    "name" : "new_name"
  }
}

当文档指定的值与现有的_source合并。当新的文档和老的文档不一致的时候,文档将会被从新建立索引。当新旧文档一样的时候,则不进行从建索引的操作。可以通过设置detect_noop为false,让任何情况下都从新建立索引,例如下面的更新操作:

{
    "doc" : {
        "name" : "new_name"
    },
    "detect_noop": false
}

删除文档

删除文档相对比较简单:

请求:DELETE http://localhost:9200/test/type1/1

返回的内容为:

{
    "found": true,
    "_index": "test",
    "_type": "type1",
    "_id": "1",
    "_version": 24,
    "_shards": {
        "total": 2,
        "successful": 1,
        "failed": 0
    }}

则表示删除了此文档。

时间: 2024-10-23 14:04:03

REST API (更新删除文档)的相关文章

大数据技术之_20_Elasticsearch学习_01_概述 + 快速入门 + Java API 操作 + 创建、删除索引 + 新建、搜索、更新删除文档 + 条件查询 + 映射操作

一 概述1.1 什么是搜索?1.2 如果用数据库做搜索会怎么样?1.3 什么是全文检索和 Lucene?1.4 什么是 Elasticsearch?1.5 Elasticsearch 的适用场景1.6 Elasticsearch 的特点1.7 Elasticsearch 的核心概念1.7.1 近实时1.7.2 Cluster(集群)1.7.3 Node(节点)1.7.4 Index(索引 --> 数据库)1.7.5 Type(类型 --> 表)1.7.6 Document(文档 -->

Elasticsearch Java API(九)--删除文档的field以及field的属性

一.需求 项目中需要实现删除文档的一个field以及删除指定field的一个属性. 以文档test/document/1为例: { "_index": "test", "_type": "document", "_id": "1", "_score": 1, "_source": { "class": "com.tes

MongoDB创建\更新\删除文档操作

?? 一.插入\创建文档 --当插入一个不存在的文档时,会自动创建一个文档 [[email protected] ~]# mongo MongoDB shell version: 2.4.14 connecting to: test > show collections > db.cols.insert({bar:"baz"}) > db.cols.find() { "_id" :ObjectId("56aac1df4e61b6d9f84

MongoDB(二)创建更新删除文档

插入并保存文档操作 用insert向目标集合插入文档,如果没有_id键则会自动添加.最后自动保存. >db.foo.insert({"bar":"baz"}) 如果要批量插入怎么办呢,看下面代码: >db.foo.insert([{"_id":0},{"_id":1},"{"_id":2}]) 以前有一个batchInsert函数,现在已经没有了.注意在批量插入的过程中如果有一个文档插

MongoDB创建、更新及删除文档

1.1插入并保存文档 插入是向MongoDB中添加数据的基本方法.对目标机使用insert方法,插入一个文档: > db.foo.insert({"bar" : "baz"}) 这个操作会给文档增加一个"_id"键(要是原来没有的话),然后将其保存到MongoDB中. 1.1.1 批量插入 如果要插入多个文档,使用批量插入会快一些.批量插入能传递一个由文档构成的数组给数据库.只有插入多个文档到一个集合的时候,这种方式才会有用,而不能批量插入

MongoDB学习笔记二:创建、更新及删除文档

插入并保存文档 对目标集使用insert方法插入一个文档: > db.foo.insert({"bar" : "baz"}) 这个操作会给文档增加一个"_id"键(要是原来没有的话),然后将其保存到MongoDB中.批量插入 如果要插入多个文档,使用批量插入会快一些.批量插入传递一个由文档构成的数组给数据库.如果只是导入数据(例如,从数据feed或者MySQL中导入),可以使用命令行工具,如mongoimport,而不是使用批量插入. 删除

mongoDB更新和删除文档(document)

整理来自 https://www.shiyanlou.com/courses/running/57 启动 $ sudo service mongodb start 进入MongoDB命令行操作界面,在命令行中敲exit可以退出 $ mongo 实验中的布尔类型的ture用1代替,false用0代替 创建数据库 范例:进入mongoDB命令行操作界面之后,进行如下操作: > use Chenshi switched to db Chenshi 您可以使用db命令查看您当前选择的数据库 > db

MongoDB数据库更新和删除文档

创建集合 createCollection() <span style="font-size:14px;">name:创建的集合名称 options:是一个作为初始化的文档(可选)</span> <span style="font-size:14px;">> db.createCollection("jingdong") #无参数 { "ok" : 1 } > show coll

03.创建、更新和删除文档。

插入: >db.collectionName.insert({"bar":"baz")} 批量插入:如果要向集合插入多个文档,使用批量插入会快一些. batchInsert函数实现批量插入,它接受一个文档数组作为参数. >db.collectionName.batchInsert([ {"_id:0}, {"_id":1}, {"_id":2} ]) >db.collectionName.find(