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

DBZ-7526 Fix table name with escaped characters

Browse Source
This commit is contained in:
mfvitale 2024-02-20 15:58:51 +01:00 committed by Chris Cranford
parent 9f1ee1421f
commit 65a34b10d3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/SignalsIT.java
View File

@ -72,7 +72,7 @@ private void signalLog(boolean includingEscapedCharacter) throws InterruptedExce
final LogInterceptor logInterceptor = new LogInterceptor(Log.class);
String signalTable = "s1.debezium_signal";
String signalTableWithEscapedCharacter = "s1.\"debezium_signal\\\"";
String signalTableWithEscapedCharacter = "s1.\"debezium_signal\"";
TestHelper.dropDefaultReplicationSlot();
TestHelper.execute(includingEscapedCharacter ? SETUP_TABLES_STMT.replace(signalTable, signalTableWithEscapedCharacter) : SETUP_TABLES_STMT);