in database/Database.go [16:39]
func NewDbClient(ctx context.Context, server string, port int, database string) (*sql.DB, error) {
logger := ctxlogger.GetLogger(ctx)
logger.Info("Creating a db client.")
// Build connection string
connString := fmt.Sprintf("server=%s;port%d;database=%s;fedauth=ActiveDirectoryDefault;", server, port, database) // Working because we're logged into azure.
db, err := sql.Open(azuread.DriverName, connString)
if err != nil {
logger.Error("Error creating connection pool: " + err.Error())
return nil, err
}
// Pinging to check that we do have access.
err = db.PingContext(ctx)
if err != nil {
logger.Error(err.Error())
return nil, err
} else {
logger.Info("Connected!")
}
return db, nil
}