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

DBZ-8127: Use SQLState instead of error strings

Browse Source
This commit is contained in:
Rajendra Dangwal 2024-08-13 14:34:27 +05:30 committed by Chris Cranford
parent d9f831d138
commit 8ca16ee452
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java
View File

@ -538,8 +538,9 @@ public Optional<SlotCreationResult> createReplicationSlot() throws SQLException
break;
}
catch (SQLException ex) {
// intercept the statement timeout error and retry
if (ex.getMessage().contains("canceling statement due to user request")) {
// intercept the statement timeout error (due to query_canceled or lock_not_available) and retry
// ref: https://www.postgresql.org/docs/current/errcodes-appendix.html
if (ex.getSQLState().equals("57014") || ex.getSQLState().equals("55P03")) {
String message = "Creation of replication slot failed; " +
"query to create replication slot timed out, please make sure that there are no long running queries on the database.";
if (++tryCount > maxRetries) {

4
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/connection/ReplicationConnectionIT.java
View File

@ -158,7 +158,7 @@ public void shouldRetryAndFailIfSlotCreationFailsWithTimeoutErrorOnLimitedRetrie
}
catch (Exception e) {
assertTrue(interceptor.containsWarnMessage("and retrying, attempt number"));
assertTrue(e.getCause().getMessage().contains("ERROR: canceling statement due to user request"));
assertTrue(((SQLException) e.getCause()).getSQLState().equals("57014"));
assertTrue(e.getMessage().contains("query to create replication slot timed out"));
throw e;
}
@ -185,7 +185,7 @@ public void shouldSucceedIfSlotCreationSucceedsAfterTimeoutErrors() throws Excep
}
catch (Exception e) {
assertTrue(interceptor.containsWarnMessage("and retrying, attempt number"));
assertTrue(e.getCause().getMessage().contains("ERROR: canceling statement due to user request"));
assertTrue(((SQLException) e.getCause()).getSQLState().equals("57014"));
assertTrue(e.getMessage().contains("query to create replication slot timed out"));
}
finally {