SpringBoot 集成 ES 使用API（一）
创建Client客户端
@Configuration
public class ESConfig {
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(
new HttpHost("127.0.0.1", 9200, "http")
)
);
return client;
}
}
测试类
@SpringBootTest
class EsApiApplicationTests {
@Autowired
@Qualifier("restHighLevelClient")
private RestHighLevelClient client;
}
索引API 使用
- 创建索引
//创建索引 client.indices().create
@Test
void testCreatedIndex() throws IOException {
//创建索引请求
CreateIndexRequest request = new CreateIndexRequest("caw_index");
//客户端执行请求 IndicesClient，请求获得响应
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
System.out.println(createIndexResponse);
}
//输出
//org.elasticsearch.client.indices.CreateIndexResponse@825209df
- 删除索引
//删除索引 client.indices().delete
@Test
void textDeleteIndex() throws IOException {
DeleteIndexRequest request = new DeleteIndexRequest("caw_index");
AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged()); //true
}
- 判断索引是否存在
//判断索引是否存在 client.indices().exists
@Test
void textExistIndex() throws IOException {
GetIndexRequest request = new GetIndexRequest("caw_index");
boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
文档API 使用
- 创建文档
//创建文档 client.index
@Test
void creteDocument() throws IOException {
User user = new User("李四", 34);
//创建请求 请求到具体的索引
IndexRequest request = new IndexRequest("caw_index");
//规则 put /caw_index/_doc/1
//设置文档id，不指定ES会随机产生
request.id("3");
request.timeout(TimeValue.timeValueSeconds(1));
request.timeout("1s");
//将User数据放入请求 json
request.source(JSON.toJSONString(user), XContentType.JSON);
//客户端发送请求，获取响应结果
IndexResponse response = client.index(request, RequestOptions.DEFAULT);
System.out.println(response.toString());
//IndexResponse[index=caw_index,type=_doc,id=id,version=1,result=created,seqNo=0,primaryTerm=1,shards={"total":2,"successful":1,"failed":0}]
System.out.println(response.status());
//CREATED
}
- 查看文档
//查看文档 client.get
@Test
void testGetDocument() throws IOException {
//查看 索引caw_index下id为1 的文档
GetRequest request = new GetRequest("caw_index","1");
GetResponse response = client.get(request, RequestOptions.DEFAULT);
//打印文档内容 {"age":34,"name":"李四"}
System.out.println(response.getSourceAsString());
//返回全部内容 和命令行一样
//{"_index":"caw_index","_type":"_doc","_id":"1","_version":1,"_seq_no":6,"_primary_term":1,"found":true,"_source":{"age":22,"name":"常奥文"}}
System.out.println(response);
}
- 判断文档是否存在
//判断文档是否存在 client.exists
@Test
void testIsExists() throws IOException {
GetRequest request = new GetRequest("caw_index", "1");
request.fetchSourceContext(new FetchSourceContext(false));
boolean exists = client.exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
- 修改文档
//修改文档 client.update
@Test
void testUpdateDocument() throws IOException {
UpdateRequest request = new UpdateRequest("caw_index", "1");
User user = new User("李四学java",23);
//将修改的内容放入请求体 也就是 doc中
request.doc(JSON.toJSONString(user), XContentType.JSON);
UpdateResponse response = client.update(request, RequestOptions.DEFAULT);
System.out.println(response.status());
}
- 删除文档
//删除文档 client.delete
@Test
void testDeleteDocument() throws IOException {
DeleteRequest request = new DeleteRequest("caw_index", "id");
request.timeout("1s");
DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);
System.out.println(response.status());
}
- 批量操作文档
//批量添加 BulkRequest client.bulk
@Test
void testBulkDocument() throws IOException {
BulkRequest request = new BulkRequest();
request.timeout("10s");
ArrayList<User> list = new ArrayList<>();
list.add(new User("请求", 11));
list.add(new User("亲戚", 13));
list.add(new User("融入", 10));
list.add(new User("一哦", 23));
list.add(new User("一样", 45));
list.add(new User("看看", 67));
list.add(new User("到底", 3));
for (int i = 0; i < list.size(); i++) {
request.add(new IndexRequest("caw_index")
.id(""+i)
.source(JSON.toJSONString(list.get(i)), XContentType.JSON));
}
client.bulk(request, RequestOptions.DEFAULT);
}
BulkRequest可执行多种操作 具体New相对应的请求
- 文档集合查询
//集合查询 SearchRequest client.search
@Test
void testSearchDocument() throws IOException {
SearchRequest request = new SearchRequest("caw_index");
//构建搜索条件
SearchSourceBuilder builder = new SearchSourceBuilder();
//查询条件 QueryBuilders
//精准搜索 termQuery
//所有搜索 matchAllQuery
//精准查询 name 包含 “一”
// TermQueryBuilder query = QueryBuilders.termQuery("name", "一");
//查询所有
MatchAllQueryBuilder allQuery = QueryBuilders.matchAllQuery();
builder.query(allQuery);
builder.from(0); //分页 pageIndex 有默认值
builder.size(5); //分页 pageSize
builder.sort("age", SortOrder.DESC); //排序
builder.timeout(new TimeValue(60, TimeUnit.SECONDS));
//将搜索条件 放入请求中
request.source(builder);
SearchResponse search = client.search(request, RequestOptions.DEFAULT);
System.out.println(JSON.toJSONString(search.getHits()));
System.out.println("=========================");
ArrayList<Object> list = new ArrayList<>();
for (SearchHit hit: search.getHits().getHits()) {
list.add(hit.getSourceAsString());
}
System.out.println(list);
}
