插入數(shù)據(jù)

Client client = null;
client = TransportClient.builder().build().addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("192.168.60.30"), 9300));
String[] in = {"reading","swiming"};        
Map map = new HashMap();
map.put("first_name", "詩詩");
map.put("last_name", "劉");
map.put("age", "22");
map.put("about", "can you guess?");
map.put("interests", in);
//插入數(shù)據(jù)
IndexResponse response = client.prepareIndex("wyg","employee","5").setSource(map).execute().actionGet();
client.close();

獲取數(shù)據(jù)

GetResponse response = client.prepareGet("wyg", "employee", "5").execute().actionGet();
Map<String,Object> map1 = new HashMap<String,Object>();
map1 = response.getSource();
if(map1==null){
    System.out.println("null");
}else{
    Iterator<Entry<String,Object>> iterator = map1.entrySet().iterator();
    while(iterator.hasNext()){
        Entry entry = iterator.next();
        System.out.println(entry.getKey()+":"+entry.getValue());
    }
}
client.close();

查詢

QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();

QueryBuilder queryBuilder = QueryBuilders.boolQuery().must(new QueryStringQueryBuilder("can you guess?").field("about"));
SearchResponse response = client.prepareSearch("wyg").setTypes("employee").setQuery(queryBuilder).execute().actionGet();
System.out.println("total:"+response.getHits().getTotalHits());
SearchHit[] searchHists = response.getHits().getHits();
if(searchHists.length>0){
    for(SearchHit hit:searchHists){
        System.out.println("about:"+hit.getSource().get("about"));
        System.out.println("first_name:"+hit.getSource().get("first_name"));
    }
}

SearchResponse response = client.prepareSearch("index1", "index2") 
//設(shè)置要查詢的索引(index) 
.setTypes("type1", "type2") 
//設(shè)置type, 這個在建立索引的時候同時設(shè)置了, 或者可以使用head工具查看 
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setetQuery(QueryBuilders.termQuery("multi", "test")) 
// Query 查詢之一."multi"是要查詢的field,"test"是要查詢的內(nèi)容
.setFilter(FilterBuilders.rangeFilter("age").from(12).to(18)) 
// Filter 查詢之二, 在這里"age"是要查詢的field, 后面的數(shù)字是查詢的條件范圍 
.setFrom(0).setSize(60).setExplain(true) 
//0-60 表示顯示數(shù)量 
.execute() 
.actionGet();

SearchResponse response = client.prepareSearch("wyg").setTypes("employee").execute().actionGet();

刪除

DeleteResponse response=client.prepareDelete("wyg", "employee", "1").execute().actionGet();

API詳解
java調(diào)用
rabbitmq