Function runTests

driver_test.go:144–203

(t *testing.T, dsn string, tests ...func(dbt *DBTest))

}

func runTests(t *testing.T, dsn string, tests ...func(dbt *DBTest)) {
	if !available {
		t.Skipf("MySQL server not running on %s", netAddr)
	}

	db, err := sql.Open(driverNameTest, dsn)
	if err != nil {
		t.Fatalf("connecting %q: %s", dsn, err)
	}
	defer db.Close()
	if err = db.Ping(); err != nil {
		t.Fatalf("connecting %q: %s", dsn, err)
	}

	dsn2 := dsn + "&interpolateParams=true"
	var db2 *sql.DB
	if _, err := ParseDSN(dsn2); err != errInvalidDSNUnsafeCollation {
		db2, err = sql.Open(driverNameTest, dsn2)
		if err != nil {
			t.Fatalf("connecting %q: %s", dsn2, err)
		}
		defer db2.Close()
	}

	dsn3 := dsn + "&compress=true"
	var db3 *sql.DB
	db3, err = sql.Open(driverNameTest, dsn3)
	if err != nil {
		t.Fatalf("connecting %q: %s", dsn3, err)
	}
	defer db3.Close()

	cleanupSql := "DROP TABLE IF EXISTS test"

	for _, test := range tests {
		t.Run("default", func(t *testing.T) {
			dbt := &DBTest{t, db}
			t.Cleanup(func() {
				db.Exec(cleanupSql)
			})
			test(dbt)
		})
		if db2 != nil {
			t.Run("interpolateParams", func(t *testing.T) {
				dbt2 := &DBTest{t, db2}
				t.Cleanup(func() {
					db2.Exec(cleanupSql)
				})
				test(dbt2)
			})
		}
		t.Run("compress", func(t *testing.T) {
			dbt3 := &DBTest{t, db3}
			t.Cleanup(func() {
				db3.Exec(cleanupSql)
			})
			test(dbt3)
		})