From 78ea5219e661df5be50e04ad02320ec703682776 Mon Sep 17 00:00:00 2001 From: Aeneas Date: Wed, 24 May 2017 10:55:39 +0200 Subject: [PATCH] config: connect to cleaned DSN Closes #464 --- config/backend_connections.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/config/backend_connections.go b/config/backend_connections.go index 37297f2585e..c6aa2513d63 100644 --- a/config/backend_connections.go +++ b/config/backend_connections.go @@ -46,12 +46,12 @@ func (c *SQLConnection) GetDatabase() *sqlx.DB { if err = pkg.Retry(c.L, time.Second*15, time.Minute*2, func() error { c.L.Infof("Connecting with %s", c.URL.Scheme+"://*:*@"+c.URL.Host+c.URL.Path+"?"+clean.RawQuery) - u := c.URL.String() - if c.URL.Scheme == "mysql" { + u := clean.String() + if clean.Scheme == "mysql" { u = strings.Replace(u, "mysql://", "", -1) } - if c.db, err = sqlx.Open(c.URL.Scheme, u); err != nil { + if c.db, err = sqlx.Open(clean.Scheme, u); err != nil { return errors.Errorf("Could not connect to SQL: %s", err) } else if err := c.db.Ping(); err != nil { return errors.Errorf("Could not connect to SQL: %s", err)