From 43cdf502ed2f00f2ee54245f430477170e99abc8 Mon Sep 17 00:00:00 2001 From: Vojtech Juranek Date: Mon, 4 Nov 2024 13:30:32 +0100 Subject: [PATCH] DBZ-8370 Migrate Oracle testsuite to async engine --- .../connector/oracle/AbstractOracleDatatypesTest.java | 4 ++-- .../io/debezium/connector/oracle/CustomSnapshotterIT.java | 4 ++-- .../java/io/debezium/connector/oracle/OracleBinaryModeIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleBlobDataTypesIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleClobDataTypeIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleConnectorFilterIT.java | 4 ++-- .../java/io/debezium/connector/oracle/OracleConnectorIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleDefaultValueIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleExtendedStringIT.java | 4 ++-- .../connector/oracle/OracleNumberNegativeScaleIT.java | 4 ++-- .../java/io/debezium/connector/oracle/OracleNumberOneIT.java | 4 ++-- .../connector/oracle/OraclePrimaryKeyLobReselectIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleRawDataTypeIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleRawToStringIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleRowIdDataTypeIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleSchemaMigrationIT.java | 4 ++-- .../oracle/OracleSkipMessagesWithoutChangeConfigIT.java | 4 ++-- .../io/debezium/connector/oracle/OracleXmlDataTypesIT.java | 4 ++-- .../io/debezium/connector/oracle/SchemaHistoryTopicIT.java | 4 ++-- .../src/test/java/io/debezium/connector/oracle/SignalsIT.java | 4 ++-- .../debezium/connector/oracle/SnapshotSelectOverridesIT.java | 4 ++-- .../io/debezium/connector/oracle/TransactionMetadataIT.java | 4 ++-- .../debezium/connector/oracle/logminer/FlushStrategyIT.java | 4 ++-- .../connector/oracle/logminer/HybridMiningStrategyIT.java | 4 ++-- .../connector/oracle/logminer/LogFileCollectorIT.java | 4 ++-- .../oracle/logminer/LogMinerSourceInfoRedoSqlIT.java | 4 ++-- .../oracle/logminer/TransactionCommitConsumerIT.java | 4 ++-- .../oracle/logminer/processor/AbstractProcessorTest.java | 4 ++-- .../oracle/logminer/processor/AbstractProcessorUnitTest.java | 4 ++-- 29 files changed, 58 insertions(+), 58 deletions(-) diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/AbstractOracleDatatypesTest.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/AbstractOracleDatatypesTest.java index b047fdd104e..fae67e49a22 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/AbstractOracleDatatypesTest.java +++ b/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. diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/CustomSnapshotterIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/CustomSnapshotterIT.java index 252ac75c327..d7a0a3e7275 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/CustomSnapshotterIT.java +++ b/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; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBinaryModeIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBinaryModeIT.java index 897cee6546f..4d4f2881610 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBinaryModeIT.java +++ b/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(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java index 6e30c2097c9..75d7a225273 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java +++ b/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"); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java index 21634ebe8d9..f3c7fbb3ed9 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java +++ b/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"); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorFilterIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorFilterIT.java index 3b9e87e62a3..ed385dd111d 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorFilterIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorFilterIT.java @@ -33,7 +33,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; /** @@ -41,7 +41,7 @@ * * @author Gunnar Morling */ -public class OracleConnectorFilterIT extends AbstractConnectorTest { +public class OracleConnectorFilterIT extends AbstractAsyncEngineConnectorTest { private static OracleConnection connection; private static OracleConnection adminConnection; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java index 35c1ee0f75b..aacff606413 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleConnectorIT.java +++ b/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); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleDefaultValueIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleDefaultValueIT.java index 4bc2773803d..4590f3b5022 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleDefaultValueIT.java +++ b/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 configUpdater; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleExtendedStringIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleExtendedStringIT.java index 0448ca65469..c79acccaa28 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleExtendedStringIT.java +++ b/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(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberNegativeScaleIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberNegativeScaleIT.java index d1e53308776..7b393cd9c28 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberNegativeScaleIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberNegativeScaleIT.java @@ -28,7 +28,7 @@ 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; /** @@ -36,7 +36,7 @@ * * @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(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberOneIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberOneIT.java index af2ea5748bf..0c8a5907306 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberOneIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleNumberOneIT.java @@ -23,7 +23,7 @@ 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; /** @@ -31,7 +31,7 @@ * * @author Chris Cranford */ -public class OracleNumberOneIT extends AbstractConnectorTest { +public class OracleNumberOneIT extends AbstractAsyncEngineConnectorTest { private OracleConnection connection; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OraclePrimaryKeyLobReselectIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OraclePrimaryKeyLobReselectIT.java index 23e77734b2b..191c9d6794c 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OraclePrimaryKeyLobReselectIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OraclePrimaryKeyLobReselectIT.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; /** * Integration tests when LOB is enabled and the primary key changes, to re-select LOB columns @@ -35,7 +35,7 @@ * * @author Chris Cranford */ -public class OraclePrimaryKeyLobReselectIT extends AbstractConnectorTest { +public class OraclePrimaryKeyLobReselectIT extends AbstractAsyncEngineConnectorTest { @Rule public TestRule skipAdapterRule = new SkipTestDependingOnAdapterNameRule(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawDataTypeIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawDataTypeIT.java index 33140d384ec..7aa51ffe6d9 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawDataTypeIT.java +++ b/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; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawToStringIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawToStringIT.java index ad4172928ba..e59f8b26cd6 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawToStringIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRawToStringIT.java @@ -23,7 +23,7 @@ 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; /** @@ -31,7 +31,7 @@ * * @author Chris Cranford */ -public class OracleRawToStringIT extends AbstractConnectorTest { +public class OracleRawToStringIT extends AbstractAsyncEngineConnectorTest { private OracleConnection connection; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRowIdDataTypeIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRowIdDataTypeIT.java index c2994f476f9..9d2b0055f29 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleRowIdDataTypeIT.java +++ b/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; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java index a9f2611db8e..a1ee76250a3 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java +++ b/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; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSkipMessagesWithoutChangeConfigIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSkipMessagesWithoutChangeConfigIT.java index 5b64d27b917..2643a7aef9e 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSkipMessagesWithoutChangeConfigIT.java +++ b/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(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleXmlDataTypesIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleXmlDataTypesIT.java index 8b53af395e9..6859244777a 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleXmlDataTypesIT.java +++ b/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"); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SchemaHistoryTopicIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SchemaHistoryTopicIT.java index 68026390ac1..dbdde4ee2ae 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SchemaHistoryTopicIT.java +++ b/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; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SignalsIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SignalsIT.java index d5cf660e932..981f52bafe0 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SignalsIT.java +++ b/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; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SnapshotSelectOverridesIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SnapshotSelectOverridesIT.java index 5a123668f09..6b67479872b 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SnapshotSelectOverridesIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/SnapshotSelectOverridesIT.java @@ -23,7 +23,7 @@ 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; /** @@ -31,7 +31,7 @@ * * @author Chris Cranford */ -public class SnapshotSelectOverridesIT extends AbstractConnectorTest { +public class SnapshotSelectOverridesIT extends AbstractAsyncEngineConnectorTest { private static final int INITIAL_RECORDS_PER_TABLE = 10; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/TransactionMetadataIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/TransactionMetadataIT.java index be9db3853c3..6230dbee1be 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/TransactionMetadataIT.java +++ b/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; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/FlushStrategyIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/FlushStrategyIT.java index 3362d7e52a1..5edb9821436 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/FlushStrategyIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/FlushStrategyIT.java @@ -30,7 +30,7 @@ import io.debezium.connector.oracle.logminer.logwriter.CommitLogWriterFlushStrategy; 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.junit.logging.LogInterceptor; import io.debezium.relational.TableId; import io.debezium.util.Strings; @@ -41,7 +41,7 @@ */ @SkipWhenAdapterNameIsNot(value = SkipWhenAdapterNameIsNot.AdapterName.LOGMINER, reason = "Flush strategy only applies to LogMiner implementation") @SkipOnReadOnly(reason = "Test expects flush table, not applicable during read only.") -public class FlushStrategyIT extends AbstractConnectorTest { +public class FlushStrategyIT extends AbstractAsyncEngineConnectorTest { @Rule public final TestRule skipAdapterRule = new SkipTestDependingOnAdapterNameRule(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/HybridMiningStrategyIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/HybridMiningStrategyIT.java index 0bf328cd5ba..7bff89739b3 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/HybridMiningStrategyIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/HybridMiningStrategyIT.java @@ -51,9 +51,9 @@ import io.debezium.data.Envelope; import io.debezium.data.VariableScaleDecimal; import io.debezium.doc.FixFor; -import io.debezium.embedded.AbstractConnectorTest; import io.debezium.embedded.EmbeddedEngineConfig; import io.debezium.embedded.KafkaConnectUtil; +import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest; import io.debezium.jdbc.TemporalPrecisionMode; import io.debezium.junit.SkipLongRunning; import io.debezium.junit.SkipTestRule; @@ -76,7 +76,7 @@ * @author Chris Cranford */ @SkipWhenAdapterNameIsNot(value = SkipWhenAdapterNameIsNot.AdapterName.LOGMINER, reason = "Only applies to LogMiner") -public class HybridMiningStrategyIT extends AbstractConnectorTest { +public class HybridMiningStrategyIT extends AbstractAsyncEngineConnectorTest { @Rule public final TestRule skipApicurioRule = new SkipTestWhenRunWithApicurioRule(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogFileCollectorIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogFileCollectorIT.java index 7e6741c9494..af4b51fa594 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogFileCollectorIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogFileCollectorIT.java @@ -33,7 +33,7 @@ import io.debezium.connector.oracle.junit.SkipWhenAdapterNameIsNot; 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.Strings; import io.debezium.util.Testing; @@ -43,7 +43,7 @@ * @author Chris Cranford */ @SkipWhenAdapterNameIsNot(value = SkipWhenAdapterNameIsNot.AdapterName.LOGMINER, reason = "LogMiner specific") -public class LogFileCollectorIT extends AbstractConnectorTest { +public class LogFileCollectorIT extends AbstractAsyncEngineConnectorTest { @Rule public final TestRule skipAdapterRule = new SkipTestDependingOnAdapterNameRule(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogMinerSourceInfoRedoSqlIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogMinerSourceInfoRedoSqlIT.java index 3395aa90e29..290b96bc039 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogMinerSourceInfoRedoSqlIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/LogMinerSourceInfoRedoSqlIT.java @@ -31,7 +31,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.Testing; /** @@ -40,7 +40,7 @@ * @author Chris Cranford */ @SkipWhenAdapterNameIsNot(value = SkipWhenAdapterNameIsNot.AdapterName.LOGMINER, reason = "Requires LogMiner") -public class LogMinerSourceInfoRedoSqlIT extends AbstractConnectorTest { +public class LogMinerSourceInfoRedoSqlIT extends AbstractAsyncEngineConnectorTest { @Rule public final TestRule skipAdapterRule = new SkipTestDependingOnAdapterNameRule(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/TransactionCommitConsumerIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/TransactionCommitConsumerIT.java index 6924e9578c6..7aec68aec26 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/TransactionCommitConsumerIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/TransactionCommitConsumerIT.java @@ -28,14 +28,14 @@ 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; /** * @author Chris Cranford */ @SkipWhenAdapterNameIsNot(SkipWhenAdapterNameIsNot.AdapterName.LOGMINER) @SkipWhenLogMiningStrategyIs(value = SkipWhenLogMiningStrategyIs.Strategy.HYBRID, reason = "Cannot use lob.enabled with Hybrid") -public class TransactionCommitConsumerIT extends AbstractConnectorTest { +public class TransactionCommitConsumerIT extends AbstractAsyncEngineConnectorTest { @Rule public final TestRule skipAdapterRule = new SkipTestDependingOnAdapterNameRule(); diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorTest.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorTest.java index adb06b5d548..04fb88da967 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorTest.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorTest.java @@ -27,7 +27,7 @@ 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.junit.logging.LogInterceptor; import io.debezium.util.Testing; @@ -37,7 +37,7 @@ * * @author Chris Cranford */ -public abstract class AbstractProcessorTest extends AbstractConnectorTest { +public abstract class AbstractProcessorTest extends AbstractAsyncEngineConnectorTest { private OracleConnection connection; diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorUnitTest.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorUnitTest.java index ae71dc395d0..e241a832d19 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorUnitTest.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorUnitTest.java @@ -46,7 +46,7 @@ import io.debezium.connector.oracle.logminer.events.LogMinerEventRow; 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.pipeline.DataChangeEvent; import io.debezium.pipeline.EventDispatcher; import io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext; @@ -64,7 +64,7 @@ * * @author Chris Cranford */ -public abstract class AbstractProcessorUnitTest extends AbstractConnectorTest { +public abstract class AbstractProcessorUnitTest extends AbstractAsyncEngineConnectorTest { private static final String TRANSACTION_ID_1 = "1234567890"; private static final String TRANSACTION_ID_2 = "9876543210";