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

support mysql driver 5.0.x & 5.1.x & 6.0.x & 8.0.x

Browse Source
This commit is contained in:
shaojin.wensj
2019-02-25 16:08:03 +08:00
parent 799b7fba18
commit f8f928601a
1 changed files with 39 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/util/MySqlUtils.java
+39 -37
View File
@@ -48,8 +48,9 @@ public class MySqlUtils {
static Class<?> class_5_MysqlXAConnection = null;
static Constructor<?> constructor_5_MysqlXAConnection = null;
static Class<?> class_5_ConnectionImpl = null;
static Method method_5_getId = null;
static Class<?> class_ConnectionImpl = null;
static Method method_getId = null;
static boolean method_getId_error = false;
static Class<?> class_6_ConnectionImpl = null;
static Method method_6_getId = null;
@@ -185,41 +186,7 @@ public class MySqlUtils {
}
public static String buildKillQuerySql(Connection connection, SQLException error) throws SQLException {
Long threadId = null;
try {
Class clazz = connection.getClass();
if (class_5_ConnectionImpl == null) {
if (clazz.getName().equals("com.mysql.jdbc.ConnectionImpl")) {
class_5_ConnectionImpl = clazz;
}
}
if (class_5_ConnectionImpl == clazz) {
if (method_5_getId == null) {
method_5_getId = class_5_ConnectionImpl.getMethod("getId");
}
threadId = (Long) method_5_getId.invoke(connection);
}
if (class_6_ConnectionImpl == null) {
if (clazz.getName().equals("com.mysql.cj.jdbc.ConnectionImpl")) {
class_6_ConnectionImpl = clazz;
}
}
if (class_6_ConnectionImpl == clazz) {
if (method_6_getId == null) {
method_6_getId = class_6_ConnectionImpl.getMethod("getId");
}
threadId = (Long) method_6_getId.invoke(connection);
}
} catch (Exception e) {
// skip
}
Long threadId = getId(connection);
if (threadId == null) {
return null;
}
@@ -364,6 +331,41 @@ public class MySqlUtils {
private static transient Method method_getLastPacketReceivedTimeMs = null;
private static transient boolean method_getLastPacketReceivedTimeMs_error = false;
public static Long getId(Object conn) {
if (conn == null) {
return null;
}
Class<?> clazz = conn.getClass();
if (class_ConnectionImpl == null) {
if (clazz.getName().equals("com.mysql.jdbc.ConnectionImpl")) {
class_ConnectionImpl = clazz;
} else if (clazz.getName().equals("com.mysql.jdbc.Connection")) { // mysql 5.0.x
class_ConnectionImpl = clazz;
} else if (clazz.getName().equals("com.mysql.cj.jdbc.ConnectionImpl")) { // mysql 5.0.x
class_ConnectionImpl = clazz;
} else if (clazz.getSuperclass().getName().equals("com.mysql.jdbc.ConnectionImpl")) {
class_ConnectionImpl = clazz.getSuperclass();
}
}
if (class_ConnectionImpl == clazz || class_ConnectionImpl == clazz.getSuperclass()) {
try {
if (method_getId == null && !method_getId_error) {
Method method = class_ConnectionImpl.getDeclaredMethod("getId");
method.setAccessible(true);
method_getId = method;
}
return (Long) method_getId.invoke(conn);
} catch (Throwable ex) {
method_getId_error = true;
}
}
return null;
}
public static long getLastPacketReceivedTimeMs(Connection conn) throws SQLException {
if (class_connectionImpl == null && !class_connectionImpl_Error) {
try {