//query String查询

@Test

public void tests() 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.160"),9300));

// QueryBuilder builder = QueryBuilders.commonTermsQuery("name", "zhaoliu");

// QueryBuilder builder = QueryBuilders.queryStringQuery("+changge -hejiu");//两个条件都得包含  +表示含有  -表示不含有

QueryBuilder builder = QueryBuilders.simpleQueryStringQuery("+changge -hejiu");//满足一个即可

SearchResponse response = client.prepareSearch("lib3")

.setQuery(builder)

.get();

SearchHits hits = response.getHits();

for(SearchHit hit : hits) {

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

}

}