分享
Golang使用MongoDB
是个懒人 · · 5261 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
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)
}
}
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信5261 次点击
上一篇:golang 多态
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
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)
}
}