Golang使用MongoDB

是个懒人 · · 3159 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

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)
    }
}

有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:是个懒人

查看原文:Golang使用MongoDB

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

3159 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传