mysql

Oct 6, 2021

Changes in this version

+ func CreateDatabaseIfNotExists(ctx context.Context, sql SQLRunner, database, charset, collate string) error

+ func CreateUserIfNotExists(ctx context.Context, sql SQLRunner, user, pass string, allowedHosts []string, ...) error

+ func DropDatabase(ctx context.Context, sql SQLRunner, database string) error

+ func DropUser(ctx context.Context, sql SQLRunner, user, host string) error

+ func Escape(sql string) string

+ type Config struct

+ Host string

+ Password string

+ Port int32

+ User string

+ func NewConfigFromClusterKey(c client.Client, clusterKey client.ObjectKey) (*Config, error)

+ func (c *Config) GetMysqlDSN() string

+ type Query struct

+ func BuildAtomicQuery(queries ...Query) Query

+ func ConcatenateQueries(queries ...Query) Query

+ func NewQuery(q string, args ...interface{}) Query

+ func (q *Query) Args() []interface{}

+ func (q *Query) String() string

+ type Rows interface

+ Err func() error

+ Next func() bool

+ Scan func(dest ...interface{}) error

+ type SQLRunner interface

+ QueryExec func(ctx context.Context, query Query) error

+ QueryRow func(ctx context.Context, query Query, dest ...interface{}) error

+ QueryRows func(ctx context.Context, query Query) (Rows, error)

+ func NewSQLRunner(cfg *Config, errs ...error) (SQLRunner, func(), error)

+ type SQLRunnerFactory func(cfg *Config, errs ...error) (SQLRunner, func(), error)