【elasticsearch系列】javaApi操作

不再赘述

以下并非全部依赖！

   
        
            org.elasticsearch
            elasticsearch
            7.14.0
        
        
        
            org.elasticsearch.client
            elasticsearch-rest-high-level-client
            7.14.0
        

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
// 关闭客户端
esClient.close();

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
// 创建索引
CreateIndexRequest request = new CreateIndexRequest("user");
CreateIndexResponse createIndexResponse = esClient.indices().create(request, RequestOptions.DEFAULT);
System.out.println("创建索引："+createIndexResponse.isAcknowledged());
// 关闭客户端
esClient.close();

创建索引：true

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
// 查询索引
GetIndexRequest request = new GetIndexRequest("user");
GetIndexResponse getIndexResponse = esClient.indices().get(request, RequestOptions.DEFAULT);
System.out.println("查询索引："+getIndexResponse.getAliases());
System.out.println("查询索引："+getIndexResponse.getMappings());
System.out.println("查询索引："+getIndexResponse.getSettings());
// 关闭客户端
esClient.close();

查询索引：{user=[]}
查询索引：{user=org.elasticsearch.cluster.metadata.Mappingmetadata@ddef3a1c}
查询索引：{user={"index.creation_date":"1634192650562","index.number_of_replicas":"1","index.number_of_shards":"1","index.provided_name":"user","index.routing.allocation.include._tier_preference":"data_content","index.uuid":"S-lEeGCCT1etEzWvKeef9g","index.version.created":"7140099"}}

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
// 删除索引
DeleteIndexRequest request = new DeleteIndexRequest("user");
AcknowledgedResponse response = esClient.indices().delete(request, RequestOptions.DEFAULT);
System.out.println("删除索引："+response.isAcknowledged());
// 关闭客户端
esClient.close();

删除索引：true

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
//向索引中插入数据
IndexRequest indexRequest = new IndexRequest();
//构造文档信息
User user = new User();
user.setName("张三");
user.setAge(18);
user.setSex("男");
ObjectMapper objectMapper=new ObjectMapper();
String userJson = objectMapper.writevalueAsString(user);
// 设置文档索引以及指定ID
indexRequest.index("user").id("1001");
//设置source，注意需要指定文档类型，这里用的是json
indexRequest.source(userJson, XContentType.JSON);
IndexResponse response = esClient.index(indexRequest, RequestOptions.DEFAULT);
System.out.println(response.getResult());
// 关闭客户端
esClient.close();

CREATED

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
//修改索引中的文档
UpdateRequest updateRequest = new UpdateRequest();
// 设置文档索引以及指定ID
updateRequest.index("user").id("1001");
//设置文档类型，以及需要更新的数据，这里是局部更新
updateRequest.doc( XContentType.JSON,"sex","女");
UpdateResponse response = esClient.update(updateRequest, RequestOptions.DEFAULT);
System.out.println(response.getResult());
// 关闭客户端
esClient.close();

UPDATED

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
//修改索引中的文档
GetRequest getRequest = new GetRequest();
// 设置文档索引以及指定ID
getRequest.index("user").id("1001");
GetResponse response = esClient.get(getRequest, RequestOptions.DEFAULT);
System.out.println(response.getSourceAsString());
// 关闭客户端
esClient.close();

{"name":"张三","age":18,"sex":"女"}

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
//修改索引中的文档
DeleteRequest deleteRequest = new DeleteRequest();
// 设置文档索引以及指定ID
deleteRequest.index("user").id("1001");
DeleteResponse response = esClient.delete(deleteRequest, RequestOptions.DEFAULT);
System.out.println(response.toString());
// 关闭客户端
esClient.close();

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
BulkRequest request=new BulkRequest();
//批量插入数据
request.add(new IndexRequest().index("user").id("1002").source(XContentType.JSON,"name","zhangsan"));
request.add(new IndexRequest().index("user").id("1003").source(XContentType.JSON,"name","lisi"));

BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
System.out.println(response.getTook()); //打印批量插入所需要的时间
// 关闭客户端
esClient.close();

// 创建客户端
RestHighLevelClient esClient=new RestHighLevelClient(
  RestClient.builder(new HttpHost("localhost",9200,"http"))
);
BulkRequest request=new BulkRequest();
//批量删除数据
request.add(new DeleteRequest().index("user").id("1002"));
request.add(new DeleteRequest().index("user").id("1003"));
BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
System.out.println(response.getTook());
// 关闭客户端
esClient.close();