From 51deace1da38504472bdec9fbdc74036996e9958 Mon Sep 17 00:00:00 2001 From: Aaron Guise Date: Mon, 9 Jun 2025 22:53:25 +1200 Subject: [PATCH] refactor: Removed standalone migration apps. Causes build fail :fire: --- migrations/migrate1.go | 105 ----------------------------------------- migrations/migrate2.go | 105 ----------------------------------------- migrations/migrate3.go | 105 ----------------------------------------- 3 files changed, 315 deletions(-) delete mode 100644 migrations/migrate1.go delete mode 100644 migrations/migrate2.go delete mode 100644 migrations/migrate3.go diff --git a/migrations/migrate1.go b/migrations/migrate1.go deleted file mode 100644 index d5bd796..0000000 --- a/migrations/migrate1.go +++ /dev/null @@ -1,105 +0,0 @@ -package main - -import ( - "encoding/json" - "github.com/openaccounting/oa-server/core/model/db" - "github.com/openaccounting/oa-server/core/model/types" - "log" - "os" -) - -func main() { - if len(os.Args) != 2 { - log.Fatal("Usage: migrate1.go ") - } - - command := os.Args[1] - - if command != "upgrade" && command != "downgrade" { - log.Fatal("Usage: migrate1.go ") - } - - //filename is the path to the json config file - var config types.Config - file, err := os.Open("./config.json") - - if err != nil { - log.Fatal(err) - } - - decoder := json.NewDecoder(file) - err = decoder.Decode(&config) - - if err != nil { - log.Fatal(err) - } - - connectionString := config.User + ":" + config.Password + "@/" + config.Database - db, err := db.NewDB(connectionString) - - if command == "upgrade" { - err = upgrade(db) - } else { - err = downgrade(db) - } - - if err != nil { - log.Fatal(err) - } - - log.Println("done") -} - -func upgrade(db *db.DB) (err error) { - tx, err := db.Begin() - - if err != nil { - return - } - - defer func() { - if p := recover(); p != nil { - tx.Rollback() - panic(p) // re-throw panic after Rollback - } else if err != nil { - tx.Rollback() - } else { - err = tx.Commit() - } - }() - - query1 := "ALTER TABLE user ADD COLUMN signupSource VARCHAR(100) NOT NULL AFTER emailVerifyCode" - - if _, err = tx.Exec(query1); err != nil { - return - } - - return -} - -func downgrade(db *db.DB) (err error) { - tx, err := db.Begin() - - if err != nil { - return - } - - defer func() { - if p := recover(); p != nil { - tx.Rollback() - panic(p) // re-throw panic after Rollback - } else if err != nil { - tx.Rollback() - } else { - err = tx.Commit() - } - }() - - query1 := "ALTER TABLE user DROP COLUMN signupSource" - - if _, err = tx.Exec(query1); err != nil { - return - } - - return -} diff --git a/migrations/migrate2.go b/migrations/migrate2.go deleted file mode 100644 index 5a09364..0000000 --- a/migrations/migrate2.go +++ /dev/null @@ -1,105 +0,0 @@ -package main - -import ( - "encoding/json" - "github.com/openaccounting/oa-server/core/model/db" - "github.com/openaccounting/oa-server/core/model/types" - "log" - "os" -) - -func main() { - if len(os.Args) != 2 { - log.Fatal("Usage: migrate2.go ") - } - - command := os.Args[1] - - if command != "upgrade" && command != "downgrade" { - log.Fatal("Usage: migrate2.go ") - } - - //filename is the path to the json config file - var config types.Config - file, err := os.Open("./config.json") - - if err != nil { - log.Fatal(err) - } - - decoder := json.NewDecoder(file) - err = decoder.Decode(&config) - - if err != nil { - log.Fatal(err) - } - - connectionString := config.User + ":" + config.Password + "@/" + config.Database - db, err := db.NewDB(connectionString) - - if command == "upgrade" { - err = upgrade(db) - } else { - err = downgrade(db) - } - - if err != nil { - log.Fatal(err) - } - - log.Println("done") -} - -func upgrade(db *db.DB) (err error) { - tx, err := db.Begin() - - if err != nil { - return - } - - defer func() { - if p := recover(); p != nil { - tx.Rollback() - panic(p) // re-throw panic after Rollback - } else if err != nil { - tx.Rollback() - } else { - err = tx.Commit() - } - }() - - query1 := "ALTER TABLE org ADD COLUMN timezone VARCHAR(100) NOT NULL AFTER `precision`" - - if _, err = tx.Exec(query1); err != nil { - return - } - - return -} - -func downgrade(db *db.DB) (err error) { - tx, err := db.Begin() - - if err != nil { - return - } - - defer func() { - if p := recover(); p != nil { - tx.Rollback() - panic(p) // re-throw panic after Rollback - } else if err != nil { - tx.Rollback() - } else { - err = tx.Commit() - } - }() - - query1 := "ALTER TABLE org DROP COLUMN timezone" - - if _, err = tx.Exec(query1); err != nil { - return - } - - return -} diff --git a/migrations/migrate3.go b/migrations/migrate3.go deleted file mode 100644 index 608e1f9..0000000 --- a/migrations/migrate3.go +++ /dev/null @@ -1,105 +0,0 @@ -package main - -import ( - "encoding/json" - "github.com/openaccounting/oa-server/core/model/db" - "github.com/openaccounting/oa-server/core/model/types" - "log" - "os" -) - -func main() { - if len(os.Args) != 2 { - log.Fatal("Usage: migrate3.go ") - } - - command := os.Args[1] - - if command != "upgrade" && command != "downgrade" { - log.Fatal("Usage: migrate3.go ") - } - - //filename is the path to the json config file - var config types.Config - file, err := os.Open("./config.json") - - if err != nil { - log.Fatal(err) - } - - decoder := json.NewDecoder(file) - err = decoder.Decode(&config) - - if err != nil { - log.Fatal(err) - } - - connectionString := config.User + ":" + config.Password + "@/" + config.Database - db, err := db.NewDB(connectionString) - - if command == "upgrade" { - err = upgrade(db) - } else { - err = downgrade(db) - } - - if err != nil { - log.Fatal(err) - } - - log.Println("done") -} - -func upgrade(db *db.DB) (err error) { - tx, err := db.Begin() - - if err != nil { - return - } - - defer func() { - if p := recover(); p != nil { - tx.Rollback() - panic(p) // re-throw panic after Rollback - } else if err != nil { - tx.Rollback() - } else { - err = tx.Commit() - } - }() - - query1 := "CREATE TABLE budgetitem (id INT UNSIGNED NOT NULL AUTO_INCREMENT, orgId BINARY(16) NOT NULL, accountId BINARY(16) NOT NULL, inserted BIGINT UNSIGNED NOT NULL, amount BIGINT NOT NULL, PRIMARY KEY(id)) ENGINE=InnoDB;" - - if _, err = tx.Exec(query1); err != nil { - return - } - - return -} - -func downgrade(db *db.DB) (err error) { - tx, err := db.Begin() - - if err != nil { - return - } - - defer func() { - if p := recover(); p != nil { - tx.Rollback() - panic(p) // re-throw panic after Rollback - } else if err != nil { - tx.Rollback() - } else { - err = tx.Commit() - } - }() - - query1 := "DROP TABLE budgetitem" - - if _, err = tx.Exec(query1); err != nil { - return - } - - return -}