cDB

Feb 6, 2025

Changes in this version

type Model

+ func (i Model[T]) Truncate(ctx *gin.Context) (err error)

Dec 23, 2024

Changes in this version

+ type GormBuilder struct

+ Conditions map[string]any

+ GroupBy string

+ OrderBy string

+ Page int64

+ Size int64

type Model

+ func (i Model[T]) GetByBuilder(ctx *gin.Context, builder GormBuilder) (result []T, err error)

+ func (i Model[T]) ListByBuilder(ctx *gin.Context, builder GormBuilder) (result []T, err error)

Dec 11, 2024

Changes in this version

+ func StartTransactionWithModel(ctx *gin.Context, model ModelInterface, ...) error

type Model

+ func (i Model[T]) StartTransaction(ctx *gin.Context, f func(ctx *gin.Context, tx *gorm.DB) (err error)) (err error)

Dec 6, 2024

Changes in this version

type Model

+ func (i Model[T]) CreateOrIgnore(ctx *gin.Context, data T, fields []string) (err error)

+ func (i Model[T]) InsertOrIgnore(ctx *gin.Context, data []T, fields []string) (err error)

+ func (i Model[T]) InsertOrUpdate(ctx *gin.Context, data []T, fields []string) (err error)

Dec 6, 2024

Changes in this version

+ type Model struct

+ func (i Model[T]) CountByConditions(ctx *gin.Context, conditions map[string]any) (total int64, err error)

+ func (i Model[T]) Create(ctx *gin.Context, data T) (err error)

+ func (i Model[T]) DeleteByConditions(ctx *gin.Context, conditions map[string]any) (err error)

+ func (i Model[T]) FindByConditions(ctx *gin.Context, conditions map[string]any) (result T, err error)

+ func (i Model[T]) FirstOrCreate(ctx *gin.Context, data T, conditions map[string]any) (created int64, err error)

+ func (i Model[T]) GetByConditions(ctx *gin.Context, conditions map[string]any) (result []T, err error)

+ func (i Model[T]) Insert(ctx *gin.Context, data []T) (err error)

+ func (i Model[T]) ListByConditions(ctx *gin.Context, conditions map[string]any, page, size int64, order string) (result []T, err error)

+ func (i Model[T]) Save(ctx *gin.Context, data T) (err error)

+ func (i Model[T]) UpdateByConditions(ctx *gin.Context, conditions map[string]any, fields map[string]any) (err error)

+ func (i Model[T]) UpdateOrCreate(ctx *gin.Context, data T, fields []string) (err error)

type ModelInterface

+ TableName func() string

Nov 22, 2024

Changes in this version

+ const Context_GormDBTransaction

+ func StartTransaction(ctx *gin.Context, name string, f func(ctx *gin.Context, tx *gorm.DB) error) error

Jul 30, 2024

Changes in this version

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

Mar 25, 2024

Changes in this version

+ type DBClient interface

type DatabaseConf

+ Connections map[string]drivers.DriverInterface

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

Mar 8, 2024

Changes in this version

+ type Client interface

Mar 6, 2024

Changes in this version

type DatabaseConf_Clickhouse

+ DialTimeout int64

Mar 6, 2024

Changes in this version

+ type ClickhouseConnector struct

+ func NewClickhouseConnector(connection string, config *DatabaseConf_Clickhouse) (*ClickhouseConnector, error)

+ func (i *ClickhouseConnector) Connect() error

+ func (i *ClickhouseConnector) GetConnection() string

+ func (i *ClickhouseConnector) GetDB() *gorm.DB

+ func (i *ClickhouseConnector) GetDriver() DriverInterface

type DBDriver

+ const ClickhouseDriver

type DatabaseConf

+ ClickhouseConnections map[string]*DatabaseConf_Clickhouse

+ type DatabaseConf_Clickhouse struct

+ Database string

+ Debug bool

+ Driver DBDriver

+ Host string

+ Password string

+ Pool *DatabaseConf_Clickhouse_Pool

+ Port int

+ ReadTimeout int64

+ Username string

+ WriteTimeout int64

+ func (i *DatabaseConf_Clickhouse) DriverName() DBDriver

+ func (i *DatabaseConf_Clickhouse) IsDebug() bool

+ type DatabaseConf_Clickhouse_Pool struct

+ ConnectTimeout int

+ MaxConnections int

+ MaxIdleConnections int

+ MaxIdleTime int

Mar 5, 2024

Changes in this version

+ func GetConnectionWithModel(ctx *gin.Context, model ModelInterface) (*gorm.DB, error)

Feb 23, 2024

Changes in this version

+ func GetConnection(ctx *gin.Context, name string) (*gorm.DB, error)

Feb 22, 2024

Changes in this version

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

type ConnectorInterface

+ GetConnection func() string

