以下所有例子中结构定义如下:复制type User struct { Id_ bson.ObjectId `bson:"_id"` Name string `bson:"name"` Age int `bson:"age"` JoinedAt time.Time `bson:"joined_at"` Interests []string `bson:"interests"` Num []int `bson:"num"` }1.2.3.4.5.6.7.8.
通过func (c *Collection) Find(query interface{}) *Query来进行查询,常用查询返回的修改Query struct可以有附加各种条件来进行过滤。

通过Query.All()可以获得所有结果,中作都通过Query.One()可以获得一个结果,常用查询注意如果没有数据或者数量超过一个,修改One()会报错。中作都
条件用bson.M{key: value},常用查询注意key必须用MongoDB中的修改字段名,而不是中作都struct的字段名。
上面代码可以把所有Users都查出来:
更简单的中作都方式是直接用FindId()方法:
复制c.FindId(objectId).One(&user)1.注意这里没有处理err。亿华云计算当找不到的常用查询时候用One()方法会出错。
注意修改单个或多个字段需要通过$set操作符号,否则集合会被替换。
补充:golang mongodb查找find demo
使用gopkg.in/mgo.v2库操作,插入操作主要使用mongodb中Collection对象的香港云服务器Find方法,函数原型:
复制func (c *Collection) Find(query interface{}) *Query1.查找的时候Find的参数都会用bson.M类型
复制type M map[string]interface{}1.例如:bson.M{"name": "Tom"}相当直接mongodb的查询条件{"name": "Tom"}
统一封装下getDB方法 复制package main import ( "fmt" "gopkg.in/mgo.v2" "gopkg.in/mgo.v2/bson" ) // get mongodb db func getDB() *mgo.Database { session, err := mgo.Dial( "172.16.27.134:10001" ) if err != nil { panic(err) } session.SetMode(mgo.Monotonic, true) db := session.DB( "test" ) return db }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20. 查找单条记录 复制func findOne() { db := getDB() c := db.C( "user" ) // 用struct接收,一般情况下都会这样处理 type User struct { Name string "bson:`name`" Age int "bson:`age`" } user := User{} err := c.Find(bson.M{ "name" : "Tom" }).One(&user) if err != nil { panic(err) } fmt.Println(user) // output: {Tom 20} // 用bson.M结构接收,当你不了解返回的数据结构格式时,可以用这个先查看,然后再定义struct格式 // 在处理mongodb组合查询时,经常这么干 result := bson.M{} err = c.Find(nil).One(&result) if err != nil { panic(err) } fmt.Println(result) // output: map[_id:ObjectIdHex("56fdce98189df8759fd61e5b") name:Tom age:20] }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. 查找多条记录 复制func findMuit() { db := getDB() c := db.C( "user" ) // 使用All方法,一次性消耗较多内存,如果数据较多,可以考虑使用迭代器 type User struct { Id bson.ObjectId `bson: "_id,omitempty" ` Name string "bson:`name`" Age int "bson:`age`" } var users []User err := c.Find(nil).All(&users) if err != nil { panic(err) } fmt.Println(users) // output: [{ObjectIdHex("56fdce98189df8759fd61e5b") Tom 20}...] // 使用迭代器获取数据可以避免一次占用较大内存 var user User iter := c.Find(nil).Iter() for iter.Next(&user) { fmt.Println(user) } // output: // {ObjectIdHex("56fdce98189df8759fd61e5b") Tom 20} // {ObjectIdHex("56fdce98189df8759fd61e5c") Tom 20} // ... }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. 查找指定字段 复制func (q *Query) Select(selector interface{}) *Query1.上面使用Select函数:
复制func findField() { db := getDB() c := db.C( "user" ) // 只读取name字段 type User struct { Name string "bson:`name`" } var users []User err := c.Find(bson.M{}).Select(bson.M{ "name" : 1 }).All(&users) if err != nil { panic(err) } fmt.Println(users) // output: [{Tom} {Tom} {Anny}...] // 只排除_id字段 type User2 struct { Name string "bson:`name`" Age int "bson:`age`" } var users2 []User2 err = c.Find(bson.M{}).Select(bson.M{ "_id" : 0 }).All(&users2) if err != nil { panic(err) } fmt.Println(users2) // output: [{Tom 20} {Tom 20} {Anny 28}...] }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. 查询嵌套格式数据 复制func findNesting() { db := getDB() c := db.C( "user" ) // 使用嵌套的struct接收数据 type User struct { Name string "bson:`name`" Age int "bson:`age`" Toys []struct { Name string "bson:`name`" } } var users User // 只查询toys字段存在的 err := c.Find(bson.M{ "toys" : bson.M{ "$exists" : true}}).One(&users) if err != nil { panic(err) } fmt.Println(users) // output: {Tom 20 [{dog}]} }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22. 查找数据总数 复制func count() { db := getDB() c := db.C( "user" ) // 查找表总数 count, err := c.Count() if err != nil { panic(err) } fmt.Println(count) // output: 8 // 结合find条件查找 count, err = c.Find(bson.M{ "name" : "Tom" }).Count() if err != nil { panic(err) } fmt.Println(count) // output: 6 }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22. 对数据进行排序使用Sort函数 复制func (q *Query) Sort(fields ...string) *Query1. 上面就是使用sort函数的方法 复制func findSort() { db := getDB() c := db.C( "user" ) type User struct { Id bson.ObjectId `bson: "_id,omitempty" ` Name string "bson:`name`" Age int "bson:`age`" } var users []User // 按照age字段降序排列,如果升序去掉横线"-"就可以了 err := c.Find(nil).Sort( "-age" ).All(&users) if err != nil { panic(err) } fmt.Println(users) // output: // [{ObjectIdHex("56fdce98189df8759fd61e5d") Anny 28} ...] // ... }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19. 分页查询使用Skip函数和Limit函数 复制func (q *Query) Skip(n int) *Query func (q *Query) Limit(n int) *Query1.2. 复制func findPage() { db := getDB() c := db.C( "user" ) type User struct { Id bson.ObjectId `bson: "_id,omitempty" ` Name string "bson:`name`" Age int "bson:`age`" } var users []User // 表示从偏移位置为2的云南idc服务商地方开始取两条记录 err := c.Find(nil).Sort( "-age" ).Skip( 2 ).Limit( 2 ).All(&users) if err != nil { panic(err) } fmt.Println(users) // output: // [{ObjectIdHex("56fdce98189df8759fd61e5d") Anny 20} ...] // ... }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.相关文章:
源码库香港云服务器益华科技服务器租用IT技术网亿华云源码下载IT资讯网企商汇码上建站多维IT资讯亿华云计算编程之道云站无忧亿华云智能时代亿华互联创站工坊汇智坊益华科技益强数据堂益强前沿资讯亿华智慧云技术快报益华IT技术论坛思维库益强IT技术网运维纵横益华科技码力社极客码头IT资讯网亿华灵动极客编程全栈开发益强编程舍云智核科技前瞻亿华智造益强编程堂益强科技益强智未来益强资讯优选
0.2482s , 17466.84375 kb
Copyright © 2025 Powered by Go 语言在 MongoDB 中常用查询与修改的操作,你都会了吗?,汇智坊 滇ICP备2023006006号-2