//term查询

@Test

public void test12() throws IOException, InterruptedException, ExecutionException {

//指定ES集群

Settings settings = Settings.builder().put("cluster.name","haijines").build();

//创建访问es服务器的客户端

TransportClient client = new PreBuiltTransportClient(settings)

.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.42.159"),9300));

//term查询

QueryBuilder builder = QueryBuilders.termQuery( "interests","changge");

SearchResponse response = client.prepareSearch("lib3")

.setQuery(builder)

.setSize(2)

.get();

SearchHits hits = response.getHits();

for(SearchHit hit : hits) {

System.out.println(hit.getSourceAsString());

Map<String, Object> map = hit.getSourceAsMap();

for(String key : map.keySet()) {

System.out.println("key="+map.get(key));

}

}

}

//terms查询

@Test

public void test13() throws IOException, InterruptedException, ExecutionException {

//指定ES集群

Settings settings = Settings.builder().put("cluster.name","haijines").build();

//创建访问es服务器的客户端

TransportClient client = new PreBuiltTransportClient(settings)

.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.42.159"),9300));

//terms查询

QueryBuilder builder = QueryBuilders.termsQuery( "interests","changge","lvyou");

SearchResponse response = client.prepareSearch("lib3")

.setQuery(builder)

.setSize(2)

.get();

SearchHits hits = response.getHits();

for(SearchHit hit : hits) {

System.out.println(hit.getSourceAsString());

Map<String, Object> map = hit.getSourceAsMap();

for(String key : map.keySet()) {

System.out.println("key="+map.get(key));

}

}

}