Skip to content

Commit 4607558

Browse files
committed
fix: correct database close calls
1 parent 278630c commit 4607558

File tree

1 file changed

+4
-10
lines changed

1 file changed

+4
-10
lines changed

controllers/database_controller.go

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,8 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
5757
return ctrl.Result{}, err
5858
}
5959

60+
defer db.Close()
61+
6062
log.Info("Connected to database server")
6163

6264
hasDatabase, err := db.HasDatabase(database.Spec.Database)
@@ -87,11 +89,6 @@ func (r *DatabaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
8789
}
8890
}
8991

90-
err = db.Close()
91-
if err != nil {
92-
return ctrl.Result{}, err
93-
}
94-
9592
log.Info("Created database and user with full access to it")
9693

9794
// Check if the Database instance is marked to be deleted, which is
@@ -171,6 +168,8 @@ func (r *DatabaseReconciler) finalizeDatabase(log logr.Logger, database *anbrate
171168
return err
172169
}
173170

171+
defer db.Close()
172+
174173
hasDatabaseUserWithAccess, err := db.HasDatabaseUserWithAccess(database.Spec.Username, database.Spec.Database)
175174
if err != nil {
176175
return err
@@ -204,11 +203,6 @@ func (r *DatabaseReconciler) finalizeDatabase(log logr.Logger, database *anbrate
204203
return err
205204
}
206205

207-
err = db.Close()
208-
if err != nil {
209-
return err
210-
}
211-
212206
log.Info("Database: '" + database.Spec.Database + "' and user: '" + database.Spec.Username + "' removed")
213207
return nil
214208
}

0 commit comments

Comments
 (0)