dao

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 1, 2025 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var App = NewAppDao()
View Source 
var Audio = NewAudioDao()
View Source 
var Chat = NewChatDao()
View Source 
var Corp = NewCorpDao()
View Source 
var Image = NewImageDao()
View Source 
var Key = NewKeyDao()
View Source 
var Midjourney = NewMidjourneyDao()
View Source 
var Model = NewModelDao()
View Source 
var ModelAgent = NewModelAgentDao()
View Source 
var SysConfig = NewSysConfigDao()
View Source 
var User = NewUserDao()

Functions

func Aggregate 

func Aggregate(ctx context.Context, database, collection string, pipeline []bson.M, result interface{}) error

func AggregateByPage 

func AggregateByPage(ctx context.Context, database, collection, countField string, paging *db.Paging, countPipeline, pipeline []bson.M, result interface{}) error

func CountDocuments 

func CountDocuments(ctx context.Context, database, collection string, filter map[string]interface{}) (int64, error)

func DeleteById 

func DeleteById(ctx context.Context, database, collection string, id interface{}) error

func DeleteMany 

func DeleteMany(ctx context.Context, database, collection string, filter map[string]interface{}) (int64, error)

func DeleteOne 

func DeleteOne(ctx context.Context, database, collection string, filter map[string]interface{}) (int64, error)

func EstimatedDocumentCount 

func EstimatedDocumentCount(ctx context.Context, database, collection string) (int64, error)

func Find 

func Find(ctx context.Context, database, collection string, filter map[string]interface{}, result interface{}, sortFields ...string) error

func FindById 

func FindById(ctx context.Context, database, collection string, id, result interface{}) error

func FindByIds 

func FindByIds(ctx context.Context, database, collection string, ids, result interface{}) error

func FindByPage 

func FindByPage(ctx context.Context, database, collection string, paging *db.Paging, filter map[string]interface{}, result interface{}, sortFields ...string) error

func FindOne 

func FindOne(ctx context.Context, database, collection string, filter map[string]interface{}, result interface{}, sortFields ...string) error

func Insert 

func Insert(ctx context.Context, database string, document interface{}) (string, error)

func Inserts 

func Inserts(ctx context.Context, database string, documents []interface{}) ([]string, error)

func UpdateById 

func UpdateById(ctx context.Context, database, collection string, id, update interface{}, isUpsert ...bool) error

func UpdateMany 

func UpdateMany(ctx context.Context, database, collection string, filter map[string]interface{}, update interface{}, isUpsert ...bool) error

func UpdateOne 

func UpdateOne(ctx context.Context, database, collection string, filter map[string]interface{}, update interface{}, isUpsert ...bool) error

Types

type AppDao 

type AppDao struct {
	*MongoDB[entity.App]
}

func NewAppDao 

func NewAppDao(database ...string) *AppDao

type AudioDao added in v0.5.0 

type AudioDao struct {
	*MongoDB[entity.Audio]
}

func NewAudioDao added in v0.5.0 

func NewAudioDao(database ...string) *AudioDao

type ChatDao 

type ChatDao struct {
	*MongoDB[entity.Chat]
}

func NewChatDao 

func NewChatDao(database ...string) *ChatDao

type CorpDao added in v0.3.0 

type CorpDao struct {
	*MongoDB[entity.Corp]
}

func NewCorpDao added in v0.3.0 

func NewCorpDao(database ...string) *CorpDao

type IMongoDB 

type IMongoDB interface{}

type ImageDao added in v0.4.0 

type ImageDao struct {
	*MongoDB[entity.Image]
}

func NewImageDao added in v0.4.0 

func NewImageDao(database ...string) *ImageDao

type KeyDao 

type KeyDao struct {
	*MongoDB[entity.Key]
}

func NewKeyDao 

func NewKeyDao(database ...string) *KeyDao

type MidjourneyDao added in v0.4.0 

type MidjourneyDao struct {
	*MongoDB[entity.Midjourney]
}

func NewMidjourneyDao added in v0.4.0 

func NewMidjourneyDao(database ...string) *MidjourneyDao

