一：配置springdata-Es

elasticseach-JPA.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:mvc="http://www.springframework.org/schema/mvc"
       xmlns:jpa="http://www.springframework.org/schema/data/jpa"
       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-4.3.xsd
         http://www.springframework.org/schema/context
         http://www.springframework.org/schema/context/spring-context-4.3.xsd
         http://www.springframework.org/schema/mvc
         http://www.springframework.org/schema/mvc/spring-mvc-4.3.xsd
         http://www.springframework.org/schema/data/jpa
         http://www.springframework.org/schema/data/jpa/spring-jpa-1.8.xsd
         http://www.springframework.org/schema/data/elasticsearch
         http://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch-1.0.xsd
       ">
   <context:component-scan base-package="com.sf.heros.mq.consumer"/>   掃描包
    <elasticsearch:transport-client id="client" cluster-name="elasticsearch"
                                    cluster-nodes="127.0.0.1:9300" client-transport-sniff="false"/>  配置鏈接端口（默認的是9200，但是我們需要與之交互，要用到配置文件裏所寫那個端口，我的是9300）
    <elasticsearch:repositories base-package="com.sf.heros.mq.consumer.dao"  springdata操作ES的 接口類
                                elasticsearch-template-ref="elasticsearchTemplate"/>
    <bean name="elasticsearchTemplate"
          class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
        <constructor-arg name="client" ref="client" />  ES操作類
    </bean>

</beans>


2：接口類

UserDao。java（增刪改查方法 與其它springdata一致，findBy等等語法參考springdata）

public interface UserDao extends ElasticsearchRepository<User,Integer> {
    List<User> findByArticleInfId(Integer aid);
}

3：實體類

@Document(indexName = "article_inf_index", type = "articleInf")
@Setting(settingPath = "elasticsearch-analyser.json")
public class User implements Serializable {
    //elasticsearch
    @org.springframework.data.annotation.Id
    private Integer articleInfId;

    @Field(type = FieldType.String)//使用ngram進行單字分詞
    private String articleTitle;

    @Field(type = FieldType.Date, store = true, format = DateFormat.custom, pattern ="yyyy-MM-dd HH:mm:ss")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern ="yyyy-MM-dd HH:mm:ss")
    private Date releaseTime;

    public Integer getArticleInfId() {
        return articleInfId;
    }

    public void setArticleInfId(Integer articleInfId) {
        this.articleInfId = articleInfId;
    }

    public String getArticleTitle() {
        return articleTitle;
    }

    public void setArticleTitle(String articleTitle) {
        this.articleTitle = articleTitle;
    }

    public Date getReleaseTime() {
        return releaseTime;
    }

    public void setReleaseTime(Date releaseTime) {
        this.releaseTime = releaseTime;
    }

    @Override
    public String toString() {
        return "User{" +
                "articleInfId=" + articleInfId +
                ", articleTitle=‘" + articleTitle + ‘\‘‘ +
                ", releaseTime=" + releaseTime +
                ‘}‘;
    }
}


4:serverce

@Service("testService")
public class ElasticsearchService {
    @Autowired
    private UserDao userDao;
    public void add(User user){
        userDao.save(user);
    }
   
    public List<User> search(Integer aid){
        Pageable pageable=new Pageable() {
            @Override
            public int getNumberOfPages() {
                return 0;
            }

            @Override
            public PageFormat getPageFormat(int pageIndex) throws IndexOutOfBoundsException {
                return null;
            }

            @Override
            public Printable getPrintable(int pageIndex) throws IndexOutOfBoundsException {
                return null;
            }
        };
        return this.userDao.findByArticleInfId(aid);
    }

public User searchByQuery(User user){
        BoolQueryBuilder qb= QueryBuilders. boolQuery();
        qb.must(QueryBuilders.matchQuery("articleInfId",12));
        Iterable<User> search = userDao.search(qb);
        return search.iterator().next();
    }
}

BoolQueryBuilder方法：

1.matchAllQuery() matchAllQuery()方法用來匹配全部文檔
2.matchQuery("filedname","value")匹配單個字段，匹配字段名為filedname,值為value的文檔
3.multiMatchQuery(Object text, String... fieldNames)多個字段匹配某一個值

QueryBuilder queryBuilder = QueryBuilders.multiMatchQuery("music", "name", "interest");//搜索name中或interest中包含有music的文檔（必須與music一致）

4.wildcardQuery()模糊查詢 ?匹配單個字符，*匹配多個字符

5.使用BoolQueryBuilder進行復合查詢

使用must：

1. //模糊查詢
2. WildcardQueryBuilder queryBuilder1 = QueryBuilders.wildcardQuery(
3. "name", "*jack*");//搜索名字中含有jack的文檔
4. WildcardQueryBuilder queryBuilder2 = QueryBuilders.wildcardQuery(
5. "interest", "*read*");//搜索interest中含有read的文檔
7. BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
8. //name中必須含有jack,interest中必須含有read,相當於and
9. boolQueryBuilder.must(queryBuilder1);
10. boolQueryBuilder.must(queryBuilder2);

使用 should：

1. WildcardQueryBuilder queryBuilder1 = QueryBuilders.wildcardQuery(
2. "name", "*jack*");//搜索名字中含有jack的文檔
3. WildcardQueryBuilder queryBuilder2 = QueryBuilders.wildcardQuery(
4. "interest", "*read*");//搜索interest中含有read的文檔
6. BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
7. //name中含有jack或者interest含有read，相當於or
8. boolQueryBuilder.should(queryBuilder1);
9. boolQueryBuilder.should(queryBuilder2);

springdata -----操作ES