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

DBZ-4850 Add several retriable SQL error codes

Browse Source
This commit is contained in:
Ethan Zou 2022-03-14 18:56:10 +08:00 committed by Chris Cranford
parent 80cda74e63
commit efdb5d21fc
4 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
COPYRIGHT.txt
View File

@ -106,6 +106,7 @@ Eric Slep
Eric Weaver
Eric S. Kreiseir
Erik Malm
Ethan Zou
Ewen Cheslack-Postava
Fabian Aussems
Fabian Martinez

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

@ -36,7 +36,10 @@ public class OracleErrorHandler extends ErrorHandler {
"ORA-26653", // Apply DBZXOUT did not start properly and is currently in state INITIALI
"ORA-01291", // missing logfile
"ORA-01327", // failed to exclusively lock system dictionary as required BUILD
"ORA-04030"); // out of process memory
"ORA-04030", // out of process memory
"ORA-00310", // archived log contains sequence *; sequence * required
"ORA-01343", // LogMiner encountered corruption in the logstream
"ORA-01371"); // Complete LogMiner dictionary not found
/**
* Contents of this set should be any type of error message text;

2
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/SqlUtils.java
View File

@ -57,7 +57,7 @@ static String currentRedoNameQuery() {
}
static String currentRedoLogSequenceQuery() {
return String.format("SELECT SEQUENCE# FROM %s WHERE STATUS = 'CURRENT'", LOG_VIEW);
return String.format("SELECT SEQUENCE# FROM %s WHERE STATUS = 'CURRENT' ORDER BY SEQUENCE#", LOG_VIEW);
}
static String databaseSupplementalLoggingAllCheckQuery() {

2
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/logminer/SqlUtilsTest.java
View File

@ -75,7 +75,7 @@ public void testStatements() {
assertThat(result).isEqualTo(expected);
result = SqlUtils.currentRedoLogSequenceQuery();
expected = "SELECT SEQUENCE# FROM V$LOG WHERE STATUS = 'CURRENT'";
expected = "SELECT SEQUENCE# FROM V$LOG WHERE STATUS = 'CURRENT' ORDER BY SEQUENCE#";
assertThat(result).isEqualTo(expected);
result = SqlUtils.databaseSupplementalLoggingAllCheckQuery();