Function DatabaseDSN

conf/conf.go:34–81

DatabaseDSN builds a MySQL DSN from DB_* environment variables.

()

// DatabaseDSN builds a MySQL DSN from DB_* environment variables.
func DatabaseDSN() (string, error) {
	user := os.Getenv("DB_USER")
	name := os.Getenv("DB_NAME")
	missing := make([]string, 0, 2)
	if user == "" {
		missing = append(missing, "DB_USER")
	}
	if name == "" {
		missing = append(missing, "DB_NAME")
	}
	if len(missing) > 0 {
		return "", fmt.Errorf("missing required database config: %s", strings.Join(missing, ", "))
	}
	if err := validateDSNPart("DB_USER", user, ":"); err != nil {
		return "", err
	}
	if err := validateDSNPart("DB_NAME", name, "/", "?"); err != nil {
		return "", err
	}

	password := os.Getenv("DB_PASSWORD")
	host := envDefault("DB_HOST", "127.0.0.1")
	port := envDefault("DB_PORT", "3306")
	charset := envDefault("DB_CHARSET", "utf8")
	parseTime, err := strconv.ParseBool(envDefault("DB_PARSE_TIME", "True"))
	if err != nil {
		return "", fmt.Errorf("invalid DB_PARSE_TIME: %w", err)
	}

	loc, err := time.LoadLocation(envDefault("DB_LOC", "Local"))
	if err != nil {
		return "", fmt.Errorf("invalid DB_LOC: %w", err)
	}

	config := mysql.NewConfig()
	config.User = user
	config.Passwd = password
	config.Net = "tcp"
	config.Addr = fmt.Sprintf("%s:%s", host, port)
	config.DBName = name
	config.ParseTime = parseTime
	config.Loc = loc
	if err := config.Apply(mysql.Charset(charset, "")); err != nil {
		return "", fmt.Errorf("invalid DB_CHARSET: %w", err)
	}

	return config.FormatDSN(), nil
}

// Init initializes configuration.
func Init() error {