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 37a98bdfcc..d09dcae74b 100644 --- a/src/main/java/com/alibaba/druid/pool/vendor/MySqlExceptionSorter.java +++ b/src/main/java/com/alibaba/druid/pool/vendor/MySqlExceptionSorter.java @@ -24,12 +24,32 @@ public class MySqlExceptionSorter implements ExceptionSorter { @Override public boolean isExceptionFatal(SQLException e) { + int loopCount = 20; + + Throwable cause = e; + while (cause != null) { + if (cause instanceof SQLException) { + SQLException sqlException = (SQLException) cause; + + if (isExceptionFatal0(sqlException)) { + return true; + } + } + cause = cause.getCause(); + if (--loopCount < 0) { + break; + } + } + return false; + } + + private boolean isExceptionFatal0(SQLException e) { String sqlState = e.getSQLState(); - if (sqlState != null && sqlState.startsWith("08")) { // per Mark Matthews at MySQL + final int errorCode = Math.abs(e.getErrorCode()); + + if (sqlState != null && sqlState.startsWith("08")) { return true; } - - final int errorCode = e.getErrorCode(); switch (errorCode) { // Communications Errors case 1040: // ER_CON_COUNT_ERROR @@ -39,35 +59,32 @@ public class MySqlExceptionSorter implements ExceptionSorter { case 1081: // ER_IPSOCK_ERROR case 1129: // ER_HOST_IS_BLOCKED case 1130: // ER_HOST_NOT_PRIVILEGED - // Authentication Errors case 1045: // ER_ACCESS_DENIED_ERROR - // Resource errors case 1004: // ER_CANT_CREATE_FILE case 1005: // ER_CANT_CREATE_TABLE case 1015: // ER_CANT_LOCK case 1021: // ER_DISK_FULL case 1041: // ER_OUT_OF_RESOURCES - // Out-of-memory errors case 1037: // ER_OUTOFMEMORY case 1038: // ER_OUT_OF_SORTMEMORY return true; - - default: - break; - } - - if (errorCode >= -10000 && errorCode <= -9000) { - return true; } + if (StringUtils.isNotBlank(e.getMessage())) { + final String errorText = e.getMessage().toUpperCase(); + + if (errorCode == 0 + && (errorText.indexOf("COMMUNICATIONS LINK FAILURE") > -1 || errorText + .indexOf("COULD NOT CREATE CONNECTION") > -1) + || errorText.indexOf("NO DATASOURCE") > -1 + || errorText.indexOf("NO ALIVE DATASOURCE") > -1) { + return true; + } + } return false; } - - public void configFromProperties(Properties properties) { - - } }