diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java index 95c61beef..539fb7b94 100644 --- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java +++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleSchemaMigrationIT.java @@ -1608,7 +1608,7 @@ private static void assertTableChangeColumn(Struct change, int index, String col private static void assertSourceTableInfo(SourceRecord record, String schema, String table) { final Struct source = ((Struct) record.value()).getStruct("source"); - assertThat(source.get("db")).isEqualTo(TestHelper.DATABASE); + assertThat(source.get("db")).isEqualTo(TestHelper.getDatabaseName()); assertThat(source.get("schema")).isEqualTo(schema); assertThat(source.get("table")).isEqualTo(table); }