Improve database logging
This commit is contained in:
+4
-2
@@ -33,11 +33,10 @@ func LaunchDB(conf config.DBConfig) error {
|
|||||||
conf.Name,
|
conf.Name,
|
||||||
)
|
)
|
||||||
|
|
||||||
log.Infof("Connecting to database with URL \"%v\"", dbURLNoPasswd)
|
|
||||||
|
|
||||||
var conn *pgx.Conn
|
var conn *pgx.Conn
|
||||||
var err error
|
var err error
|
||||||
for i := 0; i < 10; i++ {
|
for i := 0; i < 10; i++ {
|
||||||
|
log.Infof("Connecting to database with URL \"%v\" (attempt %v)", dbURLNoPasswd, i)
|
||||||
conn, err = pgx.Connect(context.Background(), dbURL)
|
conn, err = pgx.Connect(context.Background(), dbURL)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
defer conn.Close(context.Background())
|
defer conn.Close(context.Background())
|
||||||
@@ -50,6 +49,8 @@ func LaunchDB(conf config.DBConfig) error {
|
|||||||
return fmt.Errorf("Could not open database: %w", err)
|
return fmt.Errorf("Could not open database: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
log.Infof("Database connected sucessfully!")
|
||||||
|
|
||||||
versionTableExistsQuery := `
|
versionTableExistsQuery := `
|
||||||
SELECT EXISTS (
|
SELECT EXISTS (
|
||||||
SELECT FROM pg_tables
|
SELECT FROM pg_tables
|
||||||
@@ -65,6 +66,7 @@ SELECT EXISTS (
|
|||||||
if versionTableExists {
|
if versionTableExists {
|
||||||
// TODO: migrations
|
// TODO: migrations
|
||||||
} else {
|
} else {
|
||||||
|
log.Info("New database found, initializing....")
|
||||||
err = initDB(conn)
|
err = initDB(conn)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("Could not initalize database: %w", err)
|
return fmt.Errorf("Could not initalize database: %w", err)
|
||||||
|
|||||||
Reference in New Issue
Block a user