Java做客户端对Elasticsearch服务的一些操作(三)

Myth丶恋晨 2022-05-27 00:16 129阅读 0赞

**代码:**

package com.east.operation;
    
    import org.elasticsearch.action.update.UpdateRequest;
    import org.elasticsearch.client.Client;
    import org.elasticsearch.common.xcontent.XContentFactory;
    
    /**
     * 更新索引
     * @author lhy
     * @date 2018.03.20
     */
    public class UpdateIndex {
        private Client client;
    
    	public UpdateIndex(Client client) {
    		super();
    		this.client = client;
    	}
        
    	/**
    	 * 创建一个UpdateRequest,然后将其发送给client.
    	 * @throws Exception
    	 */
    	public void Update() throws Exception{
    		UpdateRequest update = new UpdateRequest();
    		update.index("student");
    		update.type("student01");
    		update.id("3");
    		update.doc(XContentFactory.jsonBuilder().startObject().field("name", "杨旭5").endObject());
    		client.update(update).get();
    		System.out.println("索引更新成功!");
    		EsQuery es = new EsQuery(client);         //查询读写出刚才更新的索引
    		es.QueryById("3");
    	}
    }

package com.east.operation;
    
    
    import org.elasticsearch.action.bulk.BulkItemResponse;
    import org.elasticsearch.action.bulk.BulkRequestBuilder;
    import org.elasticsearch.action.bulk.BulkResponse;
    import org.elasticsearch.client.Client;
    import org.elasticsearch.common.xcontent.XContentFactory;
    
    /**
     * 批量操作索引
     * @author lhy
     * @date 2018.03.22
     */
    public class BulkIndex {
        private Client client;
    
    	public BulkIndex(Client client) {
    		super();
    		this.client = client;
    	}
        
    	public void Bulk() throws Exception{
    		BulkRequestBuilder builder = client.prepareBulk();
    		
    		//1.批量添加索引数据
    		builder.add(client.prepareIndex("student", "student01", "13").setSource(XContentFactory.jsonBuilder().startObject()
    				.field("id", "13")
    				.field("name", "小徐")
    				.field("age", "25")
    				.field("score", "89")
    				.field("tel", "123456")
    				.field("sex", "男")
    				.endObject()));
    		
    		builder.add(client.prepareIndex("student", "student01", "14").setSource(XContentFactory.jsonBuilder().startObject()
    				.field("id", "14")
    				.field("name", "小斌")
    				.field("age", "26")
    				.field("score", "86")
    				.field("tel", "12345678")
    				.field("sex", "男")
    				.endObject()));
    		
    		builder.add(client.prepareIndex("student", "student01", "15").setSource(XContentFactory.jsonBuilder().startObject()
    				.field("id", "15")
    				.field("name", "小可")
    				.field("age", "22")
    				.field("score", "78")
    				.field("tel", "123456")
    				.field("sex", "男")
    				.endObject()));
    		
    		builder.add(client.prepareIndex("student", "student01", "16").setSource(XContentFactory.jsonBuilder().startObject()
    				.field("id", "16")
    				.field("name", "小阳")
    				.field("age", "22")
    				.field("score", "99")
    				.field("tel", "123456")
    				.field("sex", "男")
    				.endObject()));
    		
    		//2.批量更新_id=3的数据
    		builder.add(client.prepareUpdate("student", "student01", "3").setDoc(XContentFactory.jsonBuilder().startObject()
    				.field("name", "杨旭")
    				.endObject()));
    		
    		//3.批量删除_id=8的数据
    		builder.add(client.prepareDelete("student", "student01", "8"));
    		
    		BulkResponse response = builder.execute().actionGet();
    		for (BulkItemResponse item : response.getItems()) {
    			System.out.println("你的批量操作Response信息为: " + item.getResponse());
    		}
    		
    		//4.错误信息日志读取
    		if (response.hasFailures()) {
    			// 可在这里对于失败请求进行处理
    			for (BulkItemResponse item : response.getItems()) {
    				if (item.isFailed()) {
    					System.out.println("失败信息:--------" + item.getFailureMessage());
    				}
    			}
    		}
    	}
    }

package com.east.test;
    
    import org.elasticsearch.client.Client;
    
    import com.east.common.EsUtil;
    import com.east.operation.BulkIndex;
    import com.east.operation.UpdateIndex;
    
    public class EsBulkTest {
    	public static void main(String[] args) throws Exception {
    		// TODO Auto-generated method stub
            Client client = EsUtil.EsConnect();
            
            /**
             * 1.更新索引
             */
            UpdateIndex update = new UpdateIndex(client);
            update.Update();
            
            /**
             * 2.批量更新索引
             */
            BulkIndex bulk = new BulkIndex(client);
            bulk.Bulk();
    	}
    
    }

**批量操作结果:**

ES服务器连接成功!
    你的批量操作Response信息为: IndexResponse[index=student,type=student01,id=13,version=1,result=created,seqNo=4,primaryTerm=3,shards={"total":2,"successful":1,"failed":0}]
    你的批量操作Response信息为: IndexResponse[index=student,type=student01,id=14,version=1,result=created,seqNo=0,primaryTerm=3,shards={"total":2,"successful":1,"failed":0}]
    你的批量操作Response信息为: IndexResponse[index=student,type=student01,id=15,version=1,result=created,seqNo=8,primaryTerm=3,shards={"total":2,"successful":1,"failed":0}]
    你的批量操作Response信息为: IndexResponse[index=student,type=student01,id=16,version=1,result=created,seqNo=5,primaryTerm=3,shards={"total":2,"successful":1,"failed":0}]
    你的批量操作Response信息为: UpdateResponse[index=student,type=student01,id=3,version=4,seqNo=4,primaryTerm=3,result=updated,shards=ShardInfo{total=2, successful=1, failures=[]}]
    你的批量操作Response信息为: DeleteResponse[index=student,type=student01,id=8,version=3,result=deleted,shards=ShardInfo{total=2, successful=1, failures=[]}]