Versions in this module Expand all Collapse all v1 v1.1.0 Nov 12, 2023 Changes in this version + var Robot = NewRobotDao() + var User = NewUserDao() + var Vip = NewVipDao() + func Aggregate(ctx context.Context, database, collection string, pipeline []bson.M, ...) error + func AggregateByPage(ctx context.Context, database, collection, countField string, ...) error + func CountDocuments(ctx context.Context, database, collection string, ...) (int64, error) + func DeleteById(ctx context.Context, database, collection string, id interface{}) error + func DeleteMany(ctx context.Context, database, collection string, ...) (int64, error) + func DeleteOne(ctx context.Context, database, collection string, ...) (int64, error) + func Find(ctx context.Context, database, collection string, ...) error + func FindById(ctx context.Context, database, collection string, id, result interface{}) error + func FindByIds(ctx context.Context, database, collection string, ids, result interface{}) error + func FindByPage(ctx context.Context, database, collection string, paging *db.Paging, ...) error + func FindOne(ctx context.Context, database, collection string, ...) error + func Insert(ctx context.Context, database string, document interface{}) (string, error) + func Inserts(ctx context.Context, database string, documents []interface{}) ([]string, error) + func UpdateById(ctx context.Context, database, collection string, id, update interface{}, ...) error + func UpdateMany(ctx context.Context, database, collection string, ...) error + func UpdateOne(ctx context.Context, database, collection string, ...) error + type IMongoDB interface + type MongoDB struct + func NewMongoDB[T IMongoDB](database, collection string) *MongoDB[T] + func (m *MongoDB[T]) Aggregate(ctx context.Context, pipeline []bson.M, result interface{}) error + func (m *MongoDB[T]) AggregateByPage(ctx context.Context, countField string, paging *db.Paging, ...) error + func (m *MongoDB[T]) CountDocuments(ctx context.Context, filter map[string]interface{}) (int64, error) + func (m *MongoDB[T]) DeleteById(ctx context.Context, id interface{}) error + func (m *MongoDB[T]) DeleteMany(ctx context.Context, filter map[string]interface{}) (int64, error) + func (m *MongoDB[T]) DeleteOne(ctx context.Context, filter map[string]interface{}) (int64, error) + func (m *MongoDB[T]) Find(ctx context.Context, filter map[string]interface{}, sortFields ...string) ([]*T, error) + func (m *MongoDB[T]) FindById(ctx context.Context, id interface{}) (*T, error) + func (m *MongoDB[T]) FindByIds(ctx context.Context, ids interface{}) ([]*T, error) + func (m *MongoDB[T]) FindByPage(ctx context.Context, paging *db.Paging, filter map[string]interface{}, ...) ([]*T, error) + func (m *MongoDB[T]) FindOne(ctx context.Context, filter map[string]interface{}, sortFields ...string) (*T, error) + func (m *MongoDB[T]) Insert(ctx context.Context, document interface{}) (string, error) + func (m *MongoDB[T]) Inserts(ctx context.Context, documents []interface{}) ([]string, error) + func (m *MongoDB[T]) UpdateById(ctx context.Context, id, update interface{}, isUpsert ...bool) error + func (m *MongoDB[T]) UpdateMany(ctx context.Context, filter map[string]interface{}, update interface{}, ...) error + func (m *MongoDB[T]) UpdateOne(ctx context.Context, filter map[string]interface{}, update interface{}, ...) error + type RobotDao struct + func NewRobotDao(database ...string) *RobotDao + func (d *RobotDao) GetLoginRobot(ctx context.Context) (*entity.Robot, error) + func (d *RobotDao) GetRobotByUserId(ctx context.Context, userId int) (*entity.Robot, error) + func (d *RobotDao) GetRobotList(ctx context.Context, userIds ...int) ([]*entity.Robot, error) + func (d *RobotDao) GetRobotUserList(ctx context.Context) ([]*entity.User, error) + type UserDao struct + func NewUserDao(database ...string) *UserDao + func (d *UserDao) FindUserByUserId(ctx context.Context, userId int) (*entity.User, error) + func (d *UserDao) FindUserListByUserIds(ctx context.Context, userIds []int) ([]*entity.User, error) + type VipDao struct + func NewVipDao(database ...string) *VipDao
Go to main page