天天看点

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());
		}
}
           

继续阅读