mgo

Documentation

Index

• func CloseConnection()
• func InitConnection(databaseNames ...string) error
• type MongoOperator
  • func NewOperator(collectionName string, databaseNames ...string) *MongoOperator
  • func (mo *MongoOperator) BatchInsert(documents []interface{}) (*mongo.InsertManyResult, error)
  • func (mo *MongoOperator) Clone() *MongoOperator
  • func (mo *MongoOperator) Collection(colName string) *MongoOperator
  • func (mo *MongoOperator) Delete(filter interface{}) (*mongo.DeleteResult, error)
  • func (mo *MongoOperator) DeleteOne(filter interface{}) (*mongo.DeleteResult, error)
  • func (mo *MongoOperator) ExecuteTransaction(txnFunc func(mongo.SessionContext) error) error
  • func (mo *MongoOperator) FindAll() (*mongo.Cursor, error)
  • func (mo *MongoOperator) FindOne(result interface{}) error
  • func (mo *MongoOperator) InsertOne(document interface{}) (*mongo.InsertOneResult, error)
  • func (mo *MongoOperator) QueryCount() (int64, error)
  • func (mo *MongoOperator) SetDatabase(dbName string) *MongoOperator
  • func (mo *MongoOperator) SetPagination(page, pageSize int64) *MongoOperator
  • func (mo *MongoOperator) SetSorting(sortRules bson.D) *MongoOperator
  • func (mo *MongoOperator) Update(filter interface{}, update interface{}) (*mongo.UpdateResult, error)
  • func (mo *MongoOperator) UpdateByID(id string, update interface{}) (*mongo.UpdateResult, error)
  • func (mo *MongoOperator) Where(conditions interface{}) *MongoOperator
• type PaginationOpt

Functions

func CloseConnection

func CloseConnection()

CloseConnection 安全关闭全局连接 / Safely Close Global Connection

func InitConnection

func InitConnection(databaseNames ...string) error

InitConnection 初始化全局MongoDB连接（线程安全） Initialize Global MongoDB Connection (Thread-Safe)

Types

type MongoOperator

type MongoOperator struct {
	sync.RWMutex // 读写锁 / Read-Write Lock
	// contains filtered or unexported fields
}

MongoDB操作器（包含数据库操作配置） MongoDB Operator (Contains DB operation settings)

func NewOperator

func NewOperator(collectionName string, databaseNames ...string) *MongoOperator

NewOperator 创建新的MongoDB操作实例 / Create New MongoDB Operator Instance

func (*MongoOperator) BatchInsert

func (mo *MongoOperator) BatchInsert(documents []interface{}) (*mongo.InsertManyResult, error)

BatchInsert 批量插入文档 / Insert Multiple Documents

func (*MongoOperator) Clone

func (mo *MongoOperator) Clone() *MongoOperator

Clone 克隆操作器实例（用于链式调用） / Clone Operator Instance (For Chain Calling)

func (*MongoOperator) Collection

func (mo *MongoOperator) Collection(colName string) *MongoOperator

Collection 切换目标集合 / Switch Target Collection

func (*MongoOperator) Delete

func (mo *MongoOperator) Delete(filter interface{}) (*mongo.DeleteResult, error)

Delete 批量删除文档 / Delete Multiple Documents

func (*MongoOperator) DeleteOne

func (mo *MongoOperator) DeleteOne(filter interface{}) (*mongo.DeleteResult, error)

DeleteOne 删除单个文档 / Delete a Single Document

func (*MongoOperator) ExecuteTransaction

func (mo *MongoOperator) ExecuteTransaction(txnFunc func(mongo.SessionContext) error) error

ExecuteTransaction 执行事务操作 / Execute Transaction Operations

func (*MongoOperator) FindAll

func (mo *MongoOperator) FindAll() (*mongo.Cursor, error)

FindAll 查询多条文档（带分页）/ Find Multiple Documents (With Pagination)

func (*MongoOperator) FindOne

func (mo *MongoOperator) FindOne(result interface{}) error

FindOne 查询单条文档 / Find One Document

func (*MongoOperator) InsertOne

func (mo *MongoOperator) InsertOne(document interface{}) (*mongo.InsertOneResult, error)

InsertOne 插入单条文档 / Insert a Single Document

func (*MongoOperator) QueryCount

func (mo *MongoOperator) QueryCount() (int64, error)

QueryCount 获取匹配文档数量 / Get Count of Matching Documents

func (*MongoOperator) SetDatabase

func (mo *MongoOperator) SetDatabase(dbName string) *MongoOperator

SetDatabase 切换目标数据库 / Switch Target Database

func (*MongoOperator) SetPagination

func (mo *MongoOperator) SetPagination(page, pageSize int64) *MongoOperator

SetPagination 设置分页参数 / Set Pagination Parameters

func (*MongoOperator) SetSorting

func (mo *MongoOperator) SetSorting(sortRules bson.D) *MongoOperator

SetSorting 设置排序规则 / Set Sorting Rules

func (*MongoOperator) Update

func (mo *MongoOperator) Update(filter interface{}, update interface{}) (*mongo.UpdateResult, error)

Update 更新文档（支持批量更新）/ Update Documents (Supports Bulk Update)

func (*MongoOperator) UpdateByID

func (mo *MongoOperator) UpdateByID(id string, update interface{}) (*mongo.UpdateResult, error)

UpdateByID 通过ID更新文档 / Update Document by ID

func (*MongoOperator) Where

func (mo *MongoOperator) Where(conditions interface{}) *MongoOperator

Where 构建查询条件 / Build Query Conditions

type PaginationOpt

type PaginationOpt struct {
	Limit int64       // 返回文档数量限制 / Limit the number of documents to return
	Skip  int64       // 跳过文档数量 / Skip the number of documents
	Sort  interface{} // 排序规则 / Sorting Rules
}

PaginationOpt 分页配置参数 / Pagination Options