百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程字典 > 正文

如何通过curl方式进行ElasticSearch增删改查

toyiye 2024-06-21 11:57 8 浏览 0 评论

关于ElasticSearch增删改查的方法有很多,使用curl操作命令总结如下,如有需要可以点击收藏。

1. ElasticSearch新增数据

如果进行一个类似于SQL的 insert的操作

insert into users(name,age,email) values('ctt',18,'ctt@abc.com')

具体示例如下:

curl -XPOST "http://127.0.0.1:9200/users/_doc" -H "Content-Type: application/json" -d '
{
  "name": "ctt",
  "age": 18,
  "email": "ctt@abc.com"
}'

上面的命令使用HTTP POST方法向名为"users"的索引中添加一条文档,文档包含"name"、"age"和"email"三个字段。其中,-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体。

写了多条记录,便于后面进行测试,结果如下:

{"took":1,"timed_out":false,"_shards":{"total":5,"successful":5,"skipped":0,"failed":0},"hits":{"total":5,"max_score":1.0,"hits":[{"_index":"users","_type":"_doc","_id":"Uxz2jYYBNjbWHoXGCfXa","_score":1.0,"_source":
{
  "name": "jgt",
  "age": 29,
  "email": "jgt@abc.com"
}},{"_index":"users","_type":"_doc","_id":"UBz0jYYBNjbWHoXGufWJ","_score":1.0,"_source":
{
  "name": "ttc",
  "age": 20,
  "email": "ttc@abc.com"
}},{"_index":"users","_type":"_doc","_id":"URz1jYYBNjbWHoXGOvU0","_score":1.0,"_source":
{
  "name": "tt",
  "age": 25,
  "email": "tt@abc.com"
}},{"_index":"users","_type":"_doc","_id":"Uhz1jYYBNjbWHoXGhPWI","_score":1.0,"_source":
{
  "name": "att",
  "age": 27,
  "email": "att@abc.com"
}},{"_index":"users","_type":"_doc","_id":"TxzvjYYBNjbWHoXG-fUx","_score":1.0,"_source":
{
  "name": "ctt",
  "age": 18,
  "email": "ctt@abc.com"
}}]}}

可以用pretty加以修饰,结果集显示如下

 : {
          "name" : "ttc",
          "age" : 20,
          "email" : "ttc@abc.com"
        }
      },
      {
        "_index" : "users",
        "_type" : "_doc",
        "_id" : "URz1jYYBNjbWHoXGOvU0",
        "_score" : 1.0,
        "_source" : {
          "name" : "tt",
          "age" : 25,
          "email" : "tt@abc.com"
        }
      },
      {
        "_index" : "users",
        "_type" : "_doc",
        "_id" : "Uhz1jYYBNjbWHoXGhPWI",
        "_score" : 1.0,
        "_source" : {
          "name" : "att",
          "age" : 27,
          "email" : "att@abc.com"
        }
      },
      {
        "_index" : "users",
        "_type" : "_doc",
        "_id" : "TxzvjYYBNjbWHoXG-fUx",
        "_score" : 1.0,
        "_source" : {
          "name" : "ctt",
          "age" : 18,
          "email" : "ctt@abc.com"
        }
      }
    ]
  }
}

如果新增的文档ID由Elasticsearch自动生成,可以将"_doc"替换为"_create",这样在新增数据时,Elasticsearch会在响应中返回文档ID,示例如下:

curl -XPOST "http://127.0.0.1:9200/users/_create" -H "Content-Type: application/json" -d '
{
  "name": "ctty",
  "age": 30,
  "email": "ctty@abc.com"
}'



2. 更新记录

进行一次类似如下update的操作

update users set age=30 where name='jgt'

可以使用Elasticsearch的Update By Query API来根据条件更新数据。Update By Query API可以对符合特定条件的所有文档进行更新操作。以下是一个使用curl更新满足条件的文档的示例:

