Elasticsearch Java REST高级客户端条件更新 updateQuery

忘是亡心i 2021-11-05 23:08 1260阅读 0赞

# Elasticsearch Java REST高级客户端 条件更新 updateQuery #

Elasticsearch 7.2.0

1.条件更新

2.客户端创建

3.maven配置-pom

对人工智能感兴趣点下面链接

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

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

## 1.条件更新 ##

/**
    	 * 条件更新
    	 * 
    	 * @return
    	 */
    	public static long updateQuery() {
    		RestHighLevelClient client = getClient();
    		//参数为索引名，可以不指定，可以一个，可以多个
    		UpdateByQueryRequest request = new UpdateByQueryRequest("hockey");
    		// 更新时版本冲突
    		request.setConflicts("proceed");
    		// 设置查询条件，第一个参数是字段名，第二个参数是字段的值
    		request.setQuery(new TermQueryBuilder("first", "sam"));
    		// 更新最大文档数
    		request.setSize(10);
    		// 批次大小
    		request.setBatchSize(1000);
    //		request.setPipeline("my_pipeline");
    
    		request.setScript(new Script(ScriptType.INLINE, "painless",
    				"if (ctx._source.first == 'sam') {ctx._source.last = 'update';}", Collections.emptyMap()));
    		// 并行
    		request.setSlices(2);
    		// 使用滚动参数来控制“搜索上下文”存活的时间
    		request.setScroll(TimeValue.timeValueMinutes(10));
    		// 如果提供路由，则将路由复制到滚动查询，将流程限制为匹配该路由值的切分
    //		request.setRouting("=cat");
    
    		// 可选参数
    		// 超时
    		request.setTimeout(TimeValue.timeValueMinutes(2));
    		// 刷新索引
    		request.setRefresh(true);
    
    		try {
    			BulkByScrollResponse response = client.updateByQuery(request, RequestOptions.DEFAULT);
    			return response.getStatus().getUpdated();
    		} catch (IOException e) {
    
    			e.printStackTrace();
    		} finally {
    			try {
    				client.close();
    			} catch (IOException e) {
    
    				e.printStackTrace();
    			}
    		}
    		return -1;
    	}

## 2.客户端创建 ##

/**
    	 * 关闭客户端
    	 * 
    	 * @param client
    	 */
    	private static void close(RestHighLevelClient client) {
    		try {
    			client.close();
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}
    
    	/**
    	 * 获取客户端
    	 * 
    	 * @return
    	 */
    	private static RestHighLevelClient getClient() {
    		RestHighLevelClient client = new RestHighLevelClient(
    				RestClient.builder(new HttpHost("elk-node01", 9200, "http"), new HttpHost("elk-node02", 9200, "http"),
    						new HttpHost("elk-node03", 9200, "http")));
    		return client;
    	}

## 3、maven配置---pom ##

Elasticsearch Java REST高级客户端 maven配置

[https://blog.csdn.net/u014646662/article/details/97895028][https_blog.csdn.net_u014646662_article_details_97895028]

[Link 1]: https://www.cbedai.net/u014646662
[https_blog.csdn.net_u014646662_article_details_97895028]: https://blog.csdn.net/u014646662/article/details/97895028