现在MongoDB官方还没有推出关于官方支持的golang的driver,推荐使用的是mgo.
mgo的详细文档说明：http://godoc.org/labix.org/v2/mgo
下面是我开发中自己写的一个用mgo连接MongoDB数据库的使用实例。
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”})
}