Go與MongoDB

go沒有類這一律念,對於變量的捆綁都是由鍵值對形式的結構體(struct)實現的。
這對一樣是以鍵值對形式存儲的mongodb以及json都很是友好。因此在go中,並非很依賴創建在mongodb之上的orm,使用比較底層的驅動級的接口便可方便的進行操做。golang

本篇文章將以商品(goods)爲例,簡單講解如何使用mgo進行簡單的增刪改查操做。mongodb

mgo

mgo (pronounced as mango) is a MongoDB driver for the Go language that implements a rich and well tested selection of features under a very simple API following standard Go idioms.

打開終端輸入shell

go get gopkg.in/mgo.v2json

在當前pkg下新建goods.go文件, 對mgo提供的接口進行一些封裝:數組

func connect(cName string) (*mgo.Session, *mgo.Collection) {
    session, err := mgo.Dial("$mongoHost") //Mongodb's connection
    if err != nil {
        panic(err)
    }
    session.SetMode(mgo.Monotonic, true)
    //return a instantiated collect
    return session, session.DB(mongoDB).C(cName)
}

定義goods實例:session

type Goods struct {
    ID    string 
    Name  string 
    Price string 
    Url   string
}

接下來咱們要存入第一條記錄:code

func (a *Goods) save() error {
    s, c := connect("goods")
    defer s.Close()
    a.ID = bson.NewObjectId().Hex()
    return c.Insert(&a)
}

特別注意: 若是在定義時將ID的類型定義爲 bson.ObjectID,並指定bson標籤爲_id,mongodb將不會爲它分配新的id。可是這樣的結構在與json作交互時不是很方便。orm

在作記錄的查詢時,須要新建一個同類型的結構體或結構體數組,而後執行Find操做,若是參數爲空,則返回所有記錄:接口

func (a Goods) all() ([]Goods, error) {
    s, c := connect("goods")
    defer s.Close()
    var group []Goods
    err := c.Find(nil).All(&group)
    return group, err
}
func (a *Goods) get(id string) error {
    s, c := connect("goods")
    defer s.Close()
    return c.Find(bson.M{"id": id}).One(&a)
}

若是你熟悉mongodb的操做,能夠看出,這樣的操做與直接在shell內操做幾乎相同。get

刪除:

func (a Goods) delete() error {
    s, c := connect("goods")
    defer s.Close()
    return c.Remove(bson.M{"id": a.ID})
}

更新:

func (a *Goods) update() error {
    s, c := connect("goods")
    defer s.Close()
    c.Update(bson.M{"id": a.ID}, a)
    return a.get(a.ID)
}
相關文章
相關標籤/搜索