ES6.6.2 使用小结 - 文档操作

浅浅的花香味﹌ 2022-02-28 04:20 279阅读 0赞

1.文档基本操作分为：文档获取、删除、更新。以下是一些简单的测试。

2.假设当前ES存在如下数据(两条)。

![20190324165933149.png][]

3.文档操作源码如下：

package com.bas.demo;
    
    import com.bas.util.ESUtil;
    import org.elasticsearch.action.get.GetResponse;
    import org.elasticsearch.client.transport.TransportClient;
    import org.junit.jupiter.api.Test;
    
    import java.io.IOException;
    import java.util.concurrent.ExecutionException;
    
    import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;
    
    /**
     * 文档管理
     */
    public class DocumentDemo {
    
        public static void main(String[] args) {
            System.out.println(ESUtil.selectDocument("app_account", "blog" , "d759rmkBsxnypktQHp5P"));
        }
    
        @Test
        public void deleteDoc() {
            ESUtil.deleteDocument("app_account", "blog" , "eL59rmkBsxnypktQIJ4I");
        }
    
        @Test
        public void updateDoc() {
            try {
                ESUtil.updateDocument("app_account", "blog" , "er6VrmkBsxnypktQsZ6I" ,
                        jsonBuilder().startObject()
                                .field("title","qqqqqqqqqqqqqq")
                                .endObject());
            } catch (ExecutionException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        @Test
        public  void upsertDoc() throws IOException, ExecutionException, InterruptedException {
            ESUtil.upsertDocument("app_account", "blog" , "6J3HrmkBHcVcCKaQcmRP",
                        jsonBuilder().startObject()
                                .field("id","5")
                                .field("title","标题asd")
                                .field("content","asdhjjje")
                                .field("postdate","2019-03-24 17:38:00")
                                .field("url","bas")
                                .endObject(),
                        jsonBuilder().startObject()
                            .field("title","更新title")
                            .endObject()
                    );
        }
    
    }

其中，ES工具类位于：[ES6.6.2 使用小结 - ES工具类使用][ES6.6.2 _ - ES]

值得注意的是，方法参数的id为文档数据中的字段 "**\_id**"。

4.首先是文档的获取结果图，执行Document.main()。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70][]

5.文档删除结果图，执行Document.deleteDoc()。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 1][]

6.文档更新分两种。首先执行Document.updateDoc()如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 2][]

ES中的数据更新为现在这样：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 3][]

接着就是upsert更新type了，即：如果type中不存在这个文档就插入，存在了就更新数据，执行Document.upsertDoc()，如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 4][]

因为type中已经存在\_id为"7Z\_qrmkBHcVcCKaQfGQ3"的文档，所以执行了更新操作，如图：

![20190324171250675.png][]

同样的，如果Document.upsertDoc()中的参数改成这样时将插入数据，如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 5][]

ES新增文档了，如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 6][]

[20190324165933149.png]: /images/20220228/5e23e9d198904ad486cbb2ae9bca798e.png
[ES6.6.2 _ - ES]: https://blog.csdn.net/BAStriver/article/details/88776887
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70]: /images/20220228/71b32727a8cd40f08e26ba19e584bfb3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 1]: /images/20220228/d066e49467534c2fb3169302abc5e6c1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 2]: /images/20220228/01624ca8304e4a40855906897e25d655.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 3]: /images/20220228/934cd9f1a73f4e67b57afa65d26b27fd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 4]: /images/20220228/d4fdc276399247ad8e7d3b3fb6f0f8ef.png
[20190324171250675.png]: /images/20220228/21931b0d4a0741338accf6edc86c77fb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 5]: /images/20220228/5a032580046d46c2a06f5ce160aee397.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 6]: /images/20220228/14973ef4c5a64dbeba92ef8ae3409f6b.png