分布式搜索elasticsearch java API 之（三）------索引操作

索引数据

es索引数据非常方便，只需构建个json格式的数据提交到es就行，下面是个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(); 

 

设置线程
     当删除api在同一个节点上执行时（在一个分片中执行一个api会分配到同一个服务器上），删除api允许执行前设置线程模式 （operationThreaded选项），operationThreaded这个选项是使这个操作在另外一个线程中执行，或在一个正在请求的线程 （假设这个api仍是异步的）中执行。默认的话operationThreaded会设置成true，这意味着这个操作将在一个不同的线程中执行。下面是设置成false的方法：

 

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();