From a8a22bd828e3bd30da42a150603b5dbacd797195 Mon Sep 17 00:00:00 2001
From: Chris Cranford <chris@hibernate.org>
Date: Thu, 18 Mar 2021 16:19:36 -0400
Subject: [PATCH] DBZ-3268 Remove unused code

---
 .../connector/oracle/OracleConnection.java    | 20 -------------------
 .../XstreamStreamingChangeEventSource.java    |  4 ++--
 2 files changed, 2 insertions(+), 22 deletions(-)

diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java
index eb611b34d..e2b145b8c 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java
@@ -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();
diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/xstream/XstreamStreamingChangeEventSource.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/xstream/XstreamStreamingChangeEventSource.java
index a7cd928ba..ed01b1681 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/xstream/XstreamStreamingChangeEventSource.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/xstream/XstreamStreamingChangeEventSource.java
@@ -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()) {