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

DBZ-1401 SQL Server improved test

Browse Source
This commit is contained in:
Jiri Pechanec 2019-10-07 13:44:24 +02:00 committed by Gunnar Morling
parent ae4b5d6764
commit 71b8739565
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithoutPrimaryKeyIT.java
View File

@ -99,11 +99,13 @@ public void shouldProcessFromStreaming() throws Exception {
connection.execute(DDL_STATEMENTS);
Testing.Print.enable();
TestHelper.enableTableCdc(connection, "t1");
connection.execute("INSERT INTO t1 VALUES (1,10);");
TestHelper.enableTableCdc(connection, "t2");
connection.execute("INSERT INTO t2 VALUES (2,20);");
TestHelper.enableTableCdc(connection, "t3");
connection.execute(DML_STATEMENTS);
connection.execute("INSERT INTO t3 VALUES (3,30);");
final int expectedRecordsCount = 1 + 1 + 1;