@@ -212,11 +212,13 @@ func (r *ReconcilePostgres) Reconcile(request reconcile.Request) (_ reconcile.Re
212
212
continue
213
213
}
214
214
215
- // Create schema
216
- err = r .pg .CreateSchema (database , owner , schema , reqLogger )
217
- if err != nil {
218
- reqLogger .Error (err , fmt .Sprintf ("Could not create schema %s" , schema ))
219
- continue
215
+ if schema != "public" {
216
+ // Create schema
217
+ err = r .pg .CreateSchema (database , owner , schema , reqLogger )
218
+ if err != nil {
219
+ reqLogger .Error (err , fmt .Sprintf ("Could not create schema %s" , schema ))
220
+ continue
221
+ }
220
222
}
221
223
222
224
// Set privileges on schema
@@ -238,13 +240,7 @@ func (r *ReconcilePostgres) Reconcile(request reconcile.Request) (_ reconcile.Re
238
240
reqLogger .Error (err , fmt .Sprintf ("Could not give %s permissions for sequnces \" %s\" " , writer , "USAGE" ))
239
241
continue
240
242
}
241
- // ownerCreateSchema := true
242
- reqLogger .Info (fmt .Sprintf ("schema is %s" , schema ))
243
- if schema == "public" {
244
- reqLogger .Info ("schema is public, skipping creation" )
245
- // ownerCreateSchema = false
246
- }
247
- schemaPrivilegesOwner := postgres.PostgresSchemaPrivileges {database , owner , schema , readerPrivs , false }
243
+ schemaPrivilegesOwner := postgres.PostgresSchemaPrivileges {database , owner , schema , readerPrivs , true }
248
244
err = r .pg .SetSchemaPrivileges (schemaPrivilegesOwner , reqLogger )
249
245
if err != nil {
250
246
reqLogger .Error (err , fmt .Sprintf ("Could not give %s permissions \" %s\" " , writer , writerPrivs ))
0 commit comments