Golang使用MongoDB

go使用mongo

文档链接：https://godoc.org/labix.org/v2/mgo

mongo包下载：go get github.com/go-mgo/mgo

import (
	"fmt"
	"gopkg.in/mgo.v2"
	_ "gopkg.in/mgo.v2/bson"
	"os"
)

var Session *mgo.Session
var Databases *mgo.Database
var MgoError error

const (
	MONGO_HOST	= ""
	MONGO_PORT	= ""
	MONGO_DB	= ""
	MONGO_USER	= ""
	MONGO_PWD	= ""
)

func init() {
	// 创建链接
	Session, MgoError = mgo.Dial(fmt.Sprintf("%s:%s", MONGO_HOST, MONGO_PORT))
	if MgoError != nil {
		fmt.Println("链接失败！")
		os.Exit(1)
	}
	// 选择DB
	Databases = Session.DB(MONGO_DB)
	// 登陆
	MgoError = Databases.Login(MONGO_USER, MONGO_PWD)
	if MgoError != nil {
		fmt.Println("登陆验证失败！")
		os.Exit(1)
	}
	// defer Session.Close()
}

func Demos() {
	// 选择一个要操作的Collection
	c := Databases.C("demo")
	// count
	fmt.Println(c.Count())
	// insert
	c.Insert(map[string]string{"name": "马超"})
	// update
	c.Update(map[string]string{"name": "马超"}, map[string]string{"name": "黄忠"})
	// remove
	c.Remove(map[string]string{"name": "马超"})
	// find - count
	num, MgoError := c.Find(map[string]string{"name": "黄忠"}).Count()
	if MgoError != nil {
		fmt.Println(MgoError.Error())
	} else {
		fmt.Println(num)
	}
	// find - one
	var one map[string]interface{}
	MgoError = c.Find(map[string]string{"name": "黄忠"}).One(&one)
	if MgoError != nil {
		fmt.Println(MgoError.Error())
	} else {
		fmt.Println(one)
	}
	// find - all
	var all []map[string]interface{}
	MgoError = c.Find(map[string]string{"name": "黄忠"}).All(&all)
	if MgoError != nil {
		fmt.Println(MgoError.Error())
	} else {
		fmt.Println(all)
	}
}