diff --git a/src/main/java/com/alibaba/druid/pool/vendor/MySqlExceptionSorter.java b/src/main/java/com/alibaba/druid/pool/vendor/MySqlExceptionSorter.java index 8641cbf46a..aca249b3dd 100644 --- a/src/main/java/com/alibaba/druid/pool/vendor/MySqlExceptionSorter.java +++ b/src/main/java/com/alibaba/druid/pool/vendor/MySqlExceptionSorter.java @@ -55,9 +55,15 @@ public class MySqlExceptionSorter implements ExceptionSorter { break; } + // for oceanbase if (errorCode >= -10000 && errorCode <= -9000) { return true; } + + String className = e.getClass().getName(); + if ("com.mysql.jdbc.CommunicationsException".equals(className)) { + return true; + } String message = e.getMessage(); if (message != null && message.length() > 0) {