ElasticSearch学习笔记

- 

创建maven工程

1. 导入pom依赖
   
   
   com.fasterxml.jackson.core
   jackson-databind
   2.9.9
   
   
   org.elasticsearch
   elasticsearch
   7.8.0
   
   
   
   org.elasticsearch.client
   elasticsearch-rest-high-level-client
   7.8.0
   
   
   
   org.apache.logging.log4j
   log4j-api
   2.17.1
   
   
   
   org.apache.logging.log4j
   log4j-core
   2.17.1
   

    
        junit
        junit
        4.13.2
        test
    
   

   //创建rest高级客户端 RestHighLevelClient restHighLevelClient = new RestHighLevelClient( RestClient.builder(new HttpHost("192.168.215.137", 9200)) );

    //关闭客户端
    restHighLevelClient.close();
   

2. 创建索引
   //创建索引请求
   CreateIndexRequest user = new CreateIndexRequest(“user”);
   //创建索引 使用默认规则
   CreateIndexResponse createIndexResponse = client.indices().create(user, RequestOptions.DEFAULT);
   boolean acknowledged = createIndexResponse.isAcknowledged();
   System.out.println("acknowledged = " + acknowledged);

3. 查询索引
   GetIndexRequest getIndexRequest = new GetIndexRequest(“user”);
   GetIndexResponse getIndexResponse = restHighLevelClient.indices().get(getIndexRequest, RequestOptions.DEFAULT);
   System.out.println("getIndexResponse.getMappings() = " + getIndexResponse.getMappings());
   System.out.println("getIndexResponse.getSetting() = " + getIndexResponse.getSettings());
   System.out.println("getIndexResponse.getAliases() = " + getIndexResponse.getAliases());

4. 删除索引
   AcknowledgedResponse user = restHighLevelClient.indices().delete(new DeleteIndexRequest(“user”), RequestOptions.DEFAULT);
   System.out.println("user.isAcknowledged() = " + user.isAcknowledged());

5. 文档新增
   IndexRequest request = new IndexRequest(“user”);

    request.id("1001");
   
   
    User user1 = new User();
    user1.setAge("10");
    user1.setName("我是你爹");
    user1.setSex("男");
   
    JSONObject jsonObject = JSONUtil.parseObj(user1, true, true);
    request.source(jsonObject, XContentType.JSON);
    IndexResponse response = restHighLevelClient.index(request, RequestOptions.DEFAULT);
    System.out.println("response.getResult() = " + response.getResult());
   

6. 文档修改
   UpdateRequest request = new UpdateRequest();
   request.index(“user”).id(“1001”);
   request.doc(XContentType.JSON, “sex”, “女”);

    UpdateResponse response = client.update(request, RequestOptions.DEFAULT);
   
    System.out.println("response.getGetResult() = " + response.getResult());