mongo_driver

package
v1.0.2-0...-53992d1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 9, 2021 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNoDocuments = mongo.ErrNoDocuments

ErrNoDocuments is returned by Decode when an operation that returns a SingleResult doesn't return any documents.

Functions

This section is empty.

Types

type AggregateOptions 

type AggregateOptions = options.AggregateOptions

AggregateOptions 聚合

type BulkWriteOptions 

type BulkWriteOptions = options.BulkWriteOptions

BulkWriteOptions BulkWriteOptions

type BulkWriteResult 

type BulkWriteResult = mongo.BulkWriteResult

BulkWriteResult BulkWriteResult

type ClientName 

type ClientName string

ClientName 客户端连接

type CountOptions 

type CountOptions = options.CountOptions

CountOptions count

type Cursor 

type Cursor = mongo.Cursor

Cursor 游标

type Dao 

type Dao struct {
	ClientName ClientName
	DBName     string
	CollName   string
	// contains filtered or unexported fields
}

Dao data access operation 数据库操作结构

func NewDao 

func NewDao(clientName ClientName, dbName string, collName string) (d *Dao)

NewDao 新建数据库操作对象

func (*Dao) Aggregate 

func (d *Dao) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*Cursor, error)

Aggregate 聚合查询 Deprecated 使用AggregateSafe替换

func (*Dao) AggregateSecondaryPreferred 

func (d *Dao) AggregateSecondaryPreferred(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*Cursor, error)

AggregateSecondaryPreferred 聚合查询

func (*Dao) BulkWrite 

func (d *Dao) BulkWrite(ctx context.Context, models []WriteModel, opts ...*options.BulkWriteOptions) (*BulkWriteResult, error)

BulkWrite 批量写方法

func (*Dao) CountDocuments 

func (d *Dao) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

CountDocuments https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.CountDocuments

func (*Dao) CountDocumentsSecondaryPreferred 

func (d *Dao) CountDocumentsSecondaryPreferred(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

CountDocumentsSecondaryPreferred https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.CountDocuments

func (*Dao) DecodeOne 

func (d *Dao) DecodeOne(err error) error

DecodeOne 处理DecodeOne的错误 deprecated 该方法容易引起panic，已经废弃

func (*Dao) DefaultCtx 

func (d *Dao) DefaultCtx() (context.Context, context.CancelFunc)

DefaultCtx 默认上下文环境生成

func (*Dao) DeleteMany 

func (d *Dao) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*DeleteResult, error)

DeleteMany https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.DeleteMany

func (*Dao) DeleteOne 

func (d *Dao) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*DeleteResult, error)

DeleteOne https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.DeleteOne

func (*Dao) Distinct 

func (d *Dao) Distinct(ctx context.Context, fieldName string, filter interface{},
	opts ...*options.DistinctOptions) ([]interface{}, error)

Distinct https://github.com/mongodb/mongo-go-driver/blob/master/mongo/collection.go

func (*Dao) Find 

func (d *Dao) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*Cursor, error)

Find https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.Find

func (*Dao) FindOne 

func (d *Dao) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *SingleResult

FindOne https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.FindOne

func (*Dao) FindOneAndDelete 

func (d *Dao) FindOneAndDelete(ctx context.Context, filter interface{},
	opts ...*options.FindOneAndDeleteOptions) *SingleResult

FindOneAndDelete 删除一个

func (*Dao) FindOneAndUpdate 

func (d *Dao) FindOneAndUpdate(ctx context.Context, filter interface{},
	update interface{}, opts ...*options.FindOneAndUpdateOptions) *SingleResult

FindOneAndUpdate 更新一个

func (*Dao) FindOneSecondaryPreferred 

func (d *Dao) FindOneSecondaryPreferred(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *SingleResult

FindOneSecondaryPreferred https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.FindOne

func (*Dao) FindSecondaryPreferred 

func (d *Dao) FindSecondaryPreferred(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*Cursor, error)

FindSecondaryPreferred https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.Find

func (*Dao) HasDuplicatedError 

func (d *Dao) HasDuplicatedError(err error) bool

HasDuplicatedError 是否是重复id写入错误

func (*Dao) InsertMany 

func (d *Dao) InsertMany(ctx context.Context, documents []interface{}, opts ...*options.InsertManyOptions) (*InsertManyResult, error)

InsertMany https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.InsertMany

func (*Dao) InsertOne 

func (d *Dao) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*InsertOneResult, error)

InsertOne https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.InsertOne

func (*Dao) IsAllDuplicatedError 

func (d *Dao) IsAllDuplicatedError(err error) bool

IsAllDuplicatedError 是否是重复id写入错误

func (*Dao) Name 

func (d *Dao) Name() string

Name https://godoc.org/go.mongodb.org/mongo-driver/mongo#Collection.Name

func (*Dao) ReplaceOne 

func (d *Dao) ReplaceOne(ctx context.Context, filter interface{},
	replacement interface{}, opts ...*options.ReplaceOptions) (*UpdateResult, error)

ReplaceOne 替换一个

func (*Dao) UpdateMany 

func (d *Dao) UpdateMany(ctx context.Context, filter interface{}, update interface{},
	opts ...*options.UpdateOptions) (*UpdateResult, error)

UpdateMany https://github.com/mongodb/mongo-go-driver/blob/master/mongo/collection.go#L548

func (*Dao) UpdateOne 

func (d *Dao) UpdateOne(ctx context.Context, filter interface{}, update interface{},
	opts ...*options.UpdateOptions) (*UpdateResult, error)

UpdateOne https://github.com/mongodb/mongo-go-driver/blob/master/mongo/collection.go#L532

func (*Dao) UseSession 

func (d *Dao) UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error

UseSession 开启默认事务

type DeleteOptions 

type DeleteOptions = options.DeleteOptions

DeleteOptions 删除option

type DeleteResult 

type DeleteResult = mongo.DeleteResult

DeleteResult 删除结果

type FindOneAndDeleteOptions 

type FindOneAndDeleteOptions = options.FindOneAndDeleteOptions

FindOneAndDeleteOptions 删除一个

type FindOneAndUpdateOptions 

type FindOneAndUpdateOptions = options.FindOneAndUpdateOptions

FindOneAndUpdateOptions 更新一个

type FindOneOptions 

type FindOneOptions = options.FindOneOptions

FindOneOptions 查找option

type FindOptions 

type FindOptions = options.FindOptions

FindOptions 查找option

type InsertManyOptions 

type InsertManyOptions = options.InsertManyOptions

InsertManyOptions insertMany

type InsertManyResult 

type InsertManyResult = mongo.InsertManyResult

InsertManyResult 多个结果

type InsertOneModel 

type InsertOneModel = mongo.InsertOneModel

InsertOneModel 插入的单个model

type InsertOneOptions 

type InsertOneOptions = options.InsertOneOptions

InsertOneOptions insert

type InsertOneResult 

type InsertOneResult = mongo.InsertOneResult

InsertOneResult 插入的单个结果

type ReplaceOptions 

type ReplaceOptions = options.ReplaceOptions

ReplaceOptions 替换option

type SessionContext 

type SessionContext = mongo.SessionContext

SessionContext 事务session

type SingleResult 

type SingleResult = mongo.SingleResult

SingleResult 单个结果

type UpdateOptions 

type UpdateOptions = options.UpdateOptions

UpdateOptions 更新option

type UpdateResult 

type UpdateResult = mongo.UpdateResult

UpdateResult 更新结果

type WriteException 

type WriteException = mongo.WriteException

WriteException 写入错误

type WriteModel 

type WriteModel = mongo.WriteModel

WriteModel WriteModel

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.