如何使用springData来操作es

这篇文章主要介绍“如何使用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”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！