//查询删除

@Test

public void test8() 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));

//查询删除

BulkByScrollResponse response = DeleteByQueryAction.INSTANCE

.newRequestBuilder(client)

.filter(QueryBuilders.matchQuery("title", "数据"))

.source("index1")

.get();

//删除文档的个数

long counts = response.getDeleted();

System.out.println(counts);

}

//match_all

@Test

public void test9() 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));

//查询所有

QueryBuilder qb = QueryBuilders.matchAllQuery();

SearchResponse sr = client.prepareSearch("lib3")

.setQuery(qb)

.setSize(3).get();

SearchHits hits = sr.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));

}

}

}