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

DBZ-3752 Fix test mocks after rebase

Browse Source
This commit is contained in:
Chris Cranford 2021-07-29 05:25:55 -04:00 committed by Jiri Pechanec
parent 709a50a652
commit 492008d771
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/processor/AbstractProcessorUnitTest.java
View File

@ -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;
}