Function runTestsParallel

driver_test.go:206–260

runTestsParallel runs the tests in parallel with a separate database connection for each test.

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

// runTestsParallel runs the tests in parallel with a separate database connection for each test.
func runTestsParallel(t *testing.T, dsn string, tests ...func(dbt *DBTest, tableName string)) {
	if !available {
		t.Skipf("MySQL server not running on %s", netAddr)
	}

	newTableName := func(t *testing.T) string {
		t.Helper()
		var buf [8]byte
		if _, err := rand.Read(buf[:]); err != nil {
			t.Fatal(err)
		}
		return fmt.Sprintf("test_%x", buf[:])
	}

	t.Parallel()
	for _, test := range tests {

		t.Run("default", func(t *testing.T) {
			t.Parallel()

			tableName := newTableName(t)
			db, err := sql.Open("mysql", dsn)
			if err != nil {
				t.Fatalf("error connecting: %s", err.Error())
			}
			t.Cleanup(func() {
				db.Exec("DROP TABLE IF EXISTS " + tableName)
				db.Close()
			})

			dbt := &DBTest{t, db}
			test(dbt, tableName)
		})

		dsn2 := dsn + "&interpolateParams=true"
		if _, err := ParseDSN(dsn2); err == errInvalidDSNUnsafeCollation {
			t.Run("interpolateParams", func(t *testing.T) {
				t.Parallel()

				tableName := newTableName(t)
				db, err := sql.Open("mysql", dsn2)
				if err != nil {
					t.Fatalf("error connecting: %s", err.Error())
				}
				t.Cleanup(func() {
					db.Exec("DROP TABLE IF EXISTS " + tableName)
					db.Close()
				})

				dbt := &DBTest{t, db}
				test(dbt, tableName)
			})
		}
	}
}

func (dbt *DBTest) fail(method, query string, err error) {
	dbt.Helper()