mgo 初见

连接示例

   import (
    "gopkg.in/mgo.v2"
    "gopkg.in/mgo.v2/bson"
  )

// 连接数据库
// func Dial(url string) (*Session, error)
session, err := mgo.Dial("")
session, err := mgo.Dial("127.0.0.1")
session, err := mgo.Dial("localhost:27017")

// 获取 databse 和 collection
// func (s *Session) DB(name string) *Database
db := session.DB("test")

// func (db *Database) C(name string) *Collection
c := db.C("users")

// session 使用完毕后需要手动回收
defer session.Close()

1. 建会话session

    session,error :=mgo.Dail(url)

2. 获取database

db:=session.DB("test")

3. 获取collection

 c :=db.C("users")

4. 关闭session

通常通过在拨号时获得的初始会话中调用session.Copy创建新会话。这些新的会话将共享相同的集群信息和连接池，并且可以容易地交给用于组织逻辑的其他方法和功能。创建的每个会话都必须在其生命周期结束时调用其Close方法，因此根据情况，其资源可能会放回池中或收集。。

api

定义变量

  var (
    ErrNotFound = errors.New("not found")
    ErrCursor   = errors.New("invalid cursor")
)

检查错误是不是插入id重复的错误

   func IsDup(err error) bool

设置打印的log

  func SetLogger(logger log_Logger)

日志输出是debug还是正常模式

 func SetDebug(debug bool)