mongohelper

Documentation

Index

• Variables
• func CvtA[T any](a any) ([]T, error)
• func CvtM[T any](m any) (map[string]T, error)
• func Delete[T any](rFilter io.Reader) (int, []*T, error)
• func DeleteOne[T any](rFilter io.Reader) (int, *T, error)
• func Find[T any](rFilter io.Reader) (rt []*T, err error)
• func FindOne[T any](rFilter io.Reader) (*T, error)
• func Insert(rData io.Reader) (any, []byte, error)
• func ReplaceOne(rFilter, rData io.Reader) (any, []byte, error)
• func Update(rFilter, rUpdate io.Reader, one bool) (int, error)
• func UpdateMongoClient(ip string, port int)
• func Upsert(rData io.Reader, idField string, idValue any) (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 must be primitive.A type

func CvtM

func CvtM[T any](m any) (map[string]T, error)

m must be primitive.M type

func Delete

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

return deleted count, original objects

func DeleteOne

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

return deleted count, original object

func Find

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

return found objects

func FindOne

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

return found object, if not found, return nil

func Insert

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

return inserted id(s), inserted data

func ReplaceOne

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

return replaced count, after replacing data

func Update

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

return updated count

func UpdateMongoClient

func UpdateMongoClient(ip string, port int)

func Upsert

func Upsert(rData io.Reader, idField string, idValue any) (any, []byte, error)

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

func UseDbCol

func UseDbCol(dbName, colName string)