目录
1 创建一个Springboot工程并加入相关的依赖
<dependencies>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.75</version>
</dependency>
<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.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
2 创建一个配置，获取ES工具类对象
@Configuration
public class ESConfig {
//该对象可以对我们的ES进行相关的操作
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost(“127.0.0.1″,9200,”http”)));
return client;
}
}
3 进行相关对ES操作
3.1 操作索引—创建索引
@Autowired
private RestHighLevelClient client
//创建索引
@Test
void testCreateIndex() throws Exception {
CreateIndexRequest createIndexRequest = new CreateIndexRequest("xzj");
CreateIndexResponse response = client.indices().create(createIndexRequest, RequestOptions.DEFAULT);
System.out.println(response.isAcknowledged());
}
3.2 操作索引–删除索引
//删除索引
@Test
public void tetsDeleteIndex()throws Exception{
DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("xzj");
AcknowledgedResponse delete = client.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
3.3 索引操作–判断索引是否存在
//判断是否存在
@Test
public void testIndexExists()throws Exception{
GetIndexRequest getIndexRequest = new GetIndexRequest("xzj");
boolean exists = client.indices().exists(getIndexRequest, RequestOptions.DEFAULT);
System.out.println(exists);
}
3.4 操作文档—添加文档
//添加文档--PUT /索引/1 {name:"",age:"",address:""}
//添加
@Test
public void testIndexDoc() throws Exception{
IndexRequest indexRequest = new IndexRequest("xzj");
indexRequest.id("2");
indexRequest.source(JSON.toJSONString(new User("李四","北京",21)), XContentType.JSON);
IndexResponse index = client.index(indexRequest, RequestOptions.DEFAULT);
System.out.println(index.getResult());
}
3.5 查询文档–id
//获取文档 GET /索引/_doc/1
@Test
public void testGetDoc()throws Exception{
GetRequest getRequest = new GetRequest("xzj");
getRequest.id("1");
GetResponse response = client.get(getRequest, RequestOptions.DEFAULT);
String string = response.getSourceAsString();
User user = JSON.parseObject(string, User.class);
System.out.println(user);
Map<String, Object> map = response.getSourceAsMap();
System.out.println(map);
}
3.6 判断文档是否存在
//判断索引文档是否存在
@Test
public void testExist()throws Exception{
GetRequest getRequest = new GetRequest("xzj");
getRequest.id("2");
boolean exists = client.exists(getRequest, RequestOptions.DEFAULT);
System.out.println(exists);
}
3.7 删除文档
//删除
@Test
public void testDelete()throws Exception{
DeleteRequest deleteRequest = new DeleteRequest("xzj");
deleteRequest.id("2");
DeleteResponse delete = client.delete(deleteRequest, RequestOptions.DEFAULT);
System.out.println(delete.getResult());
}
3.8 修改文档
@Test
public void testUpdate() throws Exception{
UpdateRequest updateRequest = new UpdateRequest("xzj","2");
User user = new User();
user.setAge(18);
updateRequest.doc(JSON.toJSONString(user),XContentType.JSON);
UpdateResponse update = client.update(updateRequest, RequestOptions.DEFAULT);
System.out.println(update.getResult());
}
3.9 批量添加文档
//批量添加文档
@Test
public void testBulk()throws Exception{
BulkRequest bulkRequest = new BulkRequest("xzj");
List<User> list = new ArrayList<>();
list.add(new User("2","李四","上海",12));
list.add(new User("3","王五","北京",13));
list.add(new User("4","小王","苏州",16));
list.add(new User("5","赵六","南京",26));
list.add(new User("6","小赵","长沙",23));
list.stream().forEach(item->bulkRequest.add(new IndexRequest()
.id(item.getId()).source(JSON.toJSONString(item),XContentType.JSON)));
// for (User user:list){
IndexRequest indexRequest = new IndexRequest();
indexRequest.id(user.getId());
indexRequest.source(JSON.toJSONString(user),XContentType.JSON);
bulkRequest.add(indexRequest);
// bulkRequest.add(new IndexRequest().id(user.getId()).source(JSON.toJSONString(user),XContentType.JSON));
//
// }
BulkResponse bulk = client.bulk(bulkRequest, RequestOptions.DEFAULT);
System.out.println(bulk.hasFailures());
}
3.10 复杂查询
//搜索查询—GET /索引/_search
// {
// “query”:{
// “”:{}
// },
// “from”:
// “size”:
// “_source”:[“”,””],
// “sort”:{}// }
//1. 搜索请求对象SearchRequest
//2. 构建一个条件对象SearchSourceBuilder
//3. 把条件对象放入搜索请求对象中
//4. 执行搜索功能
//复杂查询
@Test
public void testSearch()throws Exception{
SearchRequest searchRequest = new SearchRequest("xzj");
SearchSourceBuilder searchBuilder = new SearchSourceBuilder();
MatchQueryBuilder matchQuery = QueryBuilders.matchQuery("name", "王");
searchBuilder.query(matchQuery);
searchBuilder.from(0);
searchBuilder.size(2);
searchBuilder.sort("age");
HighlightBuilder highlightBuilder = new HighlightBuilder();
highlightBuilder.field("name");
highlightBuilder.preTags("<p color='red'>");
highlightBuilder.postTags("</p>");
searchBuilder.highlighter(highlightBuilder);
searchRequest.source(searchBuilder);
SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);
System.out.println("总条数:"+search.getHits().getTotalHits().value);
SearchHit[] hits = search.getHits().getHits();
Arrays.stream(hits).forEach(item-> System.out.println(item.getSourceAsString()));
Arrays.stream(hits).forEach(item-> System.out.println(item.getHighlightFields()));
}