clean: moving the connect function

cmd/database/main.go

@@ -1,9 +1,11 @@
 package main
 
 import (
+	"database/sql"
 	"fmt"
 	"os"
 	"path/filepath"
+	"strings"
 
 	"github.com/leapkit/core/db"
 
@@ -35,9 +37,16 @@ func main() {
 
 	switch os.Args[1] {
 	case "migrate":
-		conn, err := db.Connect(url)
+		driver := "sqlite3"
+		if strings.HasPrefix(url, "postgres") {
+			driver = "postgres"
+		}
+
+		conn, err := sql.Open(driver, url)
 		if err != nil {
 			fmt.Println(err)
+
+			return
 		}
 
 		err = db.RunMigrationsDir(filepath.Join("internal", "migrations"), conn)
@@ -67,7 +76,6 @@ func main() {
 		}
 
 		fmt.Println("✅ Database dropped successfully")
-
 	default:
 		fmt.Println("command not found")
 

db/connection.go

@@ -2,7 +2,6 @@ package db
 
 import (
 	"database/sql"
-	"strings"
 	"sync"
 )
 
@@ -56,14 +55,3 @@ func WithDriver(name string) connectionOption {
 		driverName = name
 	}
 }
-
-// connect to the database based on the driver and connection string.
-func Connect(url string) (*sql.DB, error) {
-	// Based on DSN
-	driver := "sqlite3"
-	if strings.HasPrefix(url, "postgres") {
-		driver = "postgres"
-	}
-
-	return sql.Open(driver, url)
-}