Use try-with-resources

Author: mvegter

samples/mysql-schema/src/main/java/com/github/containersolutions/operator/sample/SchemaController.java

@@ -15,6 +15,7 @@
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.util.Base64;
 
 import static java.lang.String.format;
@@ -38,21 +39,27 @@ public SchemaController(KubernetesClient kubernetesClient) {
     public UpdateControl<Schema> createOrUpdateResource(Schema schema, Context<Schema> context) {
         try (Connection connection = getConnection()) {
             if (!schemaExists(connection, schema.getMetadata().getName())) {
-                connection.createStatement().execute(format("CREATE SCHEMA `%1$s` DEFAULT CHARACTER SET %2$s",
+                try (Statement statement = connection.createStatement()) {
+                    statement.execute(format("CREATE SCHEMA `%1$s` DEFAULT CHARACTER SET %2$s",
                         schema.getMetadata().getName(),
                         schema.getSpec().getEncoding()));
+                }
 
                 String password = RandomStringUtils.randomAlphanumeric(16);
                 String userName = String.format(USERNAME_FORMAT,
                         schema.getMetadata().getName());
                 String secretName = String.format(SECRET_FORMAT,
                         schema.getMetadata().getName());
-                connection.createStatement().execute(format(
-                        "CREATE USER '%1$s' IDENTIFIED BY '%2$s'",
-                        userName, password));
-                connection.createStatement().execute(format(
-                        "GRANT ALL ON `%1$s`.* TO '%2$s'",
-                        schema.getMetadata().getName(), userName));
+                try (Statement statement = connection.createStatement()) {
+                    statement.execute(format("CREATE USER '%1$s' IDENTIFIED BY '%2$s'",
+                            userName,
+                            password));
+                }
+                try (Statement statement = connection.createStatement()) {
+                    statement.execute(format("GRANT ALL ON `%1$s`.* TO '%2$s'",
+                        schema.getMetadata().getName(),
+                        userName));
+                }
                 Secret credentialsSecret = new SecretBuilder()
                         .withNewMetadata().withName(secretName).endMetadata()
                         .addToData("MYSQL_USERNAME", Base64.getEncoder().encodeToString(userName.getBytes()))
@@ -95,11 +102,17 @@ public boolean deleteResource(Schema schema, Context<Schema> context) {
 
         try (Connection connection = getConnection()) {
             if (schemaExists(connection, schema.getMetadata().getName())) {
-                connection.createStatement().execute("DROP DATABASE `" + schema.getMetadata().getName() + "`");
+                try (Statement statement = connection.createStatement()) {
+                    statement.execute(format("DROP DATABASE `%1$s`",
+                        schema.getMetadata().getName()));
+                }
                 log.info("Deleted Schema '{}'", schema.getMetadata().getName());
 
                 if (userExists(connection, schema.getStatus().getUserName())) {
-                    connection.createStatement().execute("DROP USER '" + schema.getStatus().getUserName() + "'");
+                    try (Statement statement = connection.createStatement()) {
+                        statement.execute(format("DROP USER '%1$s'",
+                            schema.getStatus().getUserName()));
+                    }
                     log.info("Deleted User '{}'", schema.getStatus().getUserName());
                 }
 
@@ -134,9 +147,10 @@ private boolean schemaExists(Connection connection, String schemaName) throws SQ
     }
 
     private boolean userExists(Connection connection, String userName) throws SQLException {
-        ResultSet resultSet = connection.createStatement().executeQuery(
-                format("SELECT User FROM mysql.user WHERE User='%1$s'", userName)
-        );
-        return resultSet.first();
+        try (Statement statement = connection.createStatement()) {
+            ResultSet resultSet = statement.executeQuery(format("SELECT User FROM mysql.user WHERE User='%1$s'",
+                userName));
+            return resultSet.first();
+        }
     }
 }