curl -XPOST "http://127.0.0.1:9200/users/_update_by_query" -H "Content-Type: application/json" -d '
{
  "query": {
    "term": {
      "name": "jgt"
    }
  },
  "script": {
    "source": "ctx._source.age = params.new_age",
    "params": {
      "new_age": 30
    }
  }
}'

更新完成后查看结果如下:

上面的命令使用HTTP POST方法向名为"users"的索引中name为“jgt”的所有文档的年龄为30。其中:

-X选项指定HTTP请求的方法
-H选项指定HTTP请求的头部信息
-d选项指定HTTP请求的数据体
"query"字段表示查询条件:"term"表示匹配字段的值等于给定值,"name"字段表示要匹配的字段,"jgt"表示要匹配的值。
"script"字段表示更新脚本:"source"表示要执行的脚本,"ctx._source.age"表示要更新的字段,"params"表示要传入的参数,"new_age"表示要更新成的新值。

除了使用Update By Query API,还可以使用Bulk API和Update API对数据进行更新。

Bulk API可以批量处理多个文档的更新、插入和删除操作。以下是一个使用curl批量更新文档的示例:

curl -XPOST "http://127.0.0.1:9200/users/_bulk" -H "Content-Type: application/json" -d '
{ "update": {"_id": "1", "_index": "users"} }
{ "doc": {"age": 16} }
{ "update": {"_id": "2", "_index": "users"} }
{ "doc": {"age": 16} }
'

上面的命令使用HTTP POST方法向名为"users"的索引中批量更新文档的age。其中:-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体,"update"表示更新操作,"_id"表示要更新的文档ID,"_index"表示要更新的索引名,"doc"表示要更新的字段和值。

Update API可以对单个文档进行更新操作。以下是一个使用curl更新单个文档的示例:

curl -XPOST "http://127.0.0.1:9200/users/_doc/1/_update" -H "Content-Type: application/json" -d '
{
 "doc": {
 "age": 16
 }
}'

上面的命令使用HTTP POST方法向名为"users"的索引中更新ID为1的文档的age为16。其中,-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体,"_doc"表示要更新的文档类型,"1"表示要更新的文档ID,"doc"表示要更新的字段和值。

需要注意的是,Bulk API和Update API都支持批量操作和复杂的更新操作,可以根据具体需求进行使用。同时,更新操作会修改原始数据,因此需要谨慎操作。

3. 删除记录

进行一次类似如下update的操作

delete from users  where name='jgt

可以使用Elasticsearch的Delete By Query API和Delete API来删除数据。

Delete By Query API可以根据特定条件删除文档。以下是一个使用curl删除满足条件的文档的示例:

curl -XPOST "http://127.0.01:9200/users/_delete_by_query" -H "Content-Type: application/json" -d '
{
 "query": {
 "term": {
 "name": "att"
 }
 }
}'

上面的命令使用HTTP POST方法向名为"users"的索引中删除"name"为"att"的所有文档。其中,-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体,"query"字段表示查询条件,"term"表示匹配字段的值等于给定值,"name"字段表示要匹配的字段,"att"表示要匹配的值。

Delete API可以删除单个文档。以下是一个使用curl删除单个文档的示例:

curl -XDELETE "http://127.0.0.1:9200/users/_doc/1"

上面的命令使用HTTP DELETE方法向名为"users"的索引中删除ID为1的文档。其中,-X选项指定HTTP请求的方法,"_doc"表示要删除的文档类型,"1"表示要删除的文档ID。

需要注意的是,删除操作会永久删除数据,因此需要谨慎操作。建议在进行删除操作前进行备份操作,以防止误操作造成数据丢失。

4. 查询记录

Elasticsearch提供了丰富的查询方式,可以根据具体的业务需求进行选择。以下是几种常用的查询方式:

4.1 Match Query

根据给定的查询条件在指定字段中进行匹配。例如,下面的查询可以匹配"my_field"字段中包含"my_value"的文档:

