MongoDB的Go语言驱动----mgo的使用指南

原文地址：https://my.oschina.net/ffs/blog/300148

go get gopkg.in/mgo.v2

示例

下面的代码是个示例。

package main 
import ( "fmt" 
	"labix.org/v2/mgo" 
	"labix.org/v2/mgo/bson" 
) 
type Person struct 
{ 
	Name string 
	Phone string 
} 

func main() 
{ 
	session, err := mgo.Dial("") 
	if err != nil { panic(err) } 
	defer session.Close() 

	session.SetMode(mgo.Monotonic, true)
	c := session.DB("test").C("people") 
	err = c.Insert(&Person{"Ale", "111111"}, &Person{"Cla", "222222222"}) 
	if err != nil { panic(err) } 
	result := Person{} 
	err = c.Find(bson.M{"name": "Ale"}).One(&result) if err != nil { panic(err) } 
	fmt.Println("Phone:", result.Phone) 
 }

具体代码什么意思先不用管，后面讲解每个方法的用法。

如何使用

下面介绍如何使用mgo，主要介绍集合的操作。对数据库，用户等操作，请自行查看文档。

第一步当然是先导入mgo包

import ( 
"gopkg.in/mgo.v2" 
"gopkg.in/mgo.v2/bson" 
)

连接服务器

通过方法Dial()来和MongoDB服务器建立连接。Dial()定义如下：

func Dial(url string) (*Session, error)

具体使用：

session, err := mgo.Dial(url)

如果是本机，并且MongoDB是默认端口27017启动的话，下面几种方式都可以。

session, err := mgo.Dial("") 
session, err := mgo.Dial("localhost") 
session, err := mgo.Dial("127.0.0.1") 
session, err := mgo.Dial("localhost:27017")
session, err := mgo.Dial("127.0.0.1:27017")

如果不在本机或端口不同，传入相应的地址即可。如：

mongodb://myuser:mypass@localhost:40001,otherhost:40001/mydb

func (s *Session) DB(name string) *Database

db := session.DB("test")

func (db *Database) C(name string) *Collection

c := db.C("users")

对集合进行操作

介绍插入、查询、修改、删除操作。

先提一下ObjectId，MongoDB每个集合都会一个名为_id的主键，这是一个24位的16进制字符串。对应到mgo中就是bson.ObjectId。

这里我们定义一个struct，用来和集合对应。

type User struct 
{ 
Id_ bson.ObjectId `bson:"_id"` 
Name string `bson:"name"` 
Age int `bson:"age"` 
JonedAt time.Time `bson:"joned_at"` 
Interests []string `bson:"interests"` 
}

注解

注意User的字段首字母大写，不然不可见。通过bson:”name”这种方式可以定义MongoDB中集合的字段名，如果不定义，mgo自动把struct的字段名首字母小写作为集合的字段名。如果不需要获得id_，Id_可以不定义，在插入的时候会自动生成。

插入

插入方法定义如下：

func (c *Collection) Insert(docs ...interface{}) error

下面代码插入两条集合数据。

err = c.Insert(&User{ Id_: bson.NewObjectId(), 
				Name: "Jimmy Kuu", 
				Age: 33, 
				JoinedAt: time.Now(),
				Interests: []string{"Develop", "Movie"}, }
				) 
if err != nil { 
	panic(err) 
} 
err = c.Insert(&User{ Id_: bson.NewObjectId(), 
				Name: "Tracy Yu", 
				Age: 31, 
				JoinedAt: time.Now(), 
				Interests: []string{"Shoping", "TV"}, }
				) 
if err != nil { 
	panic(err) 
}

这里通过bson.NewObjectId()来创建新的ObjectId，如果创建完需要用到的话，放在一个变量中即可，一般在Web开发中可以作为参数跳转到其他页面。

通过MongoDB客户端可以发现，两条即可已经插入。

{ "_id" : ObjectId( "5204af979955496907000001" ), 
"name" : "Jimmy Kuu", 
"age" : 33, 
"joned_at" : Date( 1376038807950 ), 
"interests" : [ "Develop", "Movie" ] 
} 
{ "_id" : ObjectId( "5204af979955496907000002" ), 
"name" : "Tracy Yu", 
"age" : 31, 
"joned_at" : Date( 1376038807971 ),
"interests" : [ "Shoping", "TV" ] 
}

查询

通过func (c *Collection) Find(query interface{}) *Query来进行查询，返回的Query struct可以有附加各种条件来进行过滤。

通过Query.All()可以获得所有结果，通过Query.One()可以获得一个结果，注意如果没有数据或者数量超过一个，One()会报错。

条件用bson.M{key: value}，注意key必须用MongoDB中的字段名，而不是struct的字段名。

var users []User c.Find(nil).All(&users) fmt.Println(users)

[{ObjectIdHex("5204af979955496907000001") Jimmy Kuu 33 2013-08-09 17:00:07.95 +0800 CST [Develop Movie]} {ObjectIdHex("5204af979955496907000002") Tracy Yu 31 2013-08-09 17:00:07.971 +0800 CST [Shoping TV]}]

id := "5204af979955496907000001" objectId := bson.ObjectIdHex(id) user := new(User) c.Find(bson.M{"_id": objectId}).One(&user) fmt.Println(user)

&{ObjectIdHex("5204af979955496907000001") Jimmy Kuu 33 2013-08-09 17:00:07.95 +0800 CST [Develop Movie]}

c.FindId(objectId).One(&user)

c.Find(bson.M{"name": "Jimmy Kuu"}).All(&users)

c.Find(bson.M{"name": bson.M{"$ne": "Jimmy Kuu"}}).All(&users)

c.Find(bson.M{"age": bson.M{"$gt": 32}}).All(&users)

c.Find(bson.M{"age": bson.M{"$lt": 32}}).All(&users)

c.Find(bson.M{"age": bson.M{"$gte": 33}}).All(&users)

c.Find(bson.M{"age": bson.M{"$lte": 31}}).All(&users)

c.Find(bson.M{"name": bson.M{"$in": []string{"Jimmy Kuu", "Tracy Yu"}}}).All(&users)

c.Find(bson.M{"name": "Jimmy Kuu", "age": 33}).All(&users)

c.Find(bson.M{"$or": []bson.M{bson.M{"name": "Jimmy Kuu"}, bson.M{"age": 31}}}).All(&users)

func (c *Collection) Update(selector interface{}, change interface{}) error

c.Update(bson.M{"_id": bson.ObjectIdHex("5204af979955496907000001")}, bson.M{"$set": bson.M{ "name": "Jimmy Gu", "age": 34, }})

c.Update(bson.M{"_id": bson.ObjectIdHex("5204af979955496907000001")}, bson.M{"$inc": bson.M{ "age": -1, }})

c.Update(bson.M{"_id": bson.ObjectIdHex("5204af979955496907000001")}, bson.M{"$push": bson.M{ "interests": "Golang", }})

c.Update(bson.M{"_id": bson.ObjectIdHex("5204af979955496907000001")}, bson.M{"$pull": bson.M{ "interests": "Golang", }})

c.Remove(bson.M{"name": "Jimmy Kuu"})