济南网站改版云南seo网站关键词优化软件
在企业环境中，Elasticsearch的索引CRUD（创建Create、读取Read、更新Update、删除Delete）操作是非常基础且频繁使用的功能。这些操作对于管理和维护数据至关重要，尤其是在处理大规模数据集和需要实时搜索与分析的应用场景中。
目录
Mapping映射属性
索引库的CRUD
基于Kibana的DevTools
创建索引库和映射
查询索引库
修改索引库
删除索引库
基于Java客户端（Java REST Client）
初始化RestHighLevelClient
准备索引映射
创建索引库
删除索引库
查询索引库
在Elasticsearch中，Index就类似数据库表，Mapping映射就类似表的结构。我们要向es中存储数据，必须先创建Index和Mapping。
Mapping映射属性
Mapping是对索引库中文档的约束，常见的Mapping属性包括：
字段数据类型，常见的简单类型有：
1.字符串：text（可分词的文本）、keyword（精确值，例如：品牌、国家、ip地址）
2.数值：long、integer、short、byte、double、float
3.布尔：boolean
4.日期：date
5.对象：object index：是否创建索引，默认为true
6.analyzer：使用哪种分词器
7.properties：该字段的子字段信息
举例说明：（下面的json文档）
{"age": 21,"weight": 52.1,"isMarried": false,"info": "谢谢欣赏x","email": "zy@123.cn","score": [99.1, 99.5, 98.9],"name": {"firstName": "云","lastName": "赵"}
}对应的每个字段映射（Mapping）：
索引库的CRUD
基于Kibana的DevTools
创建索引库和映射
# 创建索引库
PUT /user
{"mappings": {"properties": {"info":{"type": "text","analyzer": "ik_smart","index": true},"age":{"type": "byte"},"email":{"type": "keyword","index": false},"name":{"type": "object","properties": {"firstName":{"type": "keyword"},"lastName":{"type": "keyword"}}}}}
}
实现效果如下：
查询索引库
GET /user实现效果如下：
修改索引库
倒排索引结构虽然不复杂，但是一旦数据结构改变（比如改变了分词器），就需要重新创建倒排索引，这简直是灾难。因此索引库一旦创建，无法修改mapping。
但是允许添加新的字段到mapping中
# 修改索引库
PUT /user/_mapping
{"properties": {"id": {"type": "byte"}}
}实现效果如下：
删除索引库
删除完后再查询
# 删除索引库
DELETE /user# 查询索引库
GET /user
实现效果如下：
说明删除成功
基于Java客户端（Java REST Client）
ES官方提供了各种不同语言的客户端，用来操作ES。这些客户端的本质就是组装DSL语句，通过http请求发送给ES。
新增一个测试项目es-demo（就一个普通的spring boot项目）
初始化RestHighLevelClient
在pom.xml添加es的依赖
<!-- es 依赖--><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.12.1</version></dependency><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.12.1</version></dependency>在elasticsearch提供的API中，与elasticsearch一切交互都封装在一个名为RestHighLevelClient的类中，必须先完成这个对象的初始化，建立与elasticsearch的连接。
private RestHighLevelClient client;/*** 创建ES客户端*/@BeforeEachvoid setUp() {client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://自己的虚拟机地址:9200")));}/*** 关闭ES客户端* @throws IOException*/@AfterEachvoid tearDown() throws IOException {if (client != null) {client.close();}}/*** 测试连接*/@Testvoid testConnection() {System.out.println("client = " + client);}运行测试连接，效果如下：
解读：连接ES客户端成功
接下来，对索引的CRUD是需要通过对映射来实现的。
准备索引映射
PUT /items
{"mappings": {"properties": {"id": {"type": "keyword"},"name":{"type": "text","analyzer": "ik_max_word"},"price":{"type": "integer"},"stock":{"type": "integer"},"image":{"type": "keyword","index": false},"category":{"type": "keyword"},"brand":{"type": "keyword"},"sold":{"type": "integer"},"commentCount":{"type": "integer","index": false},"isAD":{"type": "boolean"},"updateTime":{"type": "date"}}}
}基于Java客户端的CRUD代码基本分为三步：
1.创建Request对象。因为是创建索引库的操作，因此Request是CreateIndexRequest。
2.添加请求参数。其实就是Json格式的Mapping映射参数。因为json字符串很长，这里是定义了静态字符串常量MAPPING_TEMPLATE，让代码看起来更加优雅。
3.发送请求。client.indices()方法的返回值是IndicesClient类型，封装了所有与索引库操作有关的方法。例如创建索引、删除索引、判断索引是否存在等。
创建索引库
/*** 创建索引* @throws IOException*/@Testvoid testCreateIndex() throws IOException {// 1.创建Request对象CreateIndexRequest request = new CreateIndexRequest("items");// 2.准备请求参数request.source(MAPPING_TEMPLATE, XContentType.JSON);// 3.发送请求client.indices().create(request, RequestOptions.DEFAULT);}
为了验证索引是否创建成功，创建一个方法
/*** 判断索引是否存在* @throws IOException*/@Testvoid testGetIndex() throws IOException {// 1.创建Request对象GetIndexRequest request = new GetIndexRequest("items");// 2.发送请求boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);System.out.println("存在索引 = " + exists);}实现效果如下：
items索引创建成功
删除索引库
/*** 删除索引* @throws IOException*/@Testvoid testDeleteIndex() throws IOException {// 1.创建Request对象DeleteIndexRequest request = new DeleteIndexRequest("items");// 2.发送请求client.indices().delete(request, RequestOptions.DEFAULT);}调用前面的判断索引是否存在方法，实现效果如下：
删除索引items成功
查询索引库
就是修改判断索引是否存在方法，主要返回内容一大堆。
/*** 查询索引* @throws IOException*/@Testvoid testQueryIndex() throws IOException {// 1.创建Request对象GetIndexRequest request = new GetIndexRequest("items");// 2.发送请求GetIndexResponse getIndexResponse = client.indices().get(request, RequestOptions.DEFAULT);System.out.println("getIndexResponse = " + getIndexResponse);}
实现效果如下：
查询索引items成功
注意：开发项目使用的是基于基于Java客户端（Java REST Client）来开发的。基于Kibana的DevTools一般用来测试。