elasticsearch中怎么使用update更新文档

这篇文章主要介绍“elasticsearch中怎么使用update更新文档”，在日常操作中，相信很多人在elasticsearch中怎么使用update更新文档问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”elasticsearch中怎么使用update更新文档”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

文档

添加数据

如果数据不存在，会自动创建

rst, _ := client.Index().Index("user").BodyJson(&User{Name: "hnatao", Age: 20}).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "_index": "user",     "_type": "_doc",     "_id": "iL1nWHQBIsMSghaJZ0p9",     "_version": 1,     "result": "created",     "_shards": { "total": 4, "successful": 1, "failed": 0 },     "_primary_term": 1 }

添加指定 id 的数据

指定 _id = "1"

rst, _ := client.Index().Index("user").Id("1").BodyJson(&User{Name: "lqt", Age: 22}).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "_index": "user",     "_type": "_doc",     "_id": "1",     "_version": 1,     "result": "created",     "_shards": { "total": 4, "successful": 1, "failed": 0 },     "_seq_no": 1,     "_primary_term": 1 }

更新数据

_id = "1" 已经存在，修改年龄，该操作会导致其他字段为空，因为该操作属于覆盖操作

rst, _ := client.Index().Index("user").Id("1").BodyJson(&User{Age: 23}).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "_index": "user",     "_type": "_doc",     "_id": "1",     "_version": 2,     "result": "updated",     "_shards": { "total": 4, "successful": 1, "failed": 0 },     "_seq_no": 2,     "_primary_term": 1 }

使用_update更新文档

使用map[string]interface{}更新字段

rst, _ := client.Update().Index("user").Id("1").Doc(map[string]interface{}{"age":25}).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "_index": "user",     "_type": "_doc",     "_id": "1",     "_version": 7,     "result": "updated",     "_shards": { "total": 4, "successful": 1, "failed": 0 },     "_seq_no": 7,     "_primary_term": 1 }

使用_update_by_query更新文档

q := elastic.NewMatchQuery("_id", "1") sc := elastic.NewScript("ctx._source.age=21") rst, _ := client.UpdateByQuery("user").Query(q).Script(sc).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "took": 5,     "timed_out": false,     "total": 1,     "updated": 1,     "deleted": 0,     "batches": 1,     "version_conflicts": 0,     "noops": 0,     "retries": { "bulk": 0, "search": 0 },     "throttled": "",     "throttled_millis": 0,     "requests_per_second": -1,     "throttled_until": "",     "throttled_until_millis": 0,     "failures": [] }

通过 _bulk 批量添加文档

bulkReq1 := elastic.NewBulkIndexRequest().Id("2").Doc(&User{Name: "张三", Age: 21}) bulkReq2 := elastic.NewBulkIndexRequest().Id("3").Doc(&User{Name: "李四", Age: 22}) rst, _ := client.Bulk().Index("user").Add(bulkReq1, bulkReq2).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "took": 3,     "items": [         {             "index": {                 "_index": "user",                 "_type": "_doc",                 "_id": "2",                 "_version": 1,                 "result": "created",                 "_shards": { "total": 4, "successful": 1, "failed": 0 },                 "_seq_no": 19,                 "_primary_term": 1,                 "status": 201             }         },         {             "index": {                 "_index": "user",                 "_type": "_doc",                 "_id": "3",                 "_version": 1,                 "result": "created",                 "_shards": { "total": 4, "successful": 1, "failed": 0 },                 "_seq_no": 20,                 "_primary_term": 1,                 "status": 201             }         }     ] }

通过 _bulk 批量更新文档

bulkReq1 := elastic.NewBulkUpdateRequest().Index("user").Id("2").Doc(map[string]interface{}{"age": 31}) bulkReq2 := elastic.NewBulkUpdateRequest().Index("user").Id("3").Doc(map[string]interface{}{"age": 31}) rst, _ := client.Bulk().Add(bulkReq1, bulkReq2).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "took": 7,     "items": [         {             "update": {                 "_index": "user",                 "_type": "_doc",                 "_id": "2",                 "_version": 2,                 "result": "updated",                 "_shards": { "total": 4, "successful": 1, "failed": 0 },                 "_seq_no": 21,                 "_primary_term": 1,                 "status": 200             }         },         {             "update": {                 "_index": "user",                 "_type": "_doc",                 "_id": "3",                 "_version": 2,                 "result": "updated",                 "_shards": { "total": 4, "successful": 1, "failed": 0 },                 "_seq_no": 22,                 "_primary_term": 1,                 "status": 200             }         }     ] }

