2018-05-15 13:30:37 +02:00
|
|
|
package sqlstore
|
2018-05-08 12:31:51 +02:00
|
|
|
|
2018-06-13 10:04:42 +02:00
|
|
|
import (
|
2018-07-30 09:33:49 +02:00
|
|
|
"strings"
|
2018-10-03 15:27:36 +02:00
|
|
|
|
|
|
|
mysql "github.com/go-sql-driver/mysql"
|
2018-06-13 10:04:42 +02:00
|
|
|
)
|
2018-05-08 12:31:51 +02:00
|
|
|
|
|
|
|
type Config struct {
|
2018-07-29 13:32:04 -03:00
|
|
|
URL string `default:""`
|
2018-05-08 16:21:22 +02:00
|
|
|
Driver string `default:"sqlite3"`
|
2018-05-08 12:31:51 +02:00
|
|
|
Host string `default:""`
|
|
|
|
User string `default:""`
|
|
|
|
Password string `default:""`
|
2018-05-08 12:45:24 +02:00
|
|
|
Name string `default:"fathom.db"`
|
2018-07-12 13:37:52 +02:00
|
|
|
SSLMode string `default:""`
|
2018-05-08 12:31:51 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
func (c *Config) DSN() string {
|
|
|
|
var dsn string
|
|
|
|
|
2018-07-31 15:29:15 +02:00
|
|
|
// if FATHOM_DATABASE_URL was set, use that
|
|
|
|
// this relies on the user to set the appropriate parameters, eg ?parseTime=true when using MySQL
|
|
|
|
if c.URL != "" {
|
|
|
|
return c.URL
|
|
|
|
}
|
|
|
|
|
|
|
|
// otherwise, generate from individual fields
|
2018-05-08 12:31:51 +02:00
|
|
|
switch c.Driver {
|
2018-10-03 15:27:36 +02:00
|
|
|
case POSTGRES:
|
2018-07-31 15:29:15 +02:00
|
|
|
params := map[string]string{
|
|
|
|
"host": c.Host,
|
|
|
|
"dbname": c.Name,
|
|
|
|
"user": c.User,
|
|
|
|
"password": c.Password,
|
|
|
|
"sslmode": c.SSLMode,
|
|
|
|
}
|
2018-07-30 09:33:49 +02:00
|
|
|
|
2018-07-31 15:29:15 +02:00
|
|
|
for k, v := range params {
|
|
|
|
if v == "" {
|
|
|
|
continue
|
2018-07-29 13:32:04 -03:00
|
|
|
}
|
2018-07-31 15:29:15 +02:00
|
|
|
|
|
|
|
dsn = dsn + k + "=" + v + " "
|
2018-07-29 13:32:04 -03:00
|
|
|
}
|
2018-07-31 15:29:15 +02:00
|
|
|
|
|
|
|
dsn = strings.TrimSpace(dsn)
|
2018-10-03 15:27:36 +02:00
|
|
|
case MYSQL:
|
2018-06-13 10:04:42 +02:00
|
|
|
mc := mysql.NewConfig()
|
|
|
|
mc.User = c.User
|
|
|
|
mc.Passwd = c.Password
|
|
|
|
mc.Addr = c.Host
|
|
|
|
mc.Net = "tcp"
|
|
|
|
mc.DBName = c.Name
|
|
|
|
mc.Params = map[string]string{
|
|
|
|
"parseTime": "true",
|
|
|
|
"loc": "Local",
|
|
|
|
}
|
2018-07-12 13:37:52 +02:00
|
|
|
if c.SSLMode != "" {
|
|
|
|
mc.Params["tls"] = c.SSLMode
|
|
|
|
}
|
2018-06-13 10:04:42 +02:00
|
|
|
dsn = mc.FormatDSN()
|
2018-10-03 15:27:36 +02:00
|
|
|
case SQLITE:
|
2018-05-08 16:21:22 +02:00
|
|
|
dsn = c.Name + "?_loc=auto"
|
2018-05-08 12:31:51 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
return dsn
|
|
|
|
}
|