From 39e5deb67db56d37be821079d83be9da70dc97bb Mon Sep 17 00:00:00 2001
From: KGaneshDatta <kdatta@confluent.io>
Date: Fri, 21 Nov 2025 13:23:12 +0530
Subject: [PATCH] Minor:Fix Table Mode Validation

---
 .../jdbc/validation/JdbcSourceConnectorValidation.java    | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/main/java/io/confluent/connect/jdbc/validation/JdbcSourceConnectorValidation.java b/src/main/java/io/confluent/connect/jdbc/validation/JdbcSourceConnectorValidation.java
index b5445287e..a34b2485e 100644
--- a/src/main/java/io/confluent/connect/jdbc/validation/JdbcSourceConnectorValidation.java
+++ b/src/main/java/io/confluent/connect/jdbc/validation/JdbcSourceConnectorValidation.java
@@ -155,6 +155,10 @@ private boolean validateMultiConfigs() {
    * Implements the pattern: legacyKeys vs newKeys with early returns.
    */
   private boolean validateLegacyNewConfigCompatibility() {
+    String query = config.getString(JdbcSourceConnectorConfig.QUERY_CONFIG);
+    if (query != null && !query.trim().isEmpty()) {
+      return true;
+    }
     // Define legacy and new config keys
     boolean usingLegacyConfigs = isUsingLegacyConfigs();
     boolean usingNewConfigs = isUsingNewConfigs();
@@ -273,6 +277,10 @@ private boolean addConfigErrorsForLegacyAndNewConfigConflict() {
    * Validate that at least one configuration is provided.
    */
   private boolean addConfigErrorsForNoConfigProvided() {
+    String query = config.getString(JdbcSourceConnectorConfig.QUERY_CONFIG);
+    if (query != null && !query.trim().isEmpty()) {
+      return true;
+    }
     String msg = "At least one table filtering configuration is required. "
         + "Provide one of: " + JdbcSourceConnectorConfig.TABLE_WHITELIST_CONFIG + ", "
         + JdbcSourceConnectorConfig.TABLE_BLACKLIST_CONFIG + ", "