注:现在MongoDB官方还没有推出关于官方支持的golang的driver,推荐使用的是mgo, mgo的详细文档说明:http://godoc.org/labix.org/v2/mgo
下面是开发中自己写的一个用mgo连接MongoDB数据库的使用实例。
package mainimport ( "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”})}总结
以上是内存溢出为你收集整理的golang 使用mgo 连接MongoDB全部内容,希望文章能够帮你解决golang 使用mgo 连接MongoDB所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)