es6.6.1 java客户端 client基础操作

admin管理员组

文章数量:1487745

es6.6.1 java客户端 client基础操作

1.引入jar包

<dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>6.6.1</version> </dependency>

2.测试demo

代码语言：javascript代码运行次数：0运行复制

public static void main( String[] args ) throws IOException
    {
        
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                new HttpHost("192.168.249.129", 9200, "http")));
        
//        //创建索引
//        IndexRequest indexRequest = new IndexRequest("product", "car", "1");
//        //索引index（四种json,map,XContentBuilder,object）
//        Map<String, Object> source = new HashMap<String, Object>();
//        source.put("字段1", "值1");
//        source.put("字段2", new Date());
//        source.put("字段3", "值2");
//        indexRequest.source(source);
//        IndexResponse indexResponse = client.index(indexRequest,RequestOptions.DEFAULT);
//        System.out.println(indexResponse.getResult());
//        
        //删除
        DeleteRequest deleteRequest = new DeleteRequest("product", "car", "1");
        DeleteResponse deleteResponse = client.delete(deleteRequest,RequestOptions.DEFAULT);
        System.out.println(deleteResponse.getResult());
        
        //查询
        GetRequest getRequest = new GetRequest("product", "car", "1");
        GetResponse getResponse = client.get(getRequest,RequestOptions.DEFAULT);
        System.out.println(getResponse.getSourceAsString());
        
//        判断exist
//        boolean exists = client.exists(getRequest, RequestOptions.DEFAULT);
//        System.out.println("exists="+exists);
        
        //更新
//        UpdateRequest updateRequest = new UpdateRequest("product", "car", "1");
//          Map<String, Object> source = new HashMap<String, Object>();
//          source.put("字段11", "值1");
//          source.put("字段22", new Date());
//          source.put("字段33", "值2");
//          updateRequest.doc(source);
//        UpdateResponse updateResponse = client.update(updateRequest,RequestOptions.DEFAULT);
//        System.out.println(updateResponse.getResult());
        
        
        client.close();
    }

本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。 原始发表：2021-02-03，如有侵权请联系 cloudcommunity@tencent 删除前往查看javaclient基础客户端索引

本文标签： es661 java客户端 client基础操作