db

Jul 18, 2020

Changes in this version

+ const DriverMySQL

+ const DriverPostgres

+ func MigrateMultiSet(connStr, driver string, dir MigrateDir, sets ...Migrations) (int, error)

+ func MigrateSet(connStr, driver string, dir MigrateDir, set Migrations) (int, error)

type ErrInvalidOrder

+ func (e ErrInvalidOrder) Error() string

type ErrTooBigPage

+ func (e ErrTooBigPage) Error() string

+ type Migrations struct

+ Assets migrate.MigrationSource

+ EnablePatchMode bool

+ IgnoreUnknown bool

+ Schema string

+ Table string

+ type MigrationsExecutor struct

+ func NewExecutor(connStr, driver string) (*MigrationsExecutor, error)

+ func (executor *MigrationsExecutor) Migrate(dir MigrateDir) (int, error)

+ func (executor *MigrationsExecutor) SetMigrations(set Migrations) *MigrationsExecutor

+ type SecureConfig struct

+ AutoMigrate bool

+ Driver string

+ Host string

+ InitTimeout int

+ MySQLParams string

+ Name string

+ Params *ConnectionParams

+ Password noble.Secret

+ Port int

+ SSL bool

+ User noble.Secret

+ WaitForDB bool

+ func (d SecureConfig) Config() Config

+ func (d SecureConfig) ConnectionString() string

+ func (d SecureConfig) Validate() error

Apr 28, 2020

Changes in this version

+ type Count struct

+ Count int64

type PageQuery

+ OrderBy string

+ func (pq *PageQuery) ApplyByOrderColumn(query sq.SelectBuilder) sq.SelectBuilder

type Table

+ Columns string

+ func NewTable(table, alias, columns string) Table

+ func (t *Table) CountQuery() (string, []interface{}, error)

+ func (t *Table) GetCount(sqlConn *SQLConn) (int64, error)

+ func (t *Table) SelectWithCount(sqlConn *SQLConn, dest interface{}, orderColumn string, query *PageQuery) (int64, error)

Nov 24, 2019

Changes in this version

type Config

+ AutoMigrate bool

+ ConnURL string

+ InitTimeout int

+ Params *ConnectionParams

+ WaitForDB bool

+ func (cfg *Config) URL() string

+ func (cfg Config) Validate() error

+ type ConnectionParams struct

+ MaxIdleConns int

+ MaxLifetime int64

+ MaxOpenConns int

type SQLConn

+ func NewConnector(cfg Config, logger *logrus.Entry) (*SQLConn, error)

+ func (conn *SQLConn) SetConnParams(params *ConnectionParams)

Sep 9, 2019

Changes in this version

type SQLConn

+ func (conn *SQLConn) InTx() bool

type Transactional

+ InTx func() bool

Aug 9, 2019

Changes in this version

+ const DefaultPageSize

+ const MaxPageSize

+ const OrderAscending

+ const OrderDescending

+ var ErrInvalidOrder = func(val string) error

+ var ErrTooBigPage = func(val uint64) error

+ func Init(dbConnStr string, logger *logrus.Entry) error

+ func Migrate(connStr string, dir MigrateDir) (int, error)

+ func SetAssets(assets migrate.AssetMigrationSource)

+ type Config struct

+ MaxIdleConns int

+ MaxLifetime int64

+ MaxOpenConns int

+ type MigrateDir string

+ const MigrateDown

+ const MigrateUp

+ type PageQuery struct

+ Order string

+ Page uint64

+ PageSize uint64

+ func ParsePageQuery(values url.Values) (pq PageQuery, err error)

+ func (pq *PageQuery) Apply(query sq.SelectBuilder, orderColumn string) sq.SelectBuilder

+ func (pq *PageQuery) FromRQuery(query url.Values) error

+ func (pq *PageQuery) Offset() uint64

+ func (pq *PageQuery) Validate() error

+ type SQLConn struct

+ func GetConnector() *SQLConn

+ func NewSQLConn(db *sqlx.DB, logger *logrus.Entry) *SQLConn

+ func (conn *SQLConn) Begin() error

+ func (conn *SQLConn) Clone() *SQLConn

+ func (conn *SQLConn) Commit() error

+ func (conn *SQLConn) Exec(sqq sq.Sqlizer) error

+ func (conn *SQLConn) ExecRaw(query string, args ...interface{}) error

+ func (conn *SQLConn) Get(sqq sq.Sqlizer, dest interface{}) error

+ func (conn *SQLConn) GetRaw(dest interface{}, query string, args ...interface{}) error

+ func (conn *SQLConn) Insert(sqq sq.InsertBuilder) (id interface{}, err error)

+ func (conn *SQLConn) IsInTx() bool

+ func (conn *SQLConn) Rollback() error

+ func (conn *SQLConn) Select(sqq sq.Sqlizer, dest interface{}) error

+ func (conn *SQLConn) SelectRaw(dest interface{}, query string, args ...interface{}) error

+ func (conn *SQLConn) SetConnMaxLifetime(d int64)

+ func (conn *SQLConn) SetMaxIdleConns(n int)

+ func (conn *SQLConn) SetMaxOpenConns(n int)

+ func (conn *SQLConn) SetTx(tx *sqlx.Tx)

+ func (conn *SQLConn) Stats() sql.DBStats

+ func (conn *SQLConn) Transaction(fn func() error) (err error)

+ type Table struct

+ Alias string

+ DB sq.BaseRunner

+ DQBuilder sq.DeleteBuilder

+ GQBuilder sq.SelectBuilder

+ IQBuilder sq.InsertBuilder

+ Name string

+ Page *PageQuery

+ QBuilder sq.SelectBuilder

+ UQBuilder sq.UpdateBuilder

+ func (t *Table) ApplyPage(orderColumn string)

+ func (t *Table) SetPage(pq *PageQuery)

+ func (t *Table) WithCount()

+ func (t Table) AliasedName() string

+ type Transactional interface

+ Begin func() error

+ Commit func() error

+ IsInTx func() bool

+ Rollback func() error

+ type WBase struct

+ Ctx context.Context

+ DB Transactional

+ Err error

+ Logger *logrus.Entry

+ func (s *WBase) DBTxRollback()

+ func (s *WBase) Recover()