springboot2.1.8+elasticsearch7.3.2(五)，更新UpdateRequest

我的DEMO项目下载：https://gitee.com/zhuhongliang/soringboot_elastic_search_732.git

更新使用的是UpdateRequest()类，批量更新用的是BulkRequest()

看代码：

/**
 * 更新文档
 * @param obj
 * @param id
 */
public Boolean updateDoc(Object obj, String id){
    /**
     * 设置索引，必须是小写，所以使用toLowerCase()方法进行转换
     */
    UpdateRequest request = new UpdateRequest(obj.getClass().getSimpleName().toLowerCase(), id);
    request.doc(JSONObject.toJSONString(obj), XContentType.JSON);
    try {
        UpdateResponse updateResponse = client.update(request, RequestOptions.DEFAULT);
        updateResponse.getGetResult();
        if(DocWriteResponse.Result.UPDATED == updateResponse.getResult()){
            return true;
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
    return false;
}


/**
 * 批量更新文档
 * @param list
 */
public void updateMultiDoc(List<HashMap<String,Object>> list){
    BulkRequest request = new BulkRequest();
    /**
     * 遍历
     * IndexRequest不设置id，让系统自己添加
     * DeleteRequest 批量删除
     * UpdateRequest 批量更新
     */
    list.forEach((map)->{
        Object obj = map.get("obj");
        request.add(
                new UpdateRequest(obj.getClass().getSimpleName().toLowerCase(), (String) map.get("id"))
                        .doc(JSONObject.toJSONString(obj), XContentType.JSON)
        );
    });
    try {
        BulkResponse bulkResponse = client.bulk(request,RequestOptions.DEFAULT);
        bulkResponse.forEach((BulkItemResponse bulkItemResponse)->{
            DocWriteResponse itemResponse = bulkItemResponse.getResponse();
            switch (bulkItemResponse.getOpType()) {
                case INDEX:
                case CREATE:
                    IndexResponse indexResponse = (IndexResponse) itemResponse;
                    break;
                case UPDATE:
                    UpdateResponse updateResponse = (UpdateResponse) itemResponse;
                    log.info(JSONObject.toJSONString(updateResponse));
                    if(DocWriteResponse.Result.UPDATED == updateResponse.getResult()){
                        log.info("更新成功");
                    }
                    break;
                case DELETE:
                    DeleteResponse deleteResponse = (DeleteResponse) itemResponse;
                    break;
                default:break;
            }
        });
    } catch (IOException e) {
        e.printStackTrace();
    }
}

测试方法：

/**
 * 更新
 */
@Test
public void updateDoc(){
    //先搜索一个文档
    int page =1;
    int size =1;
    System.out.println("===================只查询一条数据=========================");
    SearchHit[] hits = commodityServiceImpl.searchDoc(Article.class, "物是人非",(page-1)*size ,size, "content");
    String id;
    Article article;
    if(hits.length>=1){
        id = hits[0].getId();
        log.info("id:{}",id);
        log.info("搜索结果:{}", hits[0].getSourceAsString());
        article = JSONObject.parseObject(hits[0].getSourceAsString(), Article.class);
    }else{
        log.info("没有查询到数据");
        return;
    }
    article.setContent("更新测试_"+article.getContent());
    article.setTitle("更新测试_"+article.getTitle());
    System.out.println("===================更新数据=========================");
    Boolean updateResult = commodityServiceImpl.updateDoc(article, id);
    log.info("更新数据结果:{}",updateResult);

    //暂停五秒，等待数据更新之后再查询
    try {
        Thread.sleep(5*1000L);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    System.out.println("===================使用id查询数据，确认是否更新成功=========================");
    SearchHit[] find_hits = commodityServiceImpl.findById(Article.class, id);
    log.info("更新操作后查询到的数据:{}",find_hits);

}

/**
 * 批量更新测试
 */
@Test
public void updateMultiDoc(){
    //先搜索一批文档
    int page =1;
    int size =10;
    System.out.println("===================查询数据=========================");
    SearchHit[] hits = commodityServiceImpl.searchDoc(Article.class, "物是人非",(page-1)*size ,size,"content");
    log.info("hits的数量:{}",hits.length);
    Article article;
    String id;
    ArrayList<HashMap<String, Object>> list = new ArrayList<>(16);
    if(hits.length>=1){
        int index = 1;
        for (SearchHit hit : hits) {
            HashMap<String, Object> map = new HashMap<>(4);
            id = hit.getId();
            article = JSONObject.parseObject(hit.getSourceAsString(), Article.class);
            article.setContent("批量更新测试_"+index+article.getContent());
            article.setTitle("批量更新测试_"+index+article.getTitle());
            map.put("id", id);
            map.put("obj", article);
            list.add(map);
            index++;
        }
    }else{
        log.info("没有查询到数据");
        return;
    }
    System.out.println("===================批量更新数据=========================");
    commodityServiceImpl.updateMultiDoc(list);
    //暂停五秒，等待数据更新之后再查询
    try {
        Thread.sleep(5*1000L);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("===================再次查询数据，确认批量更新是否成功=========================");
    SearchHit[] find_hits = commodityServiceImpl.searchDoc(Article.class, "物是人非",(page-1)*size ,size,"content");
    log.info("find_hits的数量:{}",find_hits.length);
    log.info("更新操作后查询到的数据:{}", JSONArray.toJSONString(find_hits));
}

运行单个文档更新测试，日志：

===================只查询一条数据=========================
2019-09-21 15:25:26.046  INFO 281320 --- [           main] c.z.e.service.impl.ServiceImpl           : fieldName.length:1,fieldName:[content]
2019-09-21 15:25:26.332  INFO 281320 --- [           main] c.z.e.ElasticsearchDemoApplicationTests  : id:LzODT20Bk6nS0BLhTTX_
2019-09-21 15:25:26.340  INFO 281320 --- [           main] c.z.e.ElasticsearchDemoApplicationTests  : 搜索结果:{"content":"风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅","create_time":1568997067851,"title":"武陵春·春晚"}
===================更新数据=========================
2019-09-21 15:25:26.506  INFO 281320 --- [           main] c.z.e.ElasticsearchDemoApplicationTests  : 更新数据结果:true
===================使用id查询数据，确认是否更新成功=========================
2019-09-21 15:25:31.515  INFO 281320 --- [           main] c.z.e.ElasticsearchDemoApplicationTests  : 更新操作后查询到的数据:{
  "_index" : "article",
  "_type" : "_doc",
  "_id" : "LzODT20Bk6nS0BLhTTX_",
  "_score" : 1.0,
  "_source" : {
    "content" : "更新测试_风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅",
    "create_time" : 1568997067851,
    "title" : "更新测试_武陵春·春晚"
  }
}

运行批量更新测试，日志：

===================查询数据=========================
2019-09-21 15:28:48.077  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : fieldName.length:1,fieldName:[content]
2019-09-21 15:28:49.308  INFO 280564 --- [           main] c.z.e.ElasticsearchDemoApplicationTests  : hits的数量:3
===================批量更新数据=========================
2019-09-21 15:28:49.491  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : {"fragment":false,"id":"-jW4Um0Bk6nS0BLh5kJH","index":"article","primaryTerm":1,"result":"UPDATED","seqNo":11,"shardId":{"fragment":true,"id":-1,"index":{"fragment":false,"name":"article","uUID":"_na_"},"indexName":"article"},"shardInfo":{"failed":0,"failures":[],"fragment":false,"successful":1,"total":1},"type":"_doc","version":2}
2019-09-21 15:28:49.491  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : 更新成功
2019-09-21 15:28:49.491  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : {"fragment":false,"id":"_TW4Um0Bk6nS0BLh5kKL","index":"article","primaryTerm":1,"result":"UPDATED","seqNo":12,"shardId":{"fragment":true,"id":-1,"index":{"fragment":false,"name":"article","uUID":"_na_"},"indexName":"article"},"shardInfo":{"failed":0,"failures":[],"fragment":false,"successful":1,"total":1},"type":"_doc","version":2}
2019-09-21 15:28:49.491  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : 更新成功
2019-09-21 15:28:49.492  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : {"fragment":false,"id":"LzODT20Bk6nS0BLhTTX_","index":"article","primaryTerm":1,"result":"UPDATED","seqNo":13,"shardId":{"fragment":true,"id":-1,"index":{"fragment":false,"name":"article","uUID":"_na_"},"indexName":"article"},"shardInfo":{"failed":0,"failures":[],"fragment":false,"successful":1,"total":1},"type":"_doc","version":4}
2019-09-21 15:28:49.492  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : 更新成功
===================再次查询数据，确认批量更新是否成功=========================
2019-09-21 15:28:54.492  INFO 280564 --- [           main] c.z.e.service.impl.ServiceImpl           : fieldName.length:1,fieldName:[content]
2019-09-21 15:28:54.495  INFO 280564 --- [           main] c.z.e.ElasticsearchDemoApplicationTests  : find_hits的数量:3
2019-09-21 15:28:54.506  INFO 280564 --- [           main] c.z.e.ElasticsearchDemoApplicationTests  : 更新操作后查询到的数据:[{"fields":{},"fragment":false,"highlightFields":{},"id":"-jW4Um0Bk6nS0BLh5kJH","matchedQueries":[],"primaryTerm":0,"rawSortValues":[],"score":0.59859395,"seqNo":-2,"sortValues":[],"sourceAsMap":{"create_time":1569050911977,"title":"批量更新测试_1武陵春·春晚","content":"批量更新测试_1风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅"},"sourceAsString":"{\"content\":\"批量更新测试_1风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅\",\"create_time\":1569050911977,\"title\":\"批量更新测试_1武陵春·春晚\"}","sourceRef":{"fragment":true},"type":"_doc","version":-1},{"fields":{},"fragment":false,"highlightFields":{},"id":"_TW4Um0Bk6nS0BLh5kKL","matchedQueries":[],"primaryTerm":0,"rawSortValues":[],"score":0.59859395,"seqNo":-2,"sortValues":[],"sourceAsMap":{"create_time":1569050911977,"title":"批量更新测试_2武陵春·春晚","content":"批量更新测试_2风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅"},"sourceAsString":"{\"content\":\"批量更新测试_2风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅\",\"create_time\":1569050911977,\"title\":\"批量更新测试_2武陵春·春晚\"}","sourceRef":{"fragment":true},"type":"_doc","version":-1},{"fields":{},"fragment":false,"highlightFields":{},"id":"LzODT20Bk6nS0BLhTTX_","matchedQueries":[],"primaryTerm":0,"rawSortValues":[],"score":0.5617394,"seqNo":-2,"sortValues":[],"sourceAsMap":{"create_time":1568997067851,"title":"批量更新测试_3批量更新测试_1更新测试_武陵春·春晚","content":"批量更新测试_3批量更新测试_1更新测试_风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅"},"sourceAsString":"{\"content\":\"批量更新测试_3批量更新测试_1更新测试_风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\\n闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅\",\"create_time\":1568997067851,\"title\":\"批量更新测试_3批量更新测试_1更新测试_武陵春·春晚\"}","sourceRef":{"fragment":true},"type":"_doc","version":-1}]

更新和批量更新都很简单

我的DEMO项目下载：https://gitee.com/zhuhongliang/soringboot_elastic_search_732.git

朱宏亮

个人站点

springboot2.1.8+elasticsearch7.3.2(五)，更新UpdateRequest

发表评论取消回复

发表评论 取消回复

发表评论取消回复