create global default privileges in the appropriate prepared databases (zalando#1421)

machine424 · web-flow · commit 78bfba85d21f · 2021-03-26T14:19:26.000+01:00
diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go
@@ -661,6 +661,9 @@ func (c *Cluster) syncDatabases() error {
 
 	// set default privileges for prepared database
 	for _, preparedDatabase := range preparedDatabases {
+		if err := c.initDbConnWithName(preparedDatabase); err != nil {
+			return fmt.Errorf("could not init database connection to %s", preparedDatabase)
+		}
 		if err = c.execAlterGlobalDefaultPrivileges(preparedDatabase+constants.OwnerRoleNameSuffix, preparedDatabase); err != nil {
 			return err
 		}

Original file line number	Diff line number	Diff line change
`@@ -661,6 +661,9 @@ func (c *Cluster) syncDatabases() error {`
`661`	`661`
`662`	`662`	`// set default privileges for prepared database`
`663`	`663`	`for _, preparedDatabase := range preparedDatabases {`
	`664`	`+ if err := c.initDbConnWithName(preparedDatabase); err != nil {`
	`665`	`+ return fmt.Errorf("could not init database connection to %s", preparedDatabase)`
	`666`	`+ }`
`664`	`667`	`if err = c.execAlterGlobalDefaultPrivileges(preparedDatabase+constants.OwnerRoleNameSuffix, preparedDatabase); err != nil {`
`665`	`668`	`return err`
`666`	`669`	`}`