Versions in this module Expand all Collapse all v1 v1.0.0 Dec 17, 2020 Changes in this version + func ExecWithRollback(db *sql.DB, queries []QueryEntry) (res sql.Result, err error) + func Hashfnv32a(b []byte) uint32 + func IgnoreErrors(err error, ignoreErrs []terror.ErrCode) bool + func InstallArchive(ctx context.Context, rawURL string, dest string) error + func IsErrDupEntry(err error) bool + func IsErrTableNotExists(err error) bool + func IsFileExist(name string) bool + func MustExec(db *sql.DB, query string, args ...interface{}) sql.Result + func OpenDB(dsn string, maxIdleConns int) (*sql.DB, error) + func RandString(b []byte, r *rand.Rand) + func RandomlyChangeReplicaRead(job, replicaRead string, db *sql.DB) + func RunWithRetry(ctx context.Context, retryCnt int, interval time.Duration, f func() error) error + func Wget(ctx context.Context, rawURL string, dest string) (string, error) + type QueryEntry struct + Args []interface{} + ExpectAffectedRows int64 + Query string
Go to main page