【ES三周年】- 使用JavaAPI操作elasticsearch
原创【ES三周年】- 使用JavaAPI操作elasticsearch
原创
用户6044099
发布于 2023-02-25 20:51:44
发布于 2023-02-25 20:51:44
文章被收录于专栏：Elastic-search
工程准备
创建maven工程并引入Elasticsearch相关依赖：
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>7.8.0</version>
</dependency>
<!-- elasticsearch 的客户端 -->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.8.0</version>
</dependency>
<!-- elasticsearch 依赖 2.x 的 log4j -->
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>2.8.2</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.8.2</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.9</version>
</dependency>
<!-- junit 单元测试 -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>索引操作
创建索引
@Test
public void index\_create\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
//创建索引
CreateIndexRequest request = new CreateIndexRequest("student");
CreateIndexResponse createIndexResponse = esClient.indices().create(request, RequestOptions.DEFAULT);
boolean acknowledged = createIndexResponse.isAcknowledged();
System.out.println("响应状态："+acknowledged);
//关闭Elasticsearch客户端
esClient.close();
}使用Postman测试索引是否成功：
在这里插入图片描述
查询索引
@Test
public void index\_get\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
//查询索引
GetIndexRequest getIndexRequest = new GetIndexRequest("student");
GetIndexResponse getIndexResponse = esClient.indices().get(getIndexRequest, RequestOptions.DEFAULT);
System.out.println(getIndexResponse.getAliases());
System.out.println(getIndexResponse.getMappings());
System.out.println(getIndexResponse.getSettings());
//关闭Elasticsearch客户端
esClient.close();
}
在这里插入图片描述
删除索引
@Test
public void index\_delete\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
//删除索引
DeleteIndexRequest getIndexRequest = new DeleteIndexRequest("student");
AcknowledgedResponse delete = esClient.indices().delete(getIndexRequest, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
//关闭Elasticsearch客户端
esClient.close();
}文档操作
进行文档操作前，先创建文档数据对应的java实体类Student：
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class Student {
private String name;
private int age;
private String sex;
private String level;
}添加文档数据
@Test
public void doc\_insert\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
IndexRequest request = new IndexRequest();
request.index("student").id("10000");
Student student = new Student();
student.setName("王同学");
student.setAge(22);
student.setSex("男");
student.setLevel("研究生");
ObjectMapper mapper = new ObjectMapper();
String studentJson = mapper.writeValueAsString(student);
request.source(studentJson, XContentType.JSON);
IndexResponse response = esClient.index(request, RequestOptions.DEFAULT);
System.out.println(response.getResult());
//关闭Elasticsearch客户端
esClient.close();
}批量添加文档数据
@Test
public void doc\_insert\_batch\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
BulkRequest request = new BulkRequest();
request.add(new IndexRequest().index("student").id("10001").source(XContentType.JSON, "name", "张三"));
request.add(new IndexRequest().index("student").id("10002").source(XContentType.JSON, "name", "李四"));
request.add(new IndexRequest().index("student").id("10003").source(XContentType.JSON, "name", "王五"));
BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
System.out.println(response.getItems());
//关闭Elasticsearch客户端
esClient.close();
}
在这里插入图片描述
修改文档数据
@Test
public void doc\_update\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
UpdateRequest request = new UpdateRequest();
request.index("student").id("10000");
request.doc(XContentType.JSON,"sex","女");
UpdateResponse response = esClient.update(request, RequestOptions.DEFAULT);
System.out.println(response.getResult());
//关闭Elasticsearch客户端
esClient.close();
}根据id查询文档数据
@Test
public void doc\_search\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
GetRequest request = new GetRequest();
request.index("student").id("10000");
GetResponse response = esClient.get(request, RequestOptions.DEFAULT);
System.out.println(response.getSourceAsString());
//关闭Elasticsearch客户端
esClient.close();
}
在这里插入图片描述
查询当前索引所有文档数据
@Test
public void doc\_search\_all\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
SearchRequest request = new SearchRequest();
request.indices("student");
request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));
SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
SearchHits hits = response.getHits();
System.out.println(hits.getTotalHits());
for(SearchHit hit:hits){
System.out.println(hit.getSourceAsString());
}
//关闭Elasticsearch客户端
esClient.close();
}
在这里插入图片描述
分页查询
@Test
public void doc\_search\_size\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
SearchRequest request = new SearchRequest();
request.indices("student");
SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
builder.from(0);
builder.size(2);
request.source(builder);
SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
SearchHits hits = response.getHits();
System.out.println(hits.getTotalHits());
for(SearchHit hit:hits){
System.out.println(hit.getSourceAsString());
}
//关闭Elasticsearch客户端
esClient.close();
}
在这里插入图片描述
模糊查询
@Test
public void doc\_search\_match\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
SearchRequest request = new SearchRequest();
request.indices("student");
request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("name","王")));
SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
SearchHits hits = response.getHits();
System.out.println(hits.getTotalHits());
for(SearchHit hit:hits){
System.out.println(hit.getSourceAsString());
}
//关闭Elasticsearch客户端
esClient.close();
}
在这里插入图片描述
删除文档数据
@Test
public void doc\_delete\_test() throws IOException {
//创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost",9200,"http"))
);
DeleteRequest request = new DeleteRequest();
request.index("student").id("10000");
DeleteResponse response = esClient.delete(request, RequestOptions.DEFAULT);
System.out.println(response.getResult());
//关闭Elasticsearch客户端
esClient.close();
}原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
评论
登录后参与评论
推荐阅读
目录
相关产品与服务
Elasticsearch Service
腾讯云 Elasticsearch Service（ES）是云端全托管海量数据检索分析服务，拥有高性能自研内核，集成X-Pack。ES 支持通过自治索引、存算分离、集群巡检等特性轻松管理集群，也支持免运维、自动弹性、按需使用的 Serverless 模式。使用 ES 您可以高效构建信息检索、日志分析、运维监控等服务，它独特的向量检索还可助您构建基于语义、图像的AI深度应用。
腾讯云开发者
