使用go在mongodb中进行CRUD操作

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

我在学习go语言之前,在对数据库进行CRUD的操作基本是用java和sql来对mysql数据库进行操作,但是到了实习中公司业务都是用的是mongodb,通过一段学习时间后,我有了一些收获。

简述关系型数据库,非关系型数据库

关系型数据库:指采用了关系模型来组织数据的数据库。
关系模型指的就是二维表格模型,而一个关系型数据库就是由二维表及其之间的联系所组成的一个数据组织

非关系型数据库

非关系型数据库:指非关系型的,分布式的,且一般不保证遵循ACID原则的数据存储系统。

这是比较规范的说法,具体这两者谈不上谁优谁劣,各自有各自的使用场景。

其实可以粗暴的理解成一个关系型数据库基本靠使用sql语句来操作,而非关系型数据靠key-value来进行操作

(其实按我的理解非关系型数据库严格上不是一种数据库,应该是一种数据结构化存储方法的集合,可以是文档或者键值对等,但是我不知道这么说是否正确)

MongoDB

好了,上面简述了一下关系型和非关系型数据库,下面来说一下今天文章的主角。

mongodb

MongoDB 将数据存储为一个文档,数据结构由键值(key=>value)对组成。MongoDB 文档类似于 JSON 对象。字段值可以包含其他文档,数组及文档数组。

所以mongodb操作也是通过json(bson)格式来操作



那么go语言中是如何来操作mongodb

(1)数据库连接

数据库连接主要用到了mgo中的Dial()函数,连接形式如mgo.Dial(url1,url2,url3),具体代码如下:

func ConnecToDB() *mgo.Collection {
    session, err := mgo.Dial("127.0.0.1:27017")
    if err != nil {
        panic(err)
    }
    //defer session.Close()
    session.SetMode(mgo.Monotonic, true)
    c := session.DB("medex").C("student")
    return c
}复制代码

(2)插入

func InsertToMogo() {
    c := ConnecToDB()
    stu1 := Student{
        Name:  "xiaoming",
        Phone: "18933333333",
        Email: "12345678@qq.com",
        Sex:   "man",
    }
    stu2 := Student{
        Name:  "zhangdao",
        Phone: "8765432",
        Email: "133333384@qq.com",
        Sex:   "woman",
    }
    err := c.Insert(&stu1, &stu2)
    if err != nil {
        log.Fatal(err)
    }
}复制代码

(3)查询

func GetDataViaSex() {
    c := ConnecToDB()
    result := Student{}
    err := c.Find(bson.M{"sex": "woman"}).One(&result)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("student", result)
    students := make([]Student, 20)
    err = c.Find(nil).All(&students)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(students)

}复制代码

func GetDataViaId() {
    id := bson.ObjectIdHex("5a66a96306d2a40a8b884049")
    c := ConnecToDB()
    stu := &Student{}
    err := c.FindId(id).One(stu)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(stu)
}复制代码

这上面用了两种查询方法一种是查询多个,返回多个对象:many

另一种是查询单个,返回单个对象:one

(4)更新

func UpdateDBViaId() {
    //id := bson.ObjectIdHex("5a66a96306d2a40a8b884049")
    c := ConnecToDB()
    err := c.Update(bson.M{"email": "12832984@qq.com"}, bson.M{"$set": bson.M{"name": "haha", "phone": "37848"}})
    if err != nil {
        log.Fatal(err)
    }
}复制代码

(5)删除

func RemoveFromMgo() {
    c := ConnecToDB()
    _, err := c.RemoveAll(bson.M{"phone": "13480989765"})
    if err != nil {
        log.Fatal(err)
    }
}复制代码



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

本文来自:掘金

感谢作者:xjlgxlgx

查看原文:使用go在mongodb中进行CRUD操作

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

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