mongo

Dec 5, 2022

Changes in this version

+ func InjectCreatePool(fun CreateConnectFunc)

+ type CreateConnectFunc func(*MongoDB) []MongoConnect

+ type DBInfo struct

+ Client *mongo.Client

+ Config MongoConnect

+ Database *mongo.Database

+ func (d *DBInfo) Close()

+ type Host struct

+ Hst string

+ Port string

+ type MongoConnect struct

+ ConnectTimeout int

+ Database string

+ ExecuteTimeout int

+ Hosts []Host

+ Name string

+ Option Options

+ Password string

+ UserName string

+ func (m MongoConnect) String() string

+ type MongoDB struct

+ func NewDB() *MongoDB

+ func (db *MongoDB) SetDB(connectName, databaseName string) *MongoDB

+ func (db *MongoDB) SetPool(pool MongoPooler) *MongoDB

+ type MongoPool struct

+ func (m *MongoPool) AddConnect(connect MongoConnect)

+ func (m *MongoPool) AddConnects(connects []MongoConnect)

+ func (m *MongoPool) GetDB(connectName string) *DBInfo

+ func (m *MongoPool) Init(connects []MongoConnect)

+ type MongoPooler interface

+ AddConnect func(connect MongoConnect)

+ AddConnects func(connects []MongoConnect)

+ GetDB func(connectName string) *DBInfo

+ Init func(connect []MongoConnect)

+ func NewPool(config MongoConnect) MongoPooler

+ func NewPools(configs []MongoConnect) MongoPooler

+ type Options struct

+ ConnectTimeoutMS int64

+ MaxIdleTimeMS int64

+ MaxPoolSize int

+ MinPoolSize int

+ ReplicaSet string

+ Safe bool

+ SlaveOk bool

+ SocketTimeoutMS int64

+ WtimeoutMS int64

+ type Table struct

+ func (t *Table) Aggregate(pipeline interface{}, result interface{})

+ func (t *Table) CreateCollection()

+ func (t *Table) DeleteMany(filter interface{}) *mongo.DeleteResult

+ func (t *Table) DeleteOne(filter interface{}) *mongo.DeleteResult

+ func (t *Table) Find(filter interface{}, result interface{})

+ func (t *Table) FindOne(filter interface{}, result interface{})

+ func (t *Table) InsertMany(documents []interface{}) []primitive.ObjectID

+ func (t *Table) InsertOne(document interface{}) primitive.ObjectID

+ func (t *Table) Pager(filter interface{}, result interface{}, page, pageSize int64)

+ func (t *Table) ReplaceOne(filter interface{}, update interface{}) *mongo.UpdateResult

+ func (t *Table) SetDB(db *MongoDB)

+ func (t *Table) UpdateByID(id interface{}, update interface{}) *mongo.UpdateResult

+ func (t *Table) UpdateMany(filter interface{}, update interface{}) *mongo.UpdateResult

+ func (t *Table) UpdateOne(filter interface{}, update interface{}) *mongo.UpdateResult

+ type Tabler interface

+ Aggregate func(pipeline interface{}, result interface{})

+ DeleteMany func(filter interface{}) *mongo.DeleteResult

+ DeleteOne func(filter interface{}) *mongo.DeleteResult

+ Find func(filter interface{}, result interface{})

+ FindOne func(filter interface{}, result interface{})

+ InsertMany func(documents []interface{}) []primitive.ObjectID

+ InsertOne func(document interface{}) primitive.ObjectID

+ Pager func(filter interface{}, result interface{}, page, pageSize int64)

+ ReplaceOne func(filter interface{}, update interface{}) *mongo.UpdateResult

+ SetDB func(db *MongoDB)

+ UpdateByID func(id interface{}, update interface{}) *mongo.UpdateResult

+ UpdateMany func(filter interface{}, update interface{}) *mongo.UpdateResult

+ UpdateOne func(filter interface{}, update interface{}) *mongo.UpdateResult

+ func NewModel(dbName, tableName string) Tabler

+ func NewModelByConnectName(connectName, dbName, tableName string) Tabler

+ func NewTable(db *MongoDB, tableName string) Tabler