elasticsearch Java接口汇总
服务器端和客户端的elasticsearch版本号须一致setExplain(true)设置是否按查询匹配度排序
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
public class Searcher {
private TransportClient client;
public void init(){
client = new TransportClient().addTransportAddress(
new InetSocketTransportAddress("10.18.6.90", 9300));// localhost9300
}
//生成索引
public void generateIndex() {
Map<String, Object> json = new HashMap<String, Object>();
json.put("user", "hdidkv");
json.put("postDate", new Date());
json.put("message", "哥大富大贵");
IndexResponse response = this.client
.prepareIndex("twitter", "tweet", "1")
.setSource(json)
.execute()
.actionGet();
}
//查看索引
public void getIndex() {
GetResponse response = client.prepareGet("twitter", "test", "1")
.execute().actionGet();
Map<String, Object> rpMap = response.getSource();
if (rpMap == null) {
System.out.println("empty");
return;
}
Iterator<Entry<String, Object>> rpItor = rpMap.entrySet().iterator();
while (rpItor.hasNext()) {
Entry<String, Object> rpEnt = rpItor.next();
System.out.println(rpEnt.getKey() + " : " + rpEnt.getValue());
}
}
//创建一个termQuery查询
public void searchIndex() {
QueryBuilder qb = QueryBuilders.termQuery("user", "hdidkv");
SearchResponse scrollResp = client.prepareSearch("twitter")
//.setSearchType(SearchType.SCAN)
.setTypes("tweet")
.setScroll(new TimeValue(60000))
.setQuery(qb)
.setSize(100).execute().actionGet(); //100 hits per shard will be returned for each scroll
//Scroll until no hits are returned
while (true) {
scrollResp = client.prepareSearchScroll(scrollResp.getScrollId()).
setScroll(new TimeValue(600000)).execute().actionGet();
System.out.println(scrollResp.getHits().getTotalHits());
for (SearchHit hit : scrollResp.getHits()) {
Iterator<Entry<String, Object>> rpItor = hit.getSource().entrySet().iterator();
while (rpItor.hasNext()) {
Entry<String, Object> rpEnt = rpItor.next();
System.out.println(rpEnt.getKey() + " 1:1 " + rpEnt.getValue());
}
}
if (scrollResp.getHits().hits().length == 0) {
break;
}
}
}
//删除索引
public void deleteIndex() {
DeleteResponse response = client.prepareDelete("twitter", "tweet", "1")
.execute().actionGet();
}
//关闭连接
public void closeClient() {
this.client.close();
}
//练习使用elasticsearch的Java接口
public static void main(String[] args) {
//TransportClient client = new TransportClient().addTransportAddress(new InetSocketTransportAddress("10.18.6.90", 9200));
Searcher searcher = new Searcher();
searcher.init();
searcher.generateIndex();
//searcher.getIndex();
searcher.searchIndex();
searcher.closeClient();
}
}
页:
[1]