如何通过Curl方式进行ElasticSearch增删改查使用Curl操作命令总结如下

2024-07-01 00:11:06 [百科] 来源：避面尹邢网

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

作者：数据库干货铺 2023-02-27 07:37:56数据库其他数据库关于ElasticSearch增删改查的何通方法有很多，使用Curl操作命令总结如下。过C改查

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

如何通过Curl方式进行ElasticSearch增删改查使用Curl操作命令总结如下

1、过C改查ElasticSearch新增数据

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

如何通过Curl方式进行ElasticSearch增删改查使用Curl操作命令总结如下

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

具体示例如下：

如何通过Curl方式进行ElasticSearch增删改查使用Curl操作命令总结如下

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"三个字段。何通其中，过C改查-X选项指定HTTP请求的式进方法，-H选项指定HTTP请求的增删头部信息，-d选项指定HTTP请求的何通数据体。

写了多条记录，过C改查便于后面进行测试，式进结果如下：

{ "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提供了丰富的查询方式，可以根据具体的业务需求进行选择。以下是几种常用的查询方式：

（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"
}
}
}'

查询结果如下:

（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"
}
}
}'

查询结果如下：

（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）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" } }
]
}
}
}'

查询结果如下：

（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" } }
]
}
}
}'

查询结果：

（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
}
}
}
}
}
}'