mongo

Documentation

Index

• type Repository
  • func (m Repository[B, M, T]) CollWithTable() *mongo.Collection
  • func (m Repository[B, M, T]) CountByBson(condition bson.M) (int64, error)
  • func (m Repository[B, M, T]) CountByCond(condition *T) (int64, error)
  • func (m Repository[B, M, T]) CountByOption(filter interface{}, opts ...options.Lister[options.CountOptions]) (int64, error)
  • func (m Repository[B, M, T]) InsertWithOption(document interface{}, opts ...options.Lister[options.InsertOneOptions]) (string, error)
  • func (m Repository[B, M, T]) ModifyByCond(update, condition *T) (bool, error)
  • func (m Repository[B, M, T]) ModifyByCondUseBson(update, condition bson.M) (bool, error)
  • func (m Repository[B, M, T]) ModifyByID(update *T, id any, notObjectId ...bool) (bool, error)
  • func (m Repository[B, M, T]) ModifyByIdUseBson(update bson.M, id any, notObjectId ...bool) (bool, error)
  • func (m Repository[B, M, T]) ModifyOneByCond(update, condition *T) (bool, error)
  • func (m Repository[B, M, T]) ModifyOneByCondUseBson(update, condition bson.M) (bool, error)
  • func (m Repository[B, M, T]) QueryByBson(condition bson.M, orderBy []*mongostarter.OrderBy, result *[]*T, ...) error
  • func (m Repository[B, M, T]) QueryByCond(condition *T, orderBy []*mongostarter.OrderBy, result *[]*T, ...) error
  • func (m Repository[B, M, T]) QueryByID(id any, result *T, notObjectId ...bool) error
  • func (m Repository[B, M, T]) QueryByIDs(ids []any, result *[]*T, notObjectId ...bool) (err error)
  • func (m Repository[B, M, T]) QueryByOption(filter interface{}, result *[]*T, opts ...options.Lister[options.FindOptions]) error
  • func (m Repository[B, M, T]) QueryOneByBson(condition bson.M, result *T, specifyColumns ...string) error
  • func (m Repository[B, M, T]) QueryOneByCond(condition *T, result *T, specifyColumns ...string) error
  • func (m Repository[B, M, T]) QueryOneByOption(filter interface{}, result *T, opts ...options.Lister[options.FindOneOptions]) error
  • func (m Repository[B, M, T]) QueryPageByBson(condition bson.M, orderBy []*mongostarter.OrderBy, ...) error
  • func (m Repository[B, M, T]) QueryPageByCond(condition *T, orderBy []*mongostarter.OrderBy, pager *databasecloud.Pager[T], ...) error
  • func (m Repository[B, M, T]) QueryPageByOption(filter interface{}, orderBy []*mongostarter.OrderBy, ...) error
  • func (m Repository[B, M, T]) RawIMapper() B
  • func (m Repository[B, M, T]) RemoveByCond(condition *T) (bool, error)
  • func (m Repository[B, M, T]) RemoveByCondUseBson(condition bson.M) (bool, error)
  • func (m Repository[B, M, T]) RemoveByID(id any, notObjectId ...bool) (bool, error)
  • func (m Repository[B, M, T]) RemoveOneByCond(condition *T) (bool, error)
  • func (m Repository[B, M, T]) RemoveOneByCondUseBson(condition bson.M) (bool, error)
  • func (m Repository[B, M, T]) Save(entity *T) (string, error)
  • func (m Repository[B, M, T]) SaveBatch(entities *[]*T) ([]string, error)
  • func (m Repository[B, M, T]) SaveBatchUseBson(entities bson.A) ([]string, error)
  • func (m Repository[B, M, T]) SaveBatchWithOption(documents interface{}, opts ...options.Lister[options.InsertManyOptions]) ([]string, error)
  • func (m Repository[B, M, T]) SaveUseBson(entity bson.M) (string, error)

