mysql

Apr 27, 2023

Changes in this version

+ func BuildNamedColumnsValuesBatch(req interface{}) map[string]interface

+ func BuildNamedInsertSql(table string, cols []string, batch int) string

+ func JoinNamedColumnsValuesBatch(cols []string, batch int) string

+ func TransferToNamedColumnsValuesBatch(req []map[string]interface{}) map[string]interface

Dec 23, 2021

Changes in this version

type DBOption

+ func WithInterpolateParams(enabled bool) DBOption

type Mysql

+ InterpolateParams bool

+ func (x *Mysql) GetInterpolateParams() bool

Dec 21, 2021

Changes in this version

+ func ConditionWithEqualAnd(condFields ...string) string

+ func InCondition(cond string, values ...string) string

+ func NonzeroCondition(cmp SqlCompare, oper SqlOperator, arg interface{}) string

+ func NonzeroFields(arg interface{}) []string

+ func OrderCondition(orders map[string]bool) string

+ func SelectNamedContext(ctx context.Context, query string, arg interface{}, dest interface{}, ...) (err error)

Dec 7, 2021

Changes in this version

+ func GetContext(ctx context.Context, query string, arg interface{}, db *sqlx.DB, ...) (err error)

+ func GetCountContext(ctx context.Context, query string, arg interface{}, db *sqlx.DB) (count uint32, err error)

+ func NamedExecContext(ctx context.Context, query string, arg interface{}, tx *sqlx.Tx, db *sqlx.DB) (sql.Result, error)

+ func PrepareNamedContext(ctx context.Context, query string, tx *sqlx.Tx, db *sqlx.DB) (*sqlx.NamedStmt, error)

Dec 6, 2021

Changes in this version

+ func NamedInCondition(oper SqlOperator, cols []string, arg interface{}) (string, error)

type SqlCompare

+ const SqlCompareIn

Nov 27, 2021

Changes in this version

+ func GenerateInCondition(cond string, values ...string) string

+ func TxPipelined(ctx context.Context, db *sqlx.DB, fn func(*sqlx.Tx) error) (err error)

Nov 8, 2021

Changes in this version

+ func GenerateNonzeroFields(arg interface{}) []string

Oct 21, 2021

Changes in this version

type DB

+ func (d *DB) TxPipelined(ctx context.Context, fn func() error) error

+ type TxDao struct

+ func (d *TxDao) Begin(ctx context.Context, db *sqlx.DB, opts *sql.TxOptions) error

+ func (d *TxDao) Commit() error

+ func (d *TxDao) Rollback() error

Sep 25, 2021

Changes in this version

+ func ExecContext(ctx context.Context, timeout time.Duration, db *sqlx.DB, query string, ...) error

Sep 11, 2021

Changes in this version

+ func GenerateCondition(cmp SqlCompare, oper SqlOperator, query string, arg interface{}) string

+ func GenerateNameColumsCondition(cmp SqlCompare, oper SqlOperator, condFields ...string) string

+ func JoinNamedColumnsValues(cols ...string) string

+ func JoinNamedColumnsValuesWithOperator(cmp SqlCompare, oper SqlOperator, cols ...string) string

+ type SqlCompare string

+ const SqlCompareEqual

+ const SqlCompareGreatEqual

+ const SqlCompareGreater

+ const SqlCompareLessEqual

+ const SqlCompareLessThan

+ const SqlCompareLike

+ const SqlCompareNotEqual

+ type SqlOperator string

+ const SqlOperatorAnd

+ const SqlOperatorNot

+ const SqlOperatorOr

Sep 1, 2021

Changes in this version

+ var File_pkg_database_mysql_mysql_proto protoreflect.FileDescriptor

+ type CompletedConfig struct

+ func (c CompletedConfig) New() (*sqlx.DB, error)

+ type Config struct

+ Proto Mysql

+ func NewConfig(options ...ConfigOption) *Config

+ func (c *Config) Complete() CompletedConfig

+ func (o *Config) ApplyOptions(options ...ConfigOption) *Config

+ type ConfigOption interface

+ func WithViper(v *viper.Viper) ConfigOption

+ type ConfigOptionFunc func(*Config)

type DBOption

+ func WithConnMaxLifetime(connMaxLifetime time.Duration) DBOption

+ func WithDialTimeout(dialTimeout time.Duration) DBOption

+ func WithMaxConnections(maxConns int) DBOption

+ func WithMaxIdleConnections(maxIdleConns int) DBOption

+ func WithReadTimeout(readTimeout time.Duration) DBOption

+ func WithWriteTimeout(writeTimeout time.Duration) DBOption

+ type EmptyConfigOption struct

+ type Mysql struct

+ Address string

+ DbName string

+ DialTimeout *duration.Duration

+ Enabled bool

+ FailAfterDuration *duration.Duration

+ MaxConnections int32

+ MaxIdleConnections int32

+ MaxLifeTime *duration.Duration

+ MaxWaitDuration *duration.Duration

+ Password string

+ ReadTimeout *duration.Duration

+ Username string

+ WriteTimeout *duration.Duration

+ func (*Mysql) Descriptor() ([]byte, []int)

+ func (*Mysql) ProtoMessage()

+ func (x *Mysql) GetAddress() string

+ func (x *Mysql) GetDbName() string

+ func (x *Mysql) GetDialTimeout() *duration.Duration

+ func (x *Mysql) GetEnabled() bool

+ func (x *Mysql) GetFailAfterDuration() *duration.Duration

+ func (x *Mysql) GetMaxConnections() int32

+ func (x *Mysql) GetMaxIdleConnections() int32

+ func (x *Mysql) GetMaxLifeTime() *duration.Duration

+ func (x *Mysql) GetMaxWaitDuration() *duration.Duration

+ func (x *Mysql) GetPassword() string

+ func (x *Mysql) GetReadTimeout() *duration.Duration

+ func (x *Mysql) GetUsername() string

+ func (x *Mysql) GetWriteTimeout() *duration.Duration

+ func (x *Mysql) ProtoReflect() protoreflect.Message

+ func (x *Mysql) Reset()

+ func (x *Mysql) String() string

Jul 14, 2021

Changes in this version

+ const DefaultMaxConns

+ const DefaultMaxIdleConns

+ func CloseDB() error

+ func CloseTheDB(conf DBConfig) error

+ func GetDB() *sqlx.DB

+ func GetTheDB(conf DBConfig) (*sqlx.DB, error)

type DB

+ func (d *DB) Close() error

+ type SQLDB atomic.Value

+ func (m *SQLDB) Load() *sqlx.DB

+ func (m *SQLDB) Store(value *sqlx.DB)

Jun 9, 2021

Changes in this version

+ type DB struct

+ Conf DBConfig

+ func NewDB(conf DBConfig, opts ...DBOption) (*DB, error)

+ func (d *DB) GetDatabase() (*sqlx.DB, error)

+ func (d *DB) GetDatabaseUntil(maxWaitInterval time.Duration, failAfter time.Duration) (*sqlx.DB, error)

+ func (o *DB) ApplyOptions(options ...DBOption) *DB

+ type DBConfig struct

+ Address string

+ DataName string

+ DriverName string

+ Password string

+ UserName string

+ type DBOption interface

+ type DBOptionFunc func(*DB)

+ type EmptyDBOption struct