mongodb

Dec 4, 2025

Changes in this version

+ var AsteriskCharUTF8 = utf8.DecodeRuneInString(`*`)

+ var DollarCharUTF8 = utf8.DecodeRuneInString(`$`)

+ var DotCharUTF8 = utf8.DecodeRuneInString(`.`)

+ var EscapeCharUTF8 = utf8.DecodeRuneInString(`\`)

+ var LeftBracketCharUTF8 = utf8.DecodeRuneInString(`(`)

+ var LeftSquareCharUTF8 = utf8.DecodeRuneInString(`[`)

+ var PercentSignUTF8 = utf8.DecodeRuneInString("%")

+ var QMCharUTF8 = utf8.DecodeRuneInString(`?`)

+ var RightBracketCharUTF8 = utf8.DecodeRuneInString(`)`)

+ var RightSquareCharUTF8 = utf8.DecodeRuneInString(`]`)

+ var TipCharUTF8 = utf8.DecodeRuneInString(`^`)

+ var UnderscoreUTF8 = utf8.DecodeRuneInString("_")

+ func EscapeLikeString(s string) string

+ func IsNoFoundError(err error) bool

+ func WrapErr(err error) error

+ type Client struct

+ Coll *qmgo.Collection

+ Config *Config

+ DB *qmgo.Database

+ func NewClient(fn ...ClientOptionFunc) (c *Client, err error)

+ func (c *Client) BulkExecute(ctx context.Context, bulk *qmgo.Bulk) (err error)

+ func (c *Client) Collection(name string) *Client

+ func (c *Client) DeleteAll(ctx context.Context, data bson.M) error

+ func (c *Client) FindAll(ctx context.Context, filters bson.M, queryResult interface{}) error

+ func (c *Client) FindOne(ctx context.Context, filters bson.M, queryResult interface{}) error

+ func (c *Client) GetBulkContainer(collection string) (bulk *qmgo.Bulk)

+ func (c *Client) Insert(ctx context.Context, data []interface{}) error

+ func (c *Client) InsertOne(ctx context.Context, data interface{}) (id string, err error)

+ func (c *Client) QueryByPaging(ctx context.Context, filters bson.M, sort []string, pageIndex int64, ...) (totalCount int64, err error)

+ func (c *Client) Update(ctx context.Context, filters bson.M, data bson.M) error

+ func (c *Client) UpdateMany(ctx context.Context, filters bson.M, data bson.M) error

+ type ClientOptionFunc func(c *Client)

+ func SetBasicAuth(username, password string) ClientOptionFunc

+ func SetCollection(coll string) ClientOptionFunc

+ func SetConnectTimeout(t int) ClientOptionFunc

+ func SetDatabase(db string) ClientOptionFunc

+ func SetDirect(enabled bool) ClientOptionFunc

+ func SetHeartbeatInterval(t int) ClientOptionFunc

+ func SetLocalThreshold(t int) ClientOptionFunc

+ func SetMaxConnIdleTime(t int) ClientOptionFunc

+ func SetMaxPoolSize(size int) ClientOptionFunc

+ func SetMinPoolSize(size int) ClientOptionFunc

+ func SetReadConcern(level string) ClientOptionFunc

+ func SetRetryRead(enabled bool) ClientOptionFunc

+ func SetRetryWrite(enabled bool) ClientOptionFunc

+ func SetSocketTimeout(t int) ClientOptionFunc

+ func SetURI(uri string) ClientOptionFunc

+ func SetWriteConcern(level interface{}) ClientOptionFunc

+ type Config struct

+ Collection string

+ ConnTimeout time.Duration

+ Database string

+ Direct bool

+ HeartbeatInterval time.Duration

+ LocalThreshold time.Duration

+ MaxConnIdleTime time.Duration

+ MaxPoolSize uint64

+ MinPoolSize uint64

+ Password string

+ RetryRead bool

+ RetryWrite bool

+ SocketTimeout time.Duration

+ URI string

+ Username string