Elasticsearch-Java API操作（一）API基本操作（10）【更新文档数据（update）】

 

大数据技术之Elasticsearch-Java API操作（一）API基本操作

 

更新文档数据（update）

1）源代码

@Test

public void updateData() throws Throwable {

// 1 创建更新数据的请求对象

UpdateRequest updateRequest = new UpdateRequest();

updateRequest.index("blog");

updateRequest.type("article");

updateRequest.id("3");

updateRequest.doc(XContentFactory.jsonBuilder().startObject()

// 对没有的字段添加, 对已有的字段替换

.field("title", "基于Lucene的搜索服务器")

.field("content","它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。大数据前景无限")

.field("createDate", "2017-8-22").endObject());

// 2 获取更新后的值

UpdateResponse indexResponse = client.update(updateRequest).get();

// 3 打印返回的结果

System.out.println("index:" + indexResponse.getIndex());

System.out.println("type:" + indexResponse.getType());

System.out.println("id:" + indexResponse.getId());

System.out.println("version:" + indexResponse.getVersion());

System.out.println("create:" + indexResponse.getResult());

// 4 关闭连接

client.close();

}

2）结果查看

 

****自己操作****

Java代码：

// 七、更新文档-update
 @Test public void updateData() throws Exception { // 创建更新数据的请求对象
       UpdateRequest updateRequest = new UpdateRequest(); updateRequest.index("blog"); updateRequest.type("article"); updateRequest.id("Rw3d8XMBfpkCch_aW3Da"); updateRequest.doc(XContentFactory.jsonBuilder().startObject() // 对没有的字段添加, 对已有的字段替换
                .field("title", "基于Lucene的搜索服务器").field("content", "它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。大数据前景无限") .field("createDate", "2017-8-22").endObject()); UpdateResponse indexResponse = client.update(updateRequest).get(); // 打印返回结果
        System.out.println("index：" + indexResponse.getIndex()); System.out.println("type：" + indexResponse.getType()); System.out.println("id：" + indexResponse.getId()); System.out.println("version：" + indexResponse.getVersion()); System.out.println("result：" + indexResponse.getResult()); // 关闭连接
 client.close(); }

结果：