mongoPool

Documentation

Index

• func Demo()
• type Data
  • func NewData(kv ...Entity) Data
• type Entity
  • func NewEntity(Key string, Value any) Entity
• type Map
  • func NewMap(Key string, Value any) Map
• type MongoClient
  • func NewMongoClient(url string) (*MongoClient, error)
  • func (my *MongoClient) CleanCondition()
  • func (my *MongoClient) Close() error
  • func (my *MongoClient) DeleteMany() *mongo.DeleteResult
  • func (my *MongoClient) DeleteOne() *mongo.DeleteResult
  • func (my *MongoClient) FindMany(results *[]Map, ...) *MongoClient
  • func (my *MongoClient) FindOne(result *Map, ...) *MongoClient
  • func (my *MongoClient) GetClient() *mongo.Client
  • func (my *MongoClient) InsertMany(data []any) *mongo.InsertManyResult
  • func (my *MongoClient) InsertOne(data Data) *mongo.InsertOneResult
  • func (my *MongoClient) Ping()
  • func (my *MongoClient) SetCollection(collection string, opts ...*options.CollectionOptions) *MongoClient
  • func (my *MongoClient) SetDatabase(database string, opts ...*options.DatabaseOptions) *MongoClient
  • func (my *MongoClient) Where(condition Map) *MongoClient
• type MongoClientPool
  • func OnceMongoPool() *MongoClientPool
  • func (*MongoClientPool) AppendClient(key string, mongoClient *MongoClient) (*MongoClientPool, error)
  • func (*MongoClientPool) Clean() *MongoClientPool
  • func (*MongoClientPool) GetClient(key string) *MongoClient
  • func (*MongoClientPool) HasClient(key string) bool
  • func (*MongoClientPool) Remove(key string) (*MongoClientPool, error)

Functions

func Demo

func Demo()

Types

type Data

type Data = primitive.D

func NewData

func NewData(kv ...Entity) Data

NewData 新建单条数据

type Entity

type Entity = primitive.E

func NewEntity

func NewEntity(Key string, Value any) Entity

NewEntity 新建实体数据

type Map

type Map = primitive.M

func NewMap

func NewMap(Key string, Value any) Map

NewMap 新建Map数据

type MongoClient

type MongoClient struct {
	Err error
	// contains filtered or unexported fields
}

func NewMongoClient

func NewMongoClient(url string) (*MongoClient, error)

NewMongoClient 实例化：mongo客户端

func (*MongoClient) CleanCondition

func (my *MongoClient) CleanCondition()

CleanCondition 清理查询条件

func (*MongoClient) Close

func (my *MongoClient) Close() error

Close 关闭客户端

func (*MongoClient) DeleteMany

func (my *MongoClient) DeleteMany() *mongo.DeleteResult

DeleteMany 删除多条数据

func (*MongoClient) DeleteOne

func (my *MongoClient) DeleteOne() *mongo.DeleteResult

DeleteOne 删除单条数据

func (*MongoClient) FindMany

func (my *MongoClient) FindMany(results *[]Map, findOptionFn func(opt *options.FindOptions) *options.FindOptions) *MongoClient

FindMany 查询多条数据

func (*MongoClient) FindOne

func (my *MongoClient) FindOne(result *Map, findOneOptionFn func(opt *options.FindOneOptions) *options.FindOneOptions) *MongoClient

FindOne 查询一条数据

func (*MongoClient) GetClient

func (my *MongoClient) GetClient() *mongo.Client

GetClient 获取客户端链接

func (*MongoClient) InsertMany

func (my *MongoClient) InsertMany(data []any) *mongo.InsertManyResult

InsertMany 插入多条数据

func (*MongoClient) InsertOne

func (my *MongoClient) InsertOne(data Data) *mongo.InsertOneResult

InsertOne 插入一条数据

func (*MongoClient) Ping

func (my *MongoClient) Ping()

Ping 测试链接

func (*MongoClient) SetCollection

func (my *MongoClient) SetCollection(collection string, opts ...*options.CollectionOptions) *MongoClient

SetCollection 设置文档

func (*MongoClient) SetDatabase

func (my *MongoClient) SetDatabase(database string, opts ...*options.DatabaseOptions) *MongoClient

SetDatabase 设置数据库

func (*MongoClient) Where

func (my *MongoClient) Where(condition Map) *MongoClient

Where 设置查询条件

type MongoClientPool

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

func OnceMongoPool

func OnceMongoPool() *MongoClientPool

OnceMongoPool 单例化：mongodb连接池

func (*MongoClientPool) AppendClient

func (*MongoClientPool) AppendClient(key string, mongoClient *MongoClient) (*MongoClientPool, error)

AppendClient 增加客户端

func (*MongoClientPool) Clean

func (*MongoClientPool) Clean() *MongoClientPool

Clean 清理客户端

func (*MongoClientPool) GetClient

func (*MongoClientPool) GetClient(key string) *MongoClient

GetClient 获取客户端

func (*MongoClientPool) HasClient

func (*MongoClientPool) HasClient(key string) bool

HasClient 检查客户端是否存在

func (*MongoClientPool) Remove

func (*MongoClientPool) Remove(key string) (*MongoClientPool, error)

清除客户端