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

DBZ-7562 Add "default values" assertion check

Browse Source
This commit is contained in:
Chris Cranford 2024-02-26 09:16:32 -05:00 committed by Chris Cranford
parent 45805eef8c
commit 3fd66483d9
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-postgres/src/test/java/io/debezium/connector/postgresql/PostgresDefaultValueConverterIT.java
View File

@ -130,7 +130,8 @@ public void shouldTruncateDefaultValuePrecisionToMatchColumnMaxPrecision() throw
+ "CREATE TABLE s1.dbz7562 (pk SERIAL, cost numeric(12,0) not null default 0.0, PRIMARY KEY(pk));"
+ "INSERT INTO s1.dbz7562 (cost) values (2.25);"
+ "INSERT INTO s1.dbz7562 (cost) values (3);"
+ "INSERT INTO s1.dbz7562 (cost) values (0);";
+ "INSERT INTO s1.dbz7562 (cost) values (0);"
+ "INSERT INTO s1.dbz7562 default values;";
// Test Snapshot
TestHelper.execute(ddl);
@ -144,8 +145,9 @@ public void shouldTruncateDefaultValuePrecisionToMatchColumnMaxPrecision() throw
TestHelper.execute("INSERT INTO s1.dbz7562 (cost) values (5.5);");
TestHelper.execute("INSERT INTO s1.dbz7562 (cost) values (4);");
TestHelper.execute("INSERT INTO s1.dbz7562 (cost) values (0);");
TestHelper.execute("INSERT INTO s1.dbz7562 default values;");
final int expectedRecords = 6;
final int expectedRecords = 8;
final SourceRecords records = consumeRecordsByTopic(expectedRecords);
final List<SourceRecord> recordsForTopic = records.recordsForTopic(topicName("s1.dbz7562"));
assertThat(recordsForTopic).hasSize(expectedRecords);