分布式搜索elasticsearch java API 之(三)------索引操作
XContentBuilder doc = jsonBuilder() .startObject() .field("title", "this is a title!") .field("description", "descript what?") .field("price", 100) .field("onSale", true) .field("type", 1) .field("createDate", new Date()) .endObject(); client.prepareIndex("productIndex","productType").setSource(doc).execute().actionGet();
?
其中productIndex为索引库名,一个es集群中可以有多个索引库。productType为索引类型,是用来区分同索引库下不同类型的数据的,一个索引库下可以有多个索引类型。
?
删除索引数据
?
删除api允许从特定索引通过id删除json文档。有两种方法,一是通过id删除,二是通过一个Query查询条件删除,符合这些条件的数据都会被删除。
一、通过id删除
下面的例子是删除索引名为twitter,类型为tweet,id为1的文档:
?
DeleteResponse response = client .prepareDelete("twitter", "tweet", "1") .execute() .actionGet();?
?
二、通过Query删除
下面的例子是删除索引名为productIndex,title中包含query的所有文档:
?
QueryBuilder query = QueryBuilders.fieldQuery("title", "query");client.prepareDeleteByQuery("productIndex") .setQuery(query) .execute() .actionGet();?DeleteResponse response = client .prepareDelete("twitter", "tweet", "1") .setOperationThreaded(false) .execute() .actionGet();
?
?
使用Facets:
SearchResponse sr = node.client().prepareSearch() .setQuery(QueryBuilders.matchAllQuery()) .addFacet(FacetBuilders.termsFacet("f1").field("title")) .addFacet(FacetBuilders.dateHistogramFacet("f2") .field("price").interval("createDate")).execute().actionGet();TermsFacet f1 = (TermsFacet) sr.getFacets().facetsAsMap().get("f1");DateHistogramFacet f2 = (DateHistogramFacet)sr.getFacets().facetsAsMap().get("f2");
使用Percolate:
IndexResponse response = client.prepareIndex("twitter", "tweet", "1").setSource(jsonBuilder().startObject().field("user", "kimchy").field("postDate", new Date()).field("message", "trying out Elastic Search").endObject()).setPercolate("*").execute().actionGet();
?
?
?
?