+ GetDB func() *gorm.DB

+ GetDriver func() DriverInterface

type DBComponent

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

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

+ type DBContainer struct

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

+ func (i *DBContainer) GetConnector(name string) 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 DBDriver string

+ const DatabaseConfigName

+ const MysqlDriver

+ const SqliteDriver

type DatabaseConf

+ SqliteConnections map[string]*DatabaseConf_Sqlite

type DatabaseConf_MySql

+ func (i *DatabaseConf_MySql) DriverName() DBDriver

+ func (i *DatabaseConf_MySql) IsDebug() bool

+ type DatabaseConf_Sqlite struct

+ Debug bool

+ Driver DBDriver

+ File string

+ func (i *DatabaseConf_Sqlite) DriverName() DBDriver

+ func (i *DatabaseConf_Sqlite) IsDebug() bool

+ type DriverInterface interface

+ DriverName func() DBDriver

+ IsDebug func() bool

type MysqlConnector

+ func NewMysqlConnector(connection string, config *DatabaseConf_MySql) (*MysqlConnector, error)

+ func (i *MysqlConnector) GetConnection() string

+ func (i *MysqlConnector) GetDB() *gorm.DB

+ func (i *MysqlConnector) GetDriver() DriverInterface

+ type QueryDB struct

+ func WithQueryModel(ctx *gin.Context, model ModelInterface) *QueryDB

+ func (i *QueryDB) Paginate(page, size int) *QueryDB

+ func (i *QueryDB) Query() *gorm.DB

+ func (i *QueryDB) SetQuery(query *gorm.DB)

+ type SqliteConnector struct

+ func NewSqliteConnector(connection string, config *DatabaseConf_Sqlite) (*SqliteConnector, error)

+ func (i *SqliteConnector) Connect() error

+ func (i *SqliteConnector) GetConnection() string

+ func (i *SqliteConnector) GetDB() *gorm.DB

+ func (i *SqliteConnector) GetDriver() DriverInterface

Feb 4, 2024

Changes in this version

type DatabaseConf

+ func GetConf() *DatabaseConf

Feb 4, 2024

Changes in this version

+ const ConfigName

+ var Component = &DBComponent

+ func ListenConf(instance any)

+ type DBComponent struct

+ func (c *DBComponent) Inject(instance any)

+ func (c *DBComponent) ListenConf() map[string]cComponents.ListenConfigFunc

+ func (c *DBComponent) Load()

Dec 14, 2023

Changes in this version

+ func Connection(name string) *gorm.DB

+ func InjectConf(conf interface{})

+ func InjectDriver(name string, driver DatabaseConfDriverInterface)

+ func WithConnectionModel(ctx *gin.Context, model ModelInterface, driver string) *gorm.DB

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

type DatabaseConf

+ MysqlConnections map[string]*DatabaseConf_MySql

+ func GetDatabaseConf() *DatabaseConf

type DbContainer

+ func (c *DbContainer) GetConnection(name string) *gorm.DB

+ func (c *DbContainer) SaveConnection(name string, instance *gorm.DB)

+ func (c *DbContainer) SaveDriver(name string, instance DatabaseConfDriverInterface)

Aug 11, 2022

Changes in this version

+ const DB_DRIVER_MYSQL

+ func Load()

+ func Query(model ModelInterface) *gorm.DB

+ type ConnectorInterface interface

+ Connect func(DatabaseConfDriverInterface) *gorm.DB

+ type DatabaseConf map[string]DatabaseConfDriverInterface

+ func (i *DatabaseConf) ConfigName() string

+ type DatabaseConfDriverInterface interface

+ GetDriver func() string

+ type DatabaseConf_MySql struct

+ Charset string

+ Collation string

+ Database string

+ Debug bool

+ Driver string

+ HealthCheck *DatabaseConf_MySql_HealthCheck

+ Host string

+ Password string

+ Pool *DatabaseConf_MySql_Pool

+ Port int

+ Prefix string

+ Username string

+ func (i *DatabaseConf_MySql) GetDriver() string

+ type DatabaseConf_MySql_HealthCheck struct

+ Key string

+ TableName string

+ type DatabaseConf_MySql_Pool struct

+ ConnectTimeout int

+ MaxConnections int

+ MaxIdleConnections int

+ MaxIdleTime int

+ type DbContainer struct

+ Connections map[string]*gorm.DB

+ Debug map[string]bool

+ Lock *sync.Mutex

+ func (c *DbContainer) Get(name string) *gorm.DB

+ func (c *DbContainer) Save(name string, instance *gorm.DB)

+ func (c *DbContainer) SetDebug(name string, isDebug bool)

+ type ModelInterface interface

+ Connection func() string

+ type MysqlConnector struct

+ func (i *MysqlConnector) Connect(conf DatabaseConfDriverInterface) *gorm.DB