神剑山庄资源网 Design By www.hcban.com
查找 Find
m := bson.M{ "create_time": bson.M{ "$gte": start, "$lte": end, }, "account": account, "tag": "tag", } session.DB("db").C("collect").Find(m).Count()
这里查找时间戳内,账号为account,标签为tag的数据并统计个数。
聚合管道在mgo中为Pipe(pipeline interface{})
这个和bash中使用的管道很像,数据可以被层层处理。一般传入的参数为[]bson.M。这个[]bson.M里如果还有嵌套则还要使用[]bson.M
- 比如这里首先匹配标签和账号
- 时间戳在一段时间内
- 然后根据名字分组统计数量
- 最后排序取最前面的三个。
//这个就可以传入Pipe m := []bson.M{ {"$match": bson.M{"tag": "tag", "account": account, "create_time": bson.M{"$gte": start, "$lte": end}}}, {"$group": bson.M{"_id": "$TagName", "count": bson.M{"$sum": 1}}}, {"$sort": bson.M{"count": -1}}, {"$limit": 3}, } //这里就可以取到输出的数据 var values []result session.DB("db").C("collect").Pipe(m).All(&values)
简单介绍
package main import ( "gopkg.in/mgo.v2" "log" "gopkg.in/mgo.v2/bson" ) type User struct { Id bson.ObjectId `bson:"_id"` Name string `bson:"name"` PassWord string `bson:"pass_word"` Age int `bson:"age"` } func main() { db, err := mgo.Dial("mongodb://192.168.2.28:27017,192.168.2.28:27018,192.168.2.28:27019/") if err != nil { log.Fatalln(err) } defer db.Close() db.SetMode(mgo.Monotonic, true) c := db.DB("howie").C("person") //插入 /*c.Insert(&User{ Id: bson.NewObjectId(), Name: "JK_CHENG", PassWord: "123132", Age: 2, }, &User{ Id: bson.NewObjectId(), Name: "JK_WEI", PassWord: "qwer", Age: 5, }, &User{ Id: bson.NewObjectId(), Name: "JK_HE", PassWord: "6666", Age: 7, })*/ var users []User c.Find(nil).All(&users) //查询全部数据 log.Println(users) c.FindId(users[0].Id).All(&users) //通过ID查询 log.Println(users) c.Find(bson.M{"name": "JK_WEI"}).All(&users) //单条件查询(=) log.Println(users) c.Find(bson.M{"name": bson.M{"$ne": "JK_WEI"}}).All(&users) //单条件查询(!=) log.Println(users) c.Find(bson.M{"age": bson.M{"$gt": 5}}).All(&users) //单条件查询(>) log.Println(users) c.Find(bson.M{"age": bson.M{"$gte": 5}}).All(&users) //单条件查询(>=) log.Println(users) c.Find(bson.M{"age": bson.M{"$lt": 5}}).All(&users) //单条件查询(<) log.Println(users) c.Find(bson.M{"age": bson.M{"$lte": 5}}).All(&users) //单条件查询(<=) log.Println(users) /*c.Find(bson.M{"name": bson.M{"$in": []string{"JK_WEI", "JK_HE"}}}).All(&users) //单条件查询(in) log.Println(users) c.Find(bson.M{"$or": []bson.M{bson.M{"name": "JK_WEI"}, bson.M{"age": 7}}}).All(&users) //多条件查询(or) log.Println(users) c.Update(bson.M{"_id": users[0].Id}, bson.M{"$set": bson.M{"name": "JK_HOWIE", "age": 61}}) //修改字段的值($set) c.FindId(users[0].Id).All(&users) log.Println(users) c.Find(bson.M{"name": "JK_CHENG", "age": 66}).All(&users) //多条件查询(and) log.Println(users) c.Update(bson.M{"_id": users[0].Id}, bson.M{"$inc": bson.M{"age": -6,}}) //字段增加值($inc) c.FindId(users[0].Id).All(&users) log.Println(users)*/ //c.Update(bson.M{"_id": users[0].Id}, bson.M{"$push": bson.M{"interests": "PHP"}}) //从数组中增加一个元素($push) c.Update(bson.M{"_id": users[0].Id}, bson.M{"$pull": bson.M{"interests": "PHP"}}) //从数组中删除一个元素($pull) c.FindId(users[0].Id).All(&users) log.Println(users) c.Remove(bson.M{"name": "JK_CHENG"})//删除 }
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。
神剑山庄资源网 Design By www.hcban.com
神剑山庄资源网
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件!
如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
神剑山庄资源网 Design By www.hcban.com
暂无mongodb BSON的基本使用教程的评论...
更新日志
2024年10月18日
2024年10月18日
- 群星《歌手2024 第4期》[FLAC/分轨][563.76MB]
- RiffKitten-ChaosParade(2024)[24-44,1]FLAC
- RuneKlakegg-Nattevandrer(2024)[24-96]\FLAC
- 赖冰霞.2006-金嗓典藏辑2IN1(南方金点系列)2CD【南方】【WAV+CUE】
- 群星.1988-国语金曲尽精英VOL.2【瑞成】【WAV+CUE】
- 张宇.1999-雨一直下【EMI百代】【WAV+CUE】
- 袁娅维.2021-月亮失眠了(DELUXE)【华纳】【FLAC分轨】
- AlanBroadbent-JazzFunk(2024)[24-44,1]
- 梅艳芳《绝代芳华》开盘母带[低速原抓WAV+CUE]
- ABC唱片-《外国精逊母带直刻神奇黑胶[APE+CUE].
- 群星《天赐的声音第五季 第6期》[320K/MP3][101.43MB]
- 群星《天赐的声音第五季 第6期》[FLAC/分轨][526.16MB]
- 群星《说唱梦工厂 第2期》[320K/MP3][96.37MB]
- 杨宗宪.1994-留你留袂着【有容唱片】【WAV+CUE】
- 李翊君.2005-勇敢的爱【创意唱片】【WAV+CUE】