fix(connection): fix validation for mysql

danvergara · Apr 22, 2021 · c69bcf3 · c69bcf3
1 parent 6cbcbc1
commit c69bcf3
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/pkg/connection/connection.go b/pkg/connection/connection.go
@@ -72,12 +72,16 @@ func formatPostgresURL(opts command.Options) (string, error) {
 // formatMySQLURL returns valid uri for mysql connection.
 func formatMySQLURL(opts command.Options) (string, error) {
 	if !hasValidMySQLPrefix(opts.URL) {
-		return "", ErrInvalidUMySQLRLFormat
+		return "", fmt.Errorf("%s, %w", opts.URL, ErrInvalidUMySQLRLFormat)
+	}
+
+	if strings.Contains(opts.URL, "3306") {
+		return opts.URL, nil
 	}
 
 	uri, err := url.Parse(opts.URL)
 	if err != nil {
-		return "", ErrInvalidUMySQLRLFormat
+		return "", fmt.Errorf("%v %w", err, ErrInvalidUMySQLRLFormat)
 	}
 
 	result := map[string]string{}