mysql

Apr 3, 2021

Changes in this version

+ type Database interface

+ GetInstance func() *gorm.DB

+ func Connect(conf *Config) (Database, error)

Sep 23, 2020

Changes in this version

+ func Resolver() *dbresolver.DBResolver

+ func ResolverConfig(item ResolverItem) dbresolver.Config

type Config

+ Dsn string

+ type Manager struct

+ func NewManager(conf *Config) *Manager

+ func (db *Manager) Connect() error

+ type ResolverItem struct

+ Replicas []string

+ Sources []string

+ Tables []string

Jul 15, 2020

Changes in this version

+ const ColumnCreatedAt

+ const ColumnUpdatedAt

+ func RegisterCreateCallback(db *gorm.DB)

+ func RegisterUpdateCallback(db *gorm.DB)

+ type Columns map[string]interface

+ type Dao struct

+ DB *gorm.DB

+ func (dao *Dao) Create(entity interface{}) error

+ func (dao *Dao) GetByPrimaryKey(id int, entity interface{}) error

+ func (dao *Dao) Update(entity interface{}) error

Jun 13, 2020

Changes in this version

+ type Config struct

+ DataSources []DataSource

+ MaxIdleConnections int

+ MaxLifeTime int

+ MaxOpenConnections int

+ TablePrefix string

+ func (conf Config) DsnItems() []string

+ type DataSource struct

+ Host string

+ Name string

+ Password string

+ Port int

+ User string

+ type GroupManager struct

+ func New(options map[string]Config) *GroupManager

+ func (gm *GroupManager) Connect() error

+ func (gm *GroupManager) GetConnection(name string) *gorm.DB

Jun 9, 2020

Changes in this version

type Model

+ Id int

May 27, 2020

Changes in this version

+ type ReadWriteAdapter struct

+ func NewReadWriteAdapter(dialectType string, dataSourceNames []string) (*ReadWriteAdapter, error)

+ func (adapter ReadWriteAdapter) Begin() (*sql.Tx, error)

+ func (adapter ReadWriteAdapter) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ func (adapter ReadWriteAdapter) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (adapter ReadWriteAdapter) Master() *sql.DB

+ func (adapter ReadWriteAdapter) Ping() error

+ func (adapter ReadWriteAdapter) Prepare(query string) (*sql.Stmt, error)

+ func (adapter ReadWriteAdapter) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (adapter ReadWriteAdapter) QueryRow(query string, args ...interface{}) *sql.Row

+ func (adapter ReadWriteAdapter) SetConnMaxLifetime(d time.Duration)

+ func (adapter ReadWriteAdapter) SetMaxIdleConns(n int)

+ func (adapter ReadWriteAdapter) SetMaxOpenConns(n int)

+ func (adapter ReadWriteAdapter) Slave() *sql.DB

Jan 9, 2020

Changes in this version

+ type Model struct

+ CreatedAt Timestamp

+ UpdatedAt Timestamp

+ type Timestamp struct

+ func (t *Timestamp) Scan(v interface{}) error

+ func (t Timestamp) MarshalJSON() ([]byte, error)

+ func (t Timestamp) Value() (driver.Value, error)