How to use update to update documents in elasticsearch
This article mainly introduces "how to use update to update documents in elasticsearch". In daily operation, I believe many people have doubts about how to use update to update documents in elasticsearch. The editor consulted all kinds of materials and sorted out simple and easy-to-use methods of operation. I hope it will be helpful to answer the doubts about "how to use update to update documents in elasticsearch". Next, please follow the editor to study!
Document add data
If the data does not exist, it is automatically created
Rst, _: = client.Index (). Index ("user"). BodyJson (& User {Name: "hnatao", Age: 20}) .Do (ctx) buf, _: = json.Marshal (rst) fmt.Println (string (buf))
Return
{"_ index": "user", "_ type": "_ doc", "_ id": "iL1nWHQBIsMSghaJZ0p9", "_ version": 1, "result": "created", "_ shards": {"total": 4, "successful": 1, "failed": 0}, "_ primary_term": 1} add data for the specified id
Specify _ 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))
Return
{"_ index": "user", "_ type": "_ doc", "_ id": "1", "_ version": 1, "result": "created", "_ shards": {"total": 4, "successful": 1, "failed": 0}, "_ seq_no": 1, "_ primary_term": 1} update data
_ id = "1" already exists, modify the age, this operation will cause other fields to be empty, because the operation belongs to an override operation
Rst, _: = client.Index (). Index ("user"). Id ("1"). BodyJson (& User {Age: 23}) .Do (ctx) buf, _: = json.Marshal (rst) fmt.Println (string (buf))
Return
{"_ index": "user", "_ type": "_ doc", "_ id": "1", "_ version": 2, "result": "updated", "_ shards": {"total": 4, "successful": 1, "failed": 0}, "_ seq_no": 2, "_ primary_term": 1} update the document with _ update
Update fields using 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))
Return
{"_ index": "user", "_ type": "_ doc", "_ id": "1", "_ version": 7, "result": "updated", "_ shards": {"total": 4, "successful": 1, "failed": 0}, "_ seq_no": 7 "_ primary_term": 1} use _ update_by_query to update document 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))
Return
{"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": []} add documents bulkReq1: = elastic.NewBulkIndexRequest () .Id ("2") in batch via _ bulk. Doc (& User {Name: "Zhang San", Age: 21}) bulkReq2: = elastic.NewBulkIndexRequest () .Id ("3") .Doc (& User {Name: "Li Si", Age: 22}) rst _: = client.Bulk () .Index ("user") .add (bulkReq1, bulkReq2) .Do (ctx) buf, _: = json.Marshal (rst) fmt.Println (string (buf))
Return
{"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 Update the document bulkReq1: = elastic.NewBulkUpdateRequest () .Index ("user") .Id ("2") .Doc (interface {} {"age": 31}) bulkReq2: = elastic.NewBulkUpdateRequest () .Index ("user") .Id ("3") .Doc (map [string] interface {} {"age": 31}) rst via _ bulk _: = client.Bulk () .Add (bulkReq1, bulkReq2) .Do (ctx) buf, _: = json.Marshal (rst) fmt.Println (string (buf))
Return
{"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}}]} batch delete documents 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))
Return
{"took": 130,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}}]} sort by _ id ascending order Take the first two data rst, _: = client.Search (). Index ("user"). Sort ("_ id", false) .size (2) .From (0) .Do (ctx) buf, _: = json.Marshal (rst) fmt.Println (string (buf))
Return
{"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": "Zhang San" "age": 21}}]}, "_ shards": {"total": 1, "succeful": 1, "failed": 0}} sort by field value
Age descending order, _ id ascending order, first 5 items of data
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))
Return
{"hits": {"total": {"value": 8, "relation": "eq"}, "hits": [{"_ index": "user", "_ type": "_ doc", "_ id": "5", "_ seq_no": null "_ primary_term": null, "sort": [24, "5"], "_ source": {"name": "Jacky Cheung", "age": 24}}, {"_ index": "user", "_ type": "_ doc" "_ id": "4", "_ seq_no": null, "_ primary_term": null, "sort": [23, "4"], "_ source": {"name": "Andy Lau", "age": 23}} {"_ index": "user", "_ type": "_ doc", "_ id": "3", "_ seq_no": null, "_ primary_term": null, "sort": [22, "3"] "_ source": {"name": "Li Si", "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": "Zhang San", "age": 21}}]} "_ shards": {"total": 1, "successful": 1, "failed": 0}} query results show only some fields rst, _: = client.Search (). Index ("user"). FilterPath ("hits.hits._id", "hits.hits._source.name") .Do (ctx) buf, _: = json.Marshal (rst) fmt.Println (string (buf))
Return
{"hits": {"hits": [{"_ id": "1", "_ seq_no": null, "_ primary_term": null, "_ source": {"name": "lqt"} {"_ id": "2", "_ seq_no": null, "_ primary_term": null, "_ source": {"name": "Zhang San"}}, {"_ id": "3" "_ seq_no": null, "_ primary_term": null, "_ source": {"name": "Li Si"}}, {"_ id": "4", "_ seq_no": null, "_ primary_term": null "_ source": {"name": "Andy Lau"}}, {"_ id": "5", "_ seq_no": null, "_ primary_term": null "_ source": {"name": "Jacky Cheung"} query data rst according to _ id, _: = client.Get (). Index ("user"). Id ("1") .Do (ctx) buf, _: = json.Marshal (rst) fmt.Println (string (buf))
Return
{"_ index": "user", "_ type": "_ doc", "_ id": "1", "_ uid": "", "_ routing": "," _ parent ":", "_ version": 5, "_ seq_no": 5, "_ primary_term": 1, "_ source": {"name": "," age ": 23} "found": true} so far The study on "how to use update to update documents in elasticsearch" is over. I hope I can solve your doubts. The collocation of theory and practice can better help you learn, go and try it! If you want to continue to learn more related knowledge, please continue to follow the website, the editor will continue to work hard to bring you more practical articles!
