注:现在MongoDB官方还没有推出关于官方支持的golang的driver,推荐使用的是mgo,
mgo的详细文档说明:http://godoc.org/labix.org/v2/mgo
下面是开发中自己写的一个用mgo连接MongoDB数据库的使用实例。
@H_502_37@package main import ( "fmt" "labix.org/v2/mgo" "labix.org/v2/mgo/bson" ) type Person struct { NAME string PHONE string } type Men struct { Persons []Person } const = ( URL = "192.168.2.175:27017" ) func main() { session,err := mgo.Dial(URL) //连接数据库 if err != nil { panic(err) } defer session.Close() session.SetMode(mgo.Monotonic,true) db := session.DB("mydb") //数据库名称 collection := db.C("person") //如果该集合已经存在的话,则直接返回 //*****集合中元素数目******** countNum,err := collection.Count() if err != nil { panic(err) } fmt.Println("Things objects count: ",countNum) //*******插入元素******* temp := &Person{ PHONE: "18811577546",NAME: "zhangzheHero" } //一次可以插入多个对象 插入两个Person对象 err = collection.Insert(&Person{"Ale","+55 53 8116 9639"},temp) if err != nil { panic(err) } //*****查询单条数据******* result := Person{} err = collection.Find(bson.M{"phone": "456"}).One(&result) fmt.Println("Phone:",result.NAME,result.PHONE) //*****查询多条数据******* var personAll Men //存放结果 iter := collection.Find(nil).Iter() for iter.Next(&result) { fmt.Printf("Result: %v\n",result.NAME) personAll.Persons = append(personAll.Persons,result) } //*******更新数据********** err = collection.Update(bson.M{"name": "ccc"},bson.M{"$set": bson.M{"name": "ddd"}}) err = collection.Update(bson.M{"name": "ddd"},bson.M{"$set": bson.M{"phone": "12345678"}}) err = collection.Update(bson.M{"name": "aaa"},bson.M{"phone": "1245","name": "bbb"}) //******删除数据************ _,err = collection.RemoveAll(bson.M{"name": "Ale”}) }