From b13021cc7fc391dcd2f2aa0042e1c15d9a55645b Mon Sep 17 00:00:00 2001
From: NOZAIS Julien <julien1.nozais.ext@orange.com>
Date: Fri, 28 Mar 2025 16:30:02 +0100
Subject: [PATCH] Reduce repetitive logging when using a cached connection

---
 .../confluent/connect/jdbc/util/CachedConnectionProvider.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/io/confluent/connect/jdbc/util/CachedConnectionProvider.java b/src/main/java/io/confluent/connect/jdbc/util/CachedConnectionProvider.java
index e8863e88a8..81eb932f4f 100644
--- a/src/main/java/io/confluent/connect/jdbc/util/CachedConnectionProvider.java
+++ b/src/main/java/io/confluent/connect/jdbc/util/CachedConnectionProvider.java
@@ -56,12 +56,13 @@ public synchronized Connection getConnection() {
         log.info("The database connection is invalid. Reconnecting...");
         close();
         newConnection();
+      } else {
+        log.debug("Using existing database connection.");
       }
     } catch (SQLException sqle) {
       log.debug("Could not establish connection with database.", sqle);
       throw new ConnectException(sqle);
     }
-    log.debug("Database connection established.");
     return connection;
   }
 
@@ -82,6 +83,7 @@ private void newConnection() throws SQLException {
         ++count;
         log.debug("Attempting to open connection #{} to {}", count, provider);
         connection = provider.getConnection();
+        log.info("Database connection established.");
         onConnect(connection);
         return;
       } catch (SQLException sqle) {