gomongo

Documentation

Index

• type App
  • func (app *App) AggregateByFiltersSort(pipeline interface{}, opts ...*options.AggregateOptions) (result *mongo.Cursor, err error)
  • func (app *App) Close()
  • func (app *App) Collection(collection string) *App
  • func (app *App) CollectionCount() (name string, size int64)
  • func (app *App) CollectionDocuments(Skip, Limit int64, sort int, key string, value interface{}) (result *mongo.Cursor, err error)
  • func (app *App) CountDocumentsByFilters(filter interface{}) (count int64, err error)
  • func (app *App) Database(database string) *App
  • func (app *App) Delete(filter interface{}) (int64, error)
  • func (app *App) DeleteMany(key string, value interface{}) (int64, error)
  • func (app *App) Find(filter interface{}, opts ...*options.FindOptions) (result *mongo.Cursor, err error)
  • func (app *App) FindCollection(Limit int64) (result *mongo.Cursor, err error)
  • func (app *App) FindCollectionSort(Sort interface{}, Limit int64) (result *mongo.Cursor, err error)
  • func (app *App) FindMany(filter interface{}) (result *mongo.Cursor, err error)
  • func (app *App) FindManyByFilters(filter interface{}) (result *mongo.Cursor, err error)
  • func (app *App) FindManyByFiltersSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)
  • func (app *App) FindManyCollectionSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)
  • func (app *App) FindOne(filter interface{}) (result *mongo.SingleResult)
  • func (app *App) InitClient()
  • func (app *App) InsertMany(values []interface{}) (result *mongo.InsertManyResult, err error)
  • func (app *App) InsertOne(value interface{}) (result *mongo.InsertOneResult, err error)
  • func (app *App) Model(value interface{}) *App
  • func (app *App) Session() (session mongo.Session, err error)
  • func (app *App) UpdateMany(filter, update interface{}) (int64, error)
  • func (app *App) UpdateOne(filter, update interface{}) (int64, error)

Types

type App

type App struct {
	Db       *mongo.Client
	User     string // 用户名
	Password string // 密码
	Host     string // 地址
	Port     int    // 端口
	Dbname   string // 数据库
	Dns      string // 地址
	// contains filtered or unexported fields
}

App 实例

func (*App) AggregateByFiltersSort

func (app *App) AggregateByFiltersSort(pipeline interface{}, opts ...*options.AggregateOptions) (result *mongo.Cursor, err error)

AggregateByFiltersSort 统计分析

func (*App) Close

func (app *App) Close()

Close 关闭

func (*App) Collection

func (app *App) Collection(collection string) *App

func (*App) CollectionCount

func (app *App) CollectionCount() (name string, size int64)

CollectionCount 查询集合里有多少数据

func (*App) CollectionDocuments

func (app *App) CollectionDocuments(Skip, Limit int64, sort int, key string, value interface{}) (result *mongo.Cursor, err error)

CollectionDocuments 按选项查询集合 Skip 跳过 Limit 读取数量 sort 1 ，-1 . 1 为升序 ， -1 为降序

func (*App) CountDocumentsByFilters

func (app *App) CountDocumentsByFilters(filter interface{}) (count int64, err error)

CountDocumentsByFilters 统计数量

func (*App) Database

func (app *App) Database(database string) *App

func (*App) Delete

func (app *App) Delete(filter interface{}) (int64, error)

Delete 删除文档

func (*App) DeleteMany

func (app *App) DeleteMany(key string, value interface{}) (int64, error)

DeleteMany 删除多个文档

func (*App) Find

func (app *App) Find(filter interface{}, opts ...*options.FindOptions) (result *mongo.Cursor, err error)

Find 查询

func (*App) FindCollection

func (app *App) FindCollection(Limit int64) (result *mongo.Cursor, err error)

FindCollection 查询集合文档

func (*App) FindCollectionSort

func (app *App) FindCollectionSort(Sort interface{}, Limit int64) (result *mongo.Cursor, err error)

FindCollectionSort 查询集合文档支持排序

func (*App) FindMany

func (app *App) FindMany(filter interface{}) (result *mongo.Cursor, err error)

FindMany 查询多个文档

func (*App) FindManyByFilters

func (app *App) FindManyByFilters(filter interface{}) (result *mongo.Cursor, err error)

FindManyByFilters 多条件查询

func (*App) FindManyByFiltersSort

func (app *App) FindManyByFiltersSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

FindManyByFiltersSort 多条件查询支持排序

func (*App) FindManyCollectionSort

func (app *App) FindManyCollectionSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

FindManyCollectionSort 查询集合文档支持排序支持条件

func (*App) FindOne

func (app *App) FindOne(filter interface{}) (result *mongo.SingleResult)

FindOne 查询单个文档

func (*App) InitClient

func (app *App) InitClient()

InitClient 初始化连接

func (*App) InsertMany

func (app *App) InsertMany(values []interface{}) (result *mongo.InsertManyResult, err error)

InsertMany 插入多个文档

func (*App) InsertOne

func (app *App) InsertOne(value interface{}) (result *mongo.InsertOneResult, err error)

InsertOne 插入单个文档

func (*App) Model

func (app *App) Model(value interface{}) *App

func (*App) Session

func (app *App) Session() (session mongo.Session, err error)

func (*App) UpdateMany

func (app *App) UpdateMany(filter, update interface{}) (int64, error)

UpdateMany 更新多个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)

func (*App) UpdateOne

func (app *App) UpdateOne(filter, update interface{}) (int64, error)

UpdateOne 更新单个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)