ES7学习笔记（八）数据的增删改-低调大师

ES7学习笔记（八）数据的增删改

2020-05-08 499

在前面几节的内容中，我们学习索引、字段映射、分析器等，这些都是使用ES的基础，就像在数据库中创建表一样，基础工作做好以后，我们就要真正的使用它了，这一节我们要看看怎么向索引里写入数据、修改数据、删除数据，至于搜索嘛，因为ES的主要功能就是搜索，所以搜索的相关功能我们后面会展开讲。

Document的创建与更新

索引中的数据叫做document，和数据中的一条记录是一样的，而索引就像数据库中的一张表，我们向索引中添加数据，就像在数据库表中添加一条记录一样。下面我们看看怎么向索引中添加数据，

PUT /<index>/_doc/<_id>

POST /<index>/_doc/

PUT /<index>/_create/<_id>

POST /<index>/_create/<_id>

在这个POST请求中，<index>也就是索引的名字是必须的，这就好比我们向数据库中插入记录，要知道往哪张表里插是一样的。<index>后面可以是_doc或者_create，这两个是什么意思呢？咱们慢慢看，除了这两个区别以外，再有就是请求的方法了，分为POST和PUT两种。一般情况下，POST用于数据的插入，PUT用户数据的修改，是不是这样呢？咱们把这4种方式都试一下，首先我们看一下POST /<index>/_doc/这种方式的请求，

POST /ik_index/_doc
{
  "id": 1,
  "title": "苹果",
  "desc": "苹果真好吃"
}

在这里，索引我们使用的是上一节创建的ik_index，执行一下。然后我们再查询一下这个索引，

GET /ik_index/_search

返回结果如下：

{
    "took": 1000,
    "timed_out": false,
    "_shards": {
        "total": 1,
        "successful": 1,
        "skipped": 0,
        "failed": 0
    },
    "hits": {
        "total": {
            "value": 2,
            "relation": "eq"
        },
        "max_score": 1,
        "hits": [
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "1",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "大兴庞各庄的西瓜",
                    "desc": "大兴庞各庄的西瓜真是好吃，脆沙瓤，甜掉牙"
                }
            },
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "fEsN-HEBZl0Dh1ayKWZb",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "苹果",
                    "desc": "苹果真好吃"
                }
            }
        ]
    }
}

我们重点看一下hits，这是我们查询出的结果，第一条是我们上一节存入的数据，不用管它。我们看一下第二条记录，注意一下_id这个字段，这个_id是这条记录在索引里的唯一标识，在插入数据的请求中，我们没有指定这个id，ES给我们自动生成了fEsN-HEBZl0Dh1ayKWZb。那么我们可不可以指定呢？试一下，

POST /ik_index/_doc/2
{
  "id": 1,
  "title": "香蕉",
  "desc": "香蕉真好吃"
}

注意我们发送的请求，_doc后面加了2，这样就指定了id，执行一下。然后再次查询，返回的结果中，我们只截取hits的部分，如下：

"hits": [
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "1",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "大兴庞各庄的西瓜",
                    "desc": "大兴庞各庄的西瓜真是好吃，脆沙瓤，甜掉牙"
                }
            },
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "fEsN-HEBZl0Dh1ayKWZb",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "苹果",
                    "desc": "苹果真好吃"
                }
            },
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "2",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "香蕉",
                    "desc": "香蕉真好吃"
                }
            }
        ]

我们看到插入的香蕉记录，它的_id是2。那么POST请求中指定的id在索引中存在，会是什么情况呢？我们再看一下，

POST /ik_index/_doc/1
{
  "id": 1,
  "title": "香蕉",
  "desc": "香蕉真好吃"
}

还是香蕉这条数据，我们指定id=1，id=1这条数据在索引中是存在的，我们执行一下，然后查询，返回的结果如下：

"hits": [
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "fEsN-HEBZl0Dh1ayKWZb",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "苹果",
                    "desc": "苹果真好吃"
                }
            },
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "2",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "香蕉",
                    "desc": "香蕉真好吃"
                }
            },
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "1",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "香蕉",
                    "desc": "香蕉真好吃"
                }
            }
        ]

我们看到之前的那条数据被修改了，所以，关于POST /<index>/_doc/<_id>，这种添加数据的方式，我们得出结论如下：

<_id>不指定时，ES会为我们自动生成id；
指定<_id>时，且id在索引中不存在，ES将添加一条指定id的数据；
指定<_id>时，但id在索引中存在，ES将会更新这条数据；

