improve: additional logging to mysql schema e2e test (#2320)

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

sample-operators/leader-election/pom.xml

@@ -33,6 +33,12 @@
     <dependency>
       <groupId>org.apache.logging.log4j</groupId>
       <artifactId>log4j-slf4j-impl</artifactId>
+      <scope>compile</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.logging.log4j</groupId>
+      <artifactId>log4j-core</artifactId>
+      <scope>compile</scope>
     </dependency>
     <dependency>
       <groupId>org.takes</groupId>

sample-operators/mysql-schema/pom.xml

@@ -53,6 +53,11 @@
       <groupId>org.apache.logging.log4j</groupId>
       <artifactId>log4j-slf4j-impl</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.apache.logging.log4j</groupId>
+      <artifactId>log4j-core</artifactId>
+      <scope>compile</scope>
+    </dependency>
     <dependency>
       <groupId>org.junit.jupiter</groupId>
       <artifactId>junit-jupiter-api</artifactId>

sample-operators/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/dependent/SchemaDependentResource.java

@@ -30,7 +30,7 @@
 import static io.javaoperatorsdk.operator.sample.dependent.SecretDependentResource.MYSQL_SECRET_USERNAME;
 import static java.lang.String.format;
 
-@SchemaConfig(pollPeriod = 700, host = "127.0.0.1",
+@SchemaConfig(pollPeriod = 400, host = "127.0.0.1",
     port = SchemaDependentResource.LOCAL_PORT,
     user = "root", password = "password") // NOSONAR: password is only used locally, example only
 @Configured(by = SchemaConfig.class, with = ResourcePollerConfig.class,
@@ -63,7 +63,9 @@ public void configureWith(ResourcePollerConfig config) {
 
   @Override
   public Schema desired(MySQLSchema primary, Context<MySQLSchema> context) {
-    return new Schema(primary.getMetadata().getName(), primary.getSpec().getEncoding());
+    var desired = new Schema(primary.getMetadata().getName(), primary.getSpec().getEncoding());
+    log.debug("Desired schema: {}", desired);
+    return desired;
   }
 
   @Override
@@ -72,6 +74,7 @@ public Schema create(Schema target, MySQLSchema mySQLSchema, Context<MySQLSchema
       Secret secret = context.getSecondaryResource(Secret.class).orElseThrow();
       var username = decode(secret.getData().get(MYSQL_SECRET_USERNAME));
       var password = decode(secret.getData().get(MYSQL_SECRET_PASSWORD));
+      log.debug("Creating schema: {}", target);
       return SchemaService.createSchemaAndRelatedUser(
           connection,
           target.getName(),
@@ -107,8 +110,10 @@ public static String decode(String value) {
   @Override
   public Set<Schema> fetchResources(MySQLSchema primaryResource) {
     try (Connection connection = getConnection()) {
-      return SchemaService.getSchema(connection, primaryResource.getMetadata().getName())
+      var schema = SchemaService.getSchema(connection, primaryResource.getMetadata().getName())
           .map(Set::of).orElseGet(Collections::emptySet);
+      log.debug("Fetched schema: {}", schema);
+      return schema;
     } catch (SQLException e) {
       throw new RuntimeException("Error while trying read Schema", e);
     }

sample-operators/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/schema/Schema.java

@@ -28,11 +28,19 @@ public boolean equals(Object o) {
     if (o == null || getClass() != o.getClass())
       return false;
     Schema schema = (Schema) o;
-    return Objects.equals(name, schema.name) && Objects.equals(characterSet, schema.characterSet);
+    return Objects.equals(name, schema.name);
   }
 
   @Override
   public int hashCode() {
     return Objects.hash(name, characterSet);
   }
+
+  @Override
+  public String toString() {
+    return "Schema{" +
+        "name='" + name + '\'' +
+        ", characterSet='" + characterSet + '\'' +
+        '}';
+  }
 }

sample-operators/tomcat-operator/pom.xml

@@ -49,6 +49,11 @@
       <groupId>org.apache.logging.log4j</groupId>
       <artifactId>log4j-slf4j-impl</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.apache.logging.log4j</groupId>
+      <artifactId>log4j-core</artifactId>
+      <scope>compile</scope>
+    </dependency>
     <dependency>
       <groupId>org.takes</groupId>
       <artifactId>takes</artifactId>

sample-operators/webpage/pom.xml

@@ -34,6 +34,11 @@
       <groupId>org.apache.logging.log4j</groupId>
       <artifactId>log4j-slf4j-impl</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.apache.logging.log4j</groupId>
+      <artifactId>log4j-core</artifactId>
+      <scope>compile</scope>
+    </dependency>
     <dependency>
       <groupId>org.takes</groupId>
       <artifactId>takes</artifactId>