mongohelper

Documentation

Index

• Variables
• func CvtA[T any](a any) ([]T, error)
• func CvtM[T any](m any) (*T, error)
• func Delete[T any](rFilter io.Reader) (int, []*T, error)
• func DeleteAt[T any](field string, value any) (int, []*T, error)
• func DeleteOne[T any](rFilter io.Reader) (int, *T, error)
• func DeleteOneAt[T any](field string, value any) (int, *T, error)
• func DropCol(dbName, colName string) error
• func DropCurrentCol() (int, error)
• func DropDb(dbName string) error
• func Find[T any](rFilter io.Reader) (rt []*T, err error)
• func FindAt[T any](field string, value any) (rt []*T, err error)
• func FindOne[T any](rFilter io.Reader) (*T, error)
• func FindOneAt[T any](field string, value any) (*T, error)
• func Insert(rData io.Reader) (any, []byte, error)
• func RemoveFields(field string, value any, remove ...string) error
• func ReplaceOne(rFilter, rData io.Reader) (any, []byte, error)
• func ReplaceOneAt(field string, value any, rData io.Reader) (any, []byte, error)
• func Update(rFilter, rUpdate io.Reader, one bool) (int, error)
• func UpdateAt(field string, value any, rUpdate io.Reader, one bool) (int, error)
• func UpdateMongoClient(ip string, port int)
• func UpsertOneAt(field string, value any, rData io.Reader) (any, []byte, error)
• func UseDbCol(dbName, colName string)

Variables

var (
	Ctx    context.Context
	Cancel context.CancelFunc
	Client *mongo.Client
)

Functions

func CvtA

func CvtA[T any](a any) ([]T, error)

a should be primitive.A or []any type

func CvtM

func CvtM[T any](m any) (*T, error)

m should be primitive.M or map[string]any type

func Delete

func Delete[T any](rFilter io.Reader) (int, []*T, error)

return deleted count, original objects

func DeleteAt

func DeleteAt[T any](field string, value any) (int, []*T, error)

func DeleteOne

func DeleteOne[T any](rFilter io.Reader) (int, *T, error)

return deleted count, original object

func DeleteOneAt

func DeleteOneAt[T any](field string, value any) (int, *T, error)

func DropCol

func DropCol(dbName, colName string) error

func DropCurrentCol

func DropCurrentCol() (int, error)

func DropDb

func DropDb(dbName string) error

func Find

func Find[T any](rFilter io.Reader) (rt []*T, err error)

return found objects

func FindAt

func FindAt[T any](field string, value any) (rt []*T, err error)

func FindOne

func FindOne[T any](rFilter io.Reader) (*T, error)

return found object, if not found, return nil

func FindOneAt

func FindOneAt[T any](field string, value any) (*T, error)

func Insert

func Insert(rData io.Reader) (any, []byte, error)

return inserted id(s), inserted data

func RemoveFields

func RemoveFields(field string, value any, remove ...string) error

func ReplaceOne

func ReplaceOne(rFilter, rData io.Reader) (any, []byte, error)

return replaced count, after replacing data

func ReplaceOneAt

func ReplaceOneAt(field string, value any, rData io.Reader) (any, []byte, error)

if couldn't find, do nothing

func Update

func Update(rFilter, rUpdate io.Reader, one bool) (int, error)

return updated count

func UpdateAt

func UpdateAt(field string, value any, rUpdate io.Reader, one bool) (int, error)

func UpdateMongoClient

func UpdateMongoClient(ip string, port int)

func UpsertOneAt

func UpsertOneAt(field string, value any, rData io.Reader) (any, []byte, error)

if inserted, return id, inserted data if replaced, return count, after replacing data

func UseDbCol

func UseDbCol(dbName, colName string)