database connection check

pagient · May 20, 2019 · 1b66859 · 1b66859
1 parent a094d8e
commit 1b66859
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/internal/bridge/database/database.go b/internal/bridge/database/database.go
@@ -45,6 +45,13 @@ func Open() (DB, error) {
 	}
 
 	dbConn, err := sql.Open(config.Bridge.DB.Driver, connURL.String())
+	if err != nil {
+		return nil, errors.Wrap(err, "could not create db connection pool")
+	}
 
-	return &db{dbConn}, errors.Wrap(err, "could not connect to database server")
+	if err := dbConn.Ping(); err != nil {
+		dbConn.Close()
+		return nil, errors.Wrap(err, "could not connect to database server")
+	}
+	return &db{dbConn}, nil
 }