当前位置：首页 > news >正文

elasticsearch--RestClient操作索引库(java)

news 来源：原创 2024/9/21 8:17:20

参考：https://blog.csdn.net/CYK_byte/article/details/133255773

https://blog.csdn.net/weixin_45404884/article/details/137402463

java pom依赖：

        <dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.17.8</version></dependency>

测试案例：

测试类，开始是创建restClient。结束是关闭client

private RestHighLevelClient client;@BeforeEach
public void setUp() {client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http//127.0.0.1:9200")//将来如果是集群，这里还可以通过 HttpHost.create 继续连接多个节点));
}@AfterEach
public void tearDown() throws IOException {client.close();
}

这里我们创建一个测试类 HotelIndexTest ，用来演示 RestClient 操作的相关方法.
package com.gen.test.elc;import com.gen.test.elasticsearch.ElcTestApplication;
import org.apache.http.HttpHost;
import org.elasticsearch.action.DocWriteRequest;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.*;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.xcontent.XContentBuilder;
import org.elasticsearch.xcontent.XContentFactory;
import org.elasticsearch.xcontent.XContentType;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;import java.io.IOException;
import java.util.Date;@SpringBootTest(classes = ElcTestApplication.class)
public class HotelIndexTest {private RestHighLevelClient client;@BeforeEachpublic void setUp() {client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http//127.0.0.1:9200")//将来如果是集群，这里还可以通过 HttpHost.create 继续连接多个节点));}@AfterEachpublic void tearDown() throws IOException {client.close();}/*** 创建索引库* */private static final String MAPPING_TEMPLATE = "{\n" +"  \"mappings\": {\n" +"    \"properties\": {\n" +"      \"id\":{\n" +"        \"type\": \"keyword\"\n" +"      },\n" +"      \"name\":{\n" +"        \"type\": \"text\",\n" +"        \"analyzer\": \"ik_max_word\"\n" +"      },\n" +"      \"address\":{\n" +"        \"type\": \"keyword\",\n" +"        \"index\": false\n" +"      },\n" +"      \"price\":{\n" +"        \"type\": \"integer\"\n" +"      },\n" +"      \"score\":{\n" +"        \"type\": \"integer\"\n" +"      },\n" +"      \"brand\":{\n" +"        \"type\": \"keyword\"\n" +"      },\n" +"      \"city\":{\n" +"        \"type\": \"keyword\"\n" +"      },\n" +"      \"star_name\":{\n" +"        \"type\": \"keyword\"\n" +"      },\n" +"      \"business\":{\n" +"        \"type\": \"keyword\"\n" +"      },\n" +"      \"location\":{\n" +"        \"type\": \"geo_point\"\n" +"      },\n" +"      \"pic\":{\n" +"        \"type\": \"keyword\",\n" +"        \"index\": false\n" +"      }\n" +"    }\n" +"  }\n" +"}";@Testpublic void testCreateHotelIndex() throws IOException {RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://localhost:9200")));// 1.创建 Request 对象CreateIndexRequest request = new CreateIndexRequest("hotel");// 2.请求参数， MAPPING_TEMPLATE是静态常量字符串，内容是创建索引库的 DSL语句request.source(MAPPING_TEMPLATE, XContentType.JSON);// 3.发起请求CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);System.out.println(response);}/*** 删除索引库* */@Testpublic void testDeleteHotelIndex() throws IOException {RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://localhost:9200")));// 1.创建 Request对象DeleteIndexRequest request = new DeleteIndexRequest("hotel");// 2.发起请求AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);System.out.println(delete);}/*** 判断索引库是否存在* */@Testpublic void testExistsHotelIndex() throws IOException {RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://localhost:9200")));// 1.创建 Request对象GetIndexRequest request = new GetIndexRequest("hotel");// 2.发起请求boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);System.out.println(exists);}/*-----------------------------------文档操作----------------------------------------*//*** 添加酒店数据到索引库* */@Testpublic void testIndexDocument() throws IOException {// 创建Elasticsearch客户端RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")));try {// 构建请求Request request = new Request("POST", "/hotel/_doc/1"); // 自定义请求URLString template = "{\n" +"  \"name\": \"张三\",\n" +"  \"email\": \"zy@itcast.cn\"\n" +"}";request.setJsonEntity(template); // 设置请求体// 发送请求并处理响应Response response = client.getLowLevelClient().performRequest(request);int statusCode = response.getStatusLine().getStatusCode();if (statusCode == 200) { // 成功创建的状态码System.out.println("Document created successfully.");} else {System.err.println("Failed to create document. Status code: " + statusCode);}} finally {// 关闭客户端client.close();}}/***根据 id 查询酒店数据* */@Testpublic void testGetDocumentById() throws IOException {RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://localhost:9200")));// 1.创建 request对象GetRequest request = new GetRequest("hotel", "1");// 2.发送请求，得到结果GetResponse response = client.get(request, RequestOptions.DEFAULT);// 3.解析结果String json = response.getSourceAsString();System.out.println(json);client.close();}/*** 根据 id 修改酒店数据* */@Testpublic void testUpdateDocumentById() throws IOException {// 创建Elasticsearch客户端RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")));try {// 构建请求Request request = new Request("POST", "/hotel/_doc/1"); // 自定义请求URLString template = "{\n" +"  \"name\": \"张三\",\n" +"  \"email\": \"2312123@163.com\"\n" +"}";request.setJsonEntity(template); // 设置请求体// 发送请求并处理响应Response response = client.getLowLevelClient().performRequest(request);int statusCode = response.getStatusLine().getStatusCode();if (statusCode == 200) { // 成功创建的状态码System.out.println("Document created successfully.");} else {System.err.println("Failed to create document. Status code: " + statusCode);}} finally {// 关闭客户端client.close();}}/*** 根据 id 删除文档数据* */@Testpublic void testDeleteDocumentById() throws IOException {// 创建Elasticsearch客户端RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")));try {// 构建请求Request request = new Request("DELETE", "/hotel/_doc/1"); // 自定义请求URL// 发送请求并处理响应Response response = client.getLowLevelClient().performRequest(request);int statusCode = response.getStatusLine().getStatusCode();if (statusCode == 200) { // 成功创建的状态码System.out.println("Document created successfully.");} else {System.err.println("Failed to create document. Status code: " + statusCode);}} finally {// 关闭客户端client.close();}}}