<dependencies><dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-elasticsearch</artifactId><version>2.0.4.RELEASE</version></dependency><dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-elasticsearch</artifactId><version>2.0.4.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>4.2.8.RELEASE</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>1.7.12</version></dependency></dependencies>

<?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.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/data/elasticsearchhttp://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch-1.0.xsd "><!-- 扫描DAO包 自动创建实现 --><elasticsearch:repositories base-package="com.baidu.dao" /><!-- 扫描Service包 --><context:component-scan base-package="com.baidu.service" /><!-- 配置elasticsearch 连接 --><elasticsearch:transport-client id="client" cluster-nodes="localhost:9300" /><!-- spring data elasticsearch DAO 必须依赖 elasticsearchTemplate  --><bean id="elasticsearchTemplate" class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate"><constructor-arg name="client" ref="client" /></bean></beans>

package com.baidu.test01;import org.elasticsearch.client.Client;
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.Sort;
import org.springframework.data.domain.Sort.Direction;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import com.baidu.domain.Article;
import com.baidu.service.ArticleService;@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext.xml")
public class Demo01 {@Autowiredprivate ArticleService articleService;@Autowiredprivate Client client; // 基于原生API@Autowiredprivate ElasticsearchTemplate elasticsearchTemplate;@Test  public void createIndex() {//创建索引elasticsearchTemplate.createIndex(Article.class);//创建映射elasticsearchTemplate.putMapping(Article.class);}@Test  //创建文档public void createDoc() {for (int i = 2; i < 20; i++) {Article ac=new Article();ac.setId(i);ac.setTitle("testSave"+i);ac.setContent("仅仅只是在测试test"+i);//文档操作articleService.save(ac);}}@Test  //查询文档public void searchDoc() {//文档操作articleService.findAll();}@Test  //查询文档public void searchDoc01() {//文档操作articleService.findById(1);}@Test  //查询文档public void searchDoc02() {//模糊查询articleService.findByTitle("testsave");}@Test  //查询文档public void searchDoc03() {PageRequest pr=new PageRequest(0, 4,new Sort(Direction.DESC, "id"));//分页查询  按照降序排序articleService.findAll(pr);}
}

package com.baidu.service;import org.springframework.data.domain.PageRequest;import com.baidu.domain.Article;public interface ArticleService {void save(Article ac);void findAll();void findById(Integer i);void findAll(PageRequest pr);void findByTitle(String string);}　

package com.baidu.service.imp;import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.WildcardQueryBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction;
import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;
import org.springframework.data.elasticsearch.core.query.SearchQuery;
import org.springframework.stereotype.Service;import com.baidu.dao.ArticleDao;
import com.baidu.domain.Article;
import com.baidu.service.ArticleService;@Service
public class ArticleServiceImp implements ArticleService{@Autowiredprivate ArticleDao articleDao;public void save(Article ac) {articleDao.save(ac);}public void findAll() {Iterable<Article> all = articleDao.findAll();for (Article article : all) {System.out.println(article);}}public void findById(Integer i) {Article article = articleDao.findById(i);System.out.println(article);}public void findAll(PageRequest pr) {Page<Article> page = articleDao.findAll(pr);System.out.println(page.getContent());}public void findByTitle(String string) {//需要根据内容的分词进行查询QueryBuilder query= new WildcardQueryBuilder("title", "*"+string+"*");SearchQuery searchQuery = new NativeSearchQuery(query);PageRequest pr=new PageRequest(0, 4,new Sort(Direction.DESC, "id"));searchQuery.setPageable(pr);Page<Article> page = articleDao.search(searchQuery);System.out.println(page.getContent());}}

package com.baidu.dao;import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;import com.baidu.domain.Article;public interface ArticleDao extends ElasticsearchRepository<Article, Integer> {Article findById(Integer i);
}