From 4968735b73b2043c136ce8c1720a6db143349cea Mon Sep 17 00:00:00 2001
From: Jan Mussler <janm81@gmail.com>
Date: Thu, 29 Dec 2022 17:35:17 +0100
Subject: [PATCH] Update database.go

---
 pkg/cluster/database.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/pkg/cluster/database.go b/pkg/cluster/database.go
index 449f6033..a1726697 100644
--- a/pkg/cluster/database.go
+++ b/pkg/cluster/database.go
@@ -97,13 +97,17 @@ func (c *Cluster) pgConnectionString(dbname string) string {
 	if dbname == "" {
 		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),
 		dbname,
 		c.systemUsers[constants.SuperuserKeyName].Name,
 		strings.Replace(password, "$", "\\$", -1),
-		constants.PostgresConnectTimeout/time.Second)
+		constants.PostgresConnectTimeout/time.Second,
+		options)
 }
 
 func (c *Cluster) databaseAccessDisabled() bool {
-- 
GitLab