type ModelAgentDao 

type ModelAgentDao struct {
	*MongoDB[entity.ModelAgent]
}

func NewModelAgentDao 

func NewModelAgentDao(database ...string) *ModelAgentDao

type ModelDao 

type ModelDao struct {
	*MongoDB[entity.Model]
}

func NewModelDao 

func NewModelDao(database ...string) *ModelDao

type MongoDB 

type MongoDB[T IMongoDB] struct {
	*db.MongoDB
}

func NewMongoDB 

func NewMongoDB[T IMongoDB](database, collection string) *MongoDB[T]

func (*MongoDB[T]) Aggregate 

func (m *MongoDB[T]) Aggregate(ctx context.Context, pipeline []bson.M, result interface{}) error

func (*MongoDB[T]) AggregateByPage 

func (m *MongoDB[T]) AggregateByPage(ctx context.Context, countField string, paging *db.Paging, countPipeline, pipeline []bson.M, result interface{}) error

func (*MongoDB[T]) CountDocuments 

func (m *MongoDB[T]) CountDocuments(ctx context.Context, filter map[string]interface{}) (int64, error)

func (*MongoDB[T]) DeleteById 

func (m *MongoDB[T]) DeleteById(ctx context.Context, id interface{}) error

func (*MongoDB[T]) DeleteMany 

func (m *MongoDB[T]) DeleteMany(ctx context.Context, filter map[string]interface{}) (int64, error)

func (*MongoDB[T]) DeleteOne 

func (m *MongoDB[T]) DeleteOne(ctx context.Context, filter map[string]interface{}) (int64, error)

func (*MongoDB[T]) EstimatedDocumentCount 

func (m *MongoDB[T]) EstimatedDocumentCount(ctx context.Context) (int64, error)

func (*MongoDB[T]) Find 

func (m *MongoDB[T]) Find(ctx context.Context, filter map[string]interface{}, sortFields ...string) ([]*T, error)

func (*MongoDB[T]) FindById 

func (m *MongoDB[T]) FindById(ctx context.Context, id interface{}) (*T, error)

func (*MongoDB[T]) FindByIds 

func (m *MongoDB[T]) FindByIds(ctx context.Context, ids interface{}) ([]*T, error)

func (*MongoDB[T]) FindByPage 

func (m *MongoDB[T]) FindByPage(ctx context.Context, paging *db.Paging, filter map[string]interface{}, sortFields ...string) ([]*T, error)

func (*MongoDB[T]) FindOne 

func (m *MongoDB[T]) FindOne(ctx context.Context, filter map[string]interface{}, sortFields ...string) (*T, error)

func (*MongoDB[T]) Insert 

func (m *MongoDB[T]) Insert(ctx context.Context, document interface{}) (string, error)

func (*MongoDB[T]) Inserts 

func (m *MongoDB[T]) Inserts(ctx context.Context, documents []interface{}) ([]string, error)

func (*MongoDB[T]) UpdateById 

func (m *MongoDB[T]) UpdateById(ctx context.Context, id, update interface{}, isUpsert ...bool) error

func (*MongoDB[T]) UpdateMany 

func (m *MongoDB[T]) UpdateMany(ctx context.Context, filter map[string]interface{}, update interface{}, isUpsert ...bool) error

func (*MongoDB[T]) UpdateOne 

func (m *MongoDB[T]) UpdateOne(ctx context.Context, filter map[string]interface{}, update interface{}, isUpsert ...bool) error

type SysConfigDao added in v1.3.0 

type SysConfigDao struct {
	*MongoDB[entity.SysConfig]
}

func NewSysConfigDao added in v1.3.0 

func NewSysConfigDao(database ...string) *SysConfigDao

type UserDao 

type UserDao struct {
	*MongoDB[entity.User]
}

func NewUserDao 

func NewUserDao(database ...string) *UserDao

func (*UserDao) FindUserByUserId 

func (d *UserDao) FindUserByUserId(ctx context.Context, userId int) (*entity.User, error)

根据userId查询用户

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