commit
64908ed241
1 changed files with 22 additions and 0 deletions
|
@ -3,6 +3,7 @@ package datastore
|
||||||
import (
|
import (
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"os"
|
"os"
|
||||||
|
"time"
|
||||||
|
|
||||||
"github.com/drone/drone/shared/envconfig"
|
"github.com/drone/drone/shared/envconfig"
|
||||||
"github.com/drone/drone/store"
|
"github.com/drone/drone/store"
|
||||||
|
@ -66,8 +67,14 @@ func Open(driver, config string) *sql.DB {
|
||||||
log.Errorln(err)
|
log.Errorln(err)
|
||||||
log.Fatalln("database connection failed")
|
log.Fatalln("database connection failed")
|
||||||
}
|
}
|
||||||
|
|
||||||
setupMeddler(driver)
|
setupMeddler(driver)
|
||||||
|
|
||||||
|
if err := pingDatabase(db); err != nil {
|
||||||
|
log.Errorln(err)
|
||||||
|
log.Fatalln("database ping attempts failed")
|
||||||
|
}
|
||||||
|
|
||||||
if err := setupDatabase(driver, db); err != nil {
|
if err := setupDatabase(driver, db); err != nil {
|
||||||
log.Errorln(err)
|
log.Errorln(err)
|
||||||
log.Fatalln("migration failed")
|
log.Fatalln("migration failed")
|
||||||
|
@ -90,6 +97,21 @@ func openTest() *sql.DB {
|
||||||
return Open(driver, config)
|
return Open(driver, config)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// helper function to ping the database with backoff to ensure
|
||||||
|
// a connection can be established before we proceed with the
|
||||||
|
// database setup and migration.
|
||||||
|
func pingDatabase(db *sql.DB) (err error) {
|
||||||
|
for i := 0; i < 30; i++ {
|
||||||
|
err = db.Ping()
|
||||||
|
if err == nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
log.Infof("database ping failed. retry in 1s")
|
||||||
|
time.Sleep(time.Second)
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
// helper function to setup the databsae by performing
|
// helper function to setup the databsae by performing
|
||||||
// automated database migration steps.
|
// automated database migration steps.
|
||||||
func setupDatabase(driver string, db *sql.DB) error {
|
func setupDatabase(driver string, db *sql.DB) error {
|
||||||
|
|
Loading…
Reference in a new issue