6 ElasticSearch 高级-应用篇

收心

发布于 2022-01-17 14:56:53

3670

发布于 2022-01-17 14:56:53

文章被收录于专栏：Java实战博客

本片内容简介 批量操作导入数据各种查询索引别名、重建索引

所有内容我们都先介绍脚本操作、在介绍Java API操作

批量操作

bulk 批量操作：将文档增删改查一系列的操作，通过一次请求全部做完。优点：可以减少网络传输次数。

语法与案例

我们去实际操作一下吧。操作前确保索引库有 5 个文档

先查一下有没有 5 个文档

GET persion2/_search

查询后我们就开始写我们的脚本了

POST _bulk
{"delete":{"_index":"persion2","_id":"5"}}
{"create":{"_index":"persion2","_id":"8"}}
{"name":"BULK插入","age":"88"}
{"update":{"_index":"persion2","_id":"2"}}
{"doc":{"name":"二号名字被修改了"}}

上面的含义是：

删除索引库 persion2中 id 为 5 的文档
在索引库persion2中创建一个 id 为8 的文档数据又 name=”BULB插入”,age=”88″
更新索引库persion2 中 id 为2 的文档，修改其中name 为 “二号名字被修改”

注意上面的 update 就是更新，没有此 id 就会提示 document_missing_exception 说明没有找到此文档

我们执行一下看看结果代码有些长有必要看一看

{
  "took" : 12, // 这里执行需要的毫秒数
  "errors" : false, // 是否出现错误
  "items" : [
    {
      "delete" : {
        "_index" : "persion2",
        "_type" : "_doc",
        "_id" : "5",
        "_version" : 1,
        "result" : "not_found",
        "_shards" : {
          "total" : 2,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 89,
        "_primary_term" : 4,
        "status" : 404
      }
    },
    {
      "create" : {
        "_index" : "persion2",
        "_type" : "_doc",
        "_id" : "8",
        "_version" : 2,
        "result" : "created",
        "_shards" : {
          "total" : 2,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 90,
        "_primary_term" : 4,
        "status" : 201
      }
    },
    {
      "update" : {
        "_index" : "persion2",
        "_type" : "_doc",
        "_id" : "2",
        "_version" : 2,
        "result" : "updated",
        "_shards" : {
          "total" : 2,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 91,
        "_primary_term" : 4,
        "status" : 200
      }
    }
  ]
}

上面显示 errors 为 false 就是执行成功了

最终的Java 代码实现

    /**
     * 批量操作 bulk
     * @throws IOException
     */
    @Test
    void bulk() throws IOException {
        // 创建 BulkRequest 对象，用于 整合所有的操作
        BulkRequest bulkRequest = new BulkRequest();

        // 添加 删除文档 相关操作
        DeleteRequest deleteRequest = new DeleteRequest("persion2","5");
        bulkRequest.add(deleteRequest);

        // 添加 添加文档
        Map map = new HashMap();
        map.put("name","BULK插入");
        map.put("age","88");
        IndexRequest indexRequest = new IndexRequest("persion2").id("8").source(map);

        // 更新文档
        UpdateRequest updateRequest = new UpdateRequest();
        Map map1 = new HashMap();
        map1.put("name","二号名字被修改了");
        updateRequest.index("persion2").id("2").doc(map1);
        bulkRequest.add(updateRequest);


        // 执行 批量操作
        BulkResponse bulk = client.bulk(bulkRequest, RequestOptions.DEFAULT);
        RestStatus status = bulk.status();
        System.out.println(status);
    }