mongodb BSON的基本使用教程
查找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(pipelineinterface{})
这个和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},
}
//这里就可以取到输出的数据
varvalues[]result
session.DB("db").C("collect").Pipe(m).All(&values)
简单介绍
packagemain
import(
"gopkg.in/mgo.v2"
"log"
"gopkg.in/mgo.v2/bson"
)
typeUserstruct{
Idbson.ObjectId`bson:"_id"`
Namestring`bson:"name"`
PassWordstring`bson:"pass_word"`
Ageint`bson:"age"`
}
funcmain(){
db,err:=mgo.Dial("mongodb://192.168.2.28:27017,192.168.2.28:27018,192.168.2.28:27019/?replicaSet=howie")
iferr!=nil{
log.Fatalln(err)
}
deferdb.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,
})*/
varusers[]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"})//删除
}
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对毛票票的支持。