mgodb

Documentation

Index

• Variables
• func Aggregate(result interface{}, piplines interface{}) error
• func Count(model interface{}, query interface{}) int
• func DropDatabase() error
• func Execute(f func(sess *mgo.Session) error) error
• func Find(result interface{}, query interface{}, page int, pageSize int, sorts []string) error
• func FindOne(model interface{}, query interface{}) error
• func GetCollectionName(data interface{}) string
• func Init(mongodb string, concurrent int, timeout time.Duration)
• func Insert(model interface{}) error
• func InsertMany(docs []interface{}) error
• func RemoveAll(model interface{}, selector interface{}) error
• func RemoveOne(model interface{}, selector interface{}) error
• func UpdateAll(model interface{}, selector interface{}, update interface{}) (int, error)
• func UpdateOne(model interface{}, selector interface{}, update interface{}) error
• func UpsertOne(model interface{}, selector interface{}) error
• type Database
  • func (db *Database) Execute(f func(sess *mgo.Session) error) error
  • func (db *Database) Init(addr string, concurrent int, timeout time.Duration)

Variables

var (
	ErrModelNotPtr        = errors.New("model is not pointer")
	ErrModelToPtr         = errors.New("model point to another pointer")
	ErrResultNotSliceAddr = errors.New("result argument must be a slice address")
)

Functions

func Aggregate

func Aggregate(result interface{}, piplines interface{}) error

func Count

func Count(model interface{}, query interface{}) int

for example: user := &User{} Count(user, bson.M{...})

func DropDatabase

func DropDatabase() error

func Execute

func Execute(f func(sess *mgo.Session) error) error

func Find

func Find(result interface{}, query interface{}, page int, pageSize int, sorts []string) error

for example: result := []*User{} Find(&result, bson.M{...}, 1, 15, []string{...})

func FindOne

func FindOne(model interface{}, query interface{}) error

find one record for example: user := &User{} FindOne(user, bson.M{"name": "xxx"})

func GetCollectionName

func GetCollectionName(data interface{}) string

获取数据表名称

func Init

func Init(mongodb string, concurrent int, timeout time.Duration)

func Insert

func Insert(model interface{}) error

insert one record for example: user := &User{UserId: 1, Name: "xx"} Insert(user)

func InsertMany

func InsertMany(docs []interface{}) error

insert many records for example: data := []*User{user1, user2, user3} InsertMany(data)

func RemoveAll

func RemoveAll(model interface{}, selector interface{}) error

remove all record for example: user := &User{} RemoveAll(user, bson.M{"name": "xx"})

func RemoveOne

func RemoveOne(model interface{}, selector interface{}) error

remove one record for example: user := &User{} RemoveOne(user, bson.M{"name": "xx"})

func UpdateAll

func UpdateAll(model interface{}, selector interface{}, update interface{}) (int, error)

for example: user := &User{} UpdateAll(user, bson.M{...}, bson.M{"$set": bson.M{...}})

func UpdateOne

func UpdateOne(model interface{}, selector interface{}, update interface{}) error

update one record for example user := &User{} UpdateOne(user, bson.M{"name": "xx"}, bson.M{"$set": bson.M{...}})

func UpsertOne

func UpsertOne(model interface{}, selector interface{}) error

upsert one record for example user := &User{"name":"xxx", "pwd": "xx"} user.UserId = 1 UpsertOne(user, bson.M{"name": "xx"})

Types

type Database

type Database struct {
	// contains filtered or unexported fields
}

func (*Database) Execute

func (db *Database) Execute(f func(sess *mgo.Session) error) error

func (*Database) Init

func (db *Database) Init(addr string, concurrent int, timeout time.Duration)