查找 Find
m := bson.M{
"create_time": bson.M{
"$gte": start,
"$lte": end,
},
"account": account,
"tag": "tag",
}
session.DB("db").C("collect").Find(m).Count()
這里查找時(shí)間戳內(nèi)，賬號(hào)為account，標(biāo)簽為tag的數(shù)據(jù)并統(tǒng)計(jì)個(gè)數(shù)。
聚合管道在mgo中為Pipe(pipeline interface{})
這個(gè)和bash中使用的管道很像，數(shù)據(jù)可以被層層處理。一般傳入的參數(shù)為[]bson.M。這個(gè)[]bson.M里如果還有嵌套則還要使用[]bson.M
- 比如這里首先匹配標(biāo)簽和賬號(hào)
- 時(shí)間戳在一段時(shí)間內(nèi)
- 然后根據(jù)名字分組統(tǒng)計(jì)數(shù)量
- 最后排序取最前面的三個(gè)。
//這個(gè)就可以傳入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},
}
//這里就可以取到輸出的數(shù)據(jù)
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/?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) //查詢?nèi)繑?shù)據(jù)
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"}}) //從數(shù)組中增加一個(gè)元素($push)
c.Update(bson.M{"_id": users[0].Id}, bson.M{"$pull": bson.M{"interests": "PHP"}}) //從數(shù)組中刪除一個(gè)元素($pull)
c.FindId(users[0].Id).All(users)
log.Println(users)
c.Remove(bson.M{"name": "JK_CHENG"})//刪除
}
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問大家可以留言交流，謝謝大家對(duì)腳本之家的支持。
您可能感興趣的文章:- c#操作mongodb插入數(shù)據(jù)效率
- mongodb實(shí)現(xiàn)數(shù)組對(duì)象求和方法實(shí)例
- 如何優(yōu)雅的在一臺(tái)vps（云主機(jī)）上面部署vue+mongodb+express項(xiàng)目
- pyspark操作MongoDB的方法步驟
- Docker容器化部署嘗試——多容器通信(node+mongoDB+nginx)
- mongodb官方的golang驅(qū)動(dòng)基礎(chǔ)使用教程分享
- mongodb中非常好用的Aggregate入門教程
- 詳解Java 連接MongoDB集群的幾種方式
- Java mongodb連接配置實(shí)踐
- mongodb使用c#驅(qū)動(dòng)數(shù)據(jù)插入demo
