cDB

Documentation

Index

• Constants
• Variables
• func AddConnection(ctx *gin.Context, name string, connection drivers.DriverInterface) error
• func Client[T DBClient](ctx *gin.Context, name string) T
• func WithContextModel(ctx *gin.Context, model ModelInterface) *gorm.DB
• func WithQueryModel(ctx *gin.Context, model ModelInterface) drivers.GormQueryInterface
• type DBClient
• type DBComponent
  • func (i *DBComponent) Inject(instance any) bool
  • func (i *DBComponent) InjectConf(config cComponents.ConfigInterface) bool
  • func (i *DBComponent) Listen() []*cComponents.ConfigListener
  • func (i *DBComponent) Load()
• type DBContainer
  • func (i *DBContainer) Get(name string) any
  • func (i *DBContainer) GetConnector(name string) drivers.ConnectorInterface
  • func (i *DBContainer) Is(instance any) bool
  • func (i *DBContainer) Range(f func(instance any))
  • func (i *DBContainer) Remove(name string) bool
  • func (i *DBContainer) Save(instance any) bool
• type DatabaseConf
  • func (i *DatabaseConf) ConfigName() string
  • func (i *DatabaseConf) Decode(data string) error
• type ModelInterface

Constants

const (
	DatabaseConfigName = "DatabaseConf"
)

Variables

var Component = &DBComponent{}

Functions

func AddConnection

func AddConnection(ctx *gin.Context, name string, connection drivers.DriverInterface) error

func Client

func Client[T DBClient](ctx *gin.Context, name string) T

func WithContextModel

func WithContextModel(ctx *gin.Context, model ModelInterface) *gorm.DB

WithContextModel 仅用于 gorm

func WithQueryModel

func WithQueryModel(ctx *gin.Context, model ModelInterface) drivers.GormQueryInterface

Types

type DBClient

type DBClient interface {
	*gorm.DB | *redis.Client | *mgo.Database
}

type DBComponent

type DBComponent struct{}

func (*DBComponent) Inject

func (i *DBComponent) Inject(instance any) bool

func (*DBComponent) InjectConf

func (i *DBComponent) InjectConf(config cComponents.ConfigInterface) bool

func (*DBComponent) Listen

func (i *DBComponent) Listen() []*cComponents.ConfigListener

func (*DBComponent) Load

func (i *DBComponent) Load()

type DBContainer

type DBContainer struct {
	// contains filtered or unexported fields
}

func (*DBContainer) Get

func (i *DBContainer) Get(name string) any

func (*DBContainer) GetConnector

func (i *DBContainer) GetConnector(name string) drivers.ConnectorInterface

func (*DBContainer) Is

func (i *DBContainer) Is(instance any) bool

func (*DBContainer) Range

func (i *DBContainer) Range(f func(instance any))

func (*DBContainer) Remove

func (i *DBContainer) Remove(name string) bool

func (*DBContainer) Save

func (i *DBContainer) Save(instance any) bool

type DatabaseConf

type DatabaseConf struct {
	Connections map[string]drivers.DriverInterface `json:"connections"`
}

func (*DatabaseConf) ConfigName

func (i *DatabaseConf) ConfigName() string

func (*DatabaseConf) Decode

func (i *DatabaseConf) Decode(data string) error

type ModelInterface

type ModelInterface interface {
	Connection(ctx *gin.Context) string
}