ElasticSearch（五）：Java操作ElasticSearch执行查询

package com.gxy.ESChap01;  2 
import java.net.InetAddress;  4 
import org.elasticsearch.action.search.SearchRequestBuilder;  6 import org.elasticsearch.action.search.SearchResponse;  7 import org.elasticsearch.client.transport.TransportClient;  8 import org.elasticsearch.common.settings.Settings;  9 import org.elasticsearch.common.transport.InetSocketTransportAddress;  10 import org.elasticsearch.index.query.QueryBuilder;  11 import org.elasticsearch.index.query.QueryBuilders;  12 import org.elasticsearch.search.SearchHit;  13 import org.elasticsearch.search.SearchHits;  14 import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;  15 import org.elasticsearch.search.sort.SortOrder;  16 import org.elasticsearch.transport.client.PreBuiltTransportClient;  17 import org.junit.After;  18 import org.junit.Before;  19 import org.junit.Test;  20 
public class ESQuery {  22     private static String host="192.168.56.3"; // 服务器地址
    private static int port=9300; // 端口
    
    public static final String CLUSTER_NAME = "my-application"; //集群名称
    
    private TransportClient client=null;  28     
    private static Settings settings= Settings.builder()  30             .put("cluster.name",CLUSTER_NAME)  31             .put("client.transport.sniff", true)  32  .build();  33     
    //获取客户端
    @SuppressWarnings({ "resource", "unchecked" })  36  @Before  37     public void getClient() throws Exception {  38         try {  39             client = new PreBuiltTransportClient(settings)  40                     .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host),port));  41         } catch (Exception e) {  42             // TODO Auto-generated catch block
 e.printStackTrace();  44  }  45  }  46     
    //关闭客户端
 @After  49     public void close() {  50         if(client!=null) {  51  client.close();  52  }  53  }  54     
    /**
 * 查询所有  57      */
 @Test  59     public void searchAll() {  60         SearchRequestBuilder srb=client.prepareSearch("film").setTypes("dongzuo");  61         SearchResponse sr=srb.setQuery(QueryBuilders.matchAllQuery()).execute().actionGet();//查询所有
        SearchHits hits=sr.getHits();  63         for(SearchHit hit:hits) {  64  System.out.println(hit.getSourceAsString());  65  }  66  }  67     /**
 * 分页查询  69      */
 @Test  71     public void searchPaging() {  72         SearchRequestBuilder srb=client.prepareSearch("film").setTypes("dongzuo");  73         SearchResponse sr=srb.setQuery(QueryBuilders.matchAllQuery()).setFrom(0).setSize(2).execute().actionGet();  74         SearchHits hits=sr.getHits();  75         for (SearchHit hit : hits) {  76  System.out.println(hit.getSourceAsString());  77  }  78  }  79     /**
 * 排序查询  81      */
 @Test  83     public void searchOrderBy() {  84         SearchRequestBuilder srb=client.prepareSearch("film").setTypes("dongzuo");  85         SearchResponse sr=srb.setQuery(QueryBuilders.matchAllQuery())  86                 .addSort("publishDate",SortOrder.DESC).execute().actionGet();  87         SearchHits hits=sr.getHits();  88         for (SearchHit hit : hits) {  89  System.out.println(hit.getSourceAsString());  90  }  91  }  92     /**
 * 数据列过滤查询  94      */
 @Test  96     public void searchInclude() {  97         SearchRequestBuilder srb=client.prepareSearch("film").setTypes("dongzuo");  98         SearchResponse sr=srb.setQuery(QueryBuilders.matchAllQuery())  99                 .setFetchSource(new String[] {"title","price"},null) 100  .execute() 101  .actionGet(); 102         SearchHits hits=sr.getHits(); 103         for (SearchHit hit : hits) { 104  System.out.println(hit.getSourceAsString()); 105  } 106  } 107     /*** 108  * 简单条件查询 109      */
 @Test 111     public void searchByCondition() { 112         SearchRequestBuilder srb=client.prepareSearch("film").setTypes("dongzuo"); 113         SearchResponse sr=srb.setQuery(QueryBuilders.matchQuery("title","铁")) 114                 .setFetchSource(new String[] {"title","price"},null) 115  .execute() 116  .actionGet(); 117         SearchHits hits=sr.getHits(); 118         for (SearchHit hit : hits) { 119  System.out.println(hit.getSourceAsString()); 120  } 121  } 122     /**
 * 条件查询高亮实现 124      */
 @Test 126     public void searchHighlight() { 127         SearchRequestBuilder srb=client.prepareSearch("film").setTypes("dongzuo"); 128         HighlightBuilder highlightBuilder=new HighlightBuilder(); 129         highlightBuilder.preTags("<h2>"); 130         highlightBuilder.postTags("</h2>"); 131         highlightBuilder.field("title"); 132         SearchResponse sr=srb.setQuery(QueryBuilders.matchQuery("title","战")) 133  .highlighter(highlightBuilder) 134                 .setFetchSource(new String[] {"title","price"},null) 135  .execute() 136  .actionGet(); 137         SearchHits hits=sr.getHits(); 138         for (SearchHit hit : hits) { 139  System.out.println(hit.getSourceAsString()); 140  System.out.println(hit.getHighlightFields()); 141  } 142  } 143     /**
 * 多条件查询 must 145      */
 @Test 147     public void searchMutil() { 148         SearchRequestBuilder srb =client.prepareSearch("film").setTypes("dongzuo"); 149         QueryBuilder queryBuilder=QueryBuilders.matchPhraseQuery("title", "战"); 150         QueryBuilder queryBuilder2=QueryBuilders.matchPhraseQuery("content", "星球"); 151         SearchResponse sr=srb.setQuery(QueryBuilders.boolQuery() 152  .must(queryBuilder) 153  .must(queryBuilder2)) 154  .execute() 155  .actionGet(); 156         SearchHits hits=sr.getHits(); 157         for (SearchHit hit : hits) { 158  System.out.println(hit.getSourceAsString()); 159  } 160  } 161     
    /**
 * 多条件查询 mustNot 164      */
 @Test 166     public void searchMutil2() { 167         SearchRequestBuilder srb =client.prepareSearch("film").setTypes("dongzuo"); 168         QueryBuilder queryBuilder=QueryBuilders.matchPhraseQuery("title", "战"); 169         QueryBuilder queryBuilder2=QueryBuilders.matchPhraseQuery("content", "武士"); 170         SearchResponse sr=srb.setQuery(QueryBuilders.boolQuery() 171  .must(queryBuilder) 172  .mustNot(queryBuilder2)) 173  .execute() 174  .actionGet(); 175         SearchHits hits=sr.getHits(); 176         for (SearchHit hit : hits) { 177  System.out.println(hit.getSourceAsString()); 178  } 179  } 180     
    /**
 * 多条件查询 should提高得分 183  * @throws Exception 184      */
 @Test 186     public void searchMutil3()throws Exception{ 187         SearchRequestBuilder srb=client.prepareSearch("film").setTypes("dongzuo"); 188         QueryBuilder queryBuilder=QueryBuilders.matchPhraseQuery("title", "战"); 189         QueryBuilder queryBuilder2=QueryBuilders.matchPhraseQuery("content", "星球"); 190         QueryBuilder queryBuilder3=QueryBuilders.rangeQuery("publishDate").gt("2018-01-01"); 191         SearchResponse sr=srb.setQuery(QueryBuilders.boolQuery() 192  .must(queryBuilder) 193  .should(queryBuilder2) 194  .should(queryBuilder3)) 195  .execute() 196  .actionGet(); 197         SearchHits hits=sr.getHits(); 198         for(SearchHit hit:hits){ 199             System.out.println(hit.getScore()+":"+hit.getSourceAsString()); 200  } 201  } 202     /*** 203  * 多条件查询 range限制范围 204      */
 @Test 206     public void searchMutil4() { 207         SearchRequestBuilder srb = client.prepareSearch("film").setTypes("dongzuo"); 208         QueryBuilder queryBuilder=QueryBuilders.matchPhraseQuery("title", "战"); 209         QueryBuilder queryBuilder2=QueryBuilders.rangeQuery("price").lte(40); 210         SearchResponse sr=srb.setQuery(QueryBuilders.boolQuery() 211  .must(queryBuilder) 212  .filter(queryBuilder2)) 213  .execute() 214  .actionGet(); 215         SearchHits hits=sr.getHits(); 216         for (SearchHit hit : hits) { 217  System.out.println(hit.getSourceAsString()); 218  } 219  } 220 }