flaky test

Author: Columpio

core/src/main/java/io/aiven/klaw/service/DataBaseConnectivitySettingsService.java

@@ -0,0 +1,26 @@
+package io.aiven.klaw.service;
+
+public class DataBaseConnectivitySettingsService {
+    private static String globalConnectionString = "jdbc:mysql://localhost:3306/default_db";
+    private static final String DEFAULT_CONNECTION_STRING = "jdbc:mysql://localhost:3306/default_db";
+
+    public static String obtainActualConnectionString() {
+        return globalConnectionString;
+    }
+
+    public static void performConnectionStringUpdate(String newConnectionString) {
+        if (newConnectionString != null && !newConnectionString.isBlank()) {
+            globalConnectionString = newConnectionString;
+        } else {
+            throw new IllegalArgumentException("Provided connection string is invalid!");
+        }
+    }
+
+    public static void resetConnectionStringToDefault() {
+        globalConnectionString = DEFAULT_CONNECTION_STRING;
+    }
+
+    public static boolean isUsingDefaultConnectionString() {
+        return DEFAULT_CONNECTION_STRING.equals(globalConnectionString);
+    }
+}

core/src/test/java/io/aiven/klaw/service/DataBaseConnectivitySettingsServiceTest.java

@@ -0,0 +1,40 @@
+package io.aiven.klaw.service;
+
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class DataBaseConnectivitySettingsServiceTest {
+
+    @Test
+    public void returnDefaultConnectionStringInitially() {
+        assertTrue(DataBaseConnectivitySettingsService.isUsingDefaultConnectionString());
+    }
+
+    @Test
+    public void updateConnectionStringSuccessfully() {
+        DataBaseConnectivitySettingsService.performConnectionStringUpdate("jdbc:mysql://localhost:3306/test_db");
+        assertEquals("jdbc:mysql://localhost:3306/test_db",
+                DataBaseConnectivitySettingsService.obtainActualConnectionString());
+    }
+
+    @Test
+    public void throwExceptionWhenConnectionStringIsInvalid() {
+        Exception exception = assertThrows(IllegalArgumentException.class, () -> {
+            DataBaseConnectivitySettingsService.performConnectionStringUpdate("");
+        });
+        assertEquals("Provided connection string is invalid!", exception.getMessage());
+    }
+
+    @Test
+    public void resetConnectionStringToDefault() {
+        DataBaseConnectivitySettingsService.performConnectionStringUpdate("jdbc:mysql://localhost:3306/another_db");
+
+        DataBaseConnectivitySettingsService.resetConnectionStringToDefault();
+
+        assertTrue(DataBaseConnectivitySettingsService.isUsingDefaultConnectionString());
+    }
+}