libmongo

package module

v1.7.1 Latest Latest Go to latest Published: Jun 8, 2023 License: GPL-3.0 Imports: 5 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wimark/libmongo

Links

Open Source Insights

README ¶

libmongo

Wrapper for globalsign/mgo (ex standard mgo.v2 library).

copyright

Wimark Systems, 2017-2021.

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ChangeInfo ¶ added in v1.7.1

type ChangeInfo *mgo.ChangeInfo

type D ¶

type D = bson.D

type M ¶

type M = bson.M

type MongoDb ¶

type MongoDb struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func GetDb ¶

func GetDb() *MongoDb

func NewConnection ¶

func NewConnection(dsn string) (*MongoDb, error)

func NewConnectionWithTimeout ¶

func NewConnectionWithTimeout(dsn string, timeout time.Duration) (*MongoDb, error)

func (*MongoDb) CollectionNames ¶

func (db *MongoDb) CollectionNames() (names []string, err error)

func (*MongoDb) Connect ¶

func (db *MongoDb) Connect(dsn string) error

func (*MongoDb) ConnectWithTimeout ¶

func (db *MongoDb) ConnectWithTimeout(dsn string, timeout time.Duration) error

func (*MongoDb) Count ¶

func (db *MongoDb) Count(coll string, query interface{}) (int, error)

func (*MongoDb) CreateIndexKey ¶

func (db *MongoDb) CreateIndexKey(coll string, key ...string) error

func (*MongoDb) CreateIndexKeys ¶

func (db *MongoDb) CreateIndexKeys(coll string, keys ...string) error

func (*MongoDb) Disconnect ¶

func (db *MongoDb) Disconnect()

func (*MongoDb) EnsureIndex ¶ added in v1.7.1

func (db *MongoDb) EnsureIndex(coll string, index mgo.Index) error

func (*MongoDb) Find ¶

func (db *MongoDb) Find(coll string, query map[string]interface{}, v interface{}) error

func (*MongoDb) FindAll ¶

func (db *MongoDb) FindAll(coll string, v interface{}) error

func (*MongoDb) FindByID ¶

func (db *MongoDb) FindByID(coll string, id string, v interface{}) bool

func (*MongoDb) FindWithQuery ¶

func (db *MongoDb) FindWithQuery(coll string, query interface{}, v interface{}) error

func (*MongoDb) FindWithQueryAll ¶

func (db *MongoDb) FindWithQueryAll(coll string, query interface{}, v interface{}) error

func (*MongoDb) FindWithQueryOne ¶

func (db *MongoDb) FindWithQueryOne(coll string, query interface{}, v interface{}) error

func (*MongoDb) FindWithQuerySortAll ¶

func (db *MongoDb) FindWithQuerySortAll(coll string, query interface{},
	order string, v interface{}) error

func (*MongoDb) FindWithQuerySortLimitAll ¶

func (db *MongoDb) FindWithQuerySortLimitAll(coll string, query interface{},
	order string, limit int, v interface{}) error

func (*MongoDb) FindWithQuerySortLimitOffsetAll ¶

func (db *MongoDb) FindWithQuerySortLimitOffsetAll(coll string, query interface{}, sort string,
	limit int, offset int, v interface{}) error

func (*MongoDb) FindWithQuerySortLimitOffsetTotalAll ¶

func (db *MongoDb) FindWithQuerySortLimitOffsetTotalAll(coll string, query interface{},
	sort string, limit int, offset int, v interface{}, total *int) error

func (*MongoDb) FindWithQuerySortOne ¶

func (db *MongoDb) FindWithQuerySortOne(coll string, query interface{},
	order string, v interface{}) error

func (*MongoDb) Insert ¶

func (db *MongoDb) Insert(coll string, v ...interface{}) error

func (*MongoDb) InsertBulk ¶

func (db *MongoDb) InsertBulk(coll string, v ...interface{}) error

func (*MongoDb) InsertSess ¶

func (db *MongoDb) InsertSess(coll string, sess *mgo.Session,
	v ...interface{}) error

func (*MongoDb) InsertWithCheckIsDup ¶

func (db *MongoDb) InsertWithCheckIsDup(coll string, v ...interface{}) (bool, error)

func (*MongoDb) IsConnected ¶

func (db *MongoDb) IsConnected() bool

func (*MongoDb) Iter ¶

func (db *MongoDb) Iter(coll string, query []bson.M, f func(iter *mgo.Iter) error) error

func (*MongoDb) Pipe ¶

func (db *MongoDb) Pipe(coll string, query []bson.M, v interface{}) error

func (*MongoDb) PipeOne ¶

func (db *MongoDb) PipeOne(coll string, query []bson.M, v interface{}) error

func (*MongoDb) PipeWithSocketTimeOut ¶ added in v1.7.1

func (db *MongoDb) PipeWithSocketTimeOut(coll string, query []bson.M, v interface{}, timeOut time.Duration) error

func (*MongoDb) Remove ¶

func (db *MongoDb) Remove(coll string, id interface{}) error

func (*MongoDb) RemoveAll ¶

func (db *MongoDb) RemoveAll(coll string) error

func (*MongoDb) RemoveWithIDs ¶

func (db *MongoDb) RemoveWithIDs(coll string, ids interface{}) error

func (*MongoDb) RemoveWithQuery ¶

func (db *MongoDb) RemoveWithQuery(coll string, query interface{}) error

func (*MongoDb) Run ¶

func (db *MongoDb) Run(dbname string, cmd bson.D, set interface{}) error

func (*MongoDb) SessClose ¶

func (db *MongoDb) SessClose(sess *mgo.Session)

func (*MongoDb) SessCopy ¶

func (db *MongoDb) SessCopy() *mgo.Session

func (*MongoDb) SessExec ¶

func (db *MongoDb) SessExec(cb func(*mgo.Session))

func (*MongoDb) SetMaxTimeMS ¶

func (db *MongoDb) SetMaxTimeMS(d time.Duration)

func (*MongoDb) Update ¶

func (db *MongoDb) Update(coll string, id interface{}, v interface{}) error

func (*MongoDb) UpdateWithQuery ¶

func (db *MongoDb) UpdateWithQuery(coll string, query interface{}, set interface{}, opts ...func(session *mgo.Session)) error

func (*MongoDb) UpdateWithQueryAll ¶

func (db *MongoDb) UpdateWithQueryAll(coll string, query interface{}, set interface{}) error

func (*MongoDb) Upsert ¶

func (db *MongoDb) Upsert(coll string, id interface{}, v interface{}) (ChangeInfo, error)

func (*MongoDb) UpsertMulti ¶

func (db *MongoDb) UpsertMulti(coll string, id []interface{}, v []interface{}) error

func (*MongoDb) UpsertWithQuery ¶

func (db *MongoDb) UpsertWithQuery(coll string, query interface{}, set interface{}) error

Source Files ¶

View all Source files

lib.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL