diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConnection.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConnection.java
index 94abe3965507170a4b31e17ebb431ddcb4fa11f8..e2307f1ee14d2ae90e515d7234d1e943f30961cd 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConnection.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConnection.java
@@ -80,13 +80,13 @@ public class TSDBConnection implements Connection {
     }
 
     public Statement createStatement() throws SQLException {
-        if (!this.connector.isClosed()) {
+//        if (!this.connector.isClosed()) {
             TSDBStatement statement = new TSDBStatement(this, this.connector);
             statement.setConnection(this);
             return statement;
-        } else {
-            throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
-        }
+//        } else {
+//            throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
+//        }
     }
 
     public TSDBSubscribe subscribe(String topic, String sql, boolean restart) throws SQLException {