Types

type Repository

type Repository[B mongostarter.IBaseMapper[M, T], M mongostarter.BaseMapper[T], T mongostarter.IBaseModel] struct {
	Mapper B // mapper接口的声明类型
	// contains filtered or unexported fields
}

func (Repository[B, M, T]) CollWithTable

func (m Repository[B, M, T]) CollWithTable() *mongo.Collection

CollWithTable 获取mongo.Collection并已限定当前mapper对应的表名

func (Repository[B, M, T]) CountByBson

func (m Repository[B, M, T]) CountByBson(condition bson.M) (int64, error)

CountByBson 根据条件查询统计数据

func (Repository[B, M, T]) CountByCond

func (m Repository[B, M, T]) CountByCond(condition *T) (int64, error)

CountByCond 根据条件查询统计数据

func (Repository[B, M, T]) CountByOption

func (m Repository[B, M, T]) CountByOption(filter interface{}, opts ...options.Lister[options.CountOptions]) (int64, error)

CountByOption 根据条件查询统计数据

func (Repository[B, M, T]) InsertWithOption

func (m Repository[B, M, T]) InsertWithOption(document interface{}, opts ...options.Lister[options.InsertOneOptions]) (string, error)

InsertWithOption 插入数据并返回objectId

func (Repository[B, M, T]) ModifyByCond

func (m Repository[B, M, T]) ModifyByCond(update, condition *T) (bool, error)

ModifyByCond 根据条件修改数据

func (Repository[B, M, T]) ModifyByCondUseBson

func (m Repository[B, M, T]) ModifyByCondUseBson(update, condition bson.M) (bool, error)

ModifyByCondUseBson 根据条件修改数据

func (Repository[B, M, T]) ModifyByID

func (m Repository[B, M, T]) ModifyByID(update *T, id any, notObjectId ...bool) (bool, error)

ModifyByID 根据id修改数据

func (Repository[B, M, T]) ModifyByIdUseBson

func (m Repository[B, M, T]) ModifyByIdUseBson(update bson.M, id any, notObjectId ...bool) (bool, error)

ModifyByIdUseBson 根据id修改数据

func (Repository[B, M, T]) ModifyOneByCond

func (m Repository[B, M, T]) ModifyOneByCond(update, condition *T) (bool, error)

ModifyOneByCond 根据条件修改一条数据

func (Repository[B, M, T]) ModifyOneByCondUseBson

func (m Repository[B, M, T]) ModifyOneByCondUseBson(update, condition bson.M) (bool, error)

ModifyOneByCondUseBson 根据条件修改一条数据

func (Repository[B, M, T]) QueryByBson

func (m Repository[B, M, T]) QueryByBson(condition bson.M, orderBy []*mongostarter.OrderBy, result *[]*T, specifyColumns ...string) error

QueryByBson 根据条件查询数据

func (Repository[B, M, T]) QueryByCond

func (m Repository[B, M, T]) QueryByCond(condition *T, orderBy []*mongostarter.OrderBy, result *[]*T, specifyColumns ...string) error

QueryByCond 根据条件查询数据

func (Repository[B, M, T]) QueryByID

func (m Repository[B, M, T]) QueryByID(id any, result *T, notObjectId ...bool) error

QueryByID 根据id查询数据 默认匹配_id字段 传入string的主键时，默认转换为mongo hex 如果不是该类型，需设置notObjectId为true

func (Repository[B, M, T]) QueryByIDs

func (m Repository[B, M, T]) QueryByIDs(ids []any, result *[]*T, notObjectId ...bool) (err error)

QueryByIDs 根据ids查询数据 默认匹配_id字段 传入string的主键时，默认转换为mongo hex 如果不是该类型，需设置notObjectId为true

func (Repository[B, M, T]) QueryByOption

func (m Repository[B, M, T]) QueryByOption(filter interface{}, result *[]*T, opts ...options.Lister[options.FindOptions]) error

QueryByOption 根据条件查询数据

func (Repository[B, M, T]) QueryOneByBson

func (m Repository[B, M, T]) QueryOneByBson(condition bson.M, result *T, specifyColumns ...string) error

QueryOneByBson 根据条件查询一条数据

func (Repository[B, M, T]) QueryOneByCond

func (m Repository[B, M, T]) QueryOneByCond(condition *T, result *T, specifyColumns ...string) error

QueryOneByCond 根据条件查询一条数据

func (Repository[B, M, T]) QueryOneByOption

func (m Repository[B, M, T]) QueryOneByOption(filter interface{}, result *T, opts ...options.Lister[options.FindOneOptions]) error

QueryOneByOption 根据条件查询一条数据

func (Repository[B, M, T]) QueryPageByBson

func (m Repository[B, M, T]) QueryPageByBson(condition bson.M, orderBy []*mongostarter.OrderBy, pager *databasecloud.Pager[T], specifyColumns ...string) error

QueryPageByBson 根据条件查询分页数据

func (Repository[B, M, T]) QueryPageByCond

func (m Repository[B, M, T]) QueryPageByCond(condition *T, orderBy []*mongostarter.OrderBy, pager *databasecloud.Pager[T], specifyColumns ...string) error

QueryPageByCond 根据条件查询分页数据

func (Repository[B, M, T]) QueryPageByOption

func (m Repository[B, M, T]) QueryPageByOption(filter interface{}, orderBy []*mongostarter.OrderBy, pager *databasecloud.Pager[T], opts ...options.Lister[options.FindOptions]) error

QueryPageByOption 根据条件查询分页数据

func (Repository[B, M, T]) RawIMapper

func (m Repository[B, M, T]) RawIMapper() B

RawIMapper 获取原始基础Mapper

func (Repository[B, M, T]) RemoveByCond

func (m Repository[B, M, T]) RemoveByCond(condition *T) (bool, error)

RemoveByCond 根据条件删除数据

func (Repository[B, M, T]) RemoveByCondUseBson

func (m Repository[B, M, T]) RemoveByCondUseBson(condition bson.M) (bool, error)

RemoveByCondUseBson 根据条件删除数据

func (Repository[B, M, T]) RemoveByID

func (m Repository[B, M, T]) RemoveByID(id any, notObjectId ...bool) (bool, error)

RemoveByID 根据id删除数据

func (Repository[B, M, T]) RemoveOneByCond

func (m Repository[B, M, T]) RemoveOneByCond(condition *T) (bool, error)

RemoveOneByCond 根据条件删除一条数据

func (Repository[B, M, T]) RemoveOneByCondUseBson

func (m Repository[B, M, T]) RemoveOneByCondUseBson(condition bson.M) (bool, error)

RemoveOneByCondUseBson 根据条件删除一条数据

func (Repository[B, M, T]) Save

func (m Repository[B, M, T]) Save(entity *T) (string, error)

Save 保存数据 并返回objectId

func (Repository[B, M, T]) SaveBatch

func (m Repository[B, M, T]) SaveBatch(entities *[]*T) ([]string, error)

SaveBatch 批量保存数据并返回objectId

func (Repository[B, M, T]) SaveBatchUseBson

func (m Repository[B, M, T]) SaveBatchUseBson(entities bson.A) ([]string, error)

SaveBatchUseBson 批量保存数据并返回objectId

func (Repository[B, M, T]) SaveBatchWithOption

func (m Repository[B, M, T]) SaveBatchWithOption(documents interface{}, opts ...options.Lister[options.InsertManyOptions]) ([]string, error)

SaveBatchWithOption 批量保存数据并返回objectId

func (Repository[B, M, T]) SaveUseBson

func (m Repository[B, M, T]) SaveUseBson(entity bson.M) (string, error)

SaveUseBson 保存数据使用Bson返回objectId