golang mongoDB 的集合创建以及增删改查操作

mongo官方没有golang 的官方驱动,但是有一个社区驱动: http://labix.org/mgo api文档:https://godoc.org/gopkg.in/mgo.v2#Collection.Update 数据的连接操作请看的我的上一篇博客,本文重点介绍mgo的CURD操作及遇到的坑。 mog的文档可以不用特别的创建,在数据插入的时候,如果驱动发现文档不存在,会自动创建。 连接操作

type Operater struct {
    mogSession *mgo.Session
    dbname string
    document string
}
//集合的结构 其他中AGE NAME HEIGHT 名字的首字母必须大写,如果不无法访问到
type person struct {
    AGE    int
    NAME   string
    HEIGHT int
}

//连接数据库
func (operater *Operater) connect() error {
    mogsession, err := mgo.Dial(url)
    if err != nil {
        fmt.Println(err)
        return err
    }
    operater.mogSession=mogsession
    return nil
}

插入操作

//插入
func (operater *Operater) insert( p *person) error {
    collcetion:=operater.mogSession.DB(operater.dbname).C(operater.document)
    err:=collcetion.Insert(p)
    return err
}

使用方式

p:=person{
        33,
        "周杰伦",
        175,
    }
    err=op.insert(&p)
    if err != nil {
        fmt.Println("插入出错",err)
    }

更新操作,调用一次更新操作都是更新一行的。

//更新一行
func (operater *Operater) update() (error) {
    collcetion:=operater.mogSession.DB(operater.dbname).C(operater.document)
    update:=person{
        33,
        "詹姆斯",
        201,
    }
    err:=collcetion.Update(bson.M{"name": "周杰伦"},update)
    if err !=nil {
        fmt.Println(err)
    }
    return err
}

如果想更新所有可以使用UpdateAll() 方法。

查询操作

//统计集合中数据的个数
func (operater *Operater) query() ([]person,error) {
    collcetion:=operater.mogSession.DB(operater.dbname).C(operater.document)
    p:=new(person)
    p.AGE=33
    query:=collcetion.Find(nil)
    ps:=[]person{}
    query.All(&ps)
    iter:=collcetion.Find(nil).Iter()
    //单个查询
    result:=new(person)
    for iter.Next(&result) {
        fmt.Println("一个一个输出:", result)
    }
    return ps,nil
}

查询的参数可以是一个map或一个能够被bson编码的结构体。 该map的key和value可以是一般的interface{},例如bson.M。nil,相当于提供一个空document,如bson.m {}.

查询的结果展示有四个方法:One, For, Iter, or Tail

按照条件查询

func (operater *Operater) query() ([]person,error) {
    collcetion:=operater.mogSession.DB(operater.dbname).C(operater.document)
    p:=new(person)
    p.AGE=33
    query:=collcetion.Find(bson.M{"age":21})
    ps:=[]person{}
    query.All(&ps)
    fmt.Println(ps)
    return ps,nil
}

上述方法会查询age =21 的结果集。 查询条件有一个bson ,什么是bson ??

里面有一个bson 的数据结构,bson 其实就是 Binary Serialized Document Format 二进制文件存储格式,类似于JSON,它和JSON一样,支持内嵌的文档对象和数组对象。 BSON可以做为网络数据交换的一种存储形式,这个有点类似于Google的Protocol Buffer,但是BSON是一种schema-less的存储形式,它的优点是灵活性高,但它的缺点是空间利用率不是很理想, BSON有三个特点:轻量性、可遍历性、高效性。 MongoDB把BSON做为其数据的存储结构。为啥呢,一个重要的原因是BSON 可遍历。

条件查询带表达式

//条件查询
func (operater *Operater) query() ([]person,error) {
    collcetion:=operater.mogSession.DB(operater.dbname).C(operater.document)
    p:=new(person)
    p.AGE=33
    query:=collcetion.Find(bson.M{"age":bson.M{"$eq":21}})
    ps:=[]person{}
    query.All(&ps)
    fmt.Println(ps)
    return ps,nil
}

其中$eq是 查询的操作符,查询的操作符文档直接参考: https://docs.mongodb.com/manual/tutorial/query-documents/#read-operations-query-argument

删除操作

//单行删除
func (operater *Operater) delete(seletor interface{}) (error) {
    collcetion:=operater.mogSession.DB(operater.dbname).C(operater.document)
    return collcetion.Remove(seletor)
}
删除方法用法
err=op.delete(&bson.M{"height": 0})
    if err!=nil {
        fmt.Println("删除错误",err)
    }else{
        fmt.Println("删除成功")
    }

数据结构体的定义,其中AGE NAME HEIGHT 名字的首字母必须大写,如果不无法与数据库字段名相对应。

type person struct {
    AGE    int
    NAME   string
    HEIGHT int
}

如果名称不一致的解决方式

type person struct { 
    AGE    int  `bson:"age"`
    NAME   string `bson:"name"`
    HEIGHT int    `bson:"height"`
}

这一点很类似于orm的感觉

所有代码的github: https://github.com/china-muwenbo/MyTestGo/blob/master/src/com.dylan.main/mongodb/mongoCurd.go 需要的直接下载运行。

BSON 的官方解释:https://www.mongodb.com/json-and-bson

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏零基础使用Django2.0.1打造在线教育网站

零基础使用Django2.0.1打造在线教育网站(七):数据库字段的定义(上)

努力与运动兼备~有任何问题可以加我好友或者关注微信公众号,欢迎交流,我们一起进步!

43860
来自专栏青玉伏案

iOS逆向工程之Hopper中的ARM指令

虽然前段时间ARM被日本软银收购了,但是科技是无国界的,所以呢ARM相关知识该学的学。现在看ARM指令集还是倍感亲切的,毕竟大学里开了ARM这门课,并且做了不少...

36570
来自专栏技术博客

Entity Framework 系统约定配置

Code First之所以能够让开发人员以一种更加高效、灵活的方式进行数据操作有一个重要的原因在于它的约定配置。现在软件开发越来越复杂,大家都试图将软件设计的越...

10620
来自专栏我有一个梦想

QT Creator 快速入门教程 读书笔记(三)

一   信号和槽   GUI 程序除了要绘制控件,还要响应系统和用户事件,例如重绘、绘制完成、点击鼠标、敲击键盘等。当事件发生时,UI 会产生相应的变化,让用户...

31080
来自专栏大内老A

ASP.NET MVC以ModelValidator为核心的Model验证体系: ModelValidatorProviders

前面篇文章我们分别介绍用真正用于实施Model验证的ModelValidator(《ASP.NET MVC以ModelValidator为核心的Model验证体...

19050
来自专栏JackeyGao的博客

Django小技巧17: QuerySets的latest和earliest方法

就像QuerySets的first和last方法一样, Django 还提供了earliest和latest方法. 用于获取最早和最新的数据,增强代码的可读性.

32820
来自专栏hotqin888的专栏

用golang递归构建无限级树状目录json数据和数据库

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/hotqin888/article/det...

43020
来自专栏Android自学

【转】jQuery验证控件jquery.validate.js使用说明+中文API

34440
来自专栏生信宝典

Bookdown文档生成教程

bookdown是一款及其方便的编写技术文档或教材的工具,语法简洁,数据处理灵活。支持Rmarkdown或普通markdown通过pandoc软件转换为HTML...

71550
来自专栏逆向技术

PE格式第六讲,导出表

                PE格式第六讲,导出表 请注意,下方字数比较多,其实结构挺简单,但是你如果把博客内容弄明白了,对你受益匪浅,千万不要看到字...

20660

扫码关注云+社区

领取腾讯云代金券