Reduce repetitive logging when using a cached connection

Author: Dugong42

src/main/java/io/confluent/connect/jdbc/util/CachedConnectionProvider.java

@@ -56,13 +56,14 @@ public synchronized Connection getConnection() {
         log.info("The database connection is invalid. Reconnecting...");
         close();
         newConnection();
+      } else {
+        log.debug("Using existing database connection.");
+        return connection;
       }
     } catch (SQLException sqle) {
       log.debug("Could not establish connection with database.", sqle);
       throw new ConnectException(sqle);
     }
-    log.info("Database connection established.");
-    return connection;
   }
 
   @Override
@@ -83,6 +84,7 @@ private void newConnection() throws SQLException {
         log.debug("Attempting to open connection #{} to {}", count, provider);
         connection = provider.getConnection();
         onConnect(connection);
+        log.info("Database connection established.");
         return;
       } catch (SQLException sqle) {
         attempts++;