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

DBZ-2663 | Updated with checkstyle fixes.

Browse Source 
More Ref:
https://debezium.zulipchat.com/#narrow/stream/302533-dev/topic/Handling.20Transaction.20Payload.20Events.20for.20Mysql/near/289650440
https://github.com/osheroff/mysql-binlog-connector-java/pull/76#issuecomment-1185629635
This commit is contained in:
debjeetsarkar 2022-08-08 21:36:04 +02:00 committed by Jiri Pechanec
parent f41474847d
commit b824c138db
3 changed files with 19 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
View File

@ -53,9 +53,9 @@
import com.github.shyiko.mysql.binlog.event.RotateEventData; import com.github.shyiko.mysql.binlog.event.RotateEventData;
import com.github.shyiko.mysql.binlog.event.RowsQueryEventData; import com.github.shyiko.mysql.binlog.event.RowsQueryEventData;
import com.github.shyiko.mysql.binlog.event.TableMapEventData; import com.github.shyiko.mysql.binlog.event.TableMapEventData;
import com.github.shyiko.mysql.binlog.event.TransactionPayloadEventData;
import com.github.shyiko.mysql.binlog.event.UpdateRowsEventData; import com.github.shyiko.mysql.binlog.event.UpdateRowsEventData;
import com.github.shyiko.mysql.binlog.event.WriteRowsEventData; import com.github.shyiko.mysql.binlog.event.WriteRowsEventData;
import com.github.shyiko.mysql.binlog.event.TransactionPayloadEventData;
import com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException; import com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException;
import com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer; import com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer;
import com.github.shyiko.mysql.binlog.event.deserialization.GtidEventDataDeserializer; import com.github.shyiko.mysql.binlog.event.deserialization.GtidEventDataDeserializer;

33
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/TransactionPayloadIT.java
View File

@ -5,17 +5,8 @@
*/ */
package io.debezium.connector.mysql; package io.debezium.connector.mysql;
import io.debezium.config.Configuration; import static io.debezium.junit.EqualityCheck.LESS_THAN;
import io.debezium.embedded.AbstractConnectorTest; import static org.fest.assertions.Assertions.assertThat;
import io.debezium.jdbc.JdbcConnection;
import io.debezium.junit.SkipTestRule;
import io.debezium.junit.SkipWhenDatabaseVersion;
import io.debezium.util.Testing;
import org.apache.kafka.connect.source.SourceRecord;
import org.junit.After;
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
import java.io.IOException; import java.io.IOException;
import java.nio.file.Path; import java.nio.file.Path;
@ -23,8 +14,18 @@
import java.util.List; import java.util.List;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import static io.debezium.junit.EqualityCheck.LESS_THAN; import org.apache.kafka.connect.source.SourceRecord;
import static org.fest.assertions.Assertions.assertThat; import org.junit.After;
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
import io.debezium.config.Configuration;
import io.debezium.embedded.AbstractConnectorTest;
import io.debezium.jdbc.JdbcConnection;
import io.debezium.junit.SkipTestRule;
import io.debezium.junit.SkipWhenDatabaseVersion;
import io.debezium.util.Testing;
@SkipWhenDatabaseVersion(check = LESS_THAN, major = 8, minor = 0, patch = 20, reason = "MySQL 8.0.20 started supporting binlog compression") @SkipWhenDatabaseVersion(check = LESS_THAN, major = 8, minor = 0, patch = 20, reason = "MySQL 8.0.20 started supporting binlog compression")
public class TransactionPayloadIT extends AbstractConnectorTest { public class TransactionPayloadIT extends AbstractConnectorTest {
@ -60,12 +61,12 @@ public void beforeEach() throws TimeoutException, IOException, SQLException, Int
public void afterEach() { public void afterEach() {
try { try {
stopConnector(); stopConnector();
} finally { }
finally {
Testing.Files.delete(DB_HISTORY_PATH); Testing.Files.delete(DB_HISTORY_PATH);
} }
} }
@Test @Test
public void shouldCaptureMultipleWriteEvents() throws Exception { public void shouldCaptureMultipleWriteEvents() throws Exception {
config = DATABASE.defaultConfig() config = DATABASE.defaultConfig()
@ -101,4 +102,4 @@ public void shouldCaptureMultipleWriteEvents() throws Exception {
assertThat(productDmls).hasSize(1); assertThat(productDmls).hasSize(1);
assertThat(orderDmls).hasSize(4); assertThat(orderDmls).hasSize(4);
} }
} }

2
support/checkstyle/src/main/resources/io/debezium/checkstyle/message.properties
View File

@ -1,4 +1,4 @@
import.unused=Unused import - {0}. import.unused=Unused import - {0}.
import.invalidJavaDocTag=Invalid JavaDoc tag - {0} import.invalidJavaDocTag=Invalid JavaDoc tag - {0}
header.missing=Missing a header - not enough lines in file. Every source file must contain the standard header; see 'checkstyle/src/main/resources/debezium.header'. header.missing=Missing a header - not enough lines in file. Every source file must contain the standard header; see 'checkstyle/src/main/resources/debezium.header'.
header.mismatch=Line does not match expected header line of ''{0}''. Every source file must contain the standard header; see 'checkstyle/src/main/resources/debezium.header'. header.mismatch=Line does not match expected header line of ''{0}''. Every source file must contain the standard header; see 'checkstyle/src/main/resources/debezium.header'.