各位用户为了找寻关于mongodb BSON的基本使用教程的资料费劲了很多周折。这里教程网为您整理了关于mongodb BSON的基本使用教程的相关资料,仅供查阅,以下为您介绍关于mongodb BSON的基本使用教程的详细内容
查找 Find
? 1 2 3 4 5 6 7 8 9m := 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
- 比如这里首先匹配标签和账号
- 时间戳在一段时间内
- 然后根据名字分组统计数量
- 最后排序取最前面的三个。
? 1 2 3 4 5 6 7 8 9 10//这个就可以传入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)
简单介绍
? 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 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72package 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/?replicaSet=howie"
)
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"
})
//删除
}
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。
原文链接:https://www.hwholiday.com/2018/how_use_mongodb/