{ "query": { "match": { "my_field": "my_value" } } }

具体示例如下:


curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d '
{
  "query": {
    "match": {
      "name": "tt"
    }
  }
}'

查询结果如下:

4.2 Term Query

根据给定的查询条件在指定字段中进行精确匹配。

例如,下面的查询可以匹配"my_field"字段中值为"my_value"的文档:

{ "query": { "term": { "my_field": "my_value" } } }

具体示例如下:

curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d '
{
 "query": {
 "term": {
 "name": "ctt"
 }
 }
}'

查询结果如下:

4.3 Range Query

根据给定的范围查询条件在指定字段中进行匹配。

例如,下面的查询可以匹配"my_field"字段中值在10到20之间的文档:

{ "query": { "range": { "my_field": { "gte": 10, "lte": 20 } } } }

具体示例如下:

curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d '
{
  "query": {
    "range": {
      "age": {
        "gte": 10,
        "lte": 20
      }
    }
  }
}'

查询结果如下:

4.4 Bool Query

根据给定的多个查询条件进行组合查询。

例如,下面的查询可以匹配"my_field1"字段中值包含"my_value1"并且"my_field2"字段中值包含"my_value2"的文档:

{ "query": 
{ "bool": 
{ "must": [ { "match": { "my_field1": "my_value1" } }, 
            { "match": { "my_field2": "my_value2" } } 
          ]
 } } }

具体示例如下:

curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d '
{
  "query": {
    "bool": {
      "must": [
        { "match": { "name": "ctt" } },
        { "match": { "age": "18" } }
      ]
    }
  }
}'

查询结果如下:

4.5 多条件查询

在Elasticsearch中,可以使用布尔查询(Bool Query)来进行多个条件查询。Bool查询包含三种类型的子查询:must、should和must_not。

must查询:所有的查询条件都必须匹配才能返回文档。可以使用多个must子句来构建复杂的查询。
should查询:至少有一个查询条件匹配时返回文档。可以使用多个should子句来构建复杂的查询。
must_not查询:所有的查询条件都不能匹配才能返回文档。

下面是一个示例,演示如何使用Bool查询来同时匹配多个条件:

{
 "query": {
 "bool": {
 "must": [
 { "match": { "field1": "value1" } },
 { "match": { "field2": "value2" } }
 ],
 "should": [
 { "match": { "field3": "value3" } },
 { "match": { "field4": "value4" } }
 ],
 "must_not": [
 { "match": { "field5": "value5" } }
 ]
 }
 }
}

在上面的示例中,查询条件包括:

必须匹配field1为value1的文档;
必须匹配field2为value2的文档;
至少匹配一个should子句,其中field3为value3或field4为value4;
不匹配field5为value5的文档。

可以根据实际情况修改查询条件。具体示例如下:

curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d '
{
 "query": {
 "bool": {
 "must": [
 { "match": { "name": "ctt" } },
 { "match": { "age": "18" } }
 ],
 "should": [
 { "match": { "name": "tt" } },
 { "match": { "age": "18" } }
 ],
 "must_not": [
 { "match": { "name": "jgt" } }
 ]
 }
 }
}'

查询结果:

4.6 组合查询

类似于如下SQL的组合条件查询

select * from users where (name like '%ctt%' or name like '%tt%') and age >=10 and age<=2

具体示例如下:

curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d '
{
 "query": {
 "bool": {
 "should": [
 { "match": { "name": "ctt" } },
 { "match": { "name": "tt" } }
 ],
 "filter": {
 "range": {
 "age": {
 "gte": 10,
 "lte": 20
 }
 }
 }
 }
 }
}'

查询结果如下:

需要注意的是,查询操作的结果可以通过Elasticsearch的排序、过滤、聚合等方式进行处理,以满足不同的业务需求。同时,查询操作也会占用Elasticsearch的系统资源,因此需要谨慎使用,建议根据具体的业务需求选择合适的查询方式。

