mongo

package

v0.0.0-...-c18a219 Latest Latest Go to latest Published: Nov 20, 2023 License: MIT Imports: 8 Imported by: 2

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

This section is empty.

This section is empty.

func MustOpen(name string) *mongo.Database

func Open(name string) (*mongo.Database, error)

type Table[T, K any] struct {
	*mongo.Collection
}

func NewTable[T, K any](db *mongo.Database, name string, opts ...*options.CollectionOptions) *Table[T, K]

func (t *Table[T, K]) Create(ctx context.Context, doc *T) (err error)

Create insert a new document to database.

func (t *Table[T, K]) Delete(ctx context.Context, id K) (err error)

Delete deletes document by ID.

func (t *Table[T, K]) Fetch(ctx context.Context, filter, sorter any) (records []*T, err error)

Fetch returns all qualified records.

func (t *Table[T, K]) FetchByPage(ctx context.Context, pageIndex, pageSize int64, filter, sorter any) (records []*T, count int64, err error)

FetchByPage returns qualified records with paging.

func (t *Table[T, K]) Query(ctx context.Context, id K) (r *T, err error)

func (t *Table[T, K]) QueryByFilter(ctx context.Context, filter any) (r *T, err error)

func (t *Table[T, K]) Update(ctx context.Context, id K, update any) (err error)

Update updates document by ID.

func (t *Table[T, K]) Upsert(ctx context.Context, id K, update any) (err error)

Upsert updates document by ID if found, otherwise insert document.