diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
index 18ecd6bdc9..93245404e9 100644
--- a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
+++ b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
@@ -1558,6 +1558,10 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
             lastErrorTimeMillis = System.currentTimeMillis();
         }
 
+        if (sql != null && sql.length() > 1024) {
+            sql = sql.substring(0, 1024);
+        }
+
         boolean requireDiscard = false;
         final ReentrantLock lock = conn.lock;
         lock.lock();