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

DBZ-2679 Handle LCR events with database names with domains

Browse Source
This commit is contained in:
Chris Cranford 2020-11-02 16:14:22 -05:00 committed by Jiri Pechanec
parent 33b4a39930
commit 679e3b7a92
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/xstream/LcrEventHandler.java
View File

@ -119,11 +119,12 @@ private void dispatchSchemaChangeEvent(DDLLCR ddlLcr) throws InterruptedExceptio
} }
private TableId getTableId(LCR lcr) { private TableId getTableId(LCR lcr) {
final String sourceDatabaseName = lcr.getSourceDatabaseName().split("\\.")[0];
if (!this.tablenameCaseInsensitive) { if (!this.tablenameCaseInsensitive) {
return new TableId(lcr.getSourceDatabaseName(), lcr.getObjectOwner(), lcr.getObjectName()); return new TableId(sourceDatabaseName, lcr.getObjectOwner(), lcr.getObjectName());
} }
else { else {
return new TableId(lcr.getSourceDatabaseName().toLowerCase(), lcr.getObjectOwner(), lcr.getObjectName().toLowerCase()); return new TableId(sourceDatabaseName.toLowerCase(), lcr.getObjectOwner(), lcr.getObjectName().toLowerCase());
} }
} }