diff --git a/adapter/config.go b/adapter/config.go index 5d762d25..94693089 100644 --- a/adapter/config.go +++ b/adapter/config.go @@ -72,7 +72,7 @@ func (c *Config) GoFormat() string { u = fmt.Sprintf("postgres://%s:%s@%s:%s/%s", c.Username, c.Password, c.Host, c.Port, c.Database) case "mysql": c.Options.Set("parseTime", "true") - u = fmt.Sprintf("%s@tcp(%s:%s)/%s", c.Username, c.Host, c.Port, c.Database) + u = fmt.Sprintf("%s:%s@tcp(%s:%s)/%s", c.Username, c.Password, c.Host, c.Port, c.Database) case "sqlite": return fmt.Sprintf("file:%s", c.Database) default: diff --git a/adapter/config_test.go b/adapter/config_test.go index b4aca7f4..a11fc997 100644 --- a/adapter/config_test.go +++ b/adapter/config_test.go @@ -33,8 +33,8 @@ func TestNewMySQLConfig(t *testing.T) { require.Equal(t, "localhost", c.Host) require.Equal(t, "3306", c.Port) require.Equal(t, "queryx_test", c.Database) - require.Equal(t, "root@tcp(localhost:3306)/queryx_test?parseTime=true", c.URL) - require.Equal(t, "root@tcp(localhost:3306)/?parseTime=true", c.URL2) + require.Equal(t, "root:@tcp(localhost:3306)/queryx_test?parseTime=true", c.URL) + require.Equal(t, "root:@tcp(localhost:3306)/?parseTime=true", c.URL2) require.Equal(t, "mysql://root:@localhost:3306/queryx_test?parseTime=true", c.TSFormat()) }