From 492008d7710a2a294787157dc004fae9d4ca2911 Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Thu, 29 Jul 2021 05:25:55 -0400 Subject: [PATCH] DBZ-3752 Fix test mocks after rebase --- .../oracle/logminer/processor/AbstractProcessorUnitTest.java | 4 ++++ 1 file changed, 4 insertions(+) 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 fd8bc3b25..048916add 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 @@ -8,6 +8,8 @@ import static io.debezium.config.CommonConnectorConfig.DEFAULT_MAX_BATCH_SIZE; import static io.debezium.config.CommonConnectorConfig.DEFAULT_MAX_QUEUE_SIZE; import static org.fest.assertions.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.anyString; import java.sql.Connection; import java.sql.PreparedStatement; @@ -39,6 +41,7 @@ import io.debezium.connector.oracle.logminer.events.LogMinerEventRow; import io.debezium.connector.oracle.util.TestHelper; import io.debezium.embedded.AbstractConnectorTest; +import io.debezium.jdbc.JdbcConnection; import io.debezium.pipeline.DataChangeEvent; import io.debezium.pipeline.EventDispatcher; import io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext; @@ -281,6 +284,7 @@ private OracleConnection createOracleConnection() throws Exception { OracleConnection connection = Mockito.mock(OracleConnection.class); Mockito.when(connection.connection(Mockito.anyBoolean())).thenReturn(conn); + Mockito.when(connection.singleOptionalValue(anyString(), any())).thenReturn(2.f); return connection; }