通过 _bulk 批量删除文档

bulkReq1 := elastic.NewBulkDeleteRequest().Index("user").Id("2") bulkReq2 := elastic.NewBulkDeleteRequest().Index("user").Id("3") rst, _ := client.Bulk().Add(bulkReq1, bulkReq2).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "took": 130,     "items": [         {             "delete": {                 "_index": "user",                 "_type": "_doc",                 "_id": "2",                 "_version": 3,                 "result": "deleted",                 "_shards": { "total": 4, "successful": 1, "failed": 0 },                 "_seq_no": 23,                 "_primary_term": 1,                 "status": 200             }         },         {             "delete": {                 "_index": "user",                 "_type": "_doc",                 "_id": "3",                 "_version": 3,                 "result": "deleted",                 "_shards": { "total": 4, "successful": 1, "failed": 0 },                 "_seq_no": 24,                 "_primary_term": 1,                 "status": 200             }         }     ] }

按照 _id 升序排序，取前 2 个数据

rst, _ := client.Search().Index("user").Sort("_id", false).Size(2).From(0).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "took": 439,     "hits": {         "total": { "value": 8, "relation": "eq" },         "hits": [             {                 "_index": "user",                 "_type": "_doc",                 "_id": "5",                 "_seq_no": null,                 "_primary_term": null,                 "sort": ["1"],                 "_source": { "name": "lqt", "age": 21 }             },             {                 "_index": "user",                 "_type": "_doc",                 "_id": "4",                 "_seq_no": null,                 "_primary_term": null,                 "sort": ["2"],                 "_source": { "name": "张三", "age": 21 }             }         ]     },     "_shards": { "total": 1, "succeful": 1, "failed": 0 } }

按照字段值排序

年龄降序，_id升序，前 5 条数据

rst, _ := client.Search().Index("user").SortBy(elastic.NewFieldSort("age").Desc(), elastic.NewFieldSort("_id").Asc()).Size(5).From(0).Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "hits": {         "total": { "value": 8, "relation": "eq" },         "hits": [             {                 "_index": "user",                 "_type": "_doc",                 "_id": "5",                 "_seq_no": null,                 "_primary_term": null,                 "sort": [24, "5"],                 "_source": { "name": "张学友", "age": 24 }             },             {                 "_index": "user",                 "_type": "_doc",                 "_id": "4",                 "_seq_no": null,                 "_primary_term": null,                 "sort": [23, "4"],                 "_source": { "name": "刘德华", "age": 23 }             },             {                 "_index": "user",                 "_type": "_doc",                 "_id": "3",                 "_seq_no": null,                 "_primary_term": null,                 "sort": [22, "3"],                 "_source": { "name": "李四", "age": 22 }             },             {                 "_index": "user",                 "_type": "_doc",                 "_id": "1",                 "_seq_no": null,                 "_primary_term": null,                 "sort": [21, "1"],                 "_source": { "name": "lqt", "age": 21 }             },             {                 "_index": "user",                 "_type": "_doc",                 "_id": "2",                 "_seq_no": null,                 "_primary_term": null,                 "sort": [21, "2"],                 "_source": { "name": "张三", "age": 21 }             }         ]     },     "_shards": { "total": 1, "successful": 1, "failed": 0 } }

查询结果只展示部分字段

rst, _ := client.Search().Index("user").FilterPath("hits.hits._id", "hits.hits._source.name").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "hits": {         "hits": [             {                 "_id": "1",                 "_seq_no": null,                 "_primary_term": null,                 "_source": { "name": "lqt" }             },             {                 "_id": "2",                 "_seq_no": null,                 "_primary_term": null,                 "_source": { "name": "张三" }             },             {                 "_id": "3",                 "_seq_no": null,                 "_primary_term": null,                 "_source": { "name": "李四" }             },             {                 "_id": "4",                 "_seq_no": null,                 "_primary_term": null,                 "_source": { "name": "刘德华" }             },             {                 "_id": "5",                 "_seq_no": null,                 "_primary_term": null,                 "_source": { "name": "张学友" }             }         ]     } }

根据_id查询数据

rst, _ := client.Get().Index("user").Id("1").Do(ctx) buf, _ := json.Marshal(rst) fmt.Println(string(buf))

返回

{     "_index": "user",     "_type": "_doc",     "_id": "1",     "_uid": "",     "_routing": "",     "_parent": "",     "_version": 5,     "_seq_no": 5,     "_primary_term": 1,     "_source": { "name": "", "age": 23 },     "found": true }

到此，关于“elasticsearch中怎么使用update更新文档”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！