Remove port from endpoint if provided

Signed-off-by: Timotej Avsec <[email protected]>

pkg/clients/mssql/mssql.go

@@ -48,6 +48,9 @@ func New(creds map[string][]byte, database string) xsql.DB {
 	endpoint := string(creds[xpv1.ResourceCredentialsSecretEndpointKey])
 	port := string(creds[xpv1.ResourceCredentialsSecretPortKey])
 
+	// Remove port from endpoint if it is added to the endpoint
+	endpoint = strings.Split(endpoint, ":")[0]
+
 	host := endpoint
 	if port != "" {
 		host = fmt.Sprintf("%s:%s", endpoint, port)

pkg/clients/mysql/mysql.go

@@ -38,6 +38,7 @@ func New(creds map[string][]byte, tls *string) xsql.DB {
 		defaultTLS := "preferred"
 		tls = &defaultTLS
 	}
+	endpoint = strings.Split(endpoint, ":")[0]
 	dsn := DSN(username, password, endpoint, port, *tls)
 
 	return mySQLDB{

pkg/clients/postgresql/postgresql.go

@@ -5,6 +5,7 @@ import (
 	"database/sql"
 	"errors"
 	"net/url"
+	"strings"
 
 	"github.com/crossplane-contrib/provider-sql/pkg/clients/xsql"
 	"github.com/lib/pq"
@@ -38,6 +39,9 @@ func New(creds map[string][]byte, database, sslmode string) xsql.DB {
 	password := string(creds[xpv1.ResourceCredentialsSecretPasswordKey])
 	dsn := DSN(username, password, endpoint, port, database, sslmode)
 
+	// Remove port from endpoint if it is added to the endpoint
+	endpoint = strings.Split(endpoint, ":")[0]
+
 	return postgresDB{
 		dsn:      dsn,
 		endpoint: endpoint,