这篇文章主要介绍“如何使用springData来操作es”，在日常操作中，相信很多人在如何使用springData来操作es问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”如何使用springData来操作es”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
公司主营业务：成都做网站、网站设计、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联推出陆川免费做网站回馈大家。
1 Es 的配置文件 elasticsearch.yml
http.cors.enabled: true
http.cors.allow-origin: "*"
network.host: 127.0.0.1
2 配置中文分词器 （见之前的博客）
3 导入jar
4.0.0
org.springframework.boot
spring-boot-starter-parent
2.1.7.RELEASE
com.example
demo
0.0.1-SNAPSHOT
demo
Demo project for Spring Boot
1.8
org.springframework.boot
spring-boot-starter
org.springframework.boot
spring-boot-starter-test
test
org.springframework.boot
spring-boot-starter-data-elasticsearch
org.springframework.boot
spring-boot-test
org.springframework.boot
spring-boot-maven-plugin
4 编写配置文件 (7.3 暂时springdata暂时不支持)
# elasticsearch-6.5.4 需要再配置文件配置上ip地址
spring.data.elasticsearch.cluster-name=elasticsearch
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300
#设置连接超时时间
spring.data.elasticsearch.properties.transport.tcp.connect_timeout=120s
5 实体类上增加注解
/**
* @author shihaifeng
* @date 2019-08-29 14:06
* @desc (描述)
**/
@Document(indexName = "book",type = "user")
public class Book implements Serializable{
@Id //主键
private Integer id;
@Field(type = FieldType.Text, analyzer = "ik_max_word")
private String name;
@Field(type = FieldType.Text, analyzer = "ik_max_word")
private String context;
@Field(type = FieldType.Text, analyzer = "ik_smart")
private String auto;
}6 编写接口
package com.example.demo.inter;
import com.example.demo.entity.Book;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @author shihaifeng
* @date 2019-08-29 14:47
* @desc (书接口 - 用来直接操作)
*
* Book 实体对象
* Integer 是主键
**/
public interface IBookServer extends ElasticsearchRepository {
}
7 测试
package com.example.demo;
import com.example.demo.entity.Book;
import com.example.demo.inter.IBookServer;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.SearchResultMapper;
import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;
import org.springframework.data.elasticsearch.core.aggregation.impl.AggregatedPageImpl;
import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.*;
;
/**
* @author shihaifeng
* @date 2019-08-29 14:52
* @desc (描述)
**/
@RunWith(SpringRunner.class)
@SpringBootTest
public class BookTest {
@Autowired
private IBookServer bookServer;
@Autowired
private ElasticsearchTemplate elasticsearchTemplate;
/**
* 添加数据
*/
@Test
public void addBook() {
//添加一条数据
bookServer.save(new Book(1, "书名", "书内容", "作者"));
List list = new ArrayList<>();
list.add(new Book(2, "《阿弥陀佛么么哒》", "大冰，本名焉冰，1980年10月23日出生于山东省烟台市莱阳市，中国内地主持人、民谣歌手、作家、油画画师，毕业于山东艺术学院。", "大冰"));
list.add(new Book(3, "《我不》", "善意能消戾，善意能得缘，善意能带业往生，善意能回头是岸。 善意能够帮人捕捉并建立起独特的幸福感。 “我不”是一种善意坦然，也是一种善意的随缘，更是一句善意的自省", "大冰"));
list.add(new Book(4, "《乖，摸摸头》", "是由主持人大冰所著，湖南文艺出版社的一本记录了大冰十余年的江湖游历，以及他和他朋友们的爱与温暖的传奇故事的书籍。", "大冰"));
list.add(new Book(5, "《他们最幸福》", "书中讲述的故事是有关于主角大冰一段十年的精彩生长之路，也是路途中十个不同他们幸福的故事，更是一段对当下价值观有形无声的生活抗议。 多栖身份的大冰，从主持人到民谣歌手，从江湖游侠到资深文青，他抱着一只手鼓行唱在天涯中，却从未将故事写在纸面上。", "大冰"));
list.add(new Book(6, "《边城》", "沈从文的创作风格趋向浪漫主义，他要求小说的诗意效果，融写实、纪梦、象征于一体，语言格调古朴，\n" +
"沈从文及其作品沈从文及其作品(5张)句式简峭、主干突出，单纯而又厚实，朴讷而又传神", "沈从文"));
list.add(new Book(7, "《湘行散记》", "沈从文是具有特殊意义的乡村世界的主要表现者和反思者，他认为“美在生命”，虽身处于虚伪、自私和冷漠的都市，却醉心于人性之美", "沈从文"));
list.add(new Book(8, "《长河》", "“我不知道为什么忽然爱上你了。”身为任课教师的沈从文悄悄地给学生张兆和写信，他在信里这么说。", "沈从文"));
bookServer.saveAll(list);//批量添加数据
}
/**
* 查询信息
*/
@Test
public void query() {
Optional book = bookServer.findById(3);
System.out.println("------------findById-----------------");
System.out.println(book.get().toString());
Iterable books = bookServer.findAll();
System.out.println("------------findAll-----------------");
for (Book book1 : books) {
System.out.println(book1);
}
System.out.println("------------search QueryBuilder-----------------");
Page search = bookServer.search(new TermQueryBuilder("context", "沈从文"), PageRequest.of(0, 10));
for (Book book1 : search.getContent()) {
System.out.println(book1);
}
System.out.println("------------search SearchQuery (高亮显示)-----------------");
NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(QueryBuilders.termQuery("context", "沈从文")) //设置查询内容
.withHighlightFields(new HighlightBuilder.Field("context").preTags("<前缀>").postTags("")).build() //设置高亮显示
.setPageable(PageRequest.of(0, 10));//设置分页信息
AggregatedPage page = elasticsearchTemplate.queryForPage(searchQuery, Book.class, new SearchResultMapper() {
@Override
public AggregatedPage mapResults(SearchResponse searchResponse, Class aClass, Pageable pageable) {
//返回结果集重新映射
List list = new ArrayList<>();
SearchHits hits = searchResponse.getHits();
Iterator iterator = hits.iterator();
while (iterator.hasNext()){
Book book = new Book();
SearchHit searchHit = iterator.next();
Map source = searchHit.getSourceAsMap();
book.setId(Integer.valueOf(source.get("id").toString()));//设置id
book.setName(source.get("name").toString());//设置书名
book.setAuto(source.get("auto").toString());//设置作者
Map highlightFields = searchHit.getHighlightFields();//获取高亮显示的列
book.setContext(highlightFields.get("context").toString());//设置高亮显示的列
System.out.println("高亮显示的值是 = " + highlightFields.get("context"));
list.add(book);
}
//返回查询的结果
return new AggregatedPageImpl(list);
}
});
List content = page.getContent();
System.out.println("查出的总数是 = " + content.size());
}
/**
* 跟新数据
*/
@Test
public void update(){
bookServer.save(new Book(1, "书名3", "书内容3", "作者3"));
}
/**
* 删除数据
*/
@Test
public void delete(){
bookServer.delete(new Book(1, "书名3", "书内容3", "作者3"));
}
}到此，关于“如何使用springData来操作es”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！
标题名称：如何使用springData来操作es
文章分享：
http://kswsj.cn/article/jsodip.html
