db

Documentation

Index

• func Disconnect()
• func Init()
• type Collection
  • func (c *Collection) Count(selector interface{}) (int64, error)
  • func (c *Collection) Find(filter interface{}) *Session
  • func (c *Collection) Insert(document interface{}) error
  • func (c *Collection) InsertAll(documents []interface{}) error
  • func (c *Collection) InsertAllWithResult(documents []interface{}) (result *mongo.InsertManyResult, err error)
  • func (c *Collection) InsertWithResult(document interface{}) (result *mongo.InsertOneResult, err error)
  • func (c *Collection) Remove(selector interface{}) error
  • func (c *Collection) RemoveAll(selector interface{}) error
  • func (c *Collection) RemoveID(id interface{}) error
  • func (c *Collection) Update(selector interface{}, update interface{}, upsert ...bool) error
  • func (c *Collection) UpdateAll(selector interface{}, update interface{}, upsert ...bool) (*mongo.UpdateResult, error)
  • func (c *Collection) UpdateID(id interface{}, update interface{}) error
  • func (c *Collection) UpdateWithResult(selector interface{}, update interface{}, upsert ...bool) (result *mongo.UpdateResult, err error)
• type Database
  • func (d *Database) C(collection string) *Collection
  • func (d *Database) CollectionNames() (names []string, err error)
• type Session
  • func New() *Session
  • func (s *Session) All(result interface{}) error
  • func (s *Session) C(collection string) *Collection
  • func (s *Session) Client() *mongo.Client
  • func (s *Session) Connect() error
  • func (s *Session) DB(db string) *Database
  • func (s *Session) Disconnect()
  • func (s *Session) Limit(limit int64) *Session
  • func (s *Session) One(result interface{}) error
  • func (s *Session) Ping() error
  • func (s *Session) SetPoolLimit(limit uint64)
  • func (s *Session) SetUri(uri string)
  • func (s *Session) Skip(skip int64) *Session
  • func (s *Session) Sort(sort interface{}) *Session

Functions

func Disconnect

func Disconnect()

Disconnect 断开连接

func Init

func Init()

Init 初始化

Types

type Collection

type Collection struct {
	// contains filtered or unexported fields
}

Collection mongo-driver collection

func (*Collection) Count

func (c *Collection) Count(selector interface{}) (int64, error)

Count 获取与筛选器匹配的文档数

func (*Collection) Find

func (c *Collection) Find(filter interface{}) *Session

Find 按给定筛选器查找文档

func (*Collection) Insert

func (c *Collection) Insert(document interface{}) error

Insert 将单个文档插入集合

func (*Collection) InsertAll

func (c *Collection) InsertAll(documents []interface{}) error

InsertAll 插入提供的文档集

func (*Collection) InsertAllWithResult

func (c *Collection) InsertAllWithResult(documents []interface{}) (result *mongo.InsertManyResult, err error)

InsertAllWithResult 插入提供的文档集并返回插入的结果

func (*Collection) InsertWithResult

func (c *Collection) InsertWithResult(document interface{}) (result *mongo.InsertOneResult, err error)

InsertWithResult 在集合中插入一个文档，并返回插入一个结果

func (*Collection) Remove

func (c *Collection) Remove(selector interface{}) error

Remove 从集合中删除单个文档

func (*Collection) RemoveAll

func (c *Collection) RemoveAll(selector interface{}) error

RemoveAll 从集合中删除多个文档

func (*Collection) RemoveID

func (c *Collection) RemoveID(id interface{}) error

RemoveID 按id从集合中删除单个文档

func (*Collection) Update

func (c *Collection) Update(selector interface{}, update interface{}, upsert ...bool) error

Update 更新集合中的单个文档

func (*Collection) UpdateAll

func (c *Collection) UpdateAll(selector interface{}, update interface{}, upsert ...bool) (*mongo.UpdateResult, error)

UpdateAll 更新集合中的多个文档

func (*Collection) UpdateID

func (c *Collection) UpdateID(id interface{}, update interface{}) error

UpdateID 按id更新集合中的单个文档

func (*Collection) UpdateWithResult

func (c *Collection) UpdateWithResult(selector interface{}, update interface{}, upsert ...bool) (result *mongo.UpdateResult, err error)

UpdateWithResult 更新集合中的单个文档并返回更新结果

type Database

type Database struct {
	// contains filtered or unexported fields
}

Database mongo-driver database

func (*Database) C

func (d *Database) C(collection string) *Collection

C 返回集合

func (*Database) CollectionNames

func (d *Database) CollectionNames() (names []string, err error)

CollectionNames 返回数据库中存在的所有集合名称

type Session

type Session struct {
	// contains filtered or unexported fields
}

Session mongo session

var S *Session

func New

func New() *Session

New 新建

func (*Session) All

func (s *Session) All(result interface{}) error

All 查找全部

func (*Session) C

func (s *Session) C(collection string) *Collection

C 返回集合

func (*Session) Client

func (s *Session) Client() *mongo.Client

Client 返回客户端

func (*Session) Connect

func (s *Session) Connect() error

Connect 连接服务器

func (*Session) DB

func (s *Session) DB(db string) *Database

DB 返回表示命名数据库的值

func (*Session) Disconnect

func (s *Session) Disconnect()

Disconnect 断开连接

func (*Session) Limit

func (s *Session) Limit(limit int64) *Session

Limit 指定结果数的限制，负限制意味着返回一批.

func (*Session) One

func (s *Session) One(result interface{}) error

One 最多返回一个与模型匹配的文档

func (*Session) Ping

func (s *Session) Ping() error

Ping 验证客户端是否可以连接到拓扑。如果readPreference为nil，则将使用客户端的默认读取首选项。

func (*Session) SetPoolLimit

func (s *Session) SetPoolLimit(limit uint64)

SetPoolLimit 指定服务器连接池的最大值

func (*Session) SetUri

func (s *Session) SetUri(uri string)

SetUri 指定服务器连接uri

func (*Session) Skip

func (s *Session) Skip(skip int64) *Session

Skip 指定返回前要跳过的文档数。对于小于3.2的服务器版本，默认值为0

func (*Session) Sort

func (s *Session) Sort(sort interface{}) *Session

Sort 指定返回文档的顺序