原生JAVA操作 Elasticsearch文档

原生JAVA操作 Elasticsearch文档

package com.yqq.app13;import org.apache.org.elasticsearch.action.delete.DeleteRequest;import org.elasticsearch.action.get.GetRequest;import org.elasticsearch.action.get.GetResponse;import org.elasticsearch.action.index.IndexRequest;import org.elasticsearch.action.index.IndexResponse;import org.elasticsearch.client.RequestOptions;import org.elasticsearch.client.RestClient;import org.elasticsearch.client.RestHighLevelClient;import org.elasticsearch.common.xcontent.XContentFactory;import org.junit.After;import org.junit.Before;import org.junit.Test;import java.io.IOException;/** * @Author yqq * @Date 2021/11/30 16:26 * @Version 1.0 */public class DocumentTest { RestHighLevelClient client; @Before public void init(){ // 创建客户端对象，链接ES client = new RestHighLevelClient( RestClient.builder(new HttpHost("node0",9200," } //新增/修改文档 @Test public void addOrUpdateDocument(){ //创建请求对象 IndexRequest request = new IndexRequest("student").id("2"); try { request.source(XContentFactory.jsonBuilder() .startObject() .field("id",2) .field("name","乔丹") .field("info","NBA公牛队最伟大篮球巨星") .endObject()); } catch (IOException e) { e.printStackTrace(); } //发送请求 try { IndexResponse response = client.index(request, RequestOptions.DEFAULT); } catch (IOException e) { e.printStackTrace(); } } // 根据id查询文档 @Test public void findById() throws Exception{ //创建请求对象 GetRequest request = new GetRequest("student","2"); //发送请求 GetResponse response = client.get(request,RequestOptions.DEFAULT); //输出查询结果 System.out.println(response.getSourceAsString()); } // 删除文档 @Test public void deleteDocument() throws Exception{ //创建请求对象 DeleteRequest request = new DeleteRequest("student","2"); //发送请求 client.delete(request,RequestOptions.DEFAULT); } @After public void close(){ try { client.close(); } catch (IOException e) { e.printStackTrace(); } }}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。