diff --git a/src/main/java/com/alibaba/druid/filter/logging/LogFilter.java b/src/main/java/com/alibaba/druid/filter/logging/LogFilter.java index 8280bfe78f..8ee4397b17 100644 --- a/src/main/java/com/alibaba/druid/filter/logging/LogFilter.java +++ b/src/main/java/com/alibaba/druid/filter/logging/LogFilter.java @@ -15,10 +15,7 @@ */ package com.alibaba.druid.filter.logging; -import java.sql.ResultSetMetaData; -import java.sql.SQLException; -import java.sql.Savepoint; -import java.sql.Types; +import java.sql.*; import java.util.ArrayList; import java.util.List; import java.util.Properties; @@ -36,7 +33,9 @@ import com.alibaba.druid.proxy.jdbc.ResultSetProxy; import com.alibaba.druid.proxy.jdbc.StatementProxy; import com.alibaba.druid.sql.SQLUtils; import com.alibaba.druid.sql.SQLUtils.FormatOption; +import com.alibaba.druid.util.JdbcConstants; import com.alibaba.druid.util.JdbcUtils; +import com.alibaba.druid.util.MySqlUtils; /** * @author wenshao [szujobs@hotmail.com] @@ -369,7 +368,20 @@ public abstract class LogFilter extends FilterEventAdapter implements LogFilterM } if (connectionConnectAfterLogEnable && isConnectionLogEnabled()) { - connectionLog("{conn-" + connection.getId() + "} connected"); + StringBuilder msg = new StringBuilder(34) + .append("{conn-") + .append(connection.getId()); + + Connection impl = connection.getRawObject(); + if (JdbcConstants.MYSQL.equals(dataSource.getDbType())) { + Long procId = MySqlUtils.getId(impl); + if (procId != null) { + msg.append(",procId-").append(procId); + } + } + + msg.append("} connected"); + connectionLog(msg.toString()); } }