Skip to content

Commit 03f742d

Browse files
committed
made revoke more simple by just revoking all, fixed bug on grant query
1 parent ef15b4c commit 03f742d

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

pkg/controller/postgresql/default_privileges/reconciler.go

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -170,20 +170,18 @@ func inSchema(params *v1alpha1.DefaultPrivilegesParameters) string {
170170
return ""
171171
}
172172

173-
func createDefaultPrivilegesQuery(gp v1alpha1.DefaultPrivilegesParameters, q *xsql.Query) { // nolint: gocyclo
173+
func createDefaultPrivilegesQuery(gp v1alpha1.DefaultPrivilegesParameters, q *xsql.Query) {
174174

175175
roleName := pq.QuoteIdentifier(*gp.Role)
176176

177177
targetRoleName := pq.QuoteIdentifier(*gp.TargetRole)
178178

179-
objectType := objectTypes[*gp.ObjectType]
180-
181179
query := strings.TrimSpace(fmt.Sprintf(
182-
"ALTER DEFAULT PRIVILEGES FOR ROLE %s %s GRANT %s ON %s TO %s %s",
180+
"ALTER DEFAULT PRIVILEGES FOR ROLE %s %s GRANT %s ON %sS TO %s %s",
183181
targetRoleName,
184182
inSchema(&gp),
185183
strings.Join(gp.Privileges.ToStringSlice(), ","),
186-
objectType,
184+
*gp.ObjectType,
187185
roleName,
188186
withOption(gp.WithOption),
189187
))
@@ -197,10 +195,9 @@ func deleteDefaultPrivilegesQuery(gp v1alpha1.DefaultPrivilegesParameters, q *xs
197195
objectType := objectTypes[*gp.ObjectType]
198196

199197
query := strings.TrimSpace(fmt.Sprintf(
200-
"ALTER DEFAULT PRIVILEGES FOR ROLE %s %s REVOKE %s ON %s TO %s %s",
198+
"ALTER DEFAULT PRIVILEGES FOR ROLE %s %s REVOKE ALL ON %s TO %s %s",
201199
targetRoleName,
202200
inSchema(&gp),
203-
strings.Join(gp.Privileges.ToStringSlice(), ","),
204201
objectType,
205202
roleName,
206203
withOption(gp.WithOption),

0 commit comments

Comments
 (0)