DBZ-8370 Migrate Oracle testsuite to async engine

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/AbstractOracleDatatypesTest.java

@@ -41,7 +41,7 @@
 import io.debezium.data.VariableScaleDecimal;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.jdbc.JdbcValueConverters.DecimalMode;
 import io.debezium.jdbc.TemporalPrecisionMode;
 import io.debezium.time.MicroDuration;
@@ -56,7 +56,7 @@
  *
  * @author Jiri Pechanec
  */
-public abstract class AbstractOracleDatatypesTest extends AbstractConnectorTest {
+public abstract class AbstractOracleDatatypesTest extends AbstractAsyncEngineConnectorTest {
 
     /**
      * Key for schema parameter used to store DECIMAL/NUMERIC columns' precision.

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/CustomSnapshotterIT.java

@@ -21,10 +21,10 @@
 import io.debezium.config.Configuration;
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.VerifyRecord;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
-public class CustomSnapshotterIT extends AbstractConnectorTest {
+public class CustomSnapshotterIT extends AbstractAsyncEngineConnectorTest {
 
     private static OracleConnection connection;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBinaryModeIT.java

@@ -26,14 +26,14 @@
 import io.debezium.connector.oracle.junit.SkipTestDependingOnStrategyRule;
 import io.debezium.connector.oracle.junit.SkipWhenLogMiningStrategyIs;
 import io.debezium.connector.oracle.util.TestHelper;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
  * @author Chris Cranford
  */
 @SkipWhenLogMiningStrategyIs(value = SkipWhenLogMiningStrategyIs.Strategy.HYBRID, reason = "Hybrid does not support BLOB")
-public class OracleBinaryModeIT extends AbstractConnectorTest {
+public class OracleBinaryModeIT extends AbstractAsyncEngineConnectorTest {
 
     @Rule
     public final TestRule skipStrategyRule = new SkipTestDependingOnStrategyRule();

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java

@@ -40,7 +40,7 @@
 import io.debezium.data.Envelope;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.junit.logging.LogInterceptor;
 import io.debezium.util.IoUtil;
 import io.debezium.util.Testing;
@@ -53,7 +53,7 @@
  * @author Chris Cranford
  */
 @SkipWhenLogMiningStrategyIs(value = SkipWhenLogMiningStrategyIs.Strategy.HYBRID, reason = "BLOB not supported by this mine mode")
-public class OracleBlobDataTypesIT extends AbstractConnectorTest {
+public class OracleBlobDataTypesIT extends AbstractAsyncEngineConnectorTest {
 
     private static final byte[] BIN_DATA = readBinaryData("data/test_lob_data.json");
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java

@@ -41,7 +41,7 @@
 import io.debezium.data.Envelope;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.junit.logging.LogInterceptor;
 import io.debezium.util.Testing;
 
@@ -53,7 +53,7 @@
  * @author Chris Cranford
  */
 @SkipWhenLogMiningStrategyIs(value = SkipWhenLogMiningStrategyIs.Strategy.HYBRID, reason = "Hybrid does not support CLOB")
-public class OracleClobDataTypeIT extends AbstractConnectorTest {
+public class OracleClobDataTypeIT extends AbstractAsyncEngineConnectorTest {
 
     private static final String JSON_DATA = Testing.Files.readResourceAsString("data/test_lob_data.json");
     private static final String JSON_DATA2 = Testing.Files.readResourceAsString("data/test_lob_data2.json");

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorFilterIT.java

@@ -33,15 +33,15 @@
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
  * Integration test for the Debezium Oracle connector.
  *
  * @author Gunnar Morling
  */
-public class OracleConnectorFilterIT extends AbstractConnectorTest {
+public class OracleConnectorFilterIT extends AbstractAsyncEngineConnectorTest {
 
     private static OracleConnection connection;
     private static OracleConnection adminConnection;

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java

@@ -92,8 +92,8 @@
 import io.debezium.data.VariableScaleDecimal;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
 import io.debezium.embedded.EmbeddedEngineConfig;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.heartbeat.DatabaseHeartbeatImpl;
 import io.debezium.heartbeat.Heartbeat;
 import io.debezium.jdbc.JdbcConnection;
@@ -111,7 +111,7 @@
  *
  * @author Gunnar Morling
  */
-public class OracleConnectorIT extends AbstractConnectorTest {
+public class OracleConnectorIT extends AbstractAsyncEngineConnectorTest {
     private static final Logger LOGGER = LoggerFactory.getLogger(OracleConnectorIT.class);
 
     private static final long MICROS_PER_SECOND = TimeUnit.SECONDS.toMicros(1);

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleDefaultValueIT.java

@@ -27,7 +27,7 @@
 import io.debezium.data.Envelope;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.junit.logging.LogInterceptor;
 import io.debezium.time.Interval;
 import io.debezium.time.MicroDuration;
@@ -39,7 +39,7 @@
  *
  * @author Chris Cranford
  */
-public class OracleDefaultValueIT extends AbstractConnectorTest {
+public class OracleDefaultValueIT extends AbstractAsyncEngineConnectorTest {
 
     private OracleConnection connection;
     private Consumer<Configuration.Builder> configUpdater;

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleExtendedStringIT.java

@@ -27,7 +27,7 @@
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
@@ -36,7 +36,7 @@
  * @author Chris Cranford
  */
 @SkipOnDatabaseParameter(parameterName = "max_string_size", value = "EXTENDED", matches = false, reason = "Requires max_string_size set to EXTENDED")
-public class OracleExtendedStringIT extends AbstractConnectorTest {
+public class OracleExtendedStringIT extends AbstractAsyncEngineConnectorTest {
 
     @Rule
     public TestRule skipOnDatabaseParameter = new SkipTestDependingOnDatabaseParameterRule();

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberNegativeScaleIT.java

@@ -28,15 +28,15 @@
 import io.debezium.data.SchemaAndValueField;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
  * Tests Oracle NUMBER type with negative scale.
  *
  * @author vjuranek
  */
-public class OracleNumberNegativeScaleIT extends AbstractConnectorTest {
+public class OracleNumberNegativeScaleIT extends AbstractAsyncEngineConnectorTest {
 
     private static final String PRECISION_PARAMETER_KEY = "connect.decimal.precision";
     private static final Schema NUMBER_SCHEMA = Decimal.builder(0).optional().parameter(PRECISION_PARAMETER_KEY, "38").build();

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberOneIT.java

@@ -23,15 +23,15 @@
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.Envelope.FieldName;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
  * Tests the behavior of {@code NUMBER(1)} data types.
  *
  * @author Chris Cranford
  */
-public class OracleNumberOneIT extends AbstractConnectorTest {
+public class OracleNumberOneIT extends AbstractAsyncEngineConnectorTest {
 
     private OracleConnection connection;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OraclePrimaryKeyLobReselectIT.java

@@ -27,15 +27,15 @@
 import io.debezium.data.Envelope;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 
 /**
  * Integration tests when LOB is enabled and the primary key changes, to re-select LOB columns
  * within the {@link BaseChangeRecordEmitter}.
  *
  * @author Chris Cranford
  */
-public class OraclePrimaryKeyLobReselectIT extends AbstractConnectorTest {
+public class OraclePrimaryKeyLobReselectIT extends AbstractAsyncEngineConnectorTest {
 
     @Rule
     public TestRule skipAdapterRule = new SkipTestDependingOnAdapterNameRule();

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawDataTypeIT.java

@@ -28,14 +28,14 @@
 import io.debezium.data.Envelope;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 
 /**
  * Integration tests for RAW data type support.
  *
  * @author Chris Cranford
  */
-public class OracleRawDataTypeIT extends AbstractConnectorTest {
+public class OracleRawDataTypeIT extends AbstractAsyncEngineConnectorTest {
 
     private static final int RAW_LENGTH = 2000;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawToStringIT.java

@@ -23,15 +23,15 @@
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.Envelope;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
  * Tests the behavior of the {@link io.debezium.connector.oracle.converters.RawToStringConverter}.
  *
  * @author Chris Cranford
  */
-public class OracleRawToStringIT extends AbstractConnectorTest {
+public class OracleRawToStringIT extends AbstractAsyncEngineConnectorTest {
 
     private OracleConnection connection;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRowIdDataTypeIT.java

@@ -25,14 +25,14 @@
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.Envelope;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
  * @author Chris Cranford
  */
 @SkipWhenAdapterNameIsNot(value = SkipWhenAdapterNameIsNot.AdapterName.LOGMINER, reason = "Other adapters do not support ROWID data types")
-public class OracleRowIdDataTypeIT extends AbstractConnectorTest {
+public class OracleRowIdDataTypeIT extends AbstractAsyncEngineConnectorTest {
 
     private static OracleConnection connection;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java

@@ -33,7 +33,7 @@
 import io.debezium.data.Envelope.FieldName;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.junit.logging.LogInterceptor;
 import io.debezium.pipeline.ErrorHandler;
 import io.debezium.relational.RelationalDatabaseConnectorConfig.DecimalHandlingMode;
@@ -48,7 +48,7 @@
  *
  * @author Chris Cranford
  */
-public class OracleSchemaMigrationIT extends AbstractConnectorTest {
+public class OracleSchemaMigrationIT extends AbstractAsyncEngineConnectorTest {
 
     private OracleConnection connection;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSkipMessagesWithoutChangeConfigIT.java

@@ -24,14 +24,14 @@
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.Envelope;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 
 /**
  * Integration tests for config skip.messages.without.change
  *
  * @author Ronak Jain
  */
-public class OracleSkipMessagesWithoutChangeConfigIT extends AbstractConnectorTest {
+public class OracleSkipMessagesWithoutChangeConfigIT extends AbstractAsyncEngineConnectorTest {
 
     @Rule
     public final TestRule skipAdapterRule = new SkipTestDependingOnAdapterNameRule();

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleXmlDataTypesIT.java

@@ -36,7 +36,7 @@
 import io.debezium.data.Envelope;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.relational.history.SchemaHistory;
 import io.debezium.util.Testing;
 
@@ -50,7 +50,7 @@
  * @author Chris Cranford
  */
 @SkipWhenLogMiningStrategyIs(value = SkipWhenLogMiningStrategyIs.Strategy.HYBRID, reason = "Hybrid does not support XML")
-public class OracleXmlDataTypesIT extends AbstractConnectorTest {
+public class OracleXmlDataTypesIT extends AbstractAsyncEngineConnectorTest {
 
     // Short XML files
     private static final String XML_DATA = Testing.Files.readResourceAsString("data/test_xml_data_short.xml");

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SchemaHistoryTopicIT.java

@@ -23,7 +23,7 @@
 import io.debezium.connector.oracle.OracleConnectorConfig.SnapshotMode;
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
@@ -34,7 +34,7 @@
  *
  * @author Jiri Pechanec
  */
-public class SchemaHistoryTopicIT extends AbstractConnectorTest {
+public class SchemaHistoryTopicIT extends AbstractAsyncEngineConnectorTest {
 
     private static OracleConnection connection;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SignalsIT.java

@@ -22,7 +22,7 @@
 import io.debezium.config.Configuration;
 import io.debezium.connector.oracle.OracleConnectorConfig.SnapshotMode;
 import io.debezium.connector.oracle.util.TestHelper;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.junit.EqualityCheck;
 import io.debezium.junit.SkipTestRule;
 import io.debezium.junit.SkipWhenDatabaseVersion;
@@ -34,7 +34,7 @@
  * @author Jiri Pechanec
  */
 @SkipWhenDatabaseVersion(check = EqualityCheck.GREATER_THAN_OR_EQUAL, major = 21, reason = "Not compatible, schema changes cause unexpected 'COL#' columns")
-public class SignalsIT extends AbstractConnectorTest {
+public class SignalsIT extends AbstractAsyncEngineConnectorTest {
 
     private static OracleConnection connection;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SnapshotSelectOverridesIT.java

@@ -23,15 +23,15 @@
 import io.debezium.connector.oracle.util.TestHelper;
 import io.debezium.data.Envelope;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
 /**
  * Integration test for using snapshot SELECT overrides with the Debezium Oracle connector.
  *
  * @author Chris Cranford
  */
-public class SnapshotSelectOverridesIT extends AbstractConnectorTest {
+public class SnapshotSelectOverridesIT extends AbstractAsyncEngineConnectorTest {
 
     private static final int INITIAL_RECORDS_PER_TABLE = 10;
 

debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/TransactionMetadataIT.java

@@ -25,7 +25,7 @@
 import io.debezium.data.Envelope;
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Collect;
 import io.debezium.util.Testing;
 
@@ -34,7 +34,7 @@
  *
  * @author Jiri Pechanec
  */
-public class TransactionMetadataIT extends AbstractConnectorTest {
+public class TransactionMetadataIT extends AbstractAsyncEngineConnectorTest {
 
     private static OracleConnection connection;