elasticsearch操作模板Demo

package com.itheima.test; import com.itheima.entity.Article; import com.itheima.service.ArticleService; import org.elasticsearch.client.transport.TransportClient; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; 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.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.util.List; @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(locations = "classpath:applicationContext.xml") public class SpringDataESTest { @Autowired private ArticleService articleService; @Autowired private TransportClient client; @Autowired private ElasticsearchTemplate elasticsearchTemplate; /** * 创建索引 */ @Test public void creatIndex() { elasticsearchTemplate.createIndex(Article.class); elasticsearchTemplate.putMapping(Article.class); } /** * 删除索引 */ @Test public void deleteIndex() { elasticsearchTemplate.deleteIndex(Article.class); } /** * 创建文档 */ @Test public void saveArticle() { for (int i = 0; i < 10; i++) { Article article = new Article(); article.setId(i); article.setTitle(i + "测试SpringData ElasticSearch"); article.setContent(i + "Spring Data ElasticSearch 基于 spring data API 简化 elasticSearch操作，将原始操作elasticSearch的客户端API 进行封装Spring Data为Elasticsearch Elasticsearch项目提供集成搜索引擎"); articleService.save(article); } } /** * 更新文档 */ @Test public void updateArticle() { Article article = new Article(); article.setId(0); article.setTitle("update1" + "测试SpringData ElasticSearch"); article.setContent("update1" + "Spring Data ElasticSearch 基于 spring data API 简化 elasticSearch操作，将原始操作elasticSearch的客户端API 进行封装Spring Data为Elasticsearch Elasticsearch项目提供集成搜索引擎"); articleService.save(article); } /** * 删除文档 */ @Test public void deleteArticle() { Article article = new Article(); article.setId(0); articleService.delete(article); } /** * 删除文档 */ @Test public void findAllPage() { Pageable pageable = PageRequest.of(1, 10); Page<Article> all = articleService.findAll(pageable); for (Article article : all) { System.out.println(article.toString()); } } /** * 按条件查询 */ @Test public void findByTitle() { String condition = "版本"; List<Article> articles = articleService.findByTitle(condition); for (Article article : articles) { System.out.println(article.toString()); } } /** * 按条件分页查询 */ @Test public void findByTitlePage() { String condition = "版本"; Pageable pageable = PageRequest.of(0, 10); Page<Article> page = articleService.findByTitle(condition, pageable); List<Article> articles = page.getContent(); for (Article article : articles) { System.out.println(article.toString()); } } /** * 按条件查询补集 */ @Test public void findByTitleNot() { String condition = "版本1.1"; List<Article> articles = articleService.findByTitleNot(condition); for (Article article : articles) { System.out.println(article.toString()); } } }