elasticsearch入门(简单的crud操作)

本是古典何须时尚 2024-02-19 18:36 88阅读 0赞

记录一下，elasticsearch从创建索引到插入数据的一个crud操作。

一、创建索引

curl -XPUT "http://192.168.99.1:9200/productindex" -d'
    {
      "settings": {
        "number_of_shards": 1,
        "number_of_replicas": 1
      },
      "mappings": {
        "product" : {
          "properties": {
            "name" : {
              "type": "text",
              "fielddata": true
            },
            "price" : {
              "type": "long"
            }
          }
        }
      }
    }'

二、插入数据

1、如果需要插入的数据已经存在，那么执行替换操作，如果不存在则执行插入操作

**注意： 1、此处是手动指定的id的值**

**2、如果productindex/product/1 这个数据存在，如果请求体中只有name字段，那么这行数据的price字段就会被删除，即执行的是替换操作，而不是更新操作**

curl -XPUT "http://192.168.99.1:9200/productindex/product/1" -d'
    {
      "name" : "pen",
      "price" : 2
    }'

2、如果数据已经存在，那么就报错，不存在则执行插入操作

**注意：此处只需要加上\_create或加上op\_type=create即可**

curl -XPUT "http://192.168.99.1:9200/productindex/product/1?op_type=create" -d'
    {
      "name" : "new pen",
      "price" : 2
    }'

**或**

curl -XPUT "http://192.168.99.1:9200/productindex/product/1/_create" -d'
    {
      "name" : "new pen",
      "price" : 2
    }'

3、插入数据的时候自动生成id的值

**注意：此处就需要使用post请求，而不是使用put请求。**

curl -XPOST "http://192.168.99.1:9200/productindex/product" -d'
    {
      "name" : "pen",
      "price" : 2
    }'

三、修改数据

1、使用\_update或op\_type=update指定修改，数据不存在报错

curl -XPOST "http://192.168.99.1:9200/productindex/product/1/_update" -d'
    {
      "doc": {
        "name" : "update new name"
      }
    }'_update" -d'
    {
      "doc": {
        "name" : "update new name"
      }
    }'

2、使用乐观锁version控制修改（防止在并发情况下数据修改有误）

后方的这个version的值为数据当前的版本号，如果es中这个数据的版本号发生了变化，则修改失败。

curl -XPOST "http://192.168.99.1:9200/productindex/product/1/_update?version=7" -d'
    {
      "doc": {
        "name" : "update new name"
      }
    }'version=7" -d'
    {
      "doc": {
        "name" : "update new name"
      }
    }'

3、使用upsert操作，如果数据不存在则执行upsert部分（插入操作），否则执行更新操作

curl -XPOST "http://192.168.99.1:9200/productindex/product/12/_update" -d'
    {
      "doc":{
        "name":"update new value"
      },
      "upsert" : {
        "name" : "数据不存在执行插入操作",
        "price" : 1
      }
    }'

或执行如下操作 (使用doc\_as\_upsert,如果文档不存在，则将doc的部分当做upsert的部分)

curl -XPOST "http://192.168.99.1:9200/productindex/product/13/_update" -d'
    {
      "doc":{
        "name":"update new value"
      },
      "doc_as_upsert" : true
    }'"doc_as_upsert" : true
    }'

四、高亮查询

1、插入一条新的数据

curl -XPUT "http://192.168.99.1:9200/productindex/product/29" -d'
    {
      "name" : "new name",
      "desc" : "this is a desc field"
    }'

2、匹配name字段中有has name的值或desc字段中有desc的值，并对匹配到的值进行高亮

curl -XGET "http://192.168.99.1:9200/productindex/product/_search" -d'
    {
      "query": {
        "bool": {
          "should": [
            {
              "match": {
                "name": "has name"
              }
            },
            {
              "term": {
                "desc": {
                  "value": "desc"
                }
              }
            }
          ]
        }
      },
      "highlight": {
        "pre_tags": "<span style=\"color:red\">",
        "post_tags": "</span>",
        "fields": {
          "name" : {
            "pre_tags": "<span style=\"color:blue\">",
            "post_tags": "</span>"
          },
          "*" : {
            
          }
        }
      }
    }'

![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyNi81ODg4LzI1YTQxMDhkLTI4YzgtMzQwZC1iM2QwLTQwYTNjYTk0NTg3Yi5wbmc][]

五、删除数据

1、删除id=1的数据

curl -XDELETE "http://192.168.99.1:9200/productindex/product/1"

[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyNi81ODg4LzI1YTQxMDhkLTI4YzgtMzQwZC1iM2QwLTQwYTNjYTk0NTg3Yi5wbmc]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/432342c4e1d14b99a555d105455027b7.png