ElasticSearch在Java中实现批量操作

末蓝、 2022-02-19 12:55 373阅读 0赞

# ElasticSearch在Java中实现批量操作 #

适用范围ElasticSearch6.x

如果是ElasticSearch7或以上版本情转到如下链接

REST高级客户端-DocumentApi：[https://blog.csdn.net/u014646662/article/details/96473156][https_blog.csdn.net_u014646662_article_details_96473156]

REST高级客户端SearchApi：[https://blog.csdn.net/u014646662/article/details/96853830][https_blog.csdn.net_u014646662_article_details_96853830]

更多新的查询方式（ElasticSearch相关文档）：[https://blog.csdn.net/u014646662/article/category/8747782][https_blog.csdn.net_u014646662_article_category_8747782]

对人工智能感兴趣的同学，可以点击以下链接：

[现在人工智能非常火爆，很多朋友都想学，但是一般的教程都是为博硕生准备的，太难看懂了。最近发现了一个非常适合小白入门的教程，不仅通俗易懂而且还很风趣幽默。所以忍不住分享一下给大家。点这里可以跳转到教程。][Link 1]

[https://www.cbedai.net/u014646662][Link 1]

package cn.com.es.test;
    
    import java.net.InetAddress;
     
    import org.elasticsearch.action.bulk.BulkRequestBuilder;
    import org.elasticsearch.action.bulk.BulkResponse;
    import org.elasticsearch.action.get.GetResponse;
    import org.elasticsearch.action.get.MultiGetItemResponse;
    import org.elasticsearch.action.get.MultiGetResponse;
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.settings.Settings;
    import org.elasticsearch.common.transport.TransportAddress;
    import org.elasticsearch.common.xcontent.XContentFactory;
    import org.elasticsearch.transport.client.PreBuiltTransportClient;
    import org.junit.Test;
    
    public class ESMultiTest {
    	
    	/**
    	 * mget 批量查詢
    	 * @throws Exception
    	 */
    	@Test
    	public void mget() throws Exception {
    		Settings settings = Settings.builder().put("cluster.name","my-application").build();
    		@SuppressWarnings("resource")
    		TransportClient client = new PreBuiltTransportClient(settings)
    				.addTransportAddress(new TransportAddress(InetAddress.getByName("master"),9300));
    		MultiGetResponse multiGetResponse = client.prepareMultiGet()
    				.add("lib", "user", "100","101","102")
    				.add("lib2", "books", "1","2")
    				.get();
    		for (MultiGetItemResponse item : multiGetResponse) {
    			GetResponse rp = item.getResponse();
    			if(rp != null && rp.isExists()) {
    				System.out.println(rp.getSourceAsString());
    			}
    		}
    	}
    	
    	/**
    	 * bulk更新
    	 * @throws Exception
    	 */
    	@Test
    	public void bulk() throws Exception{
    		Settings settings = Settings.builder().put("cluster.name","my-application").build();
    		@SuppressWarnings("resource")
    		TransportClient client = new PreBuiltTransportClient(settings)
    				.addTransportAddress(new TransportAddress(InetAddress.getByName("master"),9300));
    		BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();
    		
    		bulkRequestBuilder.add(
    				client.prepareIndex("lib2", "books", "1")
    				.setSource(
    						XContentFactory.jsonBuilder()
    						.startObject()
    						.field("title","java")
    						.field("price","90")
    						.endObject()
    						)
    				);
    		
    		bulkRequestBuilder.add(
    				client.prepareIndex("lib2", "books", "2")
    				.setSource(
    						XContentFactory.jsonBuilder()
    						.startObject()
    						.field("title","html5")
    						.field("price","90")
    						.endObject()
    						)
    				);
    		
    		BulkResponse bulkResponse = bulkRequestBuilder.get();
    		
    		System.out.println(bulkResponse.status());
    		
    		if(bulkResponse.hasFailures()) {
    			System.out.println("存在失败操作");
    		}
    	}
    }

[https_blog.csdn.net_u014646662_article_details_96473156]: https://blog.csdn.net/u014646662/article/details/96473156
[https_blog.csdn.net_u014646662_article_details_96853830]: https://blog.csdn.net/u014646662/article/details/96853830
[https_blog.csdn.net_u014646662_article_category_8747782]: https://blog.csdn.net/u014646662/article/category/8747782
[Link 1]: https://www.cbedai.net/u014646662