good morning!!!!

Skip to content
Snippets Groups Projects
Commit f5fdddcc authored by or-else's avatar or-else
Browse files

fix root user handling in init-db

parent fa5e599c
Branches init-db-fix
No related tags found
No related merge requests found
...@@ -250,16 +250,29 @@ func main() { ...@@ -250,16 +250,29 @@ func main() {
log.Fatalln("Database not found.") log.Fatalln("Database not found.")
} }
log.Println("Database not found. Creating.") log.Println("Database not found. Creating.")
err = store.Store.InitDb(config.StoreConfig, false)
if err == nil {
log.Println("Database successfully created.")
}
} else if strings.Contains(err.Error(), "Invalid database version") { } else if strings.Contains(err.Error(), "Invalid database version") {
msg := "Wrong DB version: expected " + strconv.Itoa(adapterVersion) + ", got " + msg := "Wrong DB version: expected " + strconv.Itoa(adapterVersion) + ", got " +
strconv.Itoa(databaseVersion) + "." strconv.Itoa(databaseVersion) + "."
if *reset { if *reset {
log.Println(msg, "Dropping and recreating the database.") log.Println(msg, "Reset Requested. Dropping and recreating the database.")
err = store.Store.InitDb(config.StoreConfig, true)
if err == nil {
log.Println("Database successfully reset.")
}
} else if *upgrade { } else if *upgrade {
if databaseVersion > adapterVersion { if databaseVersion > adapterVersion {
log.Fatalln(msg, "Unable to upgrade: database has greater version than the adapter.") log.Fatalln(msg, "Unable to upgrade: database has greater version than the adapter.")
} }
log.Println(msg, "Upgrading the database.") log.Println(msg, "Upgrading the database.")
err = store.Store.UpgradeDb(config.StoreConfig)
if err == nil {
log.Println("Database successfully upgraded.")
}
} else { } else {
log.Fatalln(msg, "Use --reset to reset, --upgrade to upgrade.") log.Fatalln(msg, "Use --reset to reset, --upgrade to upgrade.")
} }
...@@ -267,34 +280,17 @@ func main() { ...@@ -267,34 +280,17 @@ func main() {
log.Fatalln("Failed to init DB adapter:", err) log.Fatalln("Failed to init DB adapter:", err)
} }
} else if *reset { } else if *reset {
log.Println("Database reset requested") log.Println("Reset requested. Dropping and recreating the database.")
} else {
log.Println("Database exists, DB version is correct. All done.")
os.Exit(0)
}
if *upgrade {
// Upgrade DB from one version to another.
err = store.Store.UpgradeDb(config.StoreConfig)
if err == nil {
log.Println("Database successfully upgraded.")
}
} else {
// Reset or create DB
err = store.Store.InitDb(config.StoreConfig, true) err = store.Store.InitDb(config.StoreConfig, true)
if err == nil { if err == nil {
var action string log.Println("Database successfully reset.")
if *reset {
action = "reset"
} else {
action = "initialized"
}
log.Println("Database", action)
} }
} else {
log.Println("Database exists, version is correct.")
} }
if err != nil { if err != nil {
log.Fatalln("Failed to init DB:", err) log.Fatalln("Failure:", err)
} }
if !*upgrade { if !*upgrade {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment