db

Documentation

Index

• Variables
• func GetCol(dbName, col string) (session *mgo.Session, collection *mgo.Collection)
• func IsFinishInit() bool
• func IsMgoDup(err error) bool
• func IsMgoNotFound(err error) bool
• func NewCollection(session *mgo.Session, dbName, name string) *mgo.Collection
• func NewObjectId() bson.ObjectId
• func NewSession() (session *mgo.Session)
• func ObjectIds(ids []string) (ret []bson.ObjectId)
• func SetOnFinishInit(f func())
• func Setup(c *MongoConfig)
• func ShareSession() *mgo.Session
• type M
  • func In(ids []string) M
  • func InID(ids []string) (ret M)
  • func (m M) Update(qs ...M) M
• type MongoConfig
• type SqlServer
  • func GetSqlServer(dataSourceName string) *SqlServer
  • func (s *SqlServer) Query(dest interface{}, query string, args ...interface{}) error

Variables

var ErrOperaBeforeInit = errors.New("please set db.SetOnFinishInit when needed operating db in init()")

Functions

func GetCol

func GetCol(dbName, col string) (session *mgo.Session, collection *mgo.Collection)

func IsFinishInit

func IsFinishInit() bool

func IsMgoDup

func IsMgoDup(err error) bool

func IsMgoNotFound

func IsMgoNotFound(err error) bool

func NewCollection

func NewCollection(session *mgo.Session, dbName, name string) *mgo.Collection

func NewObjectId

func NewObjectId() bson.ObjectId

func NewSession

func NewSession() (session *mgo.Session)

func ObjectIds

func ObjectIds(ids []string) (ret []bson.ObjectId)

func SetOnFinishInit

func SetOnFinishInit(f func())

func Setup

func Setup(c *MongoConfig)

func ShareSession

func ShareSession() *mgo.Session

Types

type M

type M bson.M

func In

func In(ids []string) M

func InID

func InID(ids []string) (ret M)

func (M) Update

func (m M) Update(qs ...M) M

type MongoConfig

type MongoConfig struct {
	MongoDB string
	DBName  string
}

type SqlServer

type SqlServer struct {
	*sqlx.DB
}

func GetSqlServer

func GetSqlServer(dataSourceName string) *SqlServer

func (*SqlServer) Query

func (s *SqlServer) Query(dest interface{}, query string, args ...interface{}) error