5.基本的索引 API操作 ⭐
(1).创建索引
package com.jsxs; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.client.indices.CreateIndexRequest; import org.elasticsearch.client.indices.CreateIndexResponse; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; import java.io.IOException; import static org.elasticsearch.client.RequestOptions.*; @SpringBootTest class JsxsEsApi01ApplicationTests { @Resource private RestHighLevelClient restHighLevelClient; // 测试索引的创建 Request @Test void testCreateIndex() throws IOException { // 1.创建一个索引叫做 kuang_index的索引对象请求 CreateIndexRequest request = new CreateIndexRequest("kuang_index"); // 2.执行创建索引的请求 获得响应 CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(request, DEFAULT); System.out.println(createIndexResponse); } }
(2).获取-删除 索引
package com.jsxs; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.support.master.AcknowledgedResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.client.indices.CreateIndexRequest; import org.elasticsearch.client.indices.CreateIndexResponse; import org.elasticsearch.client.indices.GetIndexRequest; import org.elasticsearch.client.indices.GetIndexResponse; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; import java.io.IOException; import static org.elasticsearch.client.RequestOptions.*; @SpringBootTest class JsxsEsApi01ApplicationTests { @Resource private RestHighLevelClient restHighLevelClient; @Test void contextLoads() { } // 测试索引的创建 Request @Test void testCreateIndex() throws IOException { // 1.创建一个索引叫做 kuang_index的索引对象请求 CreateIndexRequest request = new CreateIndexRequest("kuang_index"); // 2.执行创建索引的请求 获得响应 CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(request, DEFAULT); System.out.println(createIndexResponse); } // 测试获取索引的请求 @Test void testExistIndex() throws IOException { // 获取一个索引名叫做kuang_index的索引库 GetIndexRequest request = new GetIndexRequest("kuang_index"); // 2.判断这个索引库是否存在? boolean exists = restHighLevelClient.indices().exists(request, DEFAULT); System.out.println(exists); } // 删除指定的索引 @Test void testDeleteIndex() throws IOException { DeleteIndexRequest request = new DeleteIndexRequest("jsxs"); AcknowledgedResponse delete = restHighLevelClient.indices().delete(request, DEFAULT); System.out.println(delete.isAcknowledged()); } }
6.基本的文档API操作 ⭐
<!-- 引入我们的JSON包 --> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>2.0.26</version> </dependency>
(1).新增文档
package com.jsxs; import com.alibaba.fastjson2.JSON; import com.jsxs.pojo.User; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.support.master.AcknowledgedResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.client.indices.CreateIndexRequest; import org.elasticsearch.client.indices.CreateIndexResponse; import org.elasticsearch.client.indices.GetIndexRequest; import org.elasticsearch.client.indices.GetIndexResponse; import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.common.xcontent.XContentType; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; import java.io.IOException; import static org.elasticsearch.client.RequestOptions.*; @SpringBootTest class JsxsEsApi01ApplicationTests { @Resource private RestHighLevelClient restHighLevelClient; // 测试添加文档 @Test void testAddDocument() throws IOException { // 1.创建添加的对象 User user = new User("吉士先生", 3); // 2.创建索引请求操作 IndexRequest request = new IndexRequest("kuang_index"); // 3.规则 put 添加文档 // /索引/表/id request.id("1"); // 设置索引的id request.timeout(TimeValue.timeValueSeconds(1)); //设置过期时间为1秒 // 4.将我们的数据放入请求 json request.source(JSON.toJSONString(user), XContentType.JSON); // 5.客户端发送请求 IndexResponse index = restHighLevelClient.index(request, DEFAULT); // 6. System.out.println(index.toString()); System.out.println(index.status()); } }
(2).查看文档 (是否存在)
package com.jsxs; import com.alibaba.fastjson2.JSON; import com.jsxs.pojo.User; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.support.master.AcknowledgedResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.client.indices.CreateIndexRequest; import org.elasticsearch.client.indices.CreateIndexResponse; import org.elasticsearch.client.indices.GetIndexRequest; import org.elasticsearch.client.indices.GetIndexResponse; import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.common.xcontent.XContentType; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; import java.io.IOException; import static org.elasticsearch.client.RequestOptions.*; @SpringBootTest class JsxsEsApi01ApplicationTests { @Resource private RestHighLevelClient restHighLevelClient; // 获取文档,判断是否存在 get /索引/doc/id @Test void testIsExists() throws IOException { GetRequest getRequest = new GetRequest("kuang_index", "1"); // 不获取返回的 _source 的上下文了。 getRequest.fetchSourceContext(new FetchSourceContext(false)); getRequest.storedFields("_none_"); // 判断文档是否存在 boolean flag = restHighLevelClient.exists(getRequest, DEFAULT); System.out.println(flag); } }
(3).查看文档 (数据)
// 获取文档,判断是否存在 get /索引/doc/id @Test void testGetValue() throws IOException { GetRequest getRequest = new GetRequest("kuang_index", "1"); // 1.客户端请求获得数据 GetResponse getResponse = restHighLevelClient.get(getRequest, DEFAULT); // 2.打印我们的信息 System.out.println(getResponse.getSourceAsString()); }
(4).修改文档
根据索引和id
// 更新文档数据. @Test void testUpdateValue() throws IOException { // 1.更新索引为kuang_index的id为1的文档 UpdateRequest request = new UpdateRequest("kuang_index", "1"); // 2.设置超时的时间 request.timeout("1s"); User user = new User("aaaa", 111); // 3.第一个参数是: 转换为JSON对象，第二个参数是告诉别人我们是一个JSON类型 request.doc(JSON.toJSONString(user),XContentType.JSON); // 4.客户端请求修改得数据 UpdateResponse update = restHighLevelClient.update(request, DEFAULT); // 5.打印我们的信息 System.out.println(update.toString()); }
(5).删除文档
// 删除文档的记录 @Test void testDeleteRequest() throws IOException { DeleteRequest request = new DeleteRequest("kuang_index", "1"); // 1.假如请求超过1秒的话，那么就不再链接 request.timeout("1s"); // 2.请求客户端 DeleteResponse delete = restHighLevelClient.delete(request, DEFAULT); // 3.打印信息 System.out.println(delete.toString()); }
(6).批量(添加/删除/修改)文档
@Test void testBulkRequest() throws IOException { BulkRequest bulkRequest = new BulkRequest(); // 1.设置超时的时间 bulkRequest.timeout("10s"); // 2.利用链表存储数据 ArrayList<User> users = new ArrayList<>(); users.add(new User("jsxs1",1)); users.add(new User("jsxs2",2)); users.add(new User("jsxs3",3)); users.add(new User("jsxs4",4)); users.add(new User("jsxs5",5)); users.add(new User("jsxs6",6)); users.add(new User("jsxs7",7)); users.add(new User("jsxs8",8)); users.add(new User("jsxs9",9)); users.add(new User("jsxs10",10)); // 3.批量添加的操作 for (int i = 0; i < users.size(); i++) { // 批量更新和删除就在这里有一个区别 ⭐ bulkRequest.add(new IndexRequest("kuang_index") .id(""+i+1) .source(JSON.toJSONString(users.get(i)),XContentType.JSON) ); } // 4.客户端请求 BulkResponse bulk = restHighLevelClient.bulk(bulkRequest, DEFAULT); System.out.println(bulk.toString()); }
