cDB

Documentation

Index

• Constants
• func Load()
• func Query(model ModelInterface) *gorm.DB
• type ConnectorInterface
• type 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) Get(name string) *gorm.DB
  • func (c *DbContainer) Save(name string, instance *gorm.DB)
  • 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 Load

func Load()

func Query

func Query(model ModelInterface) *gorm.DB

Types

type ConnectorInterface

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

type DatabaseConf

type DatabaseConf map[string]DatabaseConfDriverInterface

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 {
	Lock        *sync.Mutex
	Connections map[string]*gorm.DB
	Debug       map[string]bool
}

func (*DbContainer) Get

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

func (*DbContainer) Save

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

func (*DbContainer) SetDebug

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

type ModelInterface

type ModelInterface interface {
	Connection() string
}

type MysqlConnector

type MysqlConnector struct{}

func (*MysqlConnector) Connect

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