在上一篇mongo中提过,我们有增量更新的需求,mongo因为深层嵌套,更新麻烦,于是采用先删除后新增的方法。同样的,es也存在深层嵌套的数据。这部分数据同样不易更新,也是在开始的时候尝试过,虽然后来和mongo同样采取了先删除后新增的方式,但这深层嵌套的更新方式还是想要记录一下
首先,下面是数据结构
{"_index" : "test_index","_type" : "_doc","_id" : "1","_score" : 1.0,"_source" : {"id" : "1","name" : "哈哈哈","pageView" : 0,"personCerts" : [{"certNo" : "333""regMajor" : "321","regType" : "231"},{"certNo" : "334""regMajor" : "322","regType" : "233},{"certNo" : "335""regMajor" : "323","regType" : "231}]}
}
我想修改 certNo = 333 的嵌套文档,使 regMajor = 000 , regType = 111 ,因为personCerts 的数组长度为3,想要匹配到 333 ,我使用了 for循环 , 语句如下
POST test_index/_update/1
{"script": {"source": """ def targets = ctx._source.personCerts
.findAll(personCert -> personCert.certNo == params.personCerts.certNo);for(personCert in targets) { personCert.regMajor = params.personCerts.regMajor ;personCert.regType = params.personCerts.regType ;}""","lang": "painless","params": {"personCerts": {"regMajor": "000","regType":"111","certNo":"333"}}}
}
java 写法如下
Map<String,Object> personCert = new HashMap<>();
personCert.put("regMajor" ,"000");
personCert.put("regType" ,"111");
personCert.put("certNo" ,"333");
Map<String, Object> personCerts = Collections.singletonMap("personCerts",personCert);Script inline = new Script(ScriptType.INLINE, "painless","def targets = ctx._source.personCerts.findAll(personCert -> personCert.certNo == params.personCerts.certNo ); " +"for(personCert in targets) { " +"personCert.regMajor = params.personCerts.regMajor ;" +"personCert.regType = params.personCerts.regType ;" +"}", personCerts);executeScript(inline,"test_index","1")
public void executeScript(Script inline, String id, String index) {UpdateRequest request = new UpdateRequest( index, id);request.script(inline);try{UpdateResponse response = restHighLevelClient.update(request, RequestOptions.DEFAULT);log.info("...... result status {} ...... ",response.status().getStatus());}catch (Exception e){log.info("...... execute script failed ...... ");}}