1、搭建工程
<?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;
@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));
}
@Test
public void findById(){
Optional<Article> optional = articleDao.findById(1l);
Article article = optional.get();
}
}
自定义查询方法
- 这里有自定义查询方法的命名规则
- 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;
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);
}
@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);
}