fanir/feedizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Activity

added retries in database.Open()

Browse source
This commit is contained in:
fanir 2022-01-25 23:58:41 +01:00
parent c81d7c3264
commit 0fd673cd19
1 changed files with 21 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
cmd/feedizer/database/database.go
View file

@ -3,6 +3,8 @@ package database
import ( import (
"database/sql" "database/sql"
"fmt" "fmt"
"log"
"time"
"git.zom.bi/fanir/feedizer/cmd/feedizer/config" "git.zom.bi/fanir/feedizer/cmd/feedizer/config"
"git.zom.bi/fanir/feedizer/models/migrations" "git.zom.bi/fanir/feedizer/models/migrations"
@ -22,7 +24,25 @@ func Open(c config.DatabaseConfig) (*sql.DB, error) {
dsn = fmt.Sprintf("postgres://%s:%s@%s:%d/%s?%s", c.Username, c.Password, c.Host, c.Port, c.Database, c.Options) dsn = fmt.Sprintf("postgres://%s:%s@%s:%d/%s?%s", c.Username, c.Password, c.Host, c.Port, c.Database, c.Options)
LogName = fmt.Sprintf("%s:%d/%s", c.Host, c.Port, c.Database) LogName = fmt.Sprintf("%s:%d/%s", c.Host, c.Port, c.Database)
} }
return sql.Open("postgres", dsn)
log.Printf("database: connecting...")
db, err := sql.Open("postgres", dsn)
if err != nil {
return nil, err
}
err = db.Ping()
for i := 1; err != nil && i < 10; i++ {
log.Printf("database: connection failed, retrying in %d seconds...", i)
time.Sleep(time.Duration(i) * time.Second)
err = db.Ping()
}
if err == nil {
log.Println("database: connection successful")
}
return db, err
} }
func Migrate(db *sql.DB) error { func Migrate(db *sql.DB) error {