test

Documentation

Index

• func DSN() string
• func DeleteAllParquetFiles()
• func DeleteFile(t *testing.T, filePath string)
• func FindParquetFile(t *testing.T, suffix string, ensureFile bool) []string
• func GetCount(t *testing.T, db *sql.DB, tableName string, where string) int
• func LockExists(t *testing.T, db *sql.DB, tableName string) bool
• func ReplicaDSN() string
• func RunSQL(t *testing.T, stmt string)
• func SetupDB(cfg *mysql.Config, threads int, seconds int) (*sql.DB, error)
• func TableExists(t *testing.T, schema, table string, db *sql.DB) bool

Functions

func DSN

func DSN() string

func DeleteAllParquetFiles

func DeleteAllParquetFiles()

func DeleteFile

func DeleteFile(t *testing.T, filePath string)

func FindParquetFile

func FindParquetFile(t *testing.T, suffix string, ensureFile bool) []string

func GetCount

func GetCount(t *testing.T, db *sql.DB, tableName string, where string) int

func LockExists

func LockExists(t *testing.T, db *sql.DB, tableName string) bool

func ReplicaDSN

func ReplicaDSN() string

func RunSQL

func RunSQL(t *testing.T, stmt string)

func SetupDB

func SetupDB(cfg *mysql.Config, threads int, seconds int) (*sql.DB, error)

func TableExists

func TableExists(t *testing.T, schema, table string, db *sql.DB) bool