gomysql

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	DBHost           string
	DBPort           string
	DBUser           string
	DBPass           string
	DBName           string
	DBSSL            string
	DBTimeout        string
	DBCharset        string
	DBCollation      string
	MigrationDir     string
	MigrationsTable  string
	ParaseTime       string
	MaxOpenConns     int
	MaxIdleConns     int
	MaxOpenConnsTime time.Duration
	MaxIdleConnsTime time.Duration
	NewrelicEnabled  bool
}

type Datastore interface {
	ConnCheck() (bool, error)
	GetStats()

	Query(query string, params []interface{}) (*sql.Rows, error)
	QueryRow(query string, params []interface{}) (*sql.Row, error)
	Exec(query string, params []interface{}) (sql.Result, error)

	QueryWithContext(ctx context.Context, query string, params []interface{}) (*sql.Rows, error)
	QueryRowWithContext(ctx context.Context, query string, params []interface{}) (*sql.Row, error)
	ExecWithContext(ctx context.Context, query string, params []interface{}) (sql.Result, error)

	Prepare(query string) (*sql.Stmt, error)
	StmtQuery(stmt *sql.Stmt, params []interface{}) (*sql.Rows, error)
	StmtQueryRow(stmt *sql.Stmt, params []interface{}) *sql.Row
	StmtExec(stmt *sql.Stmt, params []interface{}) (sql.Result, error)

	PrepareWithContext(ctx context.Context, query string) (*sql.Stmt, error)
	StmtQueryWithContext(ctx context.Context, stmt *sql.Stmt, params []interface{}) (*sql.Rows, error)
	StmtQueryRowWithContext(ctx context.Context, stmt *sql.Stmt, params []interface{}) *sql.Row
	StmtExecWithContext(ctx context.Context, stmt *sql.Stmt, params []interface{}) (sql.Result, error)

	BeginTx() (*sql.Tx, error)
	TxPrepare(tx *sql.Tx, query string) (*sql.Stmt, error)
	TxQuery(tx *sql.Tx, query string, params []interface{}) (*sql.Rows, error)
	TxQueryRow(tx *sql.Tx, query string, params []interface{}) *sql.Row
	TxExec(tx *sql.Tx, query string, params []interface{}) (sql.Result, error)
	TxCommit(tx *sql.Tx) error
	TxRollback(tx *sql.Tx) error

	BeginTxWithContext(ctx context.Context) (*sql.Tx, error)
	TxPrepareWithContext(ctx context.Context, tx *sql.Tx, query string) (*sql.Stmt, error)
	TxQueryWithContext(ctx context.Context, tx *sql.Tx, query string, params []interface{}) (*sql.Rows, error)
	TxQueryRowWithContext(ctx context.Context, tx *sql.Tx, query string, params []interface{}) *sql.Row
	TxExecWithContext(ctx context.Context, tx *sql.Tx, query string, params []interface{}) (sql.Result, error)

	Migrate() error
	// contains filtered or unexported methods
}