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

DBZ-4814 Use schema not catalog in table id

Browse Source
This commit is contained in:
Jiri Pechanec 2022-03-31 14:22:50 +02:00
parent 78206deeee
commit 1355067ef0
1 changed files with 3 additions and 3 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/RecordsStreamProducerIT.java
View File

@ -1441,7 +1441,7 @@ public void shouldNotRefreshSchemaOnUnchangedToastedData() throws Exception {
consumer.expects(1);
executeAndWait(statement);
assertWithTask(task -> {
Table tbl = ((PostgresConnectorTask) task).getTaskContext().schema().tableFor(TableId.parse("public.test_table"));
Table tbl = ((PostgresConnectorTask) task).getTaskContext().schema().tableFor(TableId.parse("public.test_table", false));
assertEquals(Arrays.asList("pk", "text", "not_toast"), tbl.retrieveColumnNames());
});
@ -1477,7 +1477,7 @@ public void shouldRefreshSchemaOnUnchangedToastedDataWhenSchemaChanged() throws
consumer.expects(1);
executeAndWait(statement);
assertWithTask(task -> {
Table tbl = ((PostgresConnectorTask) task).getTaskContext().schema().tableFor(TableId.parse("public.test_table"));
Table tbl = ((PostgresConnectorTask) task).getTaskContext().schema().tableFor(TableId.parse("public.test_table", false));
assertEquals(Arrays.asList("pk", "not_toast"), tbl.retrieveColumnNames());
});
}
@ -1521,7 +1521,7 @@ public void shouldNotPropagateUnchangedToastedData() throws Exception {
executeAndWait(statement);
consumer.process(record -> {
assertWithTask(task -> {
Table tbl = ((PostgresConnectorTask) task).getTaskContext().schema().tableFor(TableId.parse("public.test_table"));
Table tbl = ((PostgresConnectorTask) task).getTaskContext().schema().tableFor(TableId.parse("public.test_table", false));
assertEquals(Arrays.asList("pk", "text", "not_toast", "mandatory_text"), tbl.retrieveColumnNames());
});
});