elasticsearch全文检索java

/** * es全文检索java实现API * @author zxy * */

public class EsPersonDao {

/** * * @param index 查询的索引 * @param str 查询内容 * @param Page 页码 * @param Pagesize 每页显示条数 * @return SearchHits， json结构的结果集 */ public SearchHits FullTextQuery(String index,String str,int Page,int Pagesize){

//transportClient 为连接es集群的Client SearchRequestBuilder sr =transportClient.prepareSearch(index);

//query方式查询，条件为“all”，指所有可查询的field QueryBuilder queryBuilder=QueryBuilders.matchPhraseQuery("_all", str);

sr.setQuery(queryBuilder) .setFrom((Page-1)*Pagesize) .setSize(Pagesize) .execute() .actionGet();

//执行查询 SearchResponse response=sr.get();

//返回查询 SearchHits hits=response.getHits(); return hits; }

}

/** * es全文检索java实现API * @author zxy * */ public class EsPersonDao { /** * * @param index 查询的索引 * @param str 查询内容 * @param Page 页码 * @param Pagesize 每页显示条数 * @return SearchHits， json结构的结果集 */ public SearchHits FullTextQuery(String index,String str,int Page,int Pagesize){ //transportClient 为连接es集群的Client SearchRequestBuilder sr =transportClient.prepareSearch(index); //query方式查询，条件为“all”，指所有可查询的field QueryBuilder queryBuilder=QueryBuilders.matchPhraseQuery("_all", str); sr.setQuery(queryBuilder) .setFrom((Page-1)*Pagesize) .setSize(Pagesize) .execute() .actionGet(); //执行查询 SearchResponse response=sr.get(); //返回查询 SearchHits hits=response.getHits(); return hits; } }