diff --git a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleValidator.java b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleValidator.java index 34929cc0a..220ce9464 100644 --- a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleValidator.java +++ b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/OracleValidator.java @@ -19,7 +19,7 @@ package com.ververica.cdc.connectors.oracle; import org.apache.flink.table.api.TableException; import org.apache.flink.table.api.ValidationException; -import com.ververica.cdc.connectors.oracle.util.JdbcConfigurationUtil; +import com.ververica.cdc.connectors.oracle.util.OracleJdbcUrlUtils; import com.ververica.cdc.debezium.Validator; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -64,7 +64,7 @@ public class OracleValidator implements Validator { public static Connection openConnection(Properties properties) throws SQLException { DriverManager.registerDriver(new oracle.jdbc.OracleDriver()); - String url = JdbcConfigurationUtil.getConnectionUrlWithSid(properties); + String url = OracleJdbcUrlUtils.getConnectionUrlWithSid(properties); String userName = properties.getProperty("database.user"); String userpwd = properties.getProperty("database.password"); return DriverManager.getConnection(url, userName, userpwd); diff --git a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/JdbcConfigurationUtil.java b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java similarity index 92% rename from flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/JdbcConfigurationUtil.java rename to flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java index adf28f1d4..2d60bc260 100644 --- a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/JdbcConfigurationUtil.java +++ b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java @@ -20,8 +20,8 @@ package com.ververica.cdc.connectors.oracle.util; import java.util.Properties; -/** Get the JDBC configuration utility class according to debezium properties. */ -public class JdbcConfigurationUtil { +/** The utils to build the JDBC connection url for Oracle data source. */ +public class OracleJdbcUrlUtils { /** * Gets the URL in SID format.