5. 小结

ElasticSearch的使用场景和常见的操作命令和方式均很多,后续多总结归纳。

相关推荐

为何越来越多的编程语言使用JSON(为什么编程)

JSON是JavascriptObjectNotation的缩写,意思是Javascript对象表示法,是一种易于人类阅读和对编程友好的文本数据传递方法,是JavaScript语言规范定义的一个子...

何时在数据库中使用 JSON(数据库用json格式存储)

在本文中,您将了解何时应考虑将JSON数据类型添加到表中以及何时应避免使用它们。每天?分享?最新?软件?开发?,Devops,敏捷?,测试?以及?项目?管理?最新?,最热门?的?文章?,每天?花?...

MySQL 从零开始:05 数据类型(mysql数据类型有哪些,并举例)

前面的讲解中已经接触到了表的创建,表的创建是对字段的声明,比如:上述语句声明了字段的名称、类型、所占空间、默认值和是否可以为空等信息。其中的int、varchar、char和decimal都...

JSON对象花样进阶(json格式对象)

一、引言在现代Web开发中,JSON(JavaScriptObjectNotation)已经成为数据交换的标准格式。无论是从前端向后端发送数据,还是从后端接收数据,JSON都是不可或缺的一部分。...

深入理解 JSON 和 Form-data(json和formdata提交区别)

在讨论现代网络开发与API设计的语境下,理解客户端和服务器间如何有效且可靠地交换数据变得尤为关键。这里,特别值得关注的是两种主流数据格式:...

JSON 语法(json 语法 priority)

JSON语法是JavaScript语法的子集。JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔花括号保存对象方括号保存数组JS...

JSON语法详解(json的语法规则)

JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔大括号保存对象中括号保存数组注意:json的key是字符串,且必须是双引号,不能是单引号...

MySQL JSON数据类型操作(mysql的json)

概述mysql自5.7.8版本开始,就支持了json结构的数据存储和查询,这表明了mysql也在不断的学习和增加nosql数据库的有点。但mysql毕竟是关系型数据库,在处理json这种非结构化的数据...

JSON的数据模式(json数据格式示例)

像XML模式一样,JSON数据格式也有Schema,这是一个基于JSON格式的规范。JSON模式也以JSON格式编写。它用于验证JSON数据。JSON模式示例以下代码显示了基本的JSON模式。{"...

前端学习——JSON格式详解(后端json格式)

JSON(JavaScriptObjectNotation)是一种轻量级的数据交换格式。易于人阅读和编写。同时也易于机器解析和生成。它基于JavaScriptProgrammingLa...

什么是 JSON:详解 JSON 及其优势(什么叫json)

现在程序员还有谁不知道JSON吗?无论对于前端还是后端,JSON都是一种常见的数据格式。那么JSON到底是什么呢?JSON的定义...

PostgreSQL JSON 类型:处理结构化数据

PostgreSQL提供JSON类型,以存储结构化数据。JSON是一种开放的数据格式,可用于存储各种类型的值。什么是JSON类型?JSON类型表示JSON(JavaScriptO...

JavaScript:JSON、三种包装类(javascript 包)

JOSN:我们希望可以将一个对象在不同的语言中进行传递,以达到通信的目的,最佳方式就是将一个对象转换为字符串的形式JSON(JavaScriptObjectNotation)-JS的对象表示法...

Python数据分析 只要1分钟 教你玩转JSON 全程干货

Json简介:Json,全名JavaScriptObjectNotation,JSON(JavaScriptObjectNotation(记号、标记))是一种轻量级的数据交换格式。它基于J...

比较一下JSON与XML两种数据格式?(json和xml哪个好)

JSON(JavaScriptObjectNotation)和XML(eXtensibleMarkupLanguage)是在日常开发中比较常用的两种数据格式,它们主要的作用就是用来进行数据的传...

取消回复欢迎 发表评论:

请填写验证码