From f2ba1f79b847eb55518f0f1c763ee2ce0978ac61 Mon Sep 17 00:00:00 2001 From: zyyang Date: Mon, 1 Feb 2021 13:08:06 +0800 Subject: [PATCH] change --- .../taosdata/jdbc/cases/TaosInfoMonitorTest.java | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/TaosInfoMonitorTest.java b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/TaosInfoMonitorTest.java index 3dce0d69a6..2ab4045e27 100644 --- a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/TaosInfoMonitorTest.java +++ b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/TaosInfoMonitorTest.java @@ -2,9 +2,7 @@ package com.taosdata.jdbc.cases; import org.junit.Test; -import java.sql.Connection; -import java.sql.DriverManager; -import java.sql.SQLException; +import java.sql.*; import java.util.List; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; @@ -27,6 +25,18 @@ public class TaosInfoMonitorTest { return null; }).collect(Collectors.toList()); + connectionList.stream().forEach(conn -> { + try (Statement stmt = conn.createStatement()) { + ResultSet rs = stmt.executeQuery("show databases"); + while (rs.next()) { + + } + TimeUnit.MILLISECONDS.sleep(50); + } catch (SQLException | InterruptedException e) { + e.printStackTrace(); + } + }); + connectionList.stream().forEach(conn -> { try { conn.close();