Move the MySQL normalize DNS function dependency to cmd/

pull/157/head
Vojtech Vitek 2019-03-06 01:06:31 -05:00
parent f8632df590
commit 0cdcc45122
4 changed files with 40 additions and 30 deletions

View File

@ -1,8 +1,33 @@
// +build !no_mysql
// +build mysql
package main
import (
"log"
"github.com/go-sql-driver/mysql"
_ "github.com/go-sql-driver/mysql"
_ "github.com/ziutek/mymysql/godrv"
)
// normalizeMySQLDSN parses the dsn used with the mysql driver to always have
// the parameter `parseTime` set to true. This allows internal goose logic
// to assume that DATETIME/DATE/TIMESTAMP can be scanned into the time.Time
// type.
func normalizeDBString(str string) string {
var err error
str, err = normalizeMySQLDSN(dns string)
if err != nil {
log.Fatalf("failed to normalize MySQL connection string: %v", err)
}
}
func normalizeMySQLDSN(dns string) (string, error) {
config, err := mysql.ParseDSN(dsn)
if err != nil {
return "", err
}
config.ParseTime = true
return config.FormatDSN(), nil
}

View File

@ -0,0 +1,12 @@
// +build !mysql
package main
import (
_ "github.com/go-sql-driver/mysql"
_ "github.com/ziutek/mymysql/godrv"
)
func normalizeDBString(str string) string {
return str
}

View File

@ -55,13 +55,7 @@ func main() {
driver, dbstring, command := args[0], args[1], args[2]
switch dbstring {
case "":
log.Fatalf("-dbstring=%q not supported\n", dbstring)
default:
}
db, err := goose.OpenDBWithDriver(driver, dbstring)
db, err := goose.OpenDBWithDriver(driver, normalizeDBString(dbstring))
if err != nil {
log.Fatalf("-dbstring=%q: %v\n", dbstring, err)
}

23
db.go
View File

@ -3,8 +3,6 @@ package goose
import (
"database/sql"
"fmt"
"github.com/go-sql-driver/mysql"
)
// OpenDBWithDriver creates a connection a database, and modifies goose
@ -22,28 +20,9 @@ func OpenDBWithDriver(driver string, dbstring string) (*sql.DB, error) {
}
switch driver {
case "postgres", "sqlite3":
case "postgres", "sqlite3", "mysql":
return sql.Open(driver, dbstring)
case "mysql":
dsn, err := normalizeMySQLDSN(dbstring)
if err != nil {
return nil, err
}
return sql.Open(driver, dsn)
default:
return nil, fmt.Errorf("unsupported driver %s", driver)
}
}
// normalizeMySQLDSN parses the dsn used with the mysql driver to always have
// the parameter `parseTime` set to true. This allows internal goose logic
// to assume that DATETIME/DATE/TIMESTAMP can be scanned into the time.Time
// type.
func normalizeMySQLDSN(dsn string) (string, error) {
config, err := mysql.ParseDSN(dsn)
if err != nil {
return "", err
}
config.ParseTime = true
return config.FormatDSN(), nil
}