test updated

Author: pol-mfilipowicz-viant

metadata/product/mysql/sequence/transient_race_test.go

@@ -7,6 +7,7 @@ import (
 	"strconv"
 	"sync"
 	"testing"
+	"time"
 
 	_ "github.com/go-sql-driver/mysql"
 	"github.com/viant/sqlx"
@@ -57,7 +58,7 @@ func newTestDB(t *testing.T) (*sql.DB, string, string, string, string, int64) {
 	}
 
 	// Create a temporary table for this test and ensure cleanup.
-	table := "t_seq_race"
+	table := "t_seq_race_" + strconv.FormatInt(time.Now().UnixNano(), 10)
 	idCol := "id"
 	if _, err := db.Exec("DROP TABLE IF EXISTS `" + schema + "`.`" + table + "`"); err != nil {
 		t.Fatalf("drop table: %v", err)

metadata/product/mysql/test/next_sequence_test.go

@@ -29,9 +29,9 @@ func TestService_NextSequenceValue(t *testing.T) {
 		t.Skip("set TEST_MYSQL_DSN before running test")
 	}
 
-	dsnSchema := os.Getenv("TEST_MYSQL_DSN_SCHEMA")
+	dsnSchema := os.Getenv("TEST_MYSQL_SCHEMA")
 	if dsnSchema == "" {
-		t.Skip("set TEST_MYSQL_DSN_SCHEMA before running test")
+		t.Skip("set TEST_MYSQL_SCHEMA before running test")
 	}
 
 	var useCases = []struct {

metadata/product/mysql/test/sequence_test.go

@@ -29,9 +29,9 @@ func TestSequence_NextValue_Gen(t *testing.T) {
 		t.Skip("set TEST_MYSQL_DSN before running test")
 		return
 	}
-	dsnSchema := os.Getenv("TEST_MYSQL_DSN_SCHEMA")
+	dsnSchema := os.Getenv("TEST_MYSQL_SCHEMA")
 	if dsnSchema == "" {
-		t.Skip("set TEST_MYSQL_DSN_SCHEMA before running test")
+		t.Skip("set TEST_MYSQL_SCHEMA before running test")
 		return
 	}