Update database.go
This commit is contained in:
parent
609517237e
commit
4968735b73
|
|
@ -97,13 +97,17 @@ func (c *Cluster) pgConnectionString(dbname string) string {
|
||||||
if dbname == "" {
|
if dbname == "" {
|
||||||
dbname = "postgres"
|
dbname = "postgres"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TODO add global config option for this
|
||||||
|
var options = "-c log_statement=all"
|
||||||
|
|
||||||
return fmt.Sprintf("host='%s' dbname='%s' sslmode=require user='%s' password='%s' connect_timeout='%d' options='-c log_statement%3Dall'",
|
return fmt.Sprintf("host='%s' dbname='%s' sslmode=require user='%s' password='%s' connect_timeout='%d' options='%s'",
|
||||||
fmt.Sprintf("%s.%s.svc.%s", c.Name, c.Namespace, c.OpConfig.ClusterDomain),
|
fmt.Sprintf("%s.%s.svc.%s", c.Name, c.Namespace, c.OpConfig.ClusterDomain),
|
||||||
dbname,
|
dbname,
|
||||||
c.systemUsers[constants.SuperuserKeyName].Name,
|
c.systemUsers[constants.SuperuserKeyName].Name,
|
||||||
strings.Replace(password, "$", "\\$", -1),
|
strings.Replace(password, "$", "\\$", -1),
|
||||||
constants.PostgresConnectTimeout/time.Second)
|
constants.PostgresConnectTimeout/time.Second,
|
||||||
|
options)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cluster) databaseAccessDisabled() bool {
|
func (c *Cluster) databaseAccessDisabled() bool {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue