• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    mongodb BSON的基本使用教程

    查找 Find

    m := bson.M{
        "create_time": bson.M{
          "$gte": start,
          "$lte": end,
        },
        "account": account,
        "tag": "tag",
      }
      session.DB("db").C("collect").Find(m).Count()

    这里查找时间戳内,账号为account,标签为tag的数据并统计个数。

    聚合管道在mgo中为Pipe(pipeline interface{})

    这个和bash中使用的管道很像,数据可以被层层处理。一般传入的参数为[]bson.M。这个[]bson.M里如果还有嵌套则还要使用[]bson.M

    - 比如这里首先匹配标签和账号

    - 时间戳在一段时间内

    - 然后根据名字分组统计数量

    - 最后排序取最前面的三个。

      //这个就可以传入Pipe
      m := []bson.M{
        {"$match": bson.M{"tag": "tag", "account": account, "create_time": bson.M{"$gte": start, "$lte": end}}},
        {"$group": bson.M{"_id": "$TagName", "count": bson.M{"$sum": 1}}},
        {"$sort": bson.M{"count": -1}},
        {"$limit": 3},
      }
      //这里就可以取到输出的数据
      var values []result
      session.DB("db").C("collect").Pipe(m).All(values)

    简单介绍

    package main
    import (
     "gopkg.in/mgo.v2"
     "log"
     "gopkg.in/mgo.v2/bson"
    )
    type User struct {
     Id    bson.ObjectId `bson:"_id"`
     Name   string    `bson:"name"`
     PassWord string    `bson:"pass_word"`
     Age   int      `bson:"age"`
    }
    func main() {
     db, err := mgo.Dial("mongodb://192.168.2.28:27017,192.168.2.28:27018,192.168.2.28:27019/?replicaSet=howie")
     if err != nil {
     log.Fatalln(err)
     }
     defer db.Close()
     db.SetMode(mgo.Monotonic, true)
     c := db.DB("howie").C("person")
     //插入
     /*c.Insert(User{
     Id:    bson.NewObjectId(),
     Name:   "JK_CHENG",
     PassWord: "123132",
     Age: 2,
     }, User{
     Id:    bson.NewObjectId(),
     Name:   "JK_WEI",
     PassWord: "qwer",
     Age: 5,
     }, User{
     Id:    bson.NewObjectId(),
     Name:   "JK_HE",
     PassWord: "6666",
     Age: 7,
     })*/
     var users []User
     c.Find(nil).All(users) //查询全部数据
     log.Println(users)
     c.FindId(users[0].Id).All(users) //通过ID查询
     log.Println(users)
     c.Find(bson.M{"name": "JK_WEI"}).All(users) //单条件查询(=)
     log.Println(users)
     c.Find(bson.M{"name": bson.M{"$ne": "JK_WEI"}}).All(users) //单条件查询(!=)
     log.Println(users)
     c.Find(bson.M{"age": bson.M{"$gt": 5}}).All(users) //单条件查询(>)
     log.Println(users)
     c.Find(bson.M{"age": bson.M{"$gte": 5}}).All(users) //单条件查询(>=)
     log.Println(users)
     c.Find(bson.M{"age": bson.M{"$lt": 5}}).All(users) //单条件查询()
     log.Println(users)
     c.Find(bson.M{"age": bson.M{"$lte": 5}}).All(users) //单条件查询(=)
     log.Println(users)
     /*c.Find(bson.M{"name": bson.M{"$in": []string{"JK_WEI", "JK_HE"}}}).All(users) //单条件查询(in)
     log.Println(users)
     c.Find(bson.M{"$or": []bson.M{bson.M{"name": "JK_WEI"}, bson.M{"age": 7}}}).All(users) //多条件查询(or)
     log.Println(users)
     c.Update(bson.M{"_id": users[0].Id}, bson.M{"$set": bson.M{"name": "JK_HOWIE", "age": 61}}) //修改字段的值($set)
     c.FindId(users[0].Id).All(users)
     log.Println(users)
     c.Find(bson.M{"name": "JK_CHENG", "age": 66}).All(users) //多条件查询(and)
     log.Println(users)
     c.Update(bson.M{"_id": users[0].Id}, bson.M{"$inc": bson.M{"age": -6,}}) //字段增加值($inc)
     c.FindId(users[0].Id).All(users)
     log.Println(users)*/
     //c.Update(bson.M{"_id": users[0].Id}, bson.M{"$push": bson.M{"interests": "PHP"}}) //从数组中增加一个元素($push)
     c.Update(bson.M{"_id": users[0].Id}, bson.M{"$pull": bson.M{"interests": "PHP"}}) //从数组中删除一个元素($pull)
     c.FindId(users[0].Id).All(users)
     log.Println(users)
     c.Remove(bson.M{"name": "JK_CHENG"})//删除
    }

    总结

    以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。

    您可能感兴趣的文章:
    • c#操作mongodb插入数据效率
    • mongodb实现数组对象求和方法实例
    • 如何优雅的在一台vps(云主机)上面部署vue+mongodb+express项目
    • pyspark操作MongoDB的方法步骤
    • Docker容器化部署尝试——多容器通信(node+mongoDB+nginx)
    • mongodb官方的golang驱动基础使用教程分享
    • mongodb中非常好用的Aggregate入门教程
    • 详解Java 连接MongoDB集群的几种方式
    • Java mongodb连接配置实践
    • mongodb使用c#驱动数据插入demo
    上一篇:mongodb官方的golang驱动基础使用教程分享
    下一篇:通用MapReduce程序复制HBase表数据
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

    mongodb BSON的基本使用教程 mongodb,BSON,的,基本,使用,