golang的mongodb操作(mgo)

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

使用mgo http://godoc.org/labix.org/v2/mgo


package main

import (
  "fmt"
  "labix.org/v2/mgo"
  "labix.org/v2/mgo/bson"
)

type Person struct {
  NAME  string
  PHONE string
}
type Men struct {
  Persons []Person
}
const = (
  URL = "192.168.2.175:27017"
)
func main() {

  session, err := mgo.Dial(URL)  //连接数据库
  if err != nil {
    panic(err)
  }
  defer session.Close()
  session.SetMode(mgo.Monotonic, true)

  db := session.DB("mydb")	 //数据库名称
  collection := db.C("person") //如果该集合已经存在的话,则直接返回


  //*****集合中元素数目********
  countNum, err := collection.Count()
  if err != nil {
    panic(err)
  }
  fmt.Println("Things objects count: ", countNum)

  //*******插入元素*******
  temp := &Person{
    PHONE: "18811577546",
    NAME:  "zhangzheHero"
  }
    //一次可以插入多个对象 插入两个Person对象
  err = collection.Insert(&Person{"Ale", "+55 53 8116 9639"}, temp)
  if err != nil {
    panic(err)
  }

  //*****查询单条数据*******
  result := Person{}
  err = collection.Find(bson.M{"phone": "456"}).One(&result)
  fmt.Println("Phone:", result.NAME, result.PHONE)

  //*****查询多条数据*******
  var personAll Men  //存放结果
  iter := collection.Find(nil).Iter()
  for iter.Next(&result) {
    fmt.Printf("Result: %v\n", result.NAME)
    personAll.Persons = append(personAll.Persons, result)
  }

  //*******更新数据**********
  err = collection.Update(bson.M{"name": "ccc"}, bson.M{"$set": bson.M{"name": "ddd"}})
  err = collection.Update(bson.M{"name": "ddd"}, bson.M{"$set": bson.M{"phone": "12345678"}})
  err = collection.Update(bson.M{"name": "aaa"}, bson.M{"phone": "1245", "name": "bbb"})

  //******删除数据************
  _, err = collection.RemoveAll(bson.M{"name": "Ale”})
}


本文来自:开源中国博客

感谢作者:flyking

查看原文:golang的mongodb操作(mgo)

入群交流(和以上内容无关):加入Go大咖交流群,免费领全套学习资料或添加微信:muxilin131420 备注:入群;或加QQ群:729884609

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