|
|
|
@ -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);
|
|
|
|
|