elasticsearch java API------批量添加索引

hudeya

　　elasticsearch java API------批量添加索引
1.
public void bulkupdate(){
　　 
BulkRequestBuilder bulkRequest = client.prepareBulk(); 
 
try {
bulkRequest.add(client.prepareIndex("productindex", "productindex", "2") 
       .setSource(XContentFactory.jsonBuilder() 
                   .startObject() 
                       .field("user", "kimchy2") 
                       .field("postDate", new Date()) 
                       .field("message", "trying out Elastic Search") 
                   .endObject() 
                 ) 
       );
bulkRequest.add(client.prepareIndex("productindex", "productindex", "3") 
       .setSource(XContentFactory.jsonBuilder() 
                   .startObject() 
                       .field("user", "kimchy3") 
                       .field("postDate", new Date()) 
                       .field("message", "another post") 
                   .endObject() 
                 ) 
       ); 
        
BulkResponse bulkResponse = bulkRequest.execute().actionGet(); 
if (bulkResponse.hasFailures()) { 
   //处理错误 
}
bulkRequest.request().requests().clear();
　　} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} 
 


}
2.
 
[java] view plaincopy 
 

• public void testBulkIndex() throws Exception {  
  
•   
  
•     NodeBuilder builder = NodeBuilder.nodeBuilder();  
  
•     String clusterName = PropertyManager.getContextProperty("cluster.name");  
  
•     builder.clusterName(clusterName);  
  
•     Node node = builder.node();  
  
•     Client client = node.client();  
  
•   
  
•     ObjectMapper mapper = new ObjectMapper();  
  
•   
  
•     List<Person> persons = new ArrayList<Person>();  
  
•   
  
•     List<IndexRequest> requests = new ArrayList<IndexRequest>();  
  
•   
  
•     for (int i = 0; i < 10; i++) {  
  
•         Person person = new Person();  
  
•         person.setAge(20 + i);  
  
•         person.setId(UUID.randomUUID().toString());  
  
•         person.setIsStudent(true);  
  
•         person.setName("张三" + i);  
  
•         person.setSex("男");  
  
•         persons.add(person);  
  
•   
  
•         String index = "user"; // 相当于数据库名  
  
•         String type = "tb_person"; // 相当于表名  
  
•   
  
•         String json = mapper.writeValueAsString(person);  
  
•   
  
•         IndexRequest request = client  
  
•                 .prepareIndex(index, type, person.getId()).setSource(json)  
  
•                 .request();  
  
•   
  
•         requests.add(request);  
  
•     }  
  
•   
  
•     BulkRequestBuilder bulkRequest = client.prepareBulk();  
  
•   
  
•     for (IndexRequest request : requests) {  
  
•         bulkRequest.add(request);  
  
•     }  
  
•   
  
•     BulkResponse bulkResponse = bulkRequest.execute().actionGet();  
  
•     if (bulkResponse.hasFailures()) {  
  
•         Assert.fail("批量创建索引错误！");  
  
•     }  
  
• }