alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-3268 Remove unused code

Browse Source
This commit is contained in:
Chris Cranford 2021-03-18 16:19:36 -04:00 committed by Gunnar Morling
parent fae784001e
commit a8a22bd828
2 changed files with 2 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java
View File

@ -12,7 +12,6 @@
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Types;
import java.time.ZoneOffset;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
@ -38,7 +37,6 @@
import io.debezium.relational.Tables;
import io.debezium.relational.Tables.ColumnNameFilter;
import io.debezium.relational.Tables.TableFilter;
import io.debezium.util.Strings;
import oracle.jdbc.OracleTypes;
@ -362,24 +360,6 @@ public OracleConnection executeLegacy(Operations operations) throws SQLException
return this;
}
public ZoneOffset getDatabaseOffset() {
try {
final String offset = queryAndMap("SELECT DBTIMEZONE FROM DUAL", rs -> {
if (rs.next()) {
return rs.getString(1);
}
return null;
});
if (!Strings.isNullOrEmpty(offset)) {
return ZoneOffset.of(offset);
}
return null;
}
catch (SQLException e) {
throw new RuntimeException("Failed to obtain database timezone offset", e);
}
}
public static String connectionString(Configuration config) {
return config.getString(URL) != null ? config.getString(URL)
: ConnectorAdapter.parse(config.getString("connection.adapter")).getConnectionUrl();

4
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/xstream/XstreamStreamingChangeEventSource.java
View File

@ -81,10 +81,10 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
: convertScnToPosition(offsetContext.getScn());
xsOut = XStreamOut.attach((oracle.jdbc.OracleConnection) xsConnection.connection(), xStreamServerName,
startPosition, 1, 1, XStreamOut.DEFAULT_MODE);
startPosition, 1, 1, XStreamOut.DEFAULT_MODE);
LcrEventHandler handler = new LcrEventHandler(errorHandler, dispatcher, clock, schema, offsetContext,
this.tablenameCaseInsensitive, this);
this.tablenameCaseInsensitive, this);
// 2. receive events while running
while (context.isRunning()) {