{“error“:{“root

前言

最近想更新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, Map paramMap, 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;