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

DBZ-7693 Binlog test to MySQL test suite

Browse Source
This commit is contained in:
Chris Cranford 2024-04-01 11:54:04 -04:00 committed by Jiri Pechanec
parent 317bd68f10
commit 57384e6196
2 changed files with 19 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogReadOnlyIncrementalSnapshotIT.java
View File

@ -19,14 +19,12 @@
import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;
import org.apache.kafka.connect.data.Struct;
import org.apache.kafka.connect.errors.ConnectException;
import org.apache.kafka.connect.source.SourceConnector;
import org.apache.kafka.connect.source.SourceRecord;
import org.awaitility.Awaitility;
@ -38,7 +36,6 @@
import io.debezium.config.CommonConnectorConfig;
import io.debezium.config.Configuration;
import io.debezium.connector.binlog.junit.SkipWhenGtidModeIs;
import io.debezium.doc.FixFor;
import io.debezium.jdbc.JdbcConnection;
import io.debezium.junit.ConditionalFail;
@ -272,21 +269,6 @@ record -> ((Struct) record.value()).getStruct("after").getInt32(valueFieldName()
}
}
@Test(expected = ConnectException.class)
@SkipWhenGtidModeIs(value = SkipWhenGtidModeIs.GtidMode.ON, reason = "Read only connection requires GTID_MODE to be ON")
public void shouldFailIfGtidModeIsOff() throws Exception {
// Testing.Print.enable();
populateTable();
AtomicReference<Throwable> exception = new AtomicReference<>();
startConnector((success, message, error) -> exception.set(error));
waitForEngineShutdown();
stopConnector();
final Throwable e = exception.get();
if (e != null) {
throw (RuntimeException) e;
}
}
@Test
@FixFor("DBZ-5453")
@Flaky("DBZ-7572")

19
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/ReadOnlyIncrementalSnapshotIT.java
View File

@ -5,7 +5,11 @@
*/
package io.debezium.connector.mysql;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.kafka.connect.errors.ConnectException;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.TestRule;
import io.debezium.connector.binlog.BinlogReadOnlyIncrementalSnapshotIT;
@ -23,4 +27,19 @@ public class ReadOnlyIncrementalSnapshotIT extends BinlogReadOnlyIncrementalSnap
protected Class<?> getFieldReader() {
return MySqlBinaryProtocolFieldReader.class;
}
@Test(expected = ConnectException.class)
@SkipWhenGtidModeIs(value = SkipWhenGtidModeIs.GtidMode.ON, reason = "Read only connection requires GTID_MODE to be ON")
public void shouldFailIfGtidModeIsOff() throws Exception {
// Testing.Print.enable();
populateTable();
AtomicReference<Throwable> exception = new AtomicReference<>();
startConnector((success, message, error) -> exception.set(error));
waitForEngineShutdown();
stopConnector();
final Throwable e = exception.get();
if (e != null) {
throw (RuntimeException) e;
}
}
}