接下来我们再看看_doc方式的PUT请求方式，我们先不指定id，看看会是什么情况，请求如下：

PUT /ik_index/_doc
{
  "id": 1,
  "title": "葡萄",
  "desc": "葡萄真好吃"
}

执行一下，返回如下结果：

{
    "error": "Incorrect HTTP method for uri [/ik_index/_doc] and method [PUT], allowed: [POST]",
    "status": 405
}

错误信息说我们的请求不对，让我们使用POST请求，看来PUT请求不指定id是不行的。我们再看看指定一个不存在的id，是什么情况，如下：

PUT /ik_index/_doc/3
{
  "id": 1,
  "title": "葡萄",
  "desc": "葡萄真好吃"
}

执行成功，再查询一下，

"hits": [
            ……
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "3",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "葡萄",
                    "desc": "葡萄真好吃"
                }
            }
        ]

数据添加成功。再看看指定一个存在的id是什么情况，那当然是修改了，我们再试一下，

PUT /ik_index/_doc/3
{
  "id": 1,
  "title": "橘子",
  "desc": "橘子真好吃"
}

执行成功，再查询一下，

"hits": [
            ……
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "3",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "橘子",
                    "desc": "橘子真好吃"
                }
            }
        ]

没有问题，修改成功。POST /<index>/_doc/<_id>这种方式的总结如下：

<_id>必须指定，不指定会报错；
<_id>在索引中不存在，为添加新数据；
<_id>在索引中存在，为修改数据；

_doc这种请求的POST和PUT都尝试过了，再看看_create这种请求，先看看不指定id是什么情况，如下：

POST /ik_index/_create
{
  "id": 1,
  "title": "桃子",
  "desc": "桃子真好吃"
}

返回错误信息如下：

{
    "error": {
        "root_cause": [
            {
                "type": "invalid_type_name_exception",
                "reason": "mapping type name [_create] can't start with '_' unless it is called [_doc]"
            }
        ],
        "type": "invalid_type_name_exception",
        "reason": "mapping type name [_create] can't start with '_' unless it is called [_doc]"
    },
    "status": 400
}

具体内容我们也不去解读了，总之是不可以，然后加个索引中不存在id试一下，

POST /ik_index/_create/4
{
  "id": 1,
  "title": "桃子",
  "desc": "桃子真好吃"
}

返回结果创建成功，查询如下：

"hits": [
            ……
            {
                "_index": "ik_index",
                "_type": "_doc",
                "_id": "4",
                "_score": 1,
                "_source": {
                    "id": 1,
                    "title": "桃子",
                    "desc": "桃子真好吃"
                }
            }
        ]

如果id在索引中存在呢？再试，

POST /ik_index/_create/3
{
  "id": 1,
  "title": "桃子",
  "desc": "桃子真好吃"
}

返回错误：

{
    "error": {
        "root_cause": [
            {
                "type": "version_conflict_engine_exception",
                "reason": "[3]: version conflict, document already exists (current version [2])",
                "index_uuid": "W2X_riHIT4u678p8HZwnEg",
                "shard": "0",
                "index": "ik_index"
            }
        ],
        "type": "version_conflict_engine_exception",
        "reason": "[3]: version conflict, document already exists (current version [2])",
        "index_uuid": "W2X_riHIT4u678p8HZwnEg",
        "shard": "0",
        "index": "ik_index"
    },
    "status": 409
}

大致的意思是，数据已经存在了，不能再添加新记录，看来_create这种方式还是比较严格的，总结如下：

id必须指定；
指定的id如果在索引中存在，报错，添加不成功；
指定的id在索引中不存在，添加成功，符合预期；

再看看_create的PUT，应该和POST正好相反吧？我们试一下，先不指定id，试一下，

PUT /ik_index/_create
{
  "id": 1,
  "title": "火龙果",
  "desc": "火龙果真好吃"
}

返回错误，不指定id肯定是不行的，错误信息就不给大家贴出来了，然后再指定一个不存在的id，

PUT /ik_index/_create/5
{
  "id": 1,
  "title": "火龙果",
  "desc": "火龙果真好吃"
}

创建成功，查询结果就不给大家展示了，然后再换一个存在的id，如下：

PUT /ik_index/_create/4
{
  "id": 1,
  "title": "火龙果",
  "desc": "火龙果真好吃"
}

