change

src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBStatement.java

@@ -172,20 +172,14 @@ public class TSDBStatement implements Statement {
     }
 
     public boolean execute(String sql) throws SQLException {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
-        System.out.println(Thread.currentThread().getName() + " before execute " + sdf.format(new Date()) + "=====> isclosed: " + isClosed);
         if (isClosed) {
-            System.out.println(Thread.currentThread().getName() + " will throw " + sdf.format(new Date()) + "=====> isclosed: " + isClosed);
             throw new SQLException("Invalid method call on a closed statement.");
         }
         boolean res = true;
 
-        System.out.println(Thread.currentThread().getName() + " before JNI " + sdf.format(new Date()) + "=====> isclosed: " + isClosed);
         pSql = this.connector.executeQuery(sql);
-        System.out.println(Thread.currentThread().getName() + " after JNI " + sdf.format(new Date()) + "=====> isclosed: " + isClosed);
 
         long resultSetPointer = this.connector.getResultSet();
-
         if (resultSetPointer == TSDBConstants.JNI_CONNECTION_NULL) {
             this.connector.freeResultSet(pSql);
             throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
@@ -194,7 +188,6 @@ public class TSDBStatement implements Statement {
             this.connector.freeResultSet(pSql);
             res = false;
         }
-        System.out.println(Thread.currentThread().getName() + " after execute " + System.currentTimeMillis() + " =====> isclosed: " + isClosed);
 
         return res;
     }

src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/InvalidResultPointerExceptionTest.java

@@ -30,13 +30,14 @@ public class InvalidResultPointerExceptionTest {
     @Test
     public void testInvalidResultPointerException() {
         try (Connection conn = TSDBCommon.getConn("localhost")) {
-            Statement stmt = conn.createStatement();
 
             List<Thread> threads = IntStream.range(1, 2).boxed().map(i -> new Thread(() -> {
                 while (true) {
                     String sql = "insert into irp_test.weather values(now, " + random.nextInt(100) + ")";
                     try {
+                        Statement stmt = conn.createStatement();
                         stmt.execute(sql);
+                        stmt.close();
                     } catch (SQLException e) {
                         e.printStackTrace();
                     }
@@ -49,11 +50,12 @@ public class InvalidResultPointerExceptionTest {
                 }
             }, "Thread-" + i)).collect(Collectors.toList());
 
-            for (int i = 0; i < threads.size(); i++) {
-                threads.get(i).join();
+            for (Thread thread : threads)
+                thread.start();
+            for (Thread thread : threads) {
+                thread.join();
             }
 
-            stmt.close();
         } catch (SQLException e) {
             e.printStackTrace();
         } catch (ClassNotFoundException e) {