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

DBZ-3086 Legacy source info make for legacy tests

Browse Source
This commit is contained in:
Jiri Pechanec 2021-02-11 17:12:19 +01:00 committed by Gunnar Morling
parent f01af4bec8
commit 5bf5e18d81
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/legacy/BinlogReaderIT.java
View File

@ -36,6 +36,7 @@
import io.debezium.config.CommonConnectorConfig.EventProcessingFailureHandlingMode;
import io.debezium.config.Configuration;
import io.debezium.connector.mysql.MySQLConnection;
import io.debezium.connector.mysql.MySqlConnector;
import io.debezium.connector.mysql.MySqlConnectorConfig;
import io.debezium.connector.mysql.MySqlConnectorConfig.SecureConnectionMode;
import io.debezium.connector.mysql.UniqueDatabase;
@ -141,7 +142,8 @@ protected Configuration.Builder simpleConfig() {
.with(MySqlConnectorConfig.USER, "replicator")
.with(MySqlConnectorConfig.PASSWORD, "replpass")
.with(MySqlConnectorConfig.INCLUDE_SCHEMA_CHANGES, false)
.with(MySqlConnectorConfig.INCLUDE_SQL_QUERY, false);
.with(MySqlConnectorConfig.INCLUDE_SQL_QUERY, false)
.with(MySqlConnector.IMPLEMENTATION_PROP, MySqlConnector.LEGACY_IMPLEMENTATION);
}
@Test

4
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/legacy/SnapshotReaderIT.java
View File

@ -33,6 +33,7 @@
import io.debezium.config.Configuration;
import io.debezium.config.Configuration.Builder;
import io.debezium.connector.mysql.MySQLConnection;
import io.debezium.connector.mysql.MySqlConnector;
import io.debezium.connector.mysql.MySqlConnectorConfig;
import io.debezium.connector.mysql.UniqueDatabase;
import io.debezium.data.KeyValueStore;
@ -102,7 +103,8 @@ protected Configuration.Builder simpleConfig() {
.with(MySqlConnectorConfig.SNAPSHOT_LOCKING_MODE, MySqlConnectorConfig.SnapshotLockingMode.MINIMAL)
// Explicitly enable INCLUDE_SQL_QUERY connector option. For snapshots it should have no effect as
// source query should not included in snapshot events.
.with(MySqlConnectorConfig.INCLUDE_SQL_QUERY, true);
.with(MySqlConnectorConfig.INCLUDE_SQL_QUERY, true)
.with(MySqlConnector.IMPLEMENTATION_PROP, MySqlConnector.LEGACY_IMPLEMENTATION);
}
@Test