cDB

Documentation

Index

• Constants
• func Connection(name string) *gorm.DB
• func InjectConf(conf interface{})
• func Load()
• func WithConnectionModel(ctx *gin.Context, model ModelInterface, driver string) *gorm.DB
• func WithContextModel(ctx *gin.Context, model ModelInterface) *gorm.DB
• type ConnectorInterface
• type DatabaseConf
  • func GetDatabaseConf() *DatabaseConf
  • func (i *DatabaseConf) ConfigName() string
• type DatabaseConfDriverInterface
• type DatabaseConf_MySql
  • func (i *DatabaseConf_MySql) GetDriver() string
• type DatabaseConf_MySql_HealthCheck
• type DatabaseConf_MySql_Pool
• 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)
  • func (c *DbContainer) SetDebug(name string, isDebug bool)
• type ModelInterface
• type MysqlConnector
  • func (i *MysqlConnector) Connect(conf DatabaseConfDriverInterface) *gorm.DB

Constants

const (
	DB_DRIVER_MYSQL string = "mysql"
)

Functions

func Connection

func Connection(name string) *gorm.DB

func InjectConf

func InjectConf(conf interface{})

func Load

func Load()

func WithConnectionModel

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

func WithContextModel

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

Types

type ConnectorInterface

type ConnectorInterface interface {
	Connect(DatabaseConfDriverInterface) *gorm.DB
}

type DatabaseConf

type DatabaseConf struct {
	MysqlConnections map[string]*DatabaseConf_MySql `json:"mysql_connections"`
}

func GetDatabaseConf

func GetDatabaseConf() *DatabaseConf

func (*DatabaseConf) ConfigName

func (i *DatabaseConf) ConfigName() string

type DatabaseConfDriverInterface

type DatabaseConfDriverInterface interface {
	GetDriver() string
}

type DatabaseConf_MySql

type DatabaseConf_MySql struct {
	Driver      string                          `json:"driver"`
	Host        string                          `json:"host"`
	Port        int                             `json:"port"`
	Database    string                          `json:"database"`
	Username    string                          `json:"username"`
	Password    string                          `json:"password"`
	Charset     string                          `json:"charset"`
	Collation   string                          `json:"collation"`
	Prefix      string                          `json:"prefix"`
	Debug       bool                            `json:"debug"`
	Pool        *DatabaseConf_MySql_Pool        `json:"pool"`
	HealthCheck *DatabaseConf_MySql_HealthCheck `json:"health_check"`
}

func (*DatabaseConf_MySql) GetDriver

func (i *DatabaseConf_MySql) GetDriver() string

type DatabaseConf_MySql_HealthCheck

type DatabaseConf_MySql_HealthCheck struct {
	TableName string `json:"table_name"`
	Key       string `json:"key"`
}

type DatabaseConf_MySql_Pool

type DatabaseConf_MySql_Pool struct {
	MaxIdleConnections int `json:"max_idle_connections"`
	//MinConnections     int `json:"min_connections"`
	MaxConnections int `json:"max_connections"`
	ConnectTimeout int `json:"connect_timeout"`
	//WaitTimeout        int `json:"wait_timeout"`
	//Heartbeat          int `json:"heartbeat"`
	MaxIdleTime int `json:"max_idle_time"`
}

type DbContainer

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

func (*DbContainer) GetConnection

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

func (*DbContainer) SaveConnection

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

func (*DbContainer) SaveDriver

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

func (*DbContainer) SetDebug

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

type ModelInterface

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

type MysqlConnector

type MysqlConnector struct{}

func (*MysqlConnector) Connect

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