![](https://ld246.com/images/img-loading.svg)
注入
@Autowired
private RestHighLevelClient restHighLevelClient;
测试创建索引
@Test
void testCreate() throws IOException {
//创建索引请求
CreateIndexRequest request = new CreateIndexRequest("yscxy_index");
//客户端执行请求
CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);
//打印返回信息!
System.out.println(createIndexResponse);
}
测试获取索引
@Test
void testExistIndex() throws IOException {
GetIndexRequest request = new GetIndexRequest("yscxy_index");
boolean exists = restHighLevelClient.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
测试删除索引
@Test
void testDeleteIndex() throws IOException {
DeleteIndexRequest request = new DeleteIndexRequest("yscxy_index");
AcknowledgedResponse delete = restHighLevelClient.indices().delete(request,RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
测试添加文档
@Test
void testAddDocument() throws IOException {
//创建对象
User user = new User("野生程序员", 3);
//创建请求
IndexRequest request = new IndexRequest("yscxy_index");
//规则 put/yscxy_index/_doc/1
request.id("1");
request.timeout(TimeValue.timeValueSeconds(1));
//或者这样设置
request.timeout("1s");
//将我们的数据放入请求 json
IndexRequest source = request.source(JSON.toJSONString(user), XContentType.JSON);
//客户端发送请求,获取响应的结果
IndexResponse indexResponse = restHighLevelClient.index(request, RequestOptions.DEFAULT);
System.out.println(indexResponse.toString());
System.out.println(indexResponse.status());
}
获取文档
@Test
void testExists() throws IOException {
GetRequest getRequest = new GetRequest("yscxy_index","1");
//不获取返回的_source的上下文
getRequest.fetchSourceContext(new FetchSourceContext(false));
getRequest.storedFields("_none_");
boolean exists = restHighLevelClient.exists(getRequest, RequestOptions.DEFAULT);
System.out.println(exists);
}
获取文档信息
@Test
void testGetDocument() throws IOException {
GetRequest getRequest = new GetRequest("yscxy_index","1");
GetResponse getResponse = restHighLevelClient.get(getRequest, RequestOptions.DEFAULT);
System.out.println(getResponse.getSourceAsString());
System.out.println(getResponse);
}
更新文档信息
@Test
void testUpdate() throws IOException {
UpdateRequest updateRequest = new UpdateRequest("yscxy_index","1");
updateRequest.timeout("1s");
User user = new User("野生程序员JAVA", 18);
updateRequest.doc(JSON.toJSONString(user),XContentType.JSON);
UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
System.out.println(updateResponse.status());
}
删除文档记录
@Test
void testDeleteRequest() throws IOException {
DeleteRequest deleteRequest = new DeleteRequest("yscxy_index", "1");
deleteRequest.timeout("1s");
DeleteResponse deleteResponse = restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);
//打印状态
System.out.println(deleteResponse.status());
}
大批量的插入,一般是数据库导入
@Test
void testBulkRequest() throws IOException {
BulkRequest bulkRequest = new BulkRequest();
bulkRequest.timeout("10s");
ArrayList<User> list = new ArrayList<>();
list.add(new User("大神",1));
list.add(new User("小弟",5));
list.add(new User("二哈",1));
list.add(new User("龙猫",15));
list.add(new User("小老鼠",21));
list.add(new User("老大",1));
list.add(new User("牛二",1));
list.add(new User("小傻子",11));
list.add(new User("大马猴",13));
//批量处理请求(批量更新修改等等都可以这样操作!)
for (int i = 0; i < list.size(); i++) {
bulkRequest.add(
new IndexRequest("yscxy_index")
.id(""+(i+1))//如果没有写id可以自动生成
.source(JSON.toJSONString(list.get(i)),XContentType.JSON)
);
}
BulkResponse bulkItemResponses = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
System.out.println(bulkItemResponses.hasFailures());//是否执行错误
}
查询
//查询
//SearchRequest 搜索请求
//SearchSourceBuilder 条件构造
@Test
void testSearch() throws IOException {
SearchRequest searchRequest = new SearchRequest("yscxy_index");
//构建搜索条件
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//查询条件,我们可以使用QueryBuilders工具来实现
//QueryBuilders.termQuery 精确匹配
TermQueryBuilder queryBuilders = QueryBuilders.termQuery("name","牛二");
searchSourceBuilder.query(queryBuilders);
//时间限制
searchSourceBuilder.timeout(new TimeValue(1, TimeUnit.SECONDS));
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
System.out.println(JSON.toJSONString(searchResponse.getHits()));
for (SearchHit s:searchResponse.getHits().getHits()) {
System.out.println(JSON.toJSONString(s));
}
}
}
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于