本文主要是介绍【Elasticsearch】es基础入门-02.RestClient操作索引库，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
RestClient操作索引库
示例：
一.分析数据结构，写索引库
#酒店的mapper
PUT /hotel
{"mappings": {"properties": {"id":{"type": "keyword"},"name":{"type": "text","analyzer": "ik_max_word","copy_to": "all"},"address":{"type": "keyword",#不参与搜索"index": false},"price":{"type":"integer"},"score":{"type":"integer"},"brand":{"type":"keyword","copy_to": "all"},"city":{"type":"keyword"},"star_name":{"type":"keyword"},"business":{"type":"keyword","copy_to": "all"},"location":{#地址坐标数据类型"type":"geo_point"},"pic":{"type":"keyword","index": false},#字段拷贝"all":{"type": "text","analyzer": "ik_max_word"}}}
}
小知识
（一）地址坐标数据类型
-
geo_point：由纬度(latitude)和经度(longitude)确定的一个点。例如:"32.8752345,120.2981576’ -
geo_shape”有多个geo_point组成的复杂几何图形。例如一条直线，“LINESTRING(-77.03653 38.897676,77.009051 38.889939)”
（二）数据拷贝
使用copy_to属性将当前字段拷贝到指定字段
二.初始化JavaRestClient
（一）引入es的RestHighLevelClient依赖
<!--elasticsearch-->
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId>
</dependency>
（二）因为SpringBoot默认的ES版本是7.6.2，所以我们需要覆盖默认的ES版本:
<properties><elasticsearch.version>7.17.21</elasticsearch.version>
</properties>
（三）新建一个测试类，初始化JavaRestClient
public class HotelIndexTest {private RestHighLevelClient client;@Testvoid testInit(){System.out.println(client);}/*** 在每个测试方法执行前设置测试环境。* 该方法初始化一个指向本地Elasticsearch实例的RestHighLevelClient。* 这样做是为了确保每个测试都在一个干净的环境中运行，不会相互干扰。* 使用@BeforeEach注解确保这个方法在每个测试方法执行前被调用。*/@BeforeEachvoid setUp() {// 创建一个新的RestHighLevelClient实例，配置为连接到本地Elasticsearch实例client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://192.168.174.129:9200")));}/*** 在每个测试方法执行后关闭HTTP客户端。* <p>* 此方法使用了JUnit的@AfterEach注解，确保在每个测试方法执行完毕后调用。* 它的主要目的是关闭HttpClient实例，以释放资源并避免潜在的资源泄露。* 由于HttpClient在多个测试方法中被共享，确保其在每个测试之后正确关闭是很重要的。* <p>* 方法抛出的IOException被声明为被抛出，但在这个上下文中被忽略。* 这是因为关闭客户端可能引发IO异常，但在这个阶段，我们更关心的是确保客户端关闭，* 而不是处理可能的异常。如果需要处理这些异常，可以在方法中添加相应的异常处理逻辑。** @throws IOException 如果关闭客户端时发生IO异常*/@AfterEachvoid tearDown() throws IOException {client.close();}
}
运行后，出现如下图结果：
三.使用代码创建索引库
映射模板：MAPPING_TEMPLATE中的内容就是步骤一写的索引库中的内容
public class HotelIndexConstants {public 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" +" \"copy_to\": \"all\"\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" +" \"copy_to\": \"all\"\n" +" },\n" +" \"city\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"starName\": {\n" +" \"type\": \"keyword\"\n" +" },\n" +" \"business\": {\n" +" \"type\": \"keyword\",\n" +" \"copy_to\": \"all\"\n" +" },\n" +" \"pic\": {\n" +" \"type\": \"keyword\",\n" +" \"index\": false\n" +" },\n" +" \"location\": {\n" +" \"type\": \"geo_point\"\n" +" },\n" +" \"all\": {\n" +" \"type\": \"text\",\n" +" \"analyzer\": \"ik_max_word\"\n" +" }\n" +" }\n" +" }\n" +"}";
}测试类
@Test
void testCreateIndex() throws IOException {// 1.准备Request PUT /hotelCreateIndexRequest request = new CreateIndexRequest("hotel");// 2.准备请求参数：DSL参数//MAPPING_TEMPLATE静态导入request.source(MAPPING_TEMPLATE, XContentType.JSON);// 3.发送请求client.indices().create(request, RequestOptions.DEFAULT);
}
运行测试类后：
若出现一下报错
[hotel/3L_3wWeHTvSZqCkpc7Rdpw] ElasticsearchStatusException[Elasticsearch exception [type=resource_already_exists_exception, reason=index [hotel/3L_3wWeHTvSZqCkpc7Rdpw] already exists]
]
是因为名为hotel的索引库已经存在,更改方法如下：
1.删除索引库
#es可视化平台elastic上删除索引库的命令
DELETE /hotel
2.更改测试类中索引库的名称
// 1.准备Request PUT /loveCreateIndexRequest request = new CreateIndexRequest("love");
四.创建索引库操作的结果
运行后
在es可视化平台elastic上，查看创建的索引库
五.删除索引库
@Test
void testDeleteIndex() throws IOException {// 1.准备RequestDeleteIndexRequest request = new DeleteIndexRequest("hotel");// 3.发送请求client.indices().delete(request, RequestOptions.DEFAULT);
}
六.判断索引库是否存在
@Test
void testExistsIndex() throws IOException {// 1.准备RequestGetIndexRequest request = new GetIndexRequest("hotel");// 3.发送请求boolean isExists = client.indices().exists(request, RequestOptions.DEFAULT);//输出System.out.println(isExists ? "存在" : "不存在");
}
先run删除操作，再run判断操作后：
这篇关于【Elasticsearch】es基础入门-02.RestClient操作索引库的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
