ElasticSearch(4)--使用Java客户端更新文档
2018-02-06 18:12
525 查看
使用java客户端更新文档
修改结果:
package com.es.demo; import java.net.InetAddress; import java.util.HashMap; import java.util.Map; import java.util.concurrent.ExecutionException; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.index.get.GetResult; import org.junit.After; import org.junit.Before; import org.junit.Test; import com.fasterxml.jackson.databind.ObjectMapper; /** * 更新文档 * * @author Beck * @date 2018年2月6日 */ public class TestES3 { private static final String HOST = "127.0.0.1"; private static final int PORT = 9300; private static final ObjectMapper MAPPER = new ObjectMapper(); private TransportClient client = null; // 跟下文档 @Test public void updateDocument() throws InterruptedException, ExecutionException{ UpdateRequest request = new UpdateRequest("eshop", "product", "AWFlwM2XrUhLs_HfwSw1"); Map<String, Object> source = new HashMap<String,Object>(); source.put("name", "APPLE手机2"); source.put("price", 10999); request.doc(source); UpdateResponse response = this.client.update(request ).get(); System.out.println(response.getVersion()); } // 获取客户端 @Before public void getClient() throws Exception{ client = TransportClient.builder() .build() .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(HOST), PORT)); } // 关闭客户端 @After public void closeClient(){ if (this.client != null){ this.client.close(); } } }
修改结果:
相关文章推荐
- ElasticSearch(5)--使用Java客户端删除文档
- ZooKeeper之Java客户端API使用—更新数据。
- Elasticsearch .net client NEST使用说明 2.x -更新版
- Elasticsearch Java API(九)--删除文档的field以及field的属性
- ElasticSearch Java Api(三) -更新索引库
- ELK研究(一):elasticsearch java api接口操作ES集群 ---TransportClient的使用介绍 bulk批量提交数据
- elasticsearch java api使用,es java封装
- elasticSearch Java Api使用
- ElasticSearch(2)--使用Java客户端创建文档
- ElasticSearch学习13_ElasticSearch RESTful搜索引擎_Java Jest使用入门
- Elasticsearch Java API(七)--删除文档的field以及field的属性
- Elasticsearch JDBC的使用-MySQL 数据源导入和增量索引、更新
- MongoDB_Java连接mongo 使用Java程序更新集合中的文档
- Elasticsearch JDBC的使用-MySQL 数据源导入和增量索引、更新
- ELK研究(一):elasticsearch java api接口操作ES集群 ---TransportClient的使用介绍 bulk批量提交数据
- Elasticsearch JDBC的使用-MySQL 数据源导入和增量索引、更新
- RabbitMQ的java客户端API使用文档中文版
- ElasticSearch Java Api(三) -更新索引库
- Elasticsearch java API (9)更新的API
- 使用HttpWebRequest自动更新客户端应用程序