最近想更新ES里面已经存在的数据,报错
错误如下
{"error":{"root_cause":[{"type":"script_exception","reason":"compile error","script_stack":["... params.objId;ctx._source.测试搜索1=params.userNameOrRo ..."," ^---- HERE"],"script":"ctx._source.null=params.objId;ctx._source.测试搜索1=params.userNameOrRoomName;","lang":"painless","position":{"offset":42,"start":17,"end":67}}],"type":"script_exception","reason":"compile error","script_stack":["... params.objId;ctx._source.测试搜索1=params.userNameOrRo ..."," ^---- HERE"],"script":"ctx._source.null=params.objId;ctx._source.测试搜索1=params.userNameOrRoomName;","lang":"painless","position":{"offset":42,"start":17,"end":67},"caused_by":{"type":"illegal_argument_exception","reason":"unexpected character [测].","caused_by":{"type":"lexer_no_viable_alt_exception","reason":null}}},"status":400}
at org.elasticsearch.client.RestClient.convertResponse(RestClient.java:283)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:261)
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:235)
at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1514)
... 62 more
Caused by: ElasticsearchException[Elasticsearch exception [type=illegal_argument_exception, reason=unexpected character [测].]]; nested: ElasticsearchException[Elasticsearch exception [type=lexer_no_viable_alt_exception, reason=null]];
at org.elasticsearch.ElasticsearchException.innerFromXContent(ElasticsearchException.java:496)
at org.elasticsearch.ElasticsearchException.fromXContent(ElasticsearchException.java:407)
at org.elasticsearch.ElasticsearchException.innerFromXContent(ElasticsearchException.java:437)
at org.elasticsearch.ElasticsearchException.failureFromXContent(ElasticsearchException.java:603)
at org.elasticsearch.rest.BytesRestResponse.errorFromXContent(BytesRestResponse.java:169)
... 65 more
Caused by: ElasticsearchException[Elasticsearch exception [type=lexer_no_viable_alt_exception, reason=null]]
at org.elasticsearch.ElasticsearchException.innerFromXContent(ElasticsearchException.java:496)
at org.elasticsearch.ElasticsearchException.fromXContent(ElasticsearchException.java:407)
at org.elasticsearch.ElasticsearchException.innerFromXContent(ElasticsearchException.java:437)
... 69 more
代码解决:
data 业务里面的key:value
private void updateTableRelatedLogicPrepare( Map data) {
Map newParamsMap = new HashMap<>();
StringBuilder sb = new StringBuilder();
for (Map.Entry entry : data.entrySet()) {
String column_name = entry.getKey();
String key = column_name;
newParamsMap.put(key, entry.getValue());
sb.append("ctx._source." + key + "=params." + key + ";");
}
Map queryMap = new HashMap<>();
//业务主键ID
queryMap.put("objId", data.get("objId"));
esHomeService.updateByQuery("essearchobj",queryMap,sb.toString(),newParamsMap);
}
public void updateByQuery(String indexName, MapparamMap, String inline, Map inlineParamMap) { if (StringUtils.isEmpty(indexName)) { return; } if (ObjectUtil.isEmpty(paramMap)) { return; } //1、构造查询条件 BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery(); for (String key : paramMap.keySet()) { boolQueryBuilder.must(QueryBuilders.termQuery(key, paramMap.get(key))); } //2、构造查询请求 UpdateByQueryRequest updateByQueryRequest = new UpdateByQueryRequest(indexName); updateByQueryRequest.setQuery(boolQueryBuilder); updateByQueryRequest.setRefresh(true); //3、更新脚本 Script script = new Script(ScriptType.INLINE, "painless", inline, ObjectUtil.isEmpty(inlineParamMap) ? Collections.EMPTY_MAP : inlineParamMap); updateByQueryRequest.setScript(script); //4、执行脚本 BulkByScrollResponse bulkByScrollResponse = null; try { bulkByScrollResponse = restHighLevelClient.updateByQuery(updateByQueryRequest, RequestOptions.DEFAULT); log.info("updateByQuery_response:{}", JSON.toJSONString(bulkByScrollResponse)); } catch (ConnectException ce) { ce.printStackTrace(); } catch (ConnectTimeoutException ctc) { ctc.printStackTrace(); } catch (SocketTimeoutException ste) { ste.printStackTrace(); } catch (ConnectionClosedException cce) { cce.printStackTrace(); } catch (ElasticsearchException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }
@Autowired
private RestHighLevelClient restHighLevelClient;



