SpringData--Elasticsearch

川长思鸟来 2021-08-27 16:34 369阅读 0赞

### 引入依赖 ###

<?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>org.example</groupId>
        <artifactId>ES_springData</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <properties>
            <maven.compiler.source>1.8</maven.compiler.source>
            <maven.compiler.target>1.8</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>org.apache.logging.log4j</groupId>
                <artifactId>log4j-to-slf4j</artifactId>
                <version>2.9.1</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-api</artifactId>
                <version>1.7.24</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-simple</artifactId>
                <version>1.7.21</version>
            </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.12</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</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

<?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:context="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="elasticsearch" cluster-nodes="127.0.0.1:9300"/>
        
        <elasticsearch:repositories base-package="pers.zhang.repository"/>
        
        <bean id="elasticsearchTemplate" class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
            <constructor-arg name="client" ref="esClient"/>
        </bean>
    
    </beans>

### 实体 ###

package pers.zhang.entity;
    
    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;
    
    /** * @Author: acton_zhang * @Date: 2020/3/14 3:30 下午 * @Version 1.0 */
    @Document(indexName = "article-index", type = "article")
    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;
    
        public Long getId() { 
            return id;
        }
    
        public void setId(Long id) { 
            this.id = id;
        }
    
        public String getTitle() { 
            return title;
        }
    
        public void setTitle(String title) { 
            this.title = title;
        }
    
        public String getContent() { 
            return content;
        }
    
        public void setContent(String content) { 
            this.content = content;
        }
    
        @Override
        public String toString() { 
            return "Article{" +
                    "id=" + id +
                    ", title='" + title + '\'' +
                    ", content='" + content + '\'' +
                    '}';
        }
    }

### Repository ###

package pers.zhang.repository;
    
    import org.springframework.data.domain.Pageable;
    import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
    import pers.zhang.entity.Article;
    
    
    import java.util.List;
    
    /** * @Author: acton_zhang * @Date: 2020/3/14 3:35 下午 * @Version 1.0 */
    public interface ArticleRepository extends ElasticsearchRepository<Article, Long> { 
    
        //根据标题进行查询
        List<Article> findByTitle (String title);
    
        List<Article> findByTitleOrContent (String title, String context);
    
        List<Article> findByTitleOrContent (String title, String context, Pageable pageable);
    }

### 测试 ###

import org.elasticsearch.index.query.QueryBuilders;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    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.query.NativeSearchQuery;
    import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    import pers.zhang.entity.Article;
    import pers.zhang.repository.ArticleRepository;
    
    import java.util.List;
    import java.util.Optional;
    
    /** * @Author: acton_zhang * @Date: 2020/3/14 3:38 下午 * @Version 1.0 */
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:applicationContext.xml")
    public class SpringDataElasticsearchTest { 
    
        @Autowired
        ArticleRepository articleRepository;
    
        @Autowired
        ElasticsearchTemplate elasticsearchTemplate;
    
        @Test
        public void createIndex () { 
            //创建索引，配置映射关系
            elasticsearchTemplate.createIndex(Article.class);
        }
    
        @Test
        public void addDocument () { 
            Article article = new Article();
            article.setId(1l);
            article.setTitle("Maven对象模型");
            article.setContent("佛教圣地六块腹肌塑料袋放假了撒");
            articleRepository.save(article);
        }
    
        @Test
        public void deleteById () { 
            articleRepository.deleteById(1l);
        }
    
        @Test
        //查询所有
        public void findAll () { 
            Iterable<Article> all = articleRepository.findAll();
            all.forEach( a -> System.out.println(a));
        }
    
    
        @Test
        //根据id查询
        public void findById () { 
            Optional<Article> byId = articleRepository.findById(2l);
            System.out.println(byId.get());
        }
    
        @Test
        public void findByTitle () { 
            List<Article> list = articleRepository.findByTitle("对象");
            list.forEach( a -> System.out.println(a));
        }
    
    
        @Test
        //多条件查询
        public void findByTitleOrContent () { 
            List<Article> list = articleRepository.findByTitleOrContent("ddd", "放假");
            list.forEach( a -> System.out.println(a));
        }
    
        @Test
        //分页查询
        public void findByPage () { 
            Pageable pageable = PageRequest.of(0, 2);
            List<Article> list = articleRepository.findByTitleOrContent("ddd", "放假", pageable);
            list.forEach( a -> System.out.println(a));
        }
    
    
        //原生查询
        @Test
        public void testNativeSearchQuery () { 
            NativeSearchQuery query = new NativeSearchQueryBuilder()
                    .withQuery(QueryBuilders.queryStringQuery("佛放假").defaultField("content"))
                    .withPageable(PageRequest.of(0, 5))
                    .build();
            List<Article> articles = elasticsearchTemplate.queryForList(query, Article.class);
            articles.forEach(a -> System.out.println(a));
    
        }
    }