mongox

Documentation

Index

• Constants
• func Close()
• func Collection(key string) *mongo.Collection
• func DB(name string) *mongo.Database
• func IndexExisted(coll *mongo.Collection, index string) bool
• func Init()
• func New(conf Config) *mongo.Client
• func NewID() primitive.ObjectID
• type Config

Constants

const (
	ErrorDataExisted = "E11000"                        // 数据已存在
	ErrorDataIsEmpty = "mongo: no documents in result" // 没有查询到数据
)

Functions

func Close

func Close()

Close 关闭Mongodb连接

func Collection

func Collection(key string) *mongo.Collection

Collection 获取集合操作对象

func DB

func DB(name string) *mongo.Database

DB 获取数据库操作对象

func IndexExisted

func IndexExisted(coll *mongo.Collection, index string) bool

IndexExisted 检查索引是否存在

func Init

func Init()

Init 初始化mongo数据库

func New

func New(conf Config) *mongo.Client

New 注册mongodb

func NewID

func NewID() primitive.ObjectID

NewID 生成ObjectID

Types

type Config

type Config struct {
	Database   string `mapstructure:"db"`
	Conn       string `mapstructure:"conn"`
	User       string `mapstructure:"user"`
	Password   string `mapstructure:"password"`
	AuthSource string `mapstructure:"auth_source"`
	Timeout    int    `mapstructure:"timeout"`
	MaxPool    int    `mapstructure:"max_pool"`
}