
关于ElasticSearch增删改查的何通方法有很多,使用curl操作命令总结如下,过C改查如有需要可以点击收藏。式进 1、增删ElasticSearch新增数据如果进行一个类似于SQL的何通 insert的操作 复制insert into users(name,age,email) values(ctt,18,ctt@abc.com)1. 具体示例如下: 复制curl -XPOST "http://127.0.0.1:9200/users/_doc" -H "Content-Type: application/json" -d { "name": "ctt" , "age": 18 , "email": "ctt@abc.com"}1.2.3.4.5.6. 
上面的命令使用HTTP POST方法向名为"users"的索引中添加一条文档,文档包含"name"、过C改查"age"和"email"三个字段。式进其中,增删-X选项指定HTTP请求的何通方法,-H选项指定HTTP请求的过C改查头部信息,-d选项指定HTTP请求的式进数据体。 写了多条记录,增删便于后面进行测试,何通结果如下: 复制{"took":1,过C改查"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"}}]}}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26. 
可以用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" } } ] } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42. 如果新增的文档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"}1.2.3.4.5.6. 2、更新记录进行一次类似如下update的操作 复制update users set age=30 where name=jgt1. 可以使用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 } } }1.2.3.4.5.6.7.8.9.10.11.12.13.14. 更新完成后查看结果如下: 
上面的命令使用HTTP POST方法向名为"users"的索引中name为“jgt”的所有文档的年龄为30。其中: 复制-X选项指定HTTP请求的方法-H选项指定HTTP请求的头部信息-d选项指定HTTP请求的数据体"query"字段表示查询条件:"term"表示匹配字段的值等于给定值,"name"字段表示要匹配的字段,"jgt"表示要匹配的值。"script"字段表示更新脚本:"source"表示要执行的脚本,"ctx._source.age"表示要更新的字段,"params"表示要传入的参数,"new_age"表示要更新成的新值。1.2.3.4.5. 除了使用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 } } 1.2.3.4.5.6. 上面的命令使用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 } }1.2.3.4.5.6. 上面的命令使用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=jgt1. 可以使用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" } } }1.2.3.4.5.6.7.8. 上面的命令使用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"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" } } }1. 具体示例如下: 复制curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d { "query" : { "match" : { "name": "tt" } } }1.2.3.4.5.6.7.8. 查询结果如下:  (2)Term Query 根据给定的查询条件在指定字段中进行精确匹配。 例如,下面的查询可以匹配"my_field"字段中值为"my_value"的文档: 复制{ "query": { "term": { "my_field": "my_value" } } }1. 具体示例如下: 复制curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d { "query" : { "term" : { "name": "ctt" } } }1.2.3.4.5.6.7.8. 查询结果如下:  (3)Range Query 根据给定的范围查询条件在指定字段中进行匹配。 例如,下面的查询可以匹配"my_field"字段中值在10到20之间的文档: 复制{ "query": { "range": { "my_field": { "gte": 10, "lte": 20 } } } }1. 具体示例如下: 复制curl -XGET "http://127.0.0.1:9200/users/_search?pretty" -H "Content-Type: application/json" -d { "query" : { "range" : { "age" : { "gte": 10 , "lte": 20 } } } }1.2.3.4.5.6.7.8.9.10.11. 查询结果如下:  (4)Bool Query 根据给定的多个查询条件进行组合查询。 例如,下面的查询可以匹配"my_field1"字段中值包含"my_value1"并且"my_field2"字段中值包含"my_value2"的文档: 复制{ "query" : { "bool" : { "must": [ { "match": { "my_field1": "my_value1" } }, { "match": { "my_field2": "my_value2" } } ] } } }1.2.3.4.5.6. 具体示例如下: 复制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" } } ] } } }1.2.3.4.5.6.7.8.9.10.11. 查询结果如下:  (5)多条件查询 在Elasticsearch中,可以使用布尔查询(Bool Query)来进行多个条件查询。Bool查询包含三种类型的子查询:must、should和must_not。 复制must查询:所有的查询条件都必须匹配才能返回文档。可以使用多个must子句来构建复杂的查询。should查询:至少有一个查询条件匹配时返回文档。可以使用多个should子句来构建复杂的查询。must_not查询:所有的查询条件都不能匹配才能返回文档。1.2.3. 下面是一个示例,演示如何使用Bool查询来同时匹配多个条件: 复制{ "query" : { "bool" : { "must" : [ { "match": { "field1": "value1" } }, { "match": { "field2": "value2" } } ], "should" : [ { "match": { "field3": "value3" } }, { "match": { "field4": "value4" } } ], "must_not" : [ { "match": { "field5": "value5" } } ] } } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17. 在上面的示例中,查询条件包括: 复制必须匹配field1为value1的文档;必须匹配field2为value2的文档;至少匹配一个should子句,其中field3为value3或field4为value4;不匹配field5为value5的文档。1.2.3.4. 可以根据实际情况修改查询条件。具体示例如下: 复制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" } } ] } } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18. 查询结果:  (6)组合查询 类似于如下SQL的组合条件查询 复制select * from users where (name like %ctt% or name like %tt%) and age >=10 and age<=21. 具体示例如下: 复制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 } } } } } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19. 查询结果如下: 
需要注意的是,查询操作的结果可以通过Elasticsearch的排序、过滤、聚合等方式进行处理,以满足不同的业务需求。同时,查询操作也会占用Elasticsearch的系统资源,因此需要谨慎使用,建议根据具体的业务需求选择合适的查询方式。 5、小结ElasticSearch的使用场景和常见的操作命令和方式均很多,后续多总结归纳。 |