Documentation ¶
Index ¶
- Variables
- type Config
- type Executer
- func (e *Executer) Close() error
- func (e *Executer) Execute(queryReader io.Reader, vars map[string]string) error
- func (e *Executer) ExecuteContext(ctx context.Context, queryReader io.Reader, vars map[string]string) error
- func (e *Executer) LastExecuteTime() time.Time
- func (e *Executer) SetExecuteHook(hook func(query string, rowsAffected, lastInsertId int64))
- func (e *Executer) SetIsSelectFunc(f func(query string) bool)
- func (e *Executer) SetSelectHook(hook func(query string, columns []string, rows [][]string))
- func (e *Executer) SetTableSelectHook(hook func(query, table string))
- func (e *Executer) SetTimeCheckQuery(query string)
- type QueryScanner
- type SSMParameterFetcher
Constants ¶
This section is empty.
Variables ¶
var DefaultSQLDumper io.Writer = io.Discard
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { DSN string User string Password string Host string Port int Database string Location string PasswordSSMParameterName string Fetcher *SSMParameterFetcher }
Config is a connection setting to MySQL. Exists to generate a Golang connection DSN to MySQL
func NewDefaultConfig ¶
func NewDefaultConfig() *Config
NewDefaultConfig returns the config for connecting to the local MySQL server
type Executer ¶
type Executer struct {
// contains filtered or unexported fields
}
Executer queries the DB. There is no parallelism
func NewWithDB ¶ added in v0.3.0
NewWithDB returns Executer with *sql.DB Note: Since it is made assuming MySQL, it may be inconvenient for other DBs.
func (*Executer) ExecuteContext ¶ added in v0.1.4
func (e *Executer) ExecuteContext(ctx context.Context, queryReader io.Reader, vars map[string]string) error
ExecuteContext SQL execute with context.Context
func (*Executer) LastExecuteTime ¶ added in v0.2.0
LastExecuteTime returns last execute time on DB
func (*Executer) SetExecuteHook ¶ added in v0.2.0
SetExecuteHook set non select query hook
func (*Executer) SetIsSelectFunc ¶ added in v0.3.0
SetIsSelectFunc :Set the function to decide whether to execute in QueryContext
func (*Executer) SetSelectHook ¶ added in v0.2.0
SetSelectHook set select query hook
func (*Executer) SetTableSelectHook ¶ added in v0.2.0
SetTimeCheckQuery set select query hook, but result is table string
func (*Executer) SetTimeCheckQuery ¶ added in v0.3.0
SetTimeCheckQuery set time check query for non mysql db
type QueryScanner ¶
QueryScanner separate string by ; and delete newline
func NewQueryScanner ¶
func NewQueryScanner(queryReader io.Reader) *QueryScanner
NewQueryScanner returns QueryScanner
type SSMParameterFetcher ¶ added in v0.4.0
type SSMParameterFetcher struct { LoadAWSDefaultConfigOptions []func(*config.LoadOptions) error // contains filtered or unexported fields }