bagas/filekeeper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix MySQL syntax error

Browse Source
This commit is contained in:
Bagas Aulia Rezki
2024-04-28 22:57:01 +07:00
parent e6344743d5
commit 994b1faacf
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/app.go
View File

@ -35,7 +35,7 @@ func Start() {
dbPort := utils.Getenv("DB_PORT") dbPort := utils.Getenv("DB_PORT")
dbName := utils.Getenv("DB_NAME") 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 db.DB = database
Server = NewServer(serverAddr, middleware.Handler(routes.SetupRoutes()), database) Server = NewServer(serverAddr, middleware.Handler(routes.SetupRoutes()), database)

4
db/database.go
View File

@ -211,13 +211,13 @@ func (db *mySQLdb) GetUploadInfo(fileID string) (*models.FilesUploaded, error) {
} }
func (db *mySQLdb) UpdateUpdateIndex(index int, fileID string) { 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, "Uploaded": index,
}) })
} }
func (db *mySQLdb) FinalizeFileUpload(fileID string) { 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, "Done": true,
}) })
} }