学习ElasticSearch：Spring Data ElasticSearch

末蓝、 2023-06-18 06:59 11阅读 0赞

### 1、搭建工程 ###

*  导入依赖：这里是一个普通的maven工程

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.es</groupId>
        <artifactId>springdataes</artifactId>
        <version>1.0-SNAPSHOT</version>
        <properties>
            <maven.compiler.source>1.9</maven.compiler.source>
            <maven.compiler.target>1.9</maven.compiler.target>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.elasticsearch</groupId>
                <artifactId>elasticsearch</artifactId>
                <version>5.6.8</version>
            </dependency>
            <dependency>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>transport</artifactId>
                <version>5.6.8</version>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-databind</artifactId>
                <version>2.8.1</version>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-annotations</artifactId>
                <version>2.8.1</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.data</groupId>
                <artifactId>spring-data-elasticsearch</artifactId>
                <version>3.0.5.RELEASE</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.elasticsearch.plugin</groupId>
                        <artifactId>transport-netty4-client</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-test</artifactId>
                <version>5.0.4.RELEASE</version>
            </dependency>
        </dependencies>
    
    </project>

*  applicationContext.xml：这里属于spring的配置

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:content="http://www.springframework.org/schema/context" xmlns:elasticsearch="http://www.springframework.org/schema/data/elasticsearch" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/data/elasticsearch http://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch-1.0.xsd">
    
    
        <elasticsearch:transport-client id="esClient" cluster-name="my-elasticsearch" cluster-nodes="127.0.0.1:9301,127.0.0.1:9302,127.0.0.1:9303"/>
    
        <elasticsearch:repositories base-package="com.es.dao"/>
    
        <bean id="elasticsearchTemplate" class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
           <constructor-arg name="client" ref="esClient"/>
    
        </bean>
    </beans>

### 2、创建Entity类、dao ###

#### Entity ####

package com.es.entity;
    
    import lombok.Data;
    import org.springframework.data.annotation.Id;
    import org.springframework.data.elasticsearch.annotations.Document;
    import org.springframework.data.elasticsearch.annotations.Field;
    import org.springframework.data.elasticsearch.annotations.FieldType;
    
    @Document(indexName = "spring-es-blog",type = "article")
    @Data
    public class Article { 
        @Id
        @Field(type = FieldType.Long,store = true)
        private long id;
        @Field(type = FieldType.text,store = true,analyzer = "ik_smart")
        private String title;
        @Field(type = FieldType.text,store = true,analyzer = "ik_smart")
        private String content;
    }

#### dao层 ####

*  继承ElasticsearchRepository接口

package com.es.dao;
    
    import com.es.entity.Article;
    import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
    
    public interface ArticleDao extends ElasticsearchRepository<Article,Long> { 
    }

### 3、操作 ###

import com.es.dao.ArticleDao;
    import com.es.entity.Article;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    import java.util.Optional;
    
    /** * @ClassName SpringDataEsTest * @Description * @Author 戴书博 * @Date 2019/12/2 23:31 * @Version 1.0 **/
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:applicationContext.xml")
    public class SpringDataEsTest { 
    
        @Autowired
        private ArticleDao articleDao;
        @Autowired
        private ElasticsearchTemplate template;
    
        /** * 创建索引库 */
        @Test
        public void createIndex(){ 
            //创建索引、并配置映射关系。
            template.createIndex(Article.class);
            //仅配置映射
            template.putMapping(Article.class);
        }
    
        /** * 添加文档 */
        @Test
        public void addDocument(){ 
            Article article = new Article();
            article.setId(1l);
            article.setTitle("三严三实”专题教育");
            article.setContent("2015年4月10日，中共中央办公厅印发《关于在县处级以上领导干部中开展“三严三实”专题教育方案》");
            //把文档写入索引库
            articleDao.save(article);
        }
    
        /** * 删除文档 */
        @Test
        public void deleteDocument(){ 
            articleDao.deleteById(1l);
        }
    
        /** * 更新 */
        @Test
        public void updateDocument(){ 
            //先删除
            //再添加
        }
    
        /** * 简单查询 */
        @Test
        public void findAll(){ 
            Iterable<Article> articles =  articleDao.findAll();
            articles.forEach(a-> System.out.println(a));
        }
    
        /** * 根据id查询 */
        @Test
        public void findById(){ 
            Optional<Article> optional = articleDao.findById(1l);
            Article article = optional.get();
        }
    }

#### 自定义查询方法 ####

*  这里有自定义查询方法的命名规则  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU4ODQ5NQ_size_16_color_FFFFFF_t_70]
 *  dao 层

package com.es.dao;
    
    import com.es.entity.Article;
    import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
    
    import java.awt.print.Pageable;
    import java.util.List;
    
    /** * @ClassName ArticleDao * @Description * @Author 戴书博 * @Date 2019/12/2 23:24 * @Version 1.0 **/
    public interface ArticleDao extends ElasticsearchRepository<Article,Long> { 
        /** * 根据标题查询 */
        List<Article> findByTitle(String title);
    
        /** * 根据标题和内容查询 */
        List<Article> findByContentAndTitle(String content,String title);
    
        /** * 分页查询 */
        List<Article> findByContentAndTitle(String content, String title, Pageable pageable);
    
    }

*  查询方法

/** * 根据id查询 */
        @Test
        public void findById(){ 
            Optional<Article> optional = articleDao.findById(1l);
            Article article = optional.get();
        }
    
        @Test
        public void findByTitle(){ 
            List<Article> list = articleDao.findByTitle("哈哈");
            list.stream().forEach(a -> System.out.println(a));
        }
    
        @Test
        public void findByPage(){ 
            Pageable pageable = (Pageable) PageRequest.of(0,20);
            articleDao.findByContentAndTitle("ahh","dasda", pageable);
        }

*  原理是对搜索的内容先分词然后再进行查询，每个词之间都是and的关系。
 *  如果不想用and的关系，就需要使用原生的查询条件。

public void nativeSearchQuery(){ 
       //创建一个查询对象
        NativeSearchQuery query = new NativeSearchQueryBuilder()
                .withQuery(QueryBuilders.queryStringQuery("maven是一个").defaultField("title"))
                .withPageable(PageRequest.of(0,20)).build();
        //执行查询
         List<Article> list =  template.queryForList(query,Article.class);
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU4ODQ5NQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191203091632323.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU4ODQ5NQ==,size_16,color_FFFFFF,t_70