一、环境搭建
1.1 新建模块，添加依赖
<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>
1.2 编写配置文件ElasticSearchClientConfig
@Configuration
public class ElasticSearchClientConfig {
//配置多个HttpHost就是集群
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(
new HttpHost("127.0.0.1",9200,"http")));
return client;
}
}
二、关于索引的操作API
2.1 创建索引
@SpringBootTest
@RunWith(SpringRunner.class)
class TicketSearchApplicationTests {
@Resource
@Qualifier("restHighLevelClient")
private RestHighLevelClient client;
//创建索引 通过Request请求
@Test
void testCreateIndex() throws IOException {
// 1.创建索引请求
CreateIndexRequest request = new CreateIndexRequest("movie_index");
// 2.客户端执行请求，请求后获得响应
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
System.out.println(createIndexResponse);
}
}
2.2 查询索引是否存在
//获取索引，判断其是否存在
@Test
void testExistIndex() throws IOException {
//获取
GetIndexRequest request = new GetIndexRequest("movie_index");
boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
2.3 删除索引
//删除索引
@Test
void testDeleteIndex() throws IOException {
DeleteIndexRequest request = new DeleteIndexRequest("movie_index");
//删除
AcknowledgedResponse delete = client.indices().delete(request,RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
三、关于文档的操作API
3.1 导入依赖 fastJson
查询返回数据为json数据，用于将其封装为String
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.75</version>
</dependency>
3.2 创建文档
// 添加文档
@Test
void testAddDocument() throws IOException {
// 创建对象
Movie movie = new Movie().setId(1).setName("唐人街探案2").setActor("刘昊然");
// 创建请求
IndexRequest request = new IndexRequest("movie_index");
// 规则 put/movie_index/_doc/1
request.id("1");
// 过期时间
//request.timeout("1s");
request.timeout(TimeValue.timeValueSeconds(10));
// 将我们的数据放入请求，格式必须为json
request.source(JSON.toJSONString(movie), XContentType.JSON);
// 客户端发送请求，获取响应结果
IndexResponse indexResponse = client.index(request, RequestOptions.DEFAULT);
System.out.println(indexResponse.toString());
//对应命令返回状态，新增：CREATED
System.out.println(indexResponse.status());
}
3.3 查询文档是否存在
// 获取文档，判断是否存在 get/index/_doc/1
@Test
void testIsExists() throws IOException {
GetRequest getRequest = new GetRequest("movie_index", "1");
// 不获取返回的 _source的上下文
// getRequest.fetchSourceContext(new FetchSourceContext(false));
// getRequest.storedFields("_");
boolean exists = client.exists(getRequest, RequestOptions.DEFAULT);
System.out.println(exists);
}
3.4 获取文档信息（查询单个）
// 获取文档信息
@Test
void testGetDocument() throws IOException{
GetRequest getRequest = new GetRequest("movie_index", "1");
GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
// 获取文档所需内容
System.out.println(getResponse.getSourceAsString());
// 返回文档所有内容
System.out.println(getResponse);
}
3.5 修改文档信息（改）
// 修改文档记录
@Test
void testUpdateDocument() throws IOException{
UpdateRequest updateRequest = new UpdateRequest("movie_index","1");
// 设置超时时间
updateRequest.timeout("1s");
Movie movie = new Movie().setId(1).setName("唐人街探案3").setActor("刘昊然");
// 修改文档内容
updateRequest.doc(JSON.toJSONString(movie),XContentType.JSON);
UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT);
// status为OK则修改成功
System.out.println(updateResponse.status());
}
3.6 删除文档信息
// 删除文档记录
@Test
void testDeleteDocument() throws IOException{
DeleteRequest request = new DeleteRequest("movie_index","1");
// 设置超时时间
request.timeout("1s");
DeleteResponse deleteResponse = client.delete(request, RequestOptions.DEFAULT);
// status为OK则删除成功
System.out.println(deleteResponse.status());
}
3.7 批量新增
// 批量新增文档
@Test
void testBulkRequest() throws IOException{
BulkRequest bulkRequest = new BulkRequest();
bulkRequest.timeout("10s");
ArrayList<Movie> movieList = new ArrayList<>();
// 假数据，以后从数据库里查出来
for (int i = 0; i < 10; i++) {
movieList.add(new Movie().setId(i).setName("唐人街探案" + i));
}
// 批处理请求
// 不设置id则会随机生成id
for (int i = 0; i < movieList.size(); i++) {
// 批量修改和批量删除，就在这里修改对应的请求(修改IndexRequest)就可以了
bulkRequest.add(
new IndexRequest("movie_index")
.id(""+(i+1))
.source(JSON.toJSONString(movieList.get(i)),XContentType.JSON));
}
BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
// 判断是否失败，成功返回false
System.out.println(bulkResponse.hasFailures());
}
3.8 按需批量查询（重点）
// 按需求查询多个文档信息
@Test
void testSearch() throws IOException {
SearchRequest searchRequest = new SearchRequest("movie_index");
// 构建搜索条件
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
// 查询条件，可以使用QueryBuilders来实现
// 查询所有
MatchAllQueryBuilder matchAllQueryBuilder = QueryBuilders.matchAllQuery();
// 根据条件精确查询
TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "唐人街探案3");
// 根据上边查询条件进行查询
sourceBuilder.query(matchAllQueryBuilder);
// 构建分页，从from:第几条数据开始（0为第一条），size:查询几条数据
sourceBuilder.from(0);
sourceBuilder.size(5);
// 放入请求中
searchRequest.source(sourceBuilder);
// 客户端发出请求，获取响应数据
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
// 获取返回数据
SearchHits hits = searchResponse.getHits();
// 遍历获取数据中每一个值
for (SearchHit documentFields : hits.getHits()) {
System.out.println(documentFields.getSourceAsMap());
}
}
- SearchRequest 搜索请求
- searchSourceBuilder 条件构造
- HighlightBuiLder 构建高亮
- TermQueryBuiLder 精确查询
- MatchAllQueryBuilder 全查询
若有收获，就点个赞吧
0 人点赞