返回了错误的信息，如下，和POST请求是一样的，

{
    "error": {
        "root_cause": [
            {
                "type": "version_conflict_engine_exception",
                "reason": "[4]: version conflict, document already exists (current version [1])",
                "index_uuid": "W2X_riHIT4u678p8HZwnEg",
                "shard": "0",
                "index": "ik_index"
            }
        ],
        "type": "version_conflict_engine_exception",
        "reason": "[4]: version conflict, document already exists (current version [1])",
        "index_uuid": "W2X_riHIT4u678p8HZwnEg",
        "shard": "0",
        "index": "ik_index"
    },
    "status": 409
}

我们得出如下的结论：

_create这种形式的POST和PUT是一样的，没有区别；
id必须指定；
id必须在索引中不存在；

Document的删除

有了添加，肯定会有删除，删除的方式很简单，请求格式如下：

DELETE /<index>/_doc/<_id>

发送delete请求，指定数据的id，就可以了，我们试一下，删除刚刚添加的火龙果数据，它的id是5，我们发送请求如下：

DELETE /ik_index/_doc/5

执行成功，数据被成功的删除。

根据id查询Document

根据id查询数据也很简单，发送如下请求就可以完成查询，

GET <index>/_doc/<_id>

我们需要指定索引的名称，以及要查询数据的id，如下：

GET ik_index/_doc/3

返回结果如下：

{
    "_index": "ik_index",
    "_type": "_doc",
    "_id": "3",
    "_version": 2,
    "_seq_no": 5,
    "_primary_term": 3,
    "found": true,
    "_source": {
        "id": 1,
        "title": "橘子",
        "desc": "橘子真好吃"
    }
}

根据id成功的查询出来结果。

好了~ 到这里，ES数据的增删改都介绍了，下节开始，我们看看ES的核心功能——搜索。

微信关注我们

原文链接：https://yq.aliyun.com/articles/759439

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

ES7学习笔记（七）IK中文分词器

在上一节中，我们给大家介绍了ES的分析器，我相信大家对ES的全文搜索已经有了深刻的印象。分析器包含3个部分：字符过滤器、分词器、分词过滤器。在上一节的例子，大家发现了，都是英文的例子，是吧？因为ES是外国人写的嘛，中国如果要在这方面赶上来，还是需要屏幕前的小伙伴们的~ 英文呢，我们可以按照空格将一句话、一篇文章进行分词，然后对分词进行过滤，最后留下有意义的词。但是中文怎么分呢？中文的一句话是没有空格的，这就要有一个强大的中文词库，当你的内容中出现这个词时，就会将这个词提炼出来。这里大家也不用重复造轮子，经过前辈的努力，这个中文的分词器已经有了，它就是今天要给大家介绍的IK中文分词器。 IK中文分词器的安装 ES默认是没有IK中文分词器的，我们要将IK中文分词器作为一个插件安装到ES中，安装的步骤也很简单：从GitHub上下载适合自己ES版本的IK中文分词器，地址如下：https://github.com/medcl/elasticsearch-analysis-ik/releases。在我们的ES的插件目录中（${ES_HOME}/plugins）创建ik目录， mkdir ik ...

2020-05-07

503

@[toc] 一、ES备份 1.1 基本概念 Elasticsearch 副本提供了高可靠性；可以容忍部分的节点丢失而不会中断服务。但是副本并不提供对灾难性故障的保护。对这种情况，则是需要备份来进行处理。备份Elasticsearch集群可以使用 snapshot API。该API会拿到集群里当前的状态和数据然后保存到一个共享仓库里。这个备份过程是"智能"的。第一个快照会是一个数据的完整拷贝，但是所有后续的快照会保留的是已存快照和新数据之间的差异。随着不时的对数据进行快照，备份也在增量的添加和删除。这意味着后续备份会相当快速，因为它们只传输很小的数据量。每个快照可以包含在各种版本的Elasticsearch中创建的索引，并且在还原快照时，必须有可能将所有索引还原到目标集群中。如果快照中的任何索引是在不兼容的版本中创建的，则将无法还原快照。在6.x中创建的索引快照可以恢复到7.x。在5.x中创建的索引快照可以恢复到6.x。在2.x中创建的索引快照可以恢复到5.x。可以将在1.x中创建的索引快照恢复到2.x。要使用这个功能，必须先创建一个保存数据的仓库。有多个仓...

2020-06-05

645

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。