@@ -103,21 +103,6 @@ public static class OracleSourceConfig extends AbstractDBSpecificSourceConfig {
103103 @ Description ("The existing connection to use." )
104104 private OracleConnectorConfig connection ;
105105
106- @ Name (OracleConstants .ROLE )
107- @ Description ("Login role of the user when connecting to the database." )
108- @ Nullable
109- private String role ;
110-
111- @ Name (OracleConstants .NAME_DATABASE )
112- @ Description ("SID or Service Name to connect to" )
113- @ Nullable
114- private String database ;
115-
116- @ Name (OracleConstants .TRANSACTION_ISOLATION_LEVEL )
117- @ Description ("The transaction isolation level for the database session." )
118- @ Nullable
119- private String transactionIsolationLevel ;
120-
121106 @ Name (OracleConstants .DEFAULT_BATCH_VALUE )
122107 @ Description ("The default batch value that triggers an execution request." )
123108 @ Nullable
@@ -128,18 +113,6 @@ public static class OracleSourceConfig extends AbstractDBSpecificSourceConfig {
128113 @ Nullable
129114 private Integer defaultRowPrefetch ;
130115
131- public OracleSourceConfig (String host , int port , String user , String password , String jdbcPluginName ,
132- String connectionArguments , String connectionType , String role , String database ,
133- String transactionIsolationLevel , int defaultBatchValue , int defaultRowPrefetch ) {
134- this .connection = new OracleConnectorConfig (host , port , user , password , jdbcPluginName , connectionArguments ,
135- connectionType );
136- this .role = role ;
137- this .database = database ;
138- this .transactionIsolationLevel = transactionIsolationLevel ;
139- this .defaultBatchValue = defaultBatchValue ;
140- this .defaultRowPrefetch = defaultRowPrefetch ;
141- }
142-
143116 @ Override
144117 public String getConnectionString () {
145118 if (OracleConstants .TNS_CONNECTION_TYPE .equals (connection .getConnectionType ())) {
0 commit comments