[Bug] [Seatunnel-web] No configuration setting found for key 'where_c…

……ondition' (#240)
apache · Nov 11, 2024 · d11f6c5 · d11f6c5
1 parent 53b5de8
commit d11f6c5
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...org/apache/seatunnel/app/thirdparty/datasource/impl/BaseJdbcDataSourceConfigSwitcher.java b/...org/apache/seatunnel/app/thirdparty/datasource/impl/BaseJdbcDataSourceConfigSwitcher.java
@@ -139,12 +139,12 @@ public Config mergeDatasourceConfig(
                 List<String> tableFields = selectTableFields.getTableFields();
 
                 String sql = tableFieldsToSql(tableFields, databaseName, tableName);
-
-                String where_condition = connectorConfig.getString(WHERE_CONDITION);
-
-                if (where_condition != null && !where_condition.isEmpty()) {
-                    sql = sql + " " + where_condition;
-                    connectorConfig = connectorConfig.withoutPath(WHERE_CONDITION);
+                if (connectorConfig.hasPath(WHERE_CONDITION)) {
+                    String where_condition = connectorConfig.getString(WHERE_CONDITION);
+                    if (where_condition != null && !where_condition.isEmpty()) {
+                        sql = sql + " " + where_condition;
+                        connectorConfig = connectorConfig.withoutPath(WHERE_CONDITION);
+                    }
                 }
 
                 connectorConfig =