db

Documentation

Index

• Variables
• type MongoDB
  • func (m *MongoDB) Aggregate(ctx context.Context, result interface{}, opts ...*options.AggregateOptions) error
  • func (m *MongoDB) AggregateByPage(ctx context.Context, countResult, result interface{}, ...) error
  • func (m *MongoDB) CountDocuments(ctx context.Context) (int64, error)
  • func (m *MongoDB) DeleteMany(ctx context.Context) (int64, error)
  • func (m *MongoDB) DeleteOne(ctx context.Context) (int64, error)
  • func (m *MongoDB) EstimatedDocumentCount(ctx context.Context) (int64, error)
  • func (m *MongoDB) Find(ctx context.Context, result interface{}, sortFields ...string) error
  • func (m *MongoDB) FindByPage(ctx context.Context, paging *Paging, result interface{}, sortFields ...string) (err error)
  • func (m *MongoDB) FindOne(ctx context.Context, result interface{}, sortFields ...string) error
  • func (m *MongoDB) FindOneAndDelete(ctx context.Context, result interface{}) error
  • func (m *MongoDB) FindOneAndUpdate(ctx context.Context, update interface{}, result interface{}, ...) error
  • func (m *MongoDB) InsertMany(ctx context.Context, documents []interface{}) ([]interface{}, error)
  • func (m *MongoDB) InsertOne(ctx context.Context, document interface{}) (interface{}, error)
  • func (m *MongoDB) UpdateById(ctx context.Context, id, update interface{}, opts ...*options.UpdateOptions) error
  • func (m *MongoDB) UpdateMany(ctx context.Context, update interface{}, opts ...*options.UpdateOptions) error
  • func (m *MongoDB) UpdateOne(ctx context.Context, update interface{}, opts ...*options.UpdateOptions) error
• type Paging
  • func (p *Paging) GetPages()

Variables

var (
	DefaultDatabase string
)

Types

type MongoDB

type MongoDB struct {
	Database      string
	Collection    string
	Filter        map[string]interface{}
	Hint          interface{}
	CountPipeline []bson.M // AggregateByPage
	Pipeline      []bson.M // Aggregate/AggregateByPage
}

func (*MongoDB) Aggregate

func (m *MongoDB) Aggregate(ctx context.Context, result interface{}, opts ...*options.AggregateOptions) error

func (*MongoDB) AggregateByPage

func (m *MongoDB) AggregateByPage(ctx context.Context, countResult, result interface{}, opts ...*options.AggregateOptions) error

func (*MongoDB) CountDocuments

func (m *MongoDB) CountDocuments(ctx context.Context) (int64, error)

func (*MongoDB) DeleteMany

func (m *MongoDB) DeleteMany(ctx context.Context) (int64, error)

func (*MongoDB) DeleteOne

func (m *MongoDB) DeleteOne(ctx context.Context) (int64, error)

func (*MongoDB) EstimatedDocumentCount

func (m *MongoDB) EstimatedDocumentCount(ctx context.Context) (int64, error)

func (*MongoDB) Find

func (m *MongoDB) Find(ctx context.Context, result interface{}, sortFields ...string) error

func (*MongoDB) FindByPage

func (m *MongoDB) FindByPage(ctx context.Context, paging *Paging, result interface{}, sortFields ...string) (err error)

func (*MongoDB) FindOne

func (m *MongoDB) FindOne(ctx context.Context, result interface{}, sortFields ...string) error

func (*MongoDB) FindOneAndDelete

func (m *MongoDB) FindOneAndDelete(ctx context.Context, result interface{}) error

func (*MongoDB) FindOneAndUpdate

func (m *MongoDB) FindOneAndUpdate(ctx context.Context, update interface{}, result interface{}, opts ...*options.FindOneAndUpdateOptions) error

func (*MongoDB) InsertMany

func (m *MongoDB) InsertMany(ctx context.Context, documents []interface{}) ([]interface{}, error)

func (*MongoDB) InsertOne

func (m *MongoDB) InsertOne(ctx context.Context, document interface{}) (interface{}, error)

func (*MongoDB) UpdateById

func (m *MongoDB) UpdateById(ctx context.Context, id, update interface{}, opts ...*options.UpdateOptions) error

func (*MongoDB) UpdateMany

func (m *MongoDB) UpdateMany(ctx context.Context, update interface{}, opts ...*options.UpdateOptions) error

func (*MongoDB) UpdateOne

func (m *MongoDB) UpdateOne(ctx context.Context, update interface{}, opts ...*options.UpdateOptions) error

type Paging

type Paging struct {
	Page      int64 // 当前页
	PageSize  int64 // 每页条数
	Total     int64 // 总条数
	PageCount int64 // 总页数
	StartNums int64 // 起始条数
	EndNums   int64 // 结束条数
}

func (*Paging) GetPages

func (p *Paging) GetPages()

获取分页信息