diff --git a/app/app.go b/app/app.go
index a38c406..92fd49f 100644
--- a/app/app.go
+++ b/app/app.go
@@ -35,7 +35,7 @@ func Start() {
 	dbPort := utils.Getenv("DB_PORT")
 	dbName := utils.Getenv("DB_NAME")
 
-	database := db.NewPostgresDB(dbUser, dbPass, dbHost, dbPort, dbName, db.DisableSSL)
+	database := db.NewMYSQLdb(dbUser, dbPass, dbHost, dbPort, dbName)
 	db.DB = database
 
 	Server = NewServer(serverAddr, middleware.Handler(routes.SetupRoutes()), database)
diff --git a/db/database.go b/db/database.go
index 8c04e42..b3941b9 100644
--- a/db/database.go
+++ b/db/database.go
@@ -211,13 +211,13 @@ func (db *mySQLdb) GetUploadInfo(fileID string) (*models.FilesUploaded, error) {
 }
 
 func (db *mySQLdb) UpdateUpdateIndex(index int, fileID string) {
-	db.DB.Table("files_uploadeds").Where("file_id = $1", fileID).Updates(map[string]interface{}{
+	db.DB.Table("files_uploadeds").Where("file_id = ?", fileID).Updates(map[string]interface{}{
 		"Uploaded": index,
 	})
 }
 
 func (db *mySQLdb) FinalizeFileUpload(fileID string) {
-	db.DB.Table("files_uploadeds").Where("file_id = $1", fileID).Updates(map[string]interface{}{
+	db.DB.Table("files_uploadeds").Where("file_id = ?", fileID).Updates(map[string]interface{}{
 		"Done": true,
 	})
 }