mongodb

Documentation

Index

• func ObjectId(id string) (bson.ObjectID, error)
• func ParseSort(str string) bson.D
• type Model
  • func DefineModel[T any](db *MongoDb, collectionName string) *Model[T]
  • func (t *Model[T]) CountDocuments(filter bson.M, opts ...options.Lister[options.CountOptions]) (int, error)
  • func (t *Model[T]) DeleteMany(filter bson.M, opts ...options.Lister[options.DeleteOptions]) (*mongo.DeleteResult, error)
  • func (t *Model[T]) DeleteOne(filter bson.M, opts ...options.Lister[options.DeleteOptions]) (*mongo.DeleteResult, error)
  • func (t *Model[T]) Find(filter bson.M, opts ...options.Lister[options.FindOptions]) ([]T, error)
  • func (t *Model[T]) FindById(id string) (*T, error)
  • func (t *Model[T]) FindOne(filter bson.M, opts ...options.Lister[options.FindOneOptions]) (*T, error)
  • func (t *Model[T]) InsertMany(list []T) error
  • func (t *Model[T]) InsertOne(data *T) error
  • func (t *Model[T]) UpdateById(id string, data any) (int, error)
  • func (t *Model[T]) UpdateMany(filter bson.M, data any, opts ...options.Lister[options.UpdateOptions]) (int, error)
  • func (t *Model[T]) UpdateOne(filter bson.M, data any) (int, error)
• type MongoDb
  • func (t *MongoDb) Connect(appUri string, dbName string) error

Functions

func ObjectId

func ObjectId(id string) (bson.ObjectID, error)

func ParseSort

func ParseSort(str string) bson.D

将 name,-name 排序方式转成 bson.D格式

Types

type Model

type Model[T any] struct {
	Coll *mongo.Collection
}

func DefineModel

func DefineModel[T any](db *MongoDb, collectionName string) *Model[T]

func (*Model[T]) CountDocuments

func (t *Model[T]) CountDocuments(filter bson.M, opts ...options.Lister[options.CountOptions]) (int, error)

func (*Model[T]) DeleteMany

func (t *Model[T]) DeleteMany(filter bson.M, opts ...options.Lister[options.DeleteOptions]) (*mongo.DeleteResult, error)

func (*Model[T]) DeleteOne

func (t *Model[T]) DeleteOne(filter bson.M, opts ...options.Lister[options.DeleteOptions]) (*mongo.DeleteResult, error)

func (*Model[T]) Find

func (t *Model[T]) Find(filter bson.M, opts ...options.Lister[options.FindOptions]) ([]T, error)

func (*Model[T]) FindById

func (t *Model[T]) FindById(id string) (*T, error)

当找不到数据时，不返回错误

func (*Model[T]) FindOne

func (t *Model[T]) FindOne(filter bson.M, opts ...options.Lister[options.FindOneOptions]) (*T, error)

当找不到数据时，不返回错误

func (*Model[T]) InsertMany

func (t *Model[T]) InsertMany(list []T) error

注意先要为 model.Id 赋值

func (*Model[T]) InsertOne

func (t *Model[T]) InsertOne(data *T) error

注意先要为 model.Id 赋值

func (*Model[T]) UpdateById

func (t *Model[T]) UpdateById(id string, data any) (int, error)

@return 修改的数量

func (*Model[T]) UpdateMany

func (t *Model[T]) UpdateMany(filter bson.M, data any, opts ...options.Lister[options.UpdateOptions]) (int, error)

@return 修改的数量

func (*Model[T]) UpdateOne

func (t *Model[T]) UpdateOne(filter bson.M, data any) (int, error)

@return 修改的数量

type MongoDb

type MongoDb struct {
	Client *mongo.Client
	Db     *mongo.Database
}

func (*MongoDb) Connect

func (t *MongoDb) Connect(appUri string, dbName string) error