elasticsearch中怎么使用update更新文档
发表于:2024-09-21 作者:千家信息网编辑
千家信息网最后更新 2024年09月21日,这篇文章主要介绍"elasticsearch中怎么使用update更新文档",在日常操作中,相信很多人在elasticsearch中怎么使用update更新文档问题上存在疑惑,小编查阅了各式资料,整理
千家信息网最后更新 2024年09月21日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更新文档"的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注网站,小编会继续努力为大家带来更多实用的文章!
文档
更新
数据
字段
张三
学习
李四
升序
年龄
张学友
更多
刘德华
帮助
排序
查询
实用
接下来
文章
方法
理论
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
龙岗高效网络安全服务
惠州无限软件开发回收价
富国互联网科技股票基金许炎
软件开发课程视频网站
哪里有期货软件开发
vbnet数据库开发实例
沈阳装修网络安全
mc服务器怎么获得玩家头颅
小语vpn的服务器
魔兽世界服务器连接蓝条
C大规模软件开发 建议
我的世界服务器怎么关闭方块
贵州微音网络技术有限公司
网络安全先进典型案例
会员资料数据库制作
节假日数据库api
松江区通讯网络技术结构设计
信息网络安全技术控制点
mac电脑服务器地址
空间数据库的类型
公网ip访问不到web服务器
魔法金属服务器设置难度
郑州东高速服务器可以充etc
接口转换软件开发
组态软件开发版 运行版
黄浦区软件开发产品介绍
网络技术部社团
华为运动健康手环无法连接服务器
魔兽魔杖数据库
东南大学网络安全于全院士