天天看點

ElasticSearch使用—多條件查詢

       ElasticSearch多條件查詢java api例子程式。

public class EsMulConditionQuery {


	private static String index = "imgdata_index";
	private static String type = "imgdata_type";


	public static void main(String[] args) {
		Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "elasticsearch")
				.put("client.transport.sniff", true)//開啟ES嗅探功能,確定叢集連上多個節點
				.build();
	    //建立用戶端
		TransportClient transportClient = new TransportClient(settings);
		//添加es的節點資訊,可以添加1個或多個
		TransportAddress transportAddress = new InetSocketTransportAddress("218.193.126.32", 9300);
		transportClient.addTransportAddresses(transportAddress);


		// 連接配接到的節點
		ImmutableList<DiscoveryNode> connectedNodes = transportClient.connectedNodes();
		for (DiscoveryNode discoveryNode : connectedNodes) {
			System.out.println(discoveryNode.getHostAddress());
		}
		// 多條件查詢
		BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
		//多條件設定
		boolQueryBuilder.must(QueryBuilders.matchPhraseQuery("PolicyCode", "5674504720"));
		boolQueryBuilder.must(QueryBuilders.matchPhraseQuery("ServiceId", "SE2"));
		//查詢建立
		SearchResponse searchResponse = transportClient.prepareSearch(index).setTypes(type).setQuery(boolQueryBuilder)
				.get();
        //擷取查詢結果
		SearchHits hits = searchResponse.getHits();
		long totalHits = hits.getTotalHits();
		System.out.println("總數目=" + totalHits);
		SearchHit[] hits2 = hits.getHits();
		for (SearchHit searchHit : hits2) {
			System.out.println(searchHit.getSourceAsString());
		}
}
           

繼續閱讀