创建项目
问题：一定要保证 我们的导入的依赖和我们的es 版本一致
代码语言：javascript复制<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.5.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com</groupId>
<artifactId>esapi</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>esapi</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
自定义es版本，和我们安装的es版本一样
<elasticsearch.version>7.6.1</elasticsearch.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-configuration-processor</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.60</version>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>配置config
//这个是官网里面的配置，就是利用这个配置类，让我们的代码和我们的软件连接
@Configuration
public class ElasticSearchConfig {
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient Client = new RestHighLevelClient(
RestClient.builder(new HttpHost("127.0.0.1",9200,"http"))
如果是集群就构建多个
);
return Client;
}
}以上就是我们在项目里面添加了es，之后就可用代码操作es了
将配置类导入测试类里面进行使用
// 将配置类引入,利用这个配置类里面的方法对软件进行增删改查
@Autowired
@Qualifier("restHighLevelClient")
private RestHighLevelClient client;分析源码
我们在项目里面导入es的依赖之后，就要使用人家es里面的类，这个类是人家es定义的，我们拿来使用就行。那么这个es框架有多少自己的类可以让我们使用呢？
spring框架有自己的自动配置类，只要我们导入对应的依赖，比如es的依赖，那么spring框架就根据这个自己的自动配置类，将es的所有的东西都导入，之后我们就直接拿es的东西用就可以了。
我们现在是已经在项目里面导入了es的依赖，那么spring框架是如何利用自动配置类将es所有东西都引入到项目里面呢？我们现在先看spring框架的自动配置类
以上是找到了spring框架的自动配置类，我们打开org文件夹，一直往下点。现在我们要自动配置es，那么找es
以上代码里面 就自动的导入了这些类
这些类都在data文件夹下面
根据自动配置类，我们可以看到，以后我们在yml里面配置es的时候，我们要加前缀 spring.data.elasticsearch
之后的属性就是这个类里面的各种各样的属性
以上的就是es的源码，里面有很多的类，我们拿来就可以用，现在我们的项目里面要使用的是
就是以上源码中的3个类，我们拿来就可以使用了。我们现在项目里面要使用的是高级客户端，也就是第二个配置类
我们重写了第二个类，就是为了要和我们的es软件相连接
代码语言：javascript复制//这个是官网里面的配置，就是利用这个配置类，让我们的代码和我们的软件连接
@Configuration
public class ElasticSearchConfig {
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient Client = new RestHighLevelClient(
RestClient.builder(new HttpHost("127.0.0.1",9200,"http"))
);
return Client;
}
}代码操作es
已经在代码里面写了配置类，我们拿到这个配置类的对象，就是拿到和es软件连接的通道了
代码语言：javascript复制 // 将配置类引入,利用这个配置类里面的方法对软件进行增删改查
@Autowired
@Qualifier("restHighLevelClient") 里面写的是配置类里面的方法
private RestHighLevelClient client;以上就是在代码里面注入了这个配置类，之后使用client 就可以操作es了
创建索引（相当于创建数据库）
es的6.8.4 版本，我们创建索引的时候，要创建实体类，实体类上面要写索引的名字，之后执行代码 就可以创建索引了。 现在的es的版本是7.6.1 ，要创建索引，写法是：
代码语言：javascript复制@SpringBootTest
class EsapiApplicationTests {
// 将配置类引入,利用这个配置类里面的方法对软件进行增删改查
@Autowired
@Qualifier("restHighLevelClient")
private RestHighLevelClient client;
// 测试索引的创建
@Test
void testCreateIndex() throws IOException {
// 1、创建索引请求
CreateIndexRequest request = new CreateIndexRequest("jing");
// 2、客户端client执行请求 IndicesClient对象,请求后获得响应
CreateIndexResponse createIndexResponse =
client.indices().create(request, RequestOptions.DEFAULT);
System.out.println(createIndexResponse);
}
}执行完以上的代码，那么就可以创建索引了。
返回的信息是：
我们看看是不是已经创建了
已经创建索引，相当于已经创建数据库了。
判断索引在不在
代码语言：javascript复制 // 测试获取索引,判断其是否存在
@Test
void testExistIndex() throws IOException {
GetIndexRequest request = new GetIndexRequest("jing");
boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
删除索引
代码语言：javascript复制 // 删除索引
@Test
void testDeleteIndex() throws IOException {
DeleteIndexRequest request = new DeleteIndexRequest("jing");
AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
添加文档
1 先创建实体类
因为要往索引里面添加数据，所以一定要创建实体类
代码语言：javascript复制 // 向索引内添加文档
@Test
void testAddDoucument() throws IOException {
// 创建对象
User user = new User("靖", 3);
// 创建请求,这个索引要真实存在
IndexRequest request = new IndexRequest("jing");
// 规格 put /jing/_doc/1
request.id("1");
// 以下两个选择一个
request.timeout(TimeValue.timeValueSeconds(1));
request.timeout("1s");
// 将我们的数据放入请求 json
request.source(JSON.toJSONString(user), XContentType.JSON);
// 客户端发送请求 , 获取响应的结果
IndexResponse indexResponse = client.index(request,
RequestOptions.DEFAULT);
System.out.println(indexResponse.toString());
System.out.println(indexResponse.status());
// 对应我们命令返回的状态 CREATED
}
获取文档，判断是否存在
代码语言：javascript复制 // 获取文档，判断是否存在 get /index/doc/1
@Test
void testIsExists() throws IOException {
第一个参数是索引库名字，第二个参数是第几个文档，也就是id的值
GetRequest getRequest = new GetRequest("jing", "1");
// 不获取返回的 _source 的上下文了 也就是不获取_source里面的 数据
getRequest.fetchSourceContext(new FetchSourceContext(false));
不获取排序字段
getRequest.storedFields("_none_");
判断索引库里面id值的数据是不是存在
boolean exists = client.exists(getRequest, RequestOptions.DEFAULT);
System.out.println(exists);
}获取文档的信息，也就是查询数据
代码语言：javascript复制 // 获得文档信息
@Test
void testGetDocument() throws IOException {
GetRequest getRequest = new GetRequest("jing", "1");
GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
System.out.println(getResponse.getSourceAsString());
System.out.println(getResponse);
}
更新文档
代码语言：javascript复制 //跟新文档信息
@Test
void testUpdateRequest() throws IOException {
UpdateRequest updateRequest = new UpdateRequest("jing", "1");
updateRequest.timeout("1s");
User user = new User("jing说java", 18);
// 第二个参数是告诉什么类型的
updateRequest.doc(JSON.toJSONString(user), XContentType.JSON);
UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT);
System.out.println(updateResponse.status());
}
删除文档
代码语言：javascript复制 // 删除文档记录
@Test
void testDeleteRequest() throws IOException {
DeleteRequest request = new DeleteRequest("jing", "1");
request.timeout("1s");
DeleteResponse deleteResponse = client.delete(request, RequestOptions.DEFAULT);
System.out.println(deleteResponse.status());
}批量插入数据,批量更新和批量删除，
// 批量更新和批量删除，修改对应的请求就可以了 ,具体看代码
代码语言：javascript复制// 特殊的，真的项目一般都会批量插入数据！
@Test
void testBulkRequest() throws IOException {
BulkRequest bulkRequest = new BulkRequest();
bulkRequest.timeout("10s");
ArrayList<User> userList = new ArrayList<>();
userList.add(new User("jing1", 3));
userList.add(new User("jing2", 3));
userList.add(new User("jing3", 3));
userList.add(new User("lu1", 3));
userList.add(new User("liu2", 3));
userList.add(new User("liu3", 3));
// 批处理请求
for (int i = 0; i < userList.size(); i ) {
// 批量更新和批量删除，就在这里修改对应的请求就可以了
bulkRequest.add(
new IndexRequest("jing").id("" (i 1))
.source(JSON.toJSONString(userList.get(i)),
XContentType.JSON));
}
BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
System.out.println(bulkResponse.hasFailures());
// 是否失败，返回 false 代表 成功！
}
// 是否失败，返回 false 代表 成功！
查询
代码语言：javascript复制// 查询
// SearchRequest 搜索请求
// SearchSourceBuilder 条件构造
// HighlightBuilder 构建高亮
// TermQueryBuilder 精确查询
// MatchAllQueryBuilder
// xxx QueryBuilder 对应我们刚才看到的命令！
@Test
void testSearch() throws IOException {
要查询的数据库
SearchRequest searchRequest = new SearchRequest("jing");
// 构建搜索条件 ，以后条件对象都要放到这个对象里面
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.highlighter();
// 查询条件，我们可以使用 QueryBuilders 工具来实现
// QueryBuilders.termQuery 精确
//QueryBuilders.matchAllQuery() 匹配所有
创建条件对象 这个是精确查询对象
TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "jing1");
这个是创建 查询全部的对象
// MatchAllQueryBuilder matchAllQueryBuilder = QueryBuilders.matchAllQuery();
将条件对象放到 搜索条件对象里面
sourceBuilder.query(termQueryBuilder);
搜索条件对象里面设置时间
sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
将搜索条件对象 放到数据库对象里面
searchRequest.source(sourceBuilder);
执行搜索的对象
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
System.out.println(JSON.toJSONString(searchResponse.getHits()));
System.out.println("=================================");
}
