引入依赖
<?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 ">
<!--配置Client-->
<elasticsearch:transport-client id="esClient" cluster-name="elasticsearch"
cluster-nodes="127.0.0.1:9300"/>
<!--Dao包扫描-->
<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));
}
}
