Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

Merge pull request #375 from liangjie/master

Browse Source 
增强类MysqlExceptionSorter捕获异常能力
This commit is contained in:
温高铁
2013-06-28 03:29:34 -07:00
parent 0da4c693d3 78d90fa2b0
commit 3cb5d2e040
1 changed files with 34 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/pool/vendor/MySqlExceptionSorter.java
Vendored
+34 -17
View File
@@ -